Variables
Run_State_name, Run_State_value
var (
Run_State_name = map[int32]string{
0: "UNKNOWN",
1: "STARTED",
2: "COMPLETED",
3: "FAILED",
4: "ABORTED",
}
Run_State_value = map[string]int32{
"UNKNOWN": 0,
"STARTED": 1,
"COMPLETED": 2,
"FAILED": 3,
"ABORTED": 4,
}
)
Enum value maps for Run_State.
OperationMetadata_State_name, OperationMetadata_State_value
var (
OperationMetadata_State_name = map[int32]string{
0: "STATE_UNSPECIFIED",
1: "PENDING",
2: "RUNNING",
3: "SUCCEEDED",
4: "FAILED",
}
OperationMetadata_State_value = map[string]int32{
"STATE_UNSPECIFIED": 0,
"PENDING": 1,
"RUNNING": 2,
"SUCCEEDED": 3,
"FAILED": 4,
}
)
Enum value maps for OperationMetadata_State.
OperationMetadata_Type_name, OperationMetadata_Type_value
var (
OperationMetadata_Type_name = map[int32]string{
0: "TYPE_UNSPECIFIED",
1: "DELETE",
}
OperationMetadata_Type_value = map[string]int32{
"TYPE_UNSPECIFIED": 0,
"DELETE": 1,
}
)
Enum value maps for OperationMetadata_Type.
Origin_SourceType_name, Origin_SourceType_value
var (
Origin_SourceType_name = map[int32]string{
0: "SOURCE_TYPE_UNSPECIFIED",
1: "CUSTOM",
2: "BIGQUERY",
3: "DATA_FUSION",
4: "COMPOSER",
5: "LOOKER_STUDIO",
}
Origin_SourceType_value = map[string]int32{
"SOURCE_TYPE_UNSPECIFIED": 0,
"CUSTOM": 1,
"BIGQUERY": 2,
"DATA_FUSION": 3,
"COMPOSER": 4,
"LOOKER_STUDIO": 5,
}
)
Enum value maps for Origin_SourceType.
File_google_cloud_datacatalog_lineage_v1_lineage_proto
var File_google_cloud_datacatalog_lineage_v1_lineage_proto protoreflect.FileDescriptor
Functions
func RegisterLineageServer
func RegisterLineageServer(s *grpc.Server, srv LineageServer)
BatchSearchLinkProcessesRequest
type BatchSearchLinkProcessesRequest struct {
// Required. The project and location you want search in the format `projects/*/locations/*`
Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
// Required. An array of links to check for their associated LineageProcesses.
//
// The maximum number of items in this array is 100.
// If the request contains more than 100 links, it returns the
// `INVALID_ARGUMENT` error.
//
// Format: `projects/{project}/locations/{location}/links/{link}`.
Links []string `protobuf:"bytes,2,rep,name=links,proto3" json:"links,omitempty"`
// The maximum number of processes to return in a single page of the response.
// A page may contain fewer results than this value.
PageSize int32 `protobuf:"varint,3,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
// The page token received from a previous `BatchSearchLinkProcesses` call.
// Use it to get the next page.
//
// When requesting subsequent pages of a response, remember that
// all parameters must match the values you provided
// in the original request.
PageToken string `protobuf:"bytes,4,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
// contains filtered or unexported fields
}
Request message for [BatchSearchLinkProcesses][google.cloud.datacatalog.lineage.v1.Lineage.BatchSearchLinkProcesses].
func (*BatchSearchLinkProcessesRequest) Descriptor
func (*BatchSearchLinkProcessesRequest) Descriptor() ([]byte, []int)
Deprecated: Use BatchSearchLinkProcessesRequest.ProtoReflect.Descriptor instead.
func (*BatchSearchLinkProcessesRequest) GetLinks
func (x *BatchSearchLinkProcessesRequest) GetLinks() []string
func (*BatchSearchLinkProcessesRequest) GetPageSize
func (x *BatchSearchLinkProcessesRequest) GetPageSize() int32
func (*BatchSearchLinkProcessesRequest) GetPageToken
func (x *BatchSearchLinkProcessesRequest) GetPageToken() string
func (*BatchSearchLinkProcessesRequest) GetParent
func (x *BatchSearchLinkProcessesRequest) GetParent() string
func (*BatchSearchLinkProcessesRequest) ProtoMessage
func (*BatchSearchLinkProcessesRequest) ProtoMessage()
func (*BatchSearchLinkProcessesRequest) ProtoReflect
func (x *BatchSearchLinkProcessesRequest) ProtoReflect() protoreflect.Message
func (*BatchSearchLinkProcessesRequest) Reset
func (x *BatchSearchLinkProcessesRequest) Reset()
func (*BatchSearchLinkProcessesRequest) String
func (x *BatchSearchLinkProcessesRequest) String() string
BatchSearchLinkProcessesResponse
type BatchSearchLinkProcessesResponse struct {
// An array of processes associated with the specified links.
ProcessLinks []*ProcessLinks `protobuf:"bytes,1,rep,name=process_links,json=processLinks,proto3" json:"process_links,omitempty"`
// The token to specify as `page_token` in the subsequent call to get the next
// page. Omitted if there are no more pages in the response.
NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
// contains filtered or unexported fields
}
Response message for [BatchSearchLinkProcesses][google.cloud.datacatalog.lineage.v1.Lineage.BatchSearchLinkProcesses].
func (*BatchSearchLinkProcessesResponse) Descriptor
func (*BatchSearchLinkProcessesResponse) Descriptor() ([]byte, []int)
Deprecated: Use BatchSearchLinkProcessesResponse.ProtoReflect.Descriptor instead.
func (*BatchSearchLinkProcessesResponse) GetNextPageToken
func (x *BatchSearchLinkProcessesResponse) GetNextPageToken() string
func (*BatchSearchLinkProcessesResponse) GetProcessLinks
func (x *BatchSearchLinkProcessesResponse) GetProcessLinks() []*ProcessLinks
func (*BatchSearchLinkProcessesResponse) ProtoMessage
func (*BatchSearchLinkProcessesResponse) ProtoMessage()
func (*BatchSearchLinkProcessesResponse) ProtoReflect
func (x *BatchSearchLinkProcessesResponse) ProtoReflect() protoreflect.Message
func (*BatchSearchLinkProcessesResponse) Reset
func (x *BatchSearchLinkProcessesResponse) Reset()
func (*BatchSearchLinkProcessesResponse) String
func (x *BatchSearchLinkProcessesResponse) String() string
CreateLineageEventRequest
type CreateLineageEventRequest struct {
// Required. The name of the run that should own the lineage event.
Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
// Required. The lineage event to create.
LineageEvent *LineageEvent `protobuf:"bytes,2,opt,name=lineage_event,json=lineageEvent,proto3" json:"lineage_event,omitempty"`
// A unique identifier for this request. Restricted to 36 ASCII characters.
// A random UUID is recommended. This request is idempotent only if a
// `request_id` is provided.
RequestId string `protobuf:"bytes,3,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
// contains filtered or unexported fields
}
Request message for [CreateLineageEvent][google.cloud.datacatalog.lineage.v1.CreateLineageEvent].
func (*CreateLineageEventRequest) Descriptor
func (*CreateLineageEventRequest) Descriptor() ([]byte, []int)
Deprecated: Use CreateLineageEventRequest.ProtoReflect.Descriptor instead.
func (*CreateLineageEventRequest) GetLineageEvent
func (x *CreateLineageEventRequest) GetLineageEvent() *LineageEvent
func (*CreateLineageEventRequest) GetParent
func (x *CreateLineageEventRequest) GetParent() string
func (*CreateLineageEventRequest) GetRequestId
func (x *CreateLineageEventRequest) GetRequestId() string
func (*CreateLineageEventRequest) ProtoMessage
func (*CreateLineageEventRequest) ProtoMessage()
func (*CreateLineageEventRequest) ProtoReflect
func (x *CreateLineageEventRequest) ProtoReflect() protoreflect.Message
func (*CreateLineageEventRequest) Reset
func (x *CreateLineageEventRequest) Reset()
func (*CreateLineageEventRequest) String
func (x *CreateLineageEventRequest) String() string
CreateProcessRequest
type CreateProcessRequest struct {
// Required. The name of the project and its location that should own the
// process.
Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
// Required. The process to create.
Process *Process `protobuf:"bytes,2,opt,name=process,proto3" json:"process,omitempty"`
// A unique identifier for this request. Restricted to 36 ASCII characters.
// A random UUID is recommended. This request is idempotent only if a
// `request_id` is provided.
RequestId string `protobuf:"bytes,3,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
// contains filtered or unexported fields
}
Request message for [CreateProcess][google.cloud.datacatalog.lineage.v1.CreateProcess].
func (*CreateProcessRequest) Descriptor
func (*CreateProcessRequest) Descriptor() ([]byte, []int)
Deprecated: Use CreateProcessRequest.ProtoReflect.Descriptor instead.
func (*CreateProcessRequest) GetParent
func (x *CreateProcessRequest) GetParent() string
func (*CreateProcessRequest) GetProcess
func (x *CreateProcessRequest) GetProcess() *Process
func (*CreateProcessRequest) GetRequestId
func (x *CreateProcessRequest) GetRequestId() string
func (*CreateProcessRequest) ProtoMessage
func (*CreateProcessRequest) ProtoMessage()
func (*CreateProcessRequest) ProtoReflect
func (x *CreateProcessRequest) ProtoReflect() protoreflect.Message
func (*CreateProcessRequest) Reset
func (x *CreateProcessRequest) Reset()
func (*CreateProcessRequest) String
func (x *CreateProcessRequest) String() string
CreateRunRequest
type CreateRunRequest struct {
// Required. The name of the process that should own the run.
Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
// Required. The run to create.
Run *Run `protobuf:"bytes,2,opt,name=run,proto3" json:"run,omitempty"`
// A unique identifier for this request. Restricted to 36 ASCII characters.
// A random UUID is recommended. This request is idempotent only if a
// `request_id` is provided.
RequestId string `protobuf:"bytes,3,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
// contains filtered or unexported fields
}
Request message for [CreateRun][google.cloud.datacatalog.lineage.v1.CreateRun].
func (*CreateRunRequest) Descriptor
func (*CreateRunRequest) Descriptor() ([]byte, []int)
Deprecated: Use CreateRunRequest.ProtoReflect.Descriptor instead.
func (*CreateRunRequest) GetParent
func (x *CreateRunRequest) GetParent() string
func (*CreateRunRequest) GetRequestId
func (x *CreateRunRequest) GetRequestId() string
func (*CreateRunRequest) GetRun
func (x *CreateRunRequest) GetRun() *Run
func (*CreateRunRequest) ProtoMessage
func (*CreateRunRequest) ProtoMessage()
func (*CreateRunRequest) ProtoReflect
func (x *CreateRunRequest) ProtoReflect() protoreflect.Message
func (*CreateRunRequest) Reset
func (x *CreateRunRequest) Reset()
func (*CreateRunRequest) String
func (x *CreateRunRequest) String() string
DeleteLineageEventRequest
type DeleteLineageEventRequest struct {
// Required. The name of the lineage event to delete.
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// If set to true and the lineage event is not found, the request
// succeeds but the server doesn't perform any actions.
AllowMissing bool `protobuf:"varint,2,opt,name=allow_missing,json=allowMissing,proto3" json:"allow_missing,omitempty"`
// contains filtered or unexported fields
}
Request message for [DeleteLineageEvent][google.cloud.datacatalog.lineage.v1.DeleteLineageEvent].
func (*DeleteLineageEventRequest) Descriptor
func (*DeleteLineageEventRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeleteLineageEventRequest.ProtoReflect.Descriptor instead.
func (*DeleteLineageEventRequest) GetAllowMissing
func (x *DeleteLineageEventRequest) GetAllowMissing() bool
func (*DeleteLineageEventRequest) GetName
func (x *DeleteLineageEventRequest) GetName() string
func (*DeleteLineageEventRequest) ProtoMessage
func (*DeleteLineageEventRequest) ProtoMessage()
func (*DeleteLineageEventRequest) ProtoReflect
func (x *DeleteLineageEventRequest) ProtoReflect() protoreflect.Message
func (*DeleteLineageEventRequest) Reset
func (x *DeleteLineageEventRequest) Reset()
func (*DeleteLineageEventRequest) String
func (x *DeleteLineageEventRequest) String() string
DeleteProcessRequest
type DeleteProcessRequest struct {
// Required. The name of the process to delete.
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// If set to true and the process is not found, the request
// succeeds but the server doesn't perform any actions.
AllowMissing bool `protobuf:"varint,2,opt,name=allow_missing,json=allowMissing,proto3" json:"allow_missing,omitempty"`
// contains filtered or unexported fields
}
Request message for [DeleteProcess][google.cloud.datacatalog.lineage.v1.DeleteProcess].
func (*DeleteProcessRequest) Descriptor
func (*DeleteProcessRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeleteProcessRequest.ProtoReflect.Descriptor instead.
func (*DeleteProcessRequest) GetAllowMissing
func (x *DeleteProcessRequest) GetAllowMissing() bool
func (*DeleteProcessRequest) GetName
func (x *DeleteProcessRequest) GetName() string
func (*DeleteProcessRequest) ProtoMessage
func (*DeleteProcessRequest) ProtoMessage()
func (*DeleteProcessRequest) ProtoReflect
func (x *DeleteProcessRequest) ProtoReflect() protoreflect.Message
func (*DeleteProcessRequest) Reset
func (x *DeleteProcessRequest) Reset()
func (*DeleteProcessRequest) String
func (x *DeleteProcessRequest) String() string
DeleteRunRequest
type DeleteRunRequest struct {
// Required. The name of the run to delete.
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// If set to true and the run is not found, the request
// succeeds but the server doesn't perform any actions.
AllowMissing bool `protobuf:"varint,2,opt,name=allow_missing,json=allowMissing,proto3" json:"allow_missing,omitempty"`
// contains filtered or unexported fields
}
Request message for [DeleteRun][google.cloud.datacatalog.lineage.v1.DeleteRun].
func (*DeleteRunRequest) Descriptor
func (*DeleteRunRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeleteRunRequest.ProtoReflect.Descriptor instead.
func (*DeleteRunRequest) GetAllowMissing
func (x *DeleteRunRequest) GetAllowMissing() bool
func (*DeleteRunRequest) GetName
func (x *DeleteRunRequest) GetName() string
func (*DeleteRunRequest) ProtoMessage
func (*DeleteRunRequest) ProtoMessage()
func (*DeleteRunRequest) ProtoReflect
func (x *DeleteRunRequest) ProtoReflect() protoreflect.Message
func (*DeleteRunRequest) Reset
func (x *DeleteRunRequest) Reset()
func (*DeleteRunRequest) String
func (x *DeleteRunRequest) String() string
EntityReference
type EntityReference struct {
// Required. Fully Qualified Name of the entity. Useful for referencing
// entities that aren't represented as GCP resources, for example, tables in
// Dataproc Metastore API.
//
// Examples:
//
// * `bigquery:dataset.project_id.dataset_id`
// * `bigquery:table.project_id.dataset_id.table_id`
// * `pubsub:project_id.topic_id`
// * `dataproc_metastore:projectId.locationId.instanceId.databaseId.tableId`
FullyQualifiedName string `protobuf:"bytes,1,opt,name=fully_qualified_name,json=fullyQualifiedName,proto3" json:"fully_qualified_name,omitempty"`
// contains filtered or unexported fields
}
The soft reference to everything you can attach a lineage event to.
func (*EntityReference) Descriptor
func (*EntityReference) Descriptor() ([]byte, []int)
Deprecated: Use EntityReference.ProtoReflect.Descriptor instead.
func (*EntityReference) GetFullyQualifiedName
func (x *EntityReference) GetFullyQualifiedName() string
func (*EntityReference) ProtoMessage
func (*EntityReference) ProtoMessage()
func (*EntityReference) ProtoReflect
func (x *EntityReference) ProtoReflect() protoreflect.Message
func (*EntityReference) Reset
func (x *EntityReference) Reset()
func (*EntityReference) String
func (x *EntityReference) String() string
EventLink
type EventLink struct {
// Required. Reference to the source entity
Source *EntityReference `protobuf:"bytes,1,opt,name=source,proto3" json:"source,omitempty"`
// Required. Reference to the target entity
Target *EntityReference `protobuf:"bytes,2,opt,name=target,proto3" json:"target,omitempty"`
// contains filtered or unexported fields
}
A lineage between source and target entities.
func (*EventLink) Descriptor
Deprecated: Use EventLink.ProtoReflect.Descriptor instead.
func (*EventLink) GetSource
func (x *EventLink) GetSource() *EntityReference
func (*EventLink) GetTarget
func (x *EventLink) GetTarget() *EntityReference
func (*EventLink) ProtoMessage
func (*EventLink) ProtoMessage()
func (*EventLink) ProtoReflect
func (x *EventLink) ProtoReflect() protoreflect.Message
func (*EventLink) Reset
func (x *EventLink) Reset()
func (*EventLink) String
GetLineageEventRequest
type GetLineageEventRequest struct {
// Required. The name of the lineage event to get.
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// contains filtered or unexported fields
}
Request message for [GetLineageEvent][google.cloud.datacatalog.lineage.v1.GetLineageEvent].
func (*GetLineageEventRequest) Descriptor
func (*GetLineageEventRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetLineageEventRequest.ProtoReflect.Descriptor instead.
func (*GetLineageEventRequest) GetName
func (x *GetLineageEventRequest) GetName() string
func (*GetLineageEventRequest) ProtoMessage
func (*GetLineageEventRequest) ProtoMessage()
func (*GetLineageEventRequest) ProtoReflect
func (x *GetLineageEventRequest) ProtoReflect() protoreflect.Message
func (*GetLineageEventRequest) Reset
func (x *GetLineageEventRequest) Reset()
func (*GetLineageEventRequest) String
func (x *GetLineageEventRequest) String() string
GetProcessRequest
type GetProcessRequest struct {
// Required. The name of the process to get.
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// contains filtered or unexported fields
}
Request message for [GetProcess][google.cloud.datacatalog.lineage.v1.GetProcess].
func (*GetProcessRequest) Descriptor
func (*GetProcessRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetProcessRequest.ProtoReflect.Descriptor instead.
func (*GetProcessRequest) GetName
func (x *GetProcessRequest) GetName() string
func (*GetProcessRequest) ProtoMessage
func (*GetProcessRequest) ProtoMessage()
func (*GetProcessRequest) ProtoReflect
func (x *GetProcessRequest) ProtoReflect() protoreflect.Message
func (*GetProcessRequest) Reset
func (x *GetProcessRequest) Reset()
func (*GetProcessRequest) String
func (x *GetProcessRequest) String() string
GetRunRequest
type GetRunRequest struct {
// Required. The name of the run to get.
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// contains filtered or unexported fields
}
Request message for [GetRun][google.cloud.datacatalog.lineage.v1.GetRun].
func (*GetRunRequest) Descriptor
func (*GetRunRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetRunRequest.ProtoReflect.Descriptor instead.
func (*GetRunRequest) GetName
func (x *GetRunRequest) GetName() string
func (*GetRunRequest) ProtoMessage
func (*GetRunRequest) ProtoMessage()
func (*GetRunRequest) ProtoReflect
func (x *GetRunRequest) ProtoReflect() protoreflect.Message
func (*GetRunRequest) Reset
func (x *GetRunRequest) Reset()
func (*GetRunRequest) String
func (x *GetRunRequest) String() string
LineageClient
type LineageClient interface {
// Creates a new process.
CreateProcess(ctx context.Context, in *CreateProcessRequest, opts ...grpc.CallOption) (*Process, error)
// Updates a process.
UpdateProcess(ctx context.Context, in *UpdateProcessRequest, opts ...grpc.CallOption) (*Process, error)
// Gets the details of the specified process.
GetProcess(ctx context.Context, in *GetProcessRequest, opts ...grpc.CallOption) (*Process, error)
// List processes in the given project and location. List order is descending
// by insertion time.
ListProcesses(ctx context.Context, in *ListProcessesRequest, opts ...grpc.CallOption) (*ListProcessesResponse, error)
// Deletes the process with the specified name.
DeleteProcess(ctx context.Context, in *DeleteProcessRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)
// Creates a new run.
CreateRun(ctx context.Context, in *CreateRunRequest, opts ...grpc.CallOption) (*Run, error)
// Updates a run.
UpdateRun(ctx context.Context, in *UpdateRunRequest, opts ...grpc.CallOption) (*Run, error)
// Gets the details of the specified run.
GetRun(ctx context.Context, in *GetRunRequest, opts ...grpc.CallOption) (*Run, error)
// Lists runs in the given project and location. List order is descending by
// `start_time`.
ListRuns(ctx context.Context, in *ListRunsRequest, opts ...grpc.CallOption) (*ListRunsResponse, error)
// Deletes the run with the specified name.
DeleteRun(ctx context.Context, in *DeleteRunRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)
// Creates a new lineage event.
CreateLineageEvent(ctx context.Context, in *CreateLineageEventRequest, opts ...grpc.CallOption) (*LineageEvent, error)
// Gets details of a specified lineage event.
GetLineageEvent(ctx context.Context, in *GetLineageEventRequest, opts ...grpc.CallOption) (*LineageEvent, error)
// Lists lineage events in the given project and location. The list order is
// not defined.
ListLineageEvents(ctx context.Context, in *ListLineageEventsRequest, opts ...grpc.CallOption) (*ListLineageEventsResponse, error)
// Deletes the lineage event with the specified name.
DeleteLineageEvent(ctx context.Context, in *DeleteLineageEventRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
// Retrieve a list of links connected to a specific asset.
// Links represent the data flow between **source** (upstream)
// and **target** (downstream) assets in transformation pipelines.
// Links are stored in the same project as the Lineage Events that create
// them.
//
// You can retrieve links in every project where you have the
// `datalineage.events.get` permission. The project provided in the URL
// is used for Billing and Quota.
SearchLinks(ctx context.Context, in *SearchLinksRequest, opts ...grpc.CallOption) (*SearchLinksResponse, error)
// Retrieve information about LineageProcesses associated with specific
// links. LineageProcesses are transformation pipelines that result in data
// flowing from **source** to **target** assets. Links between assets
// represent this operation.
//
// If you have specific link names, you can use this method to
// verify which LineageProcesses contribute to creating those links.
// See the
// [SearchLinks][google.cloud.datacatalog.lineage.v1.Lineage.SearchLinks]
// method for more information on how to retrieve link name.
//
// You can retrieve the LineageProcess information in every project where you
// have the `datalineage.events.get` permission. The project provided in the
// URL is used for Billing and Quota.
BatchSearchLinkProcesses(ctx context.Context, in *BatchSearchLinkProcessesRequest, opts ...grpc.CallOption) (*BatchSearchLinkProcessesResponse, error)
}
LineageClient is the client API for Lineage service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewLineageClient
func NewLineageClient(cc grpc.ClientConnInterface) LineageClient
LineageEvent
type LineageEvent struct {
// Immutable. The resource name of the lineage event.
// Format:
// `projects/{project}/locations/{location}/processes/{process}/runs/{run}/lineageEvents/{lineage_event}`.
// Can be specified or auto-assigned.
// {lineage_event} must be not longer than 200 characters and only
// contain characters in a set: `a-zA-Z0-9_-:.`
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// Optional. List of source-target pairs. Can't contain more than 100 tuples.
Links []*EventLink `protobuf:"bytes,8,rep,name=links,proto3" json:"links,omitempty"`
// Optional. The beginning of the transformation which resulted in this
// lineage event. For streaming scenarios, it should be the beginning of the
// period from which the lineage is being reported.
StartTime *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
// Optional. The end of the transformation which resulted in this lineage
// event. For streaming scenarios, it should be the end of the period from
// which the lineage is being reported.
EndTime *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
// contains filtered or unexported fields
}
A lineage event represents an operation on assets. Within the operation, the data flows from the source to the target defined in the links field.
func (*LineageEvent) Descriptor
func (*LineageEvent) Descriptor() ([]byte, []int)
Deprecated: Use LineageEvent.ProtoReflect.Descriptor instead.
func (*LineageEvent) GetEndTime
func (x *LineageEvent) GetEndTime() *timestamppb.Timestamp
func (*LineageEvent) GetLinks
func (x *LineageEvent) GetLinks() []*EventLink
func (*LineageEvent) GetName
func (x *LineageEvent) GetName() string
func (*LineageEvent) GetStartTime
func (x *LineageEvent) GetStartTime() *timestamppb.Timestamp
func (*LineageEvent) ProtoMessage
func (*LineageEvent) ProtoMessage()
func (*LineageEvent) ProtoReflect
func (x *LineageEvent) ProtoReflect() protoreflect.Message
func (*LineageEvent) Reset
func (x *LineageEvent) Reset()
func (*LineageEvent) String
func (x *LineageEvent) String() string
LineageServer
type LineageServer interface {
// Creates a new process.
CreateProcess(context.Context, *CreateProcessRequest) (*Process, error)
// Updates a process.
UpdateProcess(context.Context, *UpdateProcessRequest) (*Process, error)
// Gets the details of the specified process.
GetProcess(context.Context, *GetProcessRequest) (*Process, error)
// List processes in the given project and location. List order is descending
// by insertion time.
ListProcesses(context.Context, *ListProcessesRequest) (*ListProcessesResponse, error)
// Deletes the process with the specified name.
DeleteProcess(context.Context, *DeleteProcessRequest) (*longrunningpb.Operation, error)
// Creates a new run.
CreateRun(context.Context, *CreateRunRequest) (*Run, error)
// Updates a run.
UpdateRun(context.Context, *UpdateRunRequest) (*Run, error)
// Gets the details of the specified run.
GetRun(context.Context, *GetRunRequest) (*Run, error)
// Lists runs in the given project and location. List order is descending by
// `start_time`.
ListRuns(context.Context, *ListRunsRequest) (*ListRunsResponse, error)
// Deletes the run with the specified name.
DeleteRun(context.Context, *DeleteRunRequest) (*longrunningpb.Operation, error)
// Creates a new lineage event.
CreateLineageEvent(context.Context, *CreateLineageEventRequest) (*LineageEvent, error)
// Gets details of a specified lineage event.
GetLineageEvent(context.Context, *GetLineageEventRequest) (*LineageEvent, error)
// Lists lineage events in the given project and location. The list order is
// not defined.
ListLineageEvents(context.Context, *ListLineageEventsRequest) (*ListLineageEventsResponse, error)
// Deletes the lineage event with the specified name.
DeleteLineageEvent(context.Context, *DeleteLineageEventRequest) (*emptypb.Empty, error)
// Retrieve a list of links connected to a specific asset.
// Links represent the data flow between **source** (upstream)
// and **target** (downstream) assets in transformation pipelines.
// Links are stored in the same project as the Lineage Events that create
// them.
//
// You can retrieve links in every project where you have the
// `datalineage.events.get` permission. The project provided in the URL
// is used for Billing and Quota.
SearchLinks(context.Context, *SearchLinksRequest) (*SearchLinksResponse, error)
// Retrieve information about LineageProcesses associated with specific
// links. LineageProcesses are transformation pipelines that result in data
// flowing from **source** to **target** assets. Links between assets
// represent this operation.
//
// If you have specific link names, you can use this method to
// verify which LineageProcesses contribute to creating those links.
// See the
// [SearchLinks][google.cloud.datacatalog.lineage.v1.Lineage.SearchLinks]
// method for more information on how to retrieve link name.
//
// You can retrieve the LineageProcess information in every project where you
// have the `datalineage.events.get` permission. The project provided in the
// URL is used for Billing and Quota.
BatchSearchLinkProcesses(context.Context, *BatchSearchLinkProcessesRequest) (*BatchSearchLinkProcessesResponse, error)
}
LineageServer is the server API for Lineage service.
Link
type Link struct {
// Output only. Immutable. The name of the link. Format:
// `projects/{project}/locations/{location}/links/{link}`.
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// The pointer to the entity that is the **source** of this link.
Source *EntityReference `protobuf:"bytes,2,opt,name=source,proto3" json:"source,omitempty"`
// The pointer to the entity that is the **target** of this link.
Target *EntityReference `protobuf:"bytes,3,opt,name=target,proto3" json:"target,omitempty"`
// The start of the first event establishing this link.
StartTime *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
// The end of the last event establishing this link.
EndTime *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
// contains filtered or unexported fields
}
Links represent the data flow between source (upstream) and target (downstream) assets in transformation pipelines.
Links are created when LineageEvents record data transformation between related assets.
func (*Link) Descriptor
Deprecated: Use Link.ProtoReflect.Descriptor instead.
func (*Link) GetEndTime
func (x *Link) GetEndTime() *timestamppb.Timestamp
func (*Link) GetName
func (*Link) GetSource
func (x *Link) GetSource() *EntityReference
func (*Link) GetStartTime
func (x *Link) GetStartTime() *timestamppb.Timestamp
func (*Link) GetTarget
func (x *Link) GetTarget() *EntityReference
func (*Link) ProtoMessage
func (*Link) ProtoMessage()
func (*Link) ProtoReflect
func (x *Link) ProtoReflect() protoreflect.Message
func (*Link) Reset
func (x *Link) Reset()
func (*Link) String
ListLineageEventsRequest
type ListLineageEventsRequest struct {
// Required. The name of the run that owns the collection of lineage events to
// get.
Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
// The maximum number of lineage events to return.
//
// The service may return fewer events than this value.
// If unspecified, at most 50 events are returned. The maximum value is 100;
// values greater than 100 are cut to 100.
PageSize int32 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
// The page token received from a previous `ListLineageEvents` call. Specify
// it to get the next page.
//
// When paginating, all other parameters specified in this call must
// match the parameters of the call that provided the page token.
PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
// contains filtered or unexported fields
}
Request message for [ListLineageEvents][google.cloud.datacatalog.lineage.v1.ListLineageEvents].
func (*ListLineageEventsRequest) Descriptor
func (*ListLineageEventsRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListLineageEventsRequest.ProtoReflect.Descriptor instead.
func (*ListLineageEventsRequest) GetPageSize
func (x *ListLineageEventsRequest) GetPageSize() int32
func (*ListLineageEventsRequest) GetPageToken
func (x *ListLineageEventsRequest) GetPageToken() string
func (*ListLineageEventsRequest) GetParent
func (x *ListLineageEventsRequest) GetParent() string
func (*ListLineageEventsRequest) ProtoMessage
func (*ListLineageEventsRequest) ProtoMessage()
func (*ListLineageEventsRequest) ProtoReflect
func (x *ListLineageEventsRequest) ProtoReflect() protoreflect.Message
func (*ListLineageEventsRequest) Reset
func (x *ListLineageEventsRequest) Reset()
func (*ListLineageEventsRequest) String
func (x *ListLineageEventsRequest) String() string
ListLineageEventsResponse
type ListLineageEventsResponse struct {
// Lineage events from the specified project and location.
LineageEvents []*LineageEvent `protobuf:"bytes,1,rep,name=lineage_events,json=lineageEvents,proto3" json:"lineage_events,omitempty"`
// The token to specify as `page_token` in the next call to get the next page.
// If this field is omitted, there are no subsequent pages.
NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
// contains filtered or unexported fields
}
Response message for [ListLineageEvents][google.cloud.datacatalog.lineage.v1.ListLineageEvents].
func (*ListLineageEventsResponse) Descriptor
func (*ListLineageEventsResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListLineageEventsResponse.ProtoReflect.Descriptor instead.
func (*ListLineageEventsResponse) GetLineageEvents
func (x *ListLineageEventsResponse) GetLineageEvents() []*LineageEvent
func (*ListLineageEventsResponse) GetNextPageToken
func (x *ListLineageEventsResponse) GetNextPageToken() string
func (*ListLineageEventsResponse) ProtoMessage
func (*ListLineageEventsResponse) ProtoMessage()
func (*ListLineageEventsResponse) ProtoReflect
func (x *ListLineageEventsResponse) ProtoReflect() protoreflect.Message
func (*ListLineageEventsResponse) Reset
func (x *ListLineageEventsResponse) Reset()
func (*ListLineageEventsResponse) String
func (x *ListLineageEventsResponse) String() string
ListProcessesRequest
type ListProcessesRequest struct {
// Required. The name of the project and its location that owns this
// collection of processes.
Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
// The maximum number of processes to return. The service may return
// fewer than this value. If unspecified, at most 50 processes are
// returned. The maximum value is 100; values greater than 100 are cut to
// 100.
PageSize int32 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
// The page token received from a previous `ListProcesses` call. Specify
// it to get the next page.
//
// When paginating, all other parameters specified in this call must
// match the parameters of the call that provided the page token.
PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
// contains filtered or unexported fields
}
Request message for [ListProcesses][google.cloud.datacatalog.lineage.v1.ListProcesses].
func (*ListProcessesRequest) Descriptor
func (*ListProcessesRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListProcessesRequest.ProtoReflect.Descriptor instead.
func (*ListProcessesRequest) GetPageSize
func (x *ListProcessesRequest) GetPageSize() int32
func (*ListProcessesRequest) GetPageToken
func (x *ListProcessesRequest) GetPageToken() string
func (*ListProcessesRequest) GetParent
func (x *ListProcessesRequest) GetParent() string
func (*ListProcessesRequest) ProtoMessage
func (*ListProcessesRequest) ProtoMessage()
func (*ListProcessesRequest) ProtoReflect
func (x *ListProcessesRequest) ProtoReflect() protoreflect.Message
func (*ListProcessesRequest) Reset
func (x *ListProcessesRequest) Reset()
func (*ListProcessesRequest) String
func (x *ListProcessesRequest) String() string
ListProcessesResponse
type ListProcessesResponse struct {
// The processes from the specified project and location.
Processes []*Process `protobuf:"bytes,1,rep,name=processes,proto3" json:"processes,omitempty"`
// The token to specify as `page_token` in the next call to get the next page.
// If this field is omitted, there are no subsequent pages.
NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
// contains filtered or unexported fields
}
Response message for [ListProcesses][google.cloud.datacatalog.lineage.v1.ListProcesses].
func (*ListProcessesResponse) Descriptor
func (*ListProcessesResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListProcessesResponse.ProtoReflect.Descriptor instead.
func (*ListProcessesResponse) GetNextPageToken
func (x *ListProcessesResponse) GetNextPageToken() string
func (*ListProcessesResponse) GetProcesses
func (x *ListProcessesResponse) GetProcesses() []*Process
func (*ListProcessesResponse) ProtoMessage
func (*ListProcessesResponse) ProtoMessage()
func (*ListProcessesResponse) ProtoReflect
func (x *ListProcessesResponse) ProtoReflect() protoreflect.Message
func (*ListProcessesResponse) Reset
func (x *ListProcessesResponse) Reset()
func (*ListProcessesResponse) String
func (x *ListProcessesResponse) String() string
ListRunsRequest
type ListRunsRequest struct {
// Required. The name of process that owns this collection of runs.
Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
// The maximum number of runs to return. The service may return
// fewer than this value. If unspecified, at most 50 runs are
// returned. The maximum value is 100; values greater than 100 are cut to
// 100.
PageSize int32 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
// The page token received from a previous `ListRuns` call. Specify
// it to get the next page.
//
// When paginating, all other parameters specified in this call must
// match the parameters of the call that provided the page token.
PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
// contains filtered or unexported fields
}
Request message for [ListRuns][google.cloud.datacatalog.lineage.v1.ListRuns].
func (*ListRunsRequest) Descriptor
func (*ListRunsRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListRunsRequest.ProtoReflect.Descriptor instead.
func (*ListRunsRequest) GetPageSize
func (x *ListRunsRequest) GetPageSize() int32
func (*ListRunsRequest) GetPageToken
func (x *ListRunsRequest) GetPageToken() string
func (*ListRunsRequest) GetParent
func (x *ListRunsRequest) GetParent() string
func (*ListRunsRequest) ProtoMessage
func (*ListRunsRequest) ProtoMessage()
func (*ListRunsRequest) ProtoReflect
func (x *ListRunsRequest) ProtoReflect() protoreflect.Message
func (*ListRunsRequest) Reset
func (x *ListRunsRequest) Reset()
func (*ListRunsRequest) String
func (x *ListRunsRequest) String() string
ListRunsResponse
type ListRunsResponse struct {
// The runs from the specified project and location.
Runs []*Run `protobuf:"bytes,1,rep,name=runs,proto3" json:"runs,omitempty"`
// The token to specify as `page_token` in the next call to get the next page.
// If this field is omitted, there are no subsequent pages.
NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
// contains filtered or unexported fields
}
Response message for [ListRuns][google.cloud.datacatalog.lineage.v1.ListRuns].
func (*ListRunsResponse) Descriptor
func (*ListRunsResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListRunsResponse.ProtoReflect.Descriptor instead.
func (*ListRunsResponse) GetNextPageToken
func (x *ListRunsResponse) GetNextPageToken() string
func (*ListRunsResponse) GetRuns
func (x *ListRunsResponse) GetRuns() []*Run
func (*ListRunsResponse) ProtoMessage
func (*ListRunsResponse) ProtoMessage()
func (*ListRunsResponse) ProtoReflect
func (x *ListRunsResponse) ProtoReflect() protoreflect.Message
func (*ListRunsResponse) Reset
func (x *ListRunsResponse) Reset()
func (*ListRunsResponse) String
func (x *ListRunsResponse) String() string
OperationMetadata
type OperationMetadata struct {
State OperationMetadata_State "" /* 129 byte string literal not displayed */
OperationType OperationMetadata_Type "" /* 165 byte string literal not displayed */
Resource string `protobuf:"bytes,3,opt,name=resource,proto3" json:"resource,omitempty"`
ResourceUuid string `protobuf:"bytes,4,opt,name=resource_uuid,json=resourceUuid,proto3" json:"resource_uuid,omitempty"`
CreateTime *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
EndTime *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
}
Metadata describing the operation.
func (*OperationMetadata) Descriptor
func (*OperationMetadata) Descriptor() ([]byte, []int)
Deprecated: Use OperationMetadata.ProtoReflect.Descriptor instead.
func (*OperationMetadata) GetCreateTime
func (x *OperationMetadata) GetCreateTime() *timestamppb.Timestamp
func (*OperationMetadata) GetEndTime
func (x *OperationMetadata) GetEndTime() *timestamppb.Timestamp
func (*OperationMetadata) GetOperationType
func (x *OperationMetadata) GetOperationType() OperationMetadata_Type
func (*OperationMetadata) GetResource
func (x *OperationMetadata) GetResource() string
func (*OperationMetadata) GetResourceUuid
func (x *OperationMetadata) GetResourceUuid() string
func (*OperationMetadata) GetState
func (x *OperationMetadata) GetState() OperationMetadata_State
func (*OperationMetadata) ProtoMessage
func (*OperationMetadata) ProtoMessage()
func (*OperationMetadata) ProtoReflect
func (x *OperationMetadata) ProtoReflect() protoreflect.Message
func (*OperationMetadata) Reset
func (x *OperationMetadata) Reset()
func (*OperationMetadata) String
func (x *OperationMetadata) String() string
OperationMetadata_State
type OperationMetadata_State int32
An enum with the state of the operation.
OperationMetadata_STATE_UNSPECIFIED, OperationMetadata_PENDING, OperationMetadata_RUNNING, OperationMetadata_SUCCEEDED, OperationMetadata_FAILED
const (
// Unused.
OperationMetadata_STATE_UNSPECIFIED OperationMetadata_State = 0
// The operation has been created but is not yet started.
OperationMetadata_PENDING OperationMetadata_State = 1
// The operation is underway.
OperationMetadata_RUNNING OperationMetadata_State = 2
// The operation completed successfully.
OperationMetadata_SUCCEEDED OperationMetadata_State = 3
// The operation is no longer running and did not succeed.
OperationMetadata_FAILED OperationMetadata_State = 4
)
func (OperationMetadata_State) Descriptor
func (OperationMetadata_State) Descriptor() protoreflect.EnumDescriptor
func (OperationMetadata_State) Enum
func (x OperationMetadata_State) Enum() *OperationMetadata_State
func (OperationMetadata_State) EnumDescriptor
func (OperationMetadata_State) EnumDescriptor() ([]byte, []int)
Deprecated: Use OperationMetadata_State.Descriptor instead.
func (OperationMetadata_State) Number
func (x OperationMetadata_State) Number() protoreflect.EnumNumber
func (OperationMetadata_State) String
func (x OperationMetadata_State) String() string
func (OperationMetadata_State) Type
func (OperationMetadata_State) Type() protoreflect.EnumType
OperationMetadata_Type
type OperationMetadata_Type int32
Type of the long running operation.
OperationMetadata_TYPE_UNSPECIFIED, OperationMetadata_DELETE
const (
// Unused.
OperationMetadata_TYPE_UNSPECIFIED OperationMetadata_Type = 0
// The resource deletion operation.
OperationMetadata_DELETE OperationMetadata_Type = 1
)
func (OperationMetadata_Type) Descriptor
func (OperationMetadata_Type) Descriptor() protoreflect.EnumDescriptor
func (OperationMetadata_Type) Enum
func (x OperationMetadata_Type) Enum() *OperationMetadata_Type
func (OperationMetadata_Type) EnumDescriptor
func (OperationMetadata_Type) EnumDescriptor() ([]byte, []int)
Deprecated: Use OperationMetadata_Type.Descriptor instead.
func (OperationMetadata_Type) Number
func (x OperationMetadata_Type) Number() protoreflect.EnumNumber
func (OperationMetadata_Type) String
func (x OperationMetadata_Type) String() string
func (OperationMetadata_Type) Type
func (OperationMetadata_Type) Type() protoreflect.EnumType
Origin
type Origin struct {
SourceType Origin_SourceType "" /* 151 byte string literal not displayed */
Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
}
Origin of a process.
func (*Origin) Descriptor
Deprecated: Use Origin.ProtoReflect.Descriptor instead.
func (*Origin) GetName
func (*Origin) GetSourceType
func (x *Origin) GetSourceType() Origin_SourceType
func (*Origin) ProtoMessage
func (*Origin) ProtoMessage()
func (*Origin) ProtoReflect
func (x *Origin) ProtoReflect() protoreflect.Message
func (*Origin) Reset
func (x *Origin) Reset()
func (*Origin) String
Origin_SourceType
type Origin_SourceType int32
Type of the source of a process.
Origin_SOURCE_TYPE_UNSPECIFIED, Origin_CUSTOM, Origin_BIGQUERY, Origin_DATA_FUSION, Origin_COMPOSER, Origin_LOOKER_STUDIO
const (
// Source is Unspecified
Origin_SOURCE_TYPE_UNSPECIFIED Origin_SourceType = 0
// A custom source
Origin_CUSTOM Origin_SourceType = 1
// BigQuery
Origin_BIGQUERY Origin_SourceType = 2
// Data Fusion
Origin_DATA_FUSION Origin_SourceType = 3
// Composer
Origin_COMPOSER Origin_SourceType = 4
// Looker Studio
Origin_LOOKER_STUDIO Origin_SourceType = 5
)
func (Origin_SourceType) Descriptor
func (Origin_SourceType) Descriptor() protoreflect.EnumDescriptor
func (Origin_SourceType) Enum
func (x Origin_SourceType) Enum() *Origin_SourceType
func (Origin_SourceType) EnumDescriptor
func (Origin_SourceType) EnumDescriptor() ([]byte, []int)
Deprecated: Use Origin_SourceType.Descriptor instead.
func (Origin_SourceType) Number
func (x Origin_SourceType) Number() protoreflect.EnumNumber
func (Origin_SourceType) String
func (x Origin_SourceType) String() string
func (Origin_SourceType) Type
func (Origin_SourceType) Type() protoreflect.EnumType
Process
type Process struct {
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
DisplayName string `protobuf:"bytes,2,opt,name=display_name,json=displayName,proto3" json:"display_name,omitempty"`
Attributes map[string]*structpb.Value "" /* 161 byte string literal not displayed */
Origin *Origin `protobuf:"bytes,4,opt,name=origin,proto3" json:"origin,omitempty"`
}
A process is the definition of a data transformation operation.
func (*Process) Descriptor
Deprecated: Use Process.ProtoReflect.Descriptor instead.
func (*Process) GetAttributes
func (*Process) GetDisplayName
func (*Process) GetName
func (*Process) GetOrigin
func (*Process) ProtoMessage
func (*Process) ProtoMessage()
func (*Process) ProtoReflect
func (x *Process) ProtoReflect() protoreflect.Message
func (*Process) Reset
func (x *Process) Reset()
func (*Process) String
ProcessLinkInfo
type ProcessLinkInfo struct {
// The name of the link in the format of
// `projects/{project}/locations/{location}/links/{link}`.
Link string `protobuf:"bytes,1,opt,name=link,proto3" json:"link,omitempty"`
// The start of the first event establishing this link-process tuple.
StartTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
// The end of the last event establishing this link-process tuple.
EndTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
// contains filtered or unexported fields
}
Link details.
func (*ProcessLinkInfo) Descriptor
func (*ProcessLinkInfo) Descriptor() ([]byte, []int)
Deprecated: Use ProcessLinkInfo.ProtoReflect.Descriptor instead.
func (*ProcessLinkInfo) GetEndTime
func (x *ProcessLinkInfo) GetEndTime() *timestamppb.Timestamp
func (*ProcessLinkInfo) GetLink
func (x *ProcessLinkInfo) GetLink() string
func (*ProcessLinkInfo) GetStartTime
func (x *ProcessLinkInfo) GetStartTime() *timestamppb.Timestamp
func (*ProcessLinkInfo) ProtoMessage
func (*ProcessLinkInfo) ProtoMessage()
func (*ProcessLinkInfo) ProtoReflect
func (x *ProcessLinkInfo) ProtoReflect() protoreflect.Message
func (*ProcessLinkInfo) Reset
func (x *ProcessLinkInfo) Reset()
func (*ProcessLinkInfo) String
func (x *ProcessLinkInfo) String() string
ProcessLinks
type ProcessLinks struct {
// The process name in the format of
// `projects/{project}/locations/{location}/processes/{process}`.
Process string `protobuf:"bytes,1,opt,name=process,proto3" json:"process,omitempty"`
// An array containing link details objects of the links provided in
// the original request.
//
// A single process can result in creating multiple links.
// If any of the links you provide in the request are created by
// the same process, they all are included in this array.
Links []*ProcessLinkInfo `protobuf:"bytes,2,rep,name=links,proto3" json:"links,omitempty"`
// contains filtered or unexported fields
}
Links associated with a specific process.
func (*ProcessLinks) Descriptor
func (*ProcessLinks) Descriptor() ([]byte, []int)
Deprecated: Use ProcessLinks.ProtoReflect.Descriptor instead.
func (*ProcessLinks) GetLinks
func (x *ProcessLinks) GetLinks() []*ProcessLinkInfo
func (*ProcessLinks) GetProcess
func (x *ProcessLinks) GetProcess() string
func (*ProcessLinks) ProtoMessage
func (*ProcessLinks) ProtoMessage()
func (*ProcessLinks) ProtoReflect
func (x *ProcessLinks) ProtoReflect() protoreflect.Message
func (*ProcessLinks) Reset
func (x *ProcessLinks) Reset()
func (*ProcessLinks) String
func (x *ProcessLinks) String() string
Run
type Run struct {
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
DisplayName string `protobuf:"bytes,2,opt,name=display_name,json=displayName,proto3" json:"display_name,omitempty"`
Attributes map[string]*structpb.Value "" /* 161 byte string literal not displayed */
StartTime *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
EndTime *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
State Run_State `protobuf:"varint,6,opt,name=state,proto3,enum=google.cloud.datacatalog.lineage.v1.Run_State" json:"state,omitempty"`
}
A lineage run represents an execution of a process that creates lineage events.
func (*Run) Descriptor
Deprecated: Use Run.ProtoReflect.Descriptor instead.
func (*Run) GetAttributes
func (*Run) GetDisplayName
func (*Run) GetEndTime
func (x *Run) GetEndTime() *timestamppb.Timestamp
func (*Run) GetName
func (*Run) GetStartTime
func (x *Run) GetStartTime() *timestamppb.Timestamp
func (*Run) GetState
func (*Run) ProtoMessage
func (*Run) ProtoMessage()
func (*Run) ProtoReflect
func (x *Run) ProtoReflect() protoreflect.Message
func (*Run) Reset
func (x *Run) Reset()
func (*Run) String
Run_State
type Run_State int32
The current state of the run.
Run_UNKNOWN, Run_STARTED, Run_COMPLETED, Run_FAILED, Run_ABORTED
const (
// The state is unknown. The true state may be any of the below or a
// different state that is not supported here explicitly.
Run_UNKNOWN Run_State = 0
// The run is still executing.
Run_STARTED Run_State = 1
// The run completed.
Run_COMPLETED Run_State = 2
// The run failed.
Run_FAILED Run_State = 3
// The run aborted.
Run_ABORTED Run_State = 4
)
func (Run_State) Descriptor
func (Run_State) Descriptor() protoreflect.EnumDescriptor
func (Run_State) Enum
func (Run_State) EnumDescriptor
Deprecated: Use Run_State.Descriptor instead.
func (Run_State) Number
func (x Run_State) Number() protoreflect.EnumNumber
func (Run_State) String
func (Run_State) Type
func (Run_State) Type() protoreflect.EnumType
SearchLinksRequest
type SearchLinksRequest struct {
// Required. The project and location you want search in the format `projects/*/locations/*`
Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
// The asset for which you want to retrieve links.
//
// Types that are assignable to Criteria:
// *SearchLinksRequest_Source
// *SearchLinksRequest_Target
Criteria isSearchLinksRequest_Criteria `protobuf_oneof:"criteria"`
// Optional. The maximum number of links to return in a single page of the
// response. A page may contain fewer links than this value. If unspecified,
// at most 10 links are returned.
//
// Maximum value is 100; values greater than 100 are reduced to 100.
PageSize int32 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
// Optional. The page token received from a previous `SearchLinksRequest`
// call. Use it to get the next page.
//
// When requesting subsequent pages of a response, remember that
// all parameters must match the values you provided
// in the original request.
PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
// contains filtered or unexported fields
}
Request message for [SearchLinks][google.cloud.datacatalog.lineage.v1.Lineage.SearchLinks].
func (*SearchLinksRequest) Descriptor
func (*SearchLinksRequest) Descriptor() ([]byte, []int)
Deprecated: Use SearchLinksRequest.ProtoReflect.Descriptor instead.
func (*SearchLinksRequest) GetCriteria
func (m *SearchLinksRequest) GetCriteria() isSearchLinksRequest_Criteria
func (*SearchLinksRequest) GetPageSize
func (x *SearchLinksRequest) GetPageSize() int32
func (*SearchLinksRequest) GetPageToken
func (x *SearchLinksRequest) GetPageToken() string
func (*SearchLinksRequest) GetParent
func (x *SearchLinksRequest) GetParent() string
func (*SearchLinksRequest) GetSource
func (x *SearchLinksRequest) GetSource() *EntityReference
func (*SearchLinksRequest) GetTarget
func (x *SearchLinksRequest) GetTarget() *EntityReference
func (*SearchLinksRequest) ProtoMessage
func (*SearchLinksRequest) ProtoMessage()
func (*SearchLinksRequest) ProtoReflect
func (x *SearchLinksRequest) ProtoReflect() protoreflect.Message
func (*SearchLinksRequest) Reset
func (x *SearchLinksRequest) Reset()
func (*SearchLinksRequest) String
func (x *SearchLinksRequest) String() string
SearchLinksRequest_Source
type SearchLinksRequest_Source struct {
// Optional. Send asset information in the **source** field to retrieve all
// links that lead from the specified asset to downstream assets.
Source *EntityReference `protobuf:"bytes,4,opt,name=source,proto3,oneof"`
}
SearchLinksRequest_Target
type SearchLinksRequest_Target struct {
// Optional. Send asset information in the **target** field to retrieve all
// links that lead from upstream assets to the specified asset.
Target *EntityReference `protobuf:"bytes,5,opt,name=target,proto3,oneof"`
}
SearchLinksResponse
type SearchLinksResponse struct {
// The list of links for a given asset. Can be empty if the asset has no
// relations of requested type (source or target).
Links []*Link `protobuf:"bytes,1,rep,name=links,proto3" json:"links,omitempty"`
// The token to specify as `page_token` in the subsequent call to get the next
// page. Omitted if there are no more pages in the response.
NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
// contains filtered or unexported fields
}
Response message for [SearchLinks][google.cloud.datacatalog.lineage.v1.Lineage.SearchLinks].
func (*SearchLinksResponse) Descriptor
func (*SearchLinksResponse) Descriptor() ([]byte, []int)
Deprecated: Use SearchLinksResponse.ProtoReflect.Descriptor instead.
func (*SearchLinksResponse) GetLinks
func (x *SearchLinksResponse) GetLinks() []*Link
func (*SearchLinksResponse) GetNextPageToken
func (x *SearchLinksResponse) GetNextPageToken() string
func (*SearchLinksResponse) ProtoMessage
func (*SearchLinksResponse) ProtoMessage()
func (*SearchLinksResponse) ProtoReflect
func (x *SearchLinksResponse) ProtoReflect() protoreflect.Message
func (*SearchLinksResponse) Reset
func (x *SearchLinksResponse) Reset()
func (*SearchLinksResponse) String
func (x *SearchLinksResponse) String() string
UnimplementedLineageServer
type UnimplementedLineageServer struct {
}
UnimplementedLineageServer can be embedded to have forward compatible implementations.
func (*UnimplementedLineageServer) BatchSearchLinkProcesses
func (*UnimplementedLineageServer) BatchSearchLinkProcesses(context.Context, *BatchSearchLinkProcessesRequest) (*BatchSearchLinkProcessesResponse, error)
func (*UnimplementedLineageServer) CreateLineageEvent
func (*UnimplementedLineageServer) CreateLineageEvent(context.Context, *CreateLineageEventRequest) (*LineageEvent, error)
func (*UnimplementedLineageServer) CreateProcess
func (*UnimplementedLineageServer) CreateProcess(context.Context, *CreateProcessRequest) (*Process, error)
func (*UnimplementedLineageServer) CreateRun
func (*UnimplementedLineageServer) CreateRun(context.Context, *CreateRunRequest) (*Run, error)
func (*UnimplementedLineageServer) DeleteLineageEvent
func (*UnimplementedLineageServer) DeleteLineageEvent(context.Context, *DeleteLineageEventRequest) (*emptypb.Empty, error)
func (*UnimplementedLineageServer) DeleteProcess
func (*UnimplementedLineageServer) DeleteProcess(context.Context, *DeleteProcessRequest) (*longrunningpb.Operation, error)
func (*UnimplementedLineageServer) DeleteRun
func (*UnimplementedLineageServer) DeleteRun(context.Context, *DeleteRunRequest) (*longrunningpb.Operation, error)
func (*UnimplementedLineageServer) GetLineageEvent
func (*UnimplementedLineageServer) GetLineageEvent(context.Context, *GetLineageEventRequest) (*LineageEvent, error)
func (*UnimplementedLineageServer) GetProcess
func (*UnimplementedLineageServer) GetProcess(context.Context, *GetProcessRequest) (*Process, error)
func (*UnimplementedLineageServer) GetRun
func (*UnimplementedLineageServer) GetRun(context.Context, *GetRunRequest) (*Run, error)
func (*UnimplementedLineageServer) ListLineageEvents
func (*UnimplementedLineageServer) ListLineageEvents(context.Context, *ListLineageEventsRequest) (*ListLineageEventsResponse, error)
func (*UnimplementedLineageServer) ListProcesses
func (*UnimplementedLineageServer) ListProcesses(context.Context, *ListProcessesRequest) (*ListProcessesResponse, error)
func (*UnimplementedLineageServer) ListRuns
func (*UnimplementedLineageServer) ListRuns(context.Context, *ListRunsRequest) (*ListRunsResponse, error)
func (*UnimplementedLineageServer) SearchLinks
func (*UnimplementedLineageServer) SearchLinks(context.Context, *SearchLinksRequest) (*SearchLinksResponse, error)
func (*UnimplementedLineageServer) UpdateProcess
func (*UnimplementedLineageServer) UpdateProcess(context.Context, *UpdateProcessRequest) (*Process, error)
func (*UnimplementedLineageServer) UpdateRun
func (*UnimplementedLineageServer) UpdateRun(context.Context, *UpdateRunRequest) (*Run, error)
UpdateProcessRequest
type UpdateProcessRequest struct {
// Required. The lineage process to update.
//
// The process's `name` field is used to identify the process to update.
Process *Process `protobuf:"bytes,1,opt,name=process,proto3" json:"process,omitempty"`
// The list of fields to update. Currently not used. The whole message is
// updated.
UpdateMask *fieldmaskpb.FieldMask `protobuf:"bytes,2,opt,name=update_mask,json=updateMask,proto3" json:"update_mask,omitempty"`
// If set to true and the process is not found, the request inserts it.
AllowMissing bool `protobuf:"varint,3,opt,name=allow_missing,json=allowMissing,proto3" json:"allow_missing,omitempty"`
// contains filtered or unexported fields
}
Request message for [UpdateProcess][google.cloud.datacatalog.lineage.v1.UpdateProcess].
func (*UpdateProcessRequest) Descriptor
func (*UpdateProcessRequest) Descriptor() ([]byte, []int)
Deprecated: Use UpdateProcessRequest.ProtoReflect.Descriptor instead.
func (*UpdateProcessRequest) GetAllowMissing
func (x *UpdateProcessRequest) GetAllowMissing() bool
func (*UpdateProcessRequest) GetProcess
func (x *UpdateProcessRequest) GetProcess() *Process
func (*UpdateProcessRequest) GetUpdateMask
func (x *UpdateProcessRequest) GetUpdateMask() *fieldmaskpb.FieldMask
func (*UpdateProcessRequest) ProtoMessage
func (*UpdateProcessRequest) ProtoMessage()
func (*UpdateProcessRequest) ProtoReflect
func (x *UpdateProcessRequest) ProtoReflect() protoreflect.Message
func (*UpdateProcessRequest) Reset
func (x *UpdateProcessRequest) Reset()
func (*UpdateProcessRequest) String
func (x *UpdateProcessRequest) String() string
UpdateRunRequest
type UpdateRunRequest struct {
// Required. The lineage run to update.
//
// The run's `name` field is used to identify the run to update.
//
// Format:
// `projects/{project}/locations/{location}/processes/{process}/runs/{run}`.
Run *Run `protobuf:"bytes,1,opt,name=run,proto3" json:"run,omitempty"`
// The list of fields to update. Currently not used. The whole message is
// updated.
UpdateMask *fieldmaskpb.FieldMask `protobuf:"bytes,2,opt,name=update_mask,json=updateMask,proto3" json:"update_mask,omitempty"`
// contains filtered or unexported fields
}
Request message for [UpdateRun][google.cloud.datacatalog.lineage.v1.UpdateRun].
func (*UpdateRunRequest) Descriptor
func (*UpdateRunRequest) Descriptor() ([]byte, []int)
Deprecated: Use UpdateRunRequest.ProtoReflect.Descriptor instead.
func (*UpdateRunRequest) GetRun
func (x *UpdateRunRequest) GetRun() *Run
func (*UpdateRunRequest) GetUpdateMask
func (x *UpdateRunRequest) GetUpdateMask() *fieldmaskpb.FieldMask
func (*UpdateRunRequest) ProtoMessage
func (*UpdateRunRequest) ProtoMessage()
func (*UpdateRunRequest) ProtoReflect
func (x *UpdateRunRequest) ProtoReflect() protoreflect.Message
func (*UpdateRunRequest) Reset
func (x *UpdateRunRequest) Reset()
func (*UpdateRunRequest) String
func (x *UpdateRunRequest) String() string