lineagepb

package
v1.26.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Sep 16, 2025 License: Apache-2.0 Imports: 14 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	Lineage_ProcessOpenLineageRunEvent_FullMethodName = "/google.cloud.datacatalog.lineage.v1.Lineage/ProcessOpenLineageRunEvent"
	Lineage_CreateProcess_FullMethodName              = "/google.cloud.datacatalog.lineage.v1.Lineage/CreateProcess"
	Lineage_UpdateProcess_FullMethodName              = "/google.cloud.datacatalog.lineage.v1.Lineage/UpdateProcess"
	Lineage_GetProcess_FullMethodName                 = "/google.cloud.datacatalog.lineage.v1.Lineage/GetProcess"
	Lineage_ListProcesses_FullMethodName              = "/google.cloud.datacatalog.lineage.v1.Lineage/ListProcesses"
	Lineage_DeleteProcess_FullMethodName              = "/google.cloud.datacatalog.lineage.v1.Lineage/DeleteProcess"
	Lineage_CreateRun_FullMethodName                  = "/google.cloud.datacatalog.lineage.v1.Lineage/CreateRun"
	Lineage_UpdateRun_FullMethodName                  = "/google.cloud.datacatalog.lineage.v1.Lineage/UpdateRun"
	Lineage_GetRun_FullMethodName                     = "/google.cloud.datacatalog.lineage.v1.Lineage/GetRun"
	Lineage_ListRuns_FullMethodName                   = "/google.cloud.datacatalog.lineage.v1.Lineage/ListRuns"
	Lineage_DeleteRun_FullMethodName                  = "/google.cloud.datacatalog.lineage.v1.Lineage/DeleteRun"
	Lineage_CreateLineageEvent_FullMethodName         = "/google.cloud.datacatalog.lineage.v1.Lineage/CreateLineageEvent"
	Lineage_GetLineageEvent_FullMethodName            = "/google.cloud.datacatalog.lineage.v1.Lineage/GetLineageEvent"
	Lineage_ListLineageEvents_FullMethodName          = "/google.cloud.datacatalog.lineage.v1.Lineage/ListLineageEvents"
	Lineage_DeleteLineageEvent_FullMethodName         = "/google.cloud.datacatalog.lineage.v1.Lineage/DeleteLineageEvent"
	Lineage_SearchLinks_FullMethodName                = "/google.cloud.datacatalog.lineage.v1.Lineage/SearchLinks"
	Lineage_BatchSearchLinkProcesses_FullMethodName   = "/google.cloud.datacatalog.lineage.v1.Lineage/BatchSearchLinkProcesses"
)

Variables

View Source 
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.

View Source 
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.

View Source 
var (
	OperationMetadata_Type_name = map[int32]string{
		0: "TYPE_UNSPECIFIED",
		1: "DELETE",
		2: "CREATE",
	}
	OperationMetadata_Type_value = map[string]int32{
		"TYPE_UNSPECIFIED": 0,
		"DELETE":           1,
		"CREATE":           2,
	}
)

Enum value maps for OperationMetadata_Type.

View Source 
var (
	Origin_SourceType_name = map[int32]string{
		0: "SOURCE_TYPE_UNSPECIFIED",
		1: "CUSTOM",
		2: "BIGQUERY",
		3: "DATA_FUSION",
		4: "COMPOSER",
		5: "LOOKER_STUDIO",
		6: "DATAPROC",
	}
	Origin_SourceType_value = map[string]int32{
		"SOURCE_TYPE_UNSPECIFIED": 0,
		"CUSTOM":                  1,
		"BIGQUERY":                2,
		"DATA_FUSION":             3,
		"COMPOSER":                4,
		"LOOKER_STUDIO":           5,
		"DATAPROC":                6,
	}
)

Enum value maps for Origin_SourceType.

