Package cloud.google.com/go/datacatalog/lineage/apiv1/lineagepb (v1.13.1)

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 (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 (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
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() ([]byte, []int)

Deprecated: Use EventLink.ProtoReflect.Descriptor instead.

func (x *EventLink) GetSource() *EntityReference
func (x *EventLink) GetTarget() *EntityReference
func (*EventLink) ProtoMessage()
func (x *EventLink) ProtoReflect() protoreflect.Message
func (x *EventLink) Reset()
func (x *EventLink) String() 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 (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.

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() ([]byte, []int)

Deprecated: Use Link.ProtoReflect.Descriptor instead.

func (x *Link) GetEndTime() *timestamppb.Timestamp
func (x *Link) GetName() string
func (x *Link) GetSource() *EntityReference
func (x *Link) GetStartTime() *timestamppb.Timestamp
func (x *Link) GetTarget() *EntityReference
func (*Link) ProtoMessage()
func (x *Link) ProtoReflect() protoreflect.Message
func (x *Link) Reset()
func (x *Link) String() 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 

func (*Origin) Descriptor() ([]byte, []int)

Deprecated: Use Origin.ProtoReflect.Descriptor instead.

func (*Origin) GetName 

func (x *Origin) GetName() string

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 

func (x *Origin) String() 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 

func (*Process) Descriptor() ([]byte, []int)

Deprecated: Use Process.ProtoReflect.Descriptor instead.

func (*Process) GetAttributes 

func (x *Process) GetAttributes() map[string]*structpb.Value

func (*Process) GetDisplayName 

func (x *Process) GetDisplayName() string

func (*Process) GetName 

func (x *Process) GetName() string

func (*Process) GetOrigin 

func (x *Process) GetOrigin() *Origin

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 

func (x *Process) String() 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 (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
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() ([]byte, []int)

Deprecated: Use ProcessLinks.ProtoReflect.Descriptor instead.

func (x *ProcessLinks) GetLinks() []*ProcessLinkInfo
func (x *ProcessLinks) GetProcess() string
func (*ProcessLinks) ProtoMessage()
func (x *ProcessLinks) ProtoReflect() protoreflect.Message
func (x *ProcessLinks) Reset()
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 

func (*Run) Descriptor() ([]byte, []int)

Deprecated: Use Run.ProtoReflect.Descriptor instead.

func (*Run) GetAttributes 

func (x *Run) GetAttributes() map[string]*structpb.Value

func (*Run) GetDisplayName 

func (x *Run) GetDisplayName() string

func (*Run) GetEndTime 

func (x *Run) GetEndTime() *timestamppb.Timestamp

func (*Run) GetName 

func (x *Run) GetName() string

func (*Run) GetStartTime 

func (x *Run) GetStartTime() *timestamppb.Timestamp

func (*Run) GetState 

func (x *Run) GetState() Run_State

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 

func (x *Run) String() 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 (x Run_State) Enum() *Run_State

func (Run_State) EnumDescriptor 

func (Run_State) EnumDescriptor() ([]byte, []int)

Deprecated: Use Run_State.Descriptor instead.

func (Run_State) Number 

func (x Run_State) Number() protoreflect.EnumNumber

func (Run_State) String 

func (x Run_State) String() 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 (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(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