View Source 
var File_google_cloud_datacatalog_lineage_v1_lineage_proto protoreflect.FileDescriptor
View Source 
var Lineage_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "google.cloud.datacatalog.lineage.v1.Lineage",
	HandlerType: (*LineageServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ProcessOpenLineageRunEvent",
			Handler:    _Lineage_ProcessOpenLineageRunEvent_Handler,
		},
		{
			MethodName: "CreateProcess",
			Handler:    _Lineage_CreateProcess_Handler,
		},
		{
			MethodName: "UpdateProcess",
			Handler:    _Lineage_UpdateProcess_Handler,
		},
		{
			MethodName: "GetProcess",
			Handler:    _Lineage_GetProcess_Handler,
		},
		{
			MethodName: "ListProcesses",
			Handler:    _Lineage_ListProcesses_Handler,
		},
		{
			MethodName: "DeleteProcess",
			Handler:    _Lineage_DeleteProcess_Handler,
		},
		{
			MethodName: "CreateRun",
			Handler:    _Lineage_CreateRun_Handler,
		},
		{
			MethodName: "UpdateRun",
			Handler:    _Lineage_UpdateRun_Handler,
		},
		{
			MethodName: "GetRun",
			Handler:    _Lineage_GetRun_Handler,
		},
		{
			MethodName: "ListRuns",
			Handler:    _Lineage_ListRuns_Handler,
		},
		{
			MethodName: "DeleteRun",
			Handler:    _Lineage_DeleteRun_Handler,
		},
		{
			MethodName: "CreateLineageEvent",
			Handler:    _Lineage_CreateLineageEvent_Handler,
		},
		{
			MethodName: "GetLineageEvent",
			Handler:    _Lineage_GetLineageEvent_Handler,
		},
		{
			MethodName: "ListLineageEvents",
			Handler:    _Lineage_ListLineageEvents_Handler,
		},
		{
			MethodName: "DeleteLineageEvent",
			Handler:    _Lineage_DeleteLineageEvent_Handler,
		},
		{
			MethodName: "SearchLinks",
			Handler:    _Lineage_SearchLinks_Handler,
		},
		{
			MethodName: "BatchSearchLinkProcesses",
			Handler:    _Lineage_BatchSearchLinkProcesses_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "google/cloud/datacatalog/lineage/v1/lineage.proto",
}

Lineage_ServiceDesc is the grpc.ServiceDesc for Lineage service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterLineageServer 

func RegisterLineageServer(s grpc.ServiceRegistrar, srv LineageServer)

Types

type BatchSearchLinkProcessesRequest 

type BatchSearchLinkProcessesRequest struct {

	// Required. The project and location where you want to search.
	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 deprecated 

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

type 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 deprecated 

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

type 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 deprecated 

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

type 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 deprecated 

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

type 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 deprecated 

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

type 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 deprecated 

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

type 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 deprecated 

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

type 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 deprecated 

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

type EntityReference 

type EntityReference struct {

	// Required. [Fully Qualified Name
	// (FQN)](https://cloud.google.com/data-catalog/docs/fully-qualified-names)
	// of the entity.
	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 deprecated 

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 deprecated 

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

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 

func (x *EventLink) String() string

type 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 deprecated 

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

type 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 deprecated 

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

type 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 deprecated 

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

type LineageClient 

type LineageClient interface {
	// Creates new lineage events together with their parents: process and run.
	// Updates the process and run if they already exist.
	// Mapped from Open Lineage specification:
	// https://github.com/OpenLineage/OpenLineage/blob/main/spec/OpenLineage.json.
	ProcessOpenLineageRunEvent(ctx context.Context, in *ProcessOpenLineageRunEventRequest, opts ...grpc.CallOption) (*ProcessOpenLineageRunEventResponse, error)
	// 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://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewLineageClient 

func NewLineageClient(cc grpc.ClientConnInterface) LineageClient

type 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"`
	// Required. 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 deprecated 

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

type LineageServer 

type LineageServer interface {
	// Creates new lineage events together with their parents: process and run.
	// Updates the process and run if they already exist.
	// Mapped from Open Lineage specification:
	// https://github.com/OpenLineage/OpenLineage/blob/main/spec/OpenLineage.json.
	ProcessOpenLineageRunEvent(context.Context, *ProcessOpenLineageRunEventRequest) (*ProcessOpenLineageRunEventResponse, error)
	// 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. All implementations should embed UnimplementedLineageServer for forward compatibility 

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 

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

Deprecated: Use Link.ProtoReflect.Descriptor instead.

func (*Link) GetEndTime 

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

func (*Link) GetName 

func (x *Link) GetName() string

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 

func (x *Link) String() string

type 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 deprecated 

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

type 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 deprecated 

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

type 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 deprecated 

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

type 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 deprecated 

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

type 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 deprecated 

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

type 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 deprecated 

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

type OperationMetadata 

type OperationMetadata struct {

	// Output only. The current operation state.
	State OperationMetadata_State `` /* 129-byte string literal not displayed */
	// Output only. The type of the operation being performed.
	OperationType OperationMetadata_Type `` /* 165-byte string literal not displayed */
	// Output only. The [relative name]
	// (https://cloud.google.com//apis/design/resource_names#relative_resource_name)
	// of the resource being operated on.
	Resource string `protobuf:"bytes,3,opt,name=resource,proto3" json:"resource,omitempty"`
	// Output only. The UUID of the resource being operated on.
	ResourceUuid string `protobuf:"bytes,4,opt,name=resource_uuid,json=resourceUuid,proto3" json:"resource_uuid,omitempty"`
	// Output only. The timestamp of the operation submission to the server.
	CreateTime *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	// Output only. The timestamp of the operation termination, regardless of its
	// success. This field is unset if the operation is still ongoing.
	EndTime *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
	// contains filtered or unexported fields
}

Metadata describing the operation.

func (*OperationMetadata) Descriptor deprecated 

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

type OperationMetadata_State 

type OperationMetadata_State int32

An enum with the state of the operation. 

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 deprecated 

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

type OperationMetadata_Type 

type OperationMetadata_Type int32

Type of the long running operation. 

const (
	// Unused.
	OperationMetadata_TYPE_UNSPECIFIED OperationMetadata_Type = 0
	// The resource deletion operation.
	OperationMetadata_DELETE OperationMetadata_Type = 1
	// The resource creation operation.
	OperationMetadata_CREATE OperationMetadata_Type = 2
)

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 deprecated 

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

type Origin 

type Origin struct {

	// Type of the source.
	//
	// Use of a source_type other than `CUSTOM` for process creation
	// or updating is highly discouraged, and may be restricted in the future
	// without notice.
	SourceType Origin_SourceType `` /* 151-byte string literal not displayed */
	// If the source_type isn't CUSTOM, the value of this field should be a GCP
	// resource name of the system, which reports lineage. The project and
	// location parts of the resource name must match the project and location of
	// the lineage resource being created. Examples:
	//
	//   - `{source_type: COMPOSER, name:
	//     "projects/foo/locations/us/environments/bar"}`
	//   - `{source_type: BIGQUERY, name: "projects/foo/locations/eu"}`
	//   - `{source_type: CUSTOM,   name: "myCustomIntegration"}`
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

Origin of a process.

func (*Origin) Descriptor deprecated 

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

type Origin_SourceType 

type Origin_SourceType int32

Type of the source of a process. 

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
	// Dataproc
	Origin_DATAPROC Origin_SourceType = 6
)

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 deprecated 

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

type Process 

type Process struct {

	// Immutable. The resource name of the lineage process. Format:
	// `projects/{project}/locations/{location}/processes/{process}`.
	// Can be specified or auto-assigned.
	// {process} 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. A human-readable name you can set to display in a user interface.
	// Must be not longer than 200 characters and only contain UTF-8 letters
	// or numbers, spaces or characters like `_-:&.`
	DisplayName string `protobuf:"bytes,2,opt,name=display_name,json=displayName,proto3" json:"display_name,omitempty"`
	// Optional. The attributes of the process. Should only be used for the
	// purpose of non-semantic management (classifying, describing or labeling the
	// process).
	//
	// Up to 100 attributes are allowed.
	Attributes map[string]*structpb.Value `` /* 161-byte string literal not displayed */
	// Optional. The origin of this process and its runs and lineage events.
	Origin *Origin `protobuf:"bytes,4,opt,name=origin,proto3" json:"origin,omitempty"`
	// contains filtered or unexported fields
}

A process is the definition of a data transformation operation.

func (*Process) Descriptor deprecated 

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

type 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 deprecated 

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 deprecated 

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

Deprecated: Use ProcessLinks.ProtoReflect.Descriptor instead. 

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

type ProcessOpenLineageRunEventRequest added in v1.19.0 

type ProcessOpenLineageRunEventRequest struct {

	// Required. The name of the project and its location that should own the
	// process, run, and lineage event.
	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	// Required. OpenLineage message following OpenLineage format:
	// https://github.com/OpenLineage/OpenLineage/blob/main/spec/OpenLineage.json
	OpenLineage *structpb.Struct `protobuf:"bytes,2,opt,name=open_lineage,json=openLineage,proto3" json:"open_lineage,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 [ProcessOpenLineageRunEvent][google.cloud.datacatalog.lineage.v1.ProcessOpenLineageRunEvent].

func (*ProcessOpenLineageRunEventRequest) Descriptor deprecated added in v1.19.0 

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

Deprecated: Use ProcessOpenLineageRunEventRequest.ProtoReflect.Descriptor instead.

func (*ProcessOpenLineageRunEventRequest) GetOpenLineage added in v1.19.0 

func (x *ProcessOpenLineageRunEventRequest) GetOpenLineage() *structpb.Struct

func (*ProcessOpenLineageRunEventRequest) GetParent added in v1.19.0 

func (x *ProcessOpenLineageRunEventRequest) GetParent() string

func (*ProcessOpenLineageRunEventRequest) GetRequestId added in v1.19.0 

func (x *ProcessOpenLineageRunEventRequest) GetRequestId() string

func (*ProcessOpenLineageRunEventRequest) ProtoMessage added in v1.19.0 

func (*ProcessOpenLineageRunEventRequest) ProtoMessage()

func (*ProcessOpenLineageRunEventRequest) ProtoReflect added in v1.19.0 

func (x *ProcessOpenLineageRunEventRequest) ProtoReflect() protoreflect.Message

func (*ProcessOpenLineageRunEventRequest) Reset added in v1.19.0 

func (x *ProcessOpenLineageRunEventRequest) Reset()

func (*ProcessOpenLineageRunEventRequest) String added in v1.19.0 

func (x *ProcessOpenLineageRunEventRequest) String() string

type ProcessOpenLineageRunEventResponse added in v1.19.0 

type ProcessOpenLineageRunEventResponse struct {

	// Created process name.
	// Format: `projects/{project}/locations/{location}/processes/{process}`.
	Process string `protobuf:"bytes,1,opt,name=process,proto3" json:"process,omitempty"`
	// Created run name.
	// Format:
	// `projects/{project}/locations/{location}/processes/{process}/runs/{run}`.
	Run string `protobuf:"bytes,2,opt,name=run,proto3" json:"run,omitempty"`
	// Created lineage event names.
	// Format:
	// `projects/{project}/locations/{location}/processes/{process}/runs/{run}/lineageEvents/{lineage_event}`.
	LineageEvents []string `protobuf:"bytes,3,rep,name=lineage_events,json=lineageEvents,proto3" json:"lineage_events,omitempty"`
	// contains filtered or unexported fields
}

Response message for [ProcessOpenLineageRunEvent][google.cloud.datacatalog.lineage.v1.ProcessOpenLineageRunEvent].

func (*ProcessOpenLineageRunEventResponse) Descriptor deprecated added in v1.19.0 

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

Deprecated: Use ProcessOpenLineageRunEventResponse.ProtoReflect.Descriptor instead.

func (*ProcessOpenLineageRunEventResponse) GetLineageEvents added in v1.19.0 

func (x *ProcessOpenLineageRunEventResponse) GetLineageEvents() []string

func (*ProcessOpenLineageRunEventResponse) GetProcess added in v1.19.0 

func (x *ProcessOpenLineageRunEventResponse) GetProcess() string

func (*ProcessOpenLineageRunEventResponse) GetRun added in v1.19.0 

func (x *ProcessOpenLineageRunEventResponse) GetRun() string

func (*ProcessOpenLineageRunEventResponse) ProtoMessage added in v1.19.0 

func (*ProcessOpenLineageRunEventResponse) ProtoMessage()

func (*ProcessOpenLineageRunEventResponse) ProtoReflect added in v1.19.0 

func (x *ProcessOpenLineageRunEventResponse) ProtoReflect() protoreflect.Message

func (*ProcessOpenLineageRunEventResponse) Reset added in v1.19.0 

func (x *ProcessOpenLineageRunEventResponse) Reset()

func (*ProcessOpenLineageRunEventResponse) String added in v1.19.0 

func (x *ProcessOpenLineageRunEventResponse) String() string

type Run 

type Run struct {

	// Immutable. The resource name of the run. Format:
	// `projects/{project}/locations/{location}/processes/{process}/runs/{run}`.
	// Can be specified or auto-assigned.
	// {run} 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. A human-readable name you can set to display in a user interface.
	// Must be not longer than 1024 characters and only contain UTF-8 letters
	// or numbers, spaces or characters like `_-:&.`
	DisplayName string `protobuf:"bytes,2,opt,name=display_name,json=displayName,proto3" json:"display_name,omitempty"`
	// Optional. The attributes of the run. Should only be used for the purpose of
	// non-semantic management (classifying, describing or labeling the run).
	//
	// Up to 100 attributes are allowed.
	Attributes map[string]*structpb.Value `` /* 161-byte string literal not displayed */
	// Required. The timestamp of the start of the run.
	StartTime *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	// Optional. The timestamp of the end of the run.
	EndTime *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
	// Required. The state of the run.
	State Run_State `protobuf:"varint,6,opt,name=state,proto3,enum=google.cloud.datacatalog.lineage.v1.Run_State" json:"state,omitempty"`
	// contains filtered or unexported fields
}

A lineage run represents an execution of a process that creates lineage events.

func (*Run) Descriptor deprecated 

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

type Run_State 

type Run_State int32

The current state of the run. 

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 deprecated 

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

type SearchLinksRequest 

type SearchLinksRequest struct {

	// Required. The project and location you want search in.
	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 deprecated 

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

type 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"`
}

type 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"`
}

type 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 deprecated 

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

type UnimplementedLineageServer 

type UnimplementedLineageServer struct {
}

UnimplementedLineageServer should 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) ProcessOpenLineageRunEvent added in v1.19.0 

func (UnimplementedLineageServer) ProcessOpenLineageRunEvent(context.Context, *ProcessOpenLineageRunEventRequest) (*ProcessOpenLineageRunEventResponse, 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)

type UnsafeLineageServer added in v1.26.1 

type UnsafeLineageServer interface {
	// contains filtered or unexported methods
}

UnsafeLineageServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to LineageServer will result in compilation errors.

type 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 deprecated 

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

type 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"`
	// If set to true and the run is not found, the request creates 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 [UpdateRun][google.cloud.datacatalog.lineage.v1.UpdateRun].

func (*UpdateRunRequest) Descriptor deprecated 

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

Deprecated: Use UpdateRunRequest.ProtoReflect.Descriptor instead.

func (*UpdateRunRequest) GetAllowMissing added in v1.19.0 

func (x *UpdateRunRequest) GetAllowMissing() bool

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.