artifact_registry

package
v0.1.0 Latest Latest
Warning

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

 Go to latest Published: Jun 8, 2021 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	Default_ListOperationOptions_OrderByField_Field = ListOperationOptions_OrderByField_ID
	Default_ListOperationOptions_OrderByField_IsAsc = bool(true)
)

Default values for ListOperationOptions_OrderByField fields.

View Source 
const (
	Default_ListOperationOptions_MaxResultSize = int32(20)
)

Default values for ListOperationOptions fields.

View Source 
const (
	Default_MigrationOptions_DowngradeToSchemaVersion = int64(-1)
)

Default values for MigrationOptions fields.

View Source 
const (
	Default_PutArtifactTypeRequest_AllFieldsMatch = bool(true)
)

Default values for PutArtifactTypeRequest fields.

View Source 
const (
	Default_PutContextTypeRequest_AllFieldsMatch = bool(true)
)

Default values for PutContextTypeRequest fields.

View Source 
const (
	Default_PutExecutionTypeRequest_AllFieldsMatch = bool(true)
)

Default values for PutExecutionTypeRequest fields.

View Source 
const (
	Default_PutTypesRequest_AllFieldsMatch = bool(true)
)

Default values for PutTypesRequest fields.

Variables

View Source 
var (
	ArtifactData_ArtifactType_name = map[int32]string{
		0: "MODEL",
		1: "METRICS",
		2: "DATASET",
		3: "OTHER",
	}
	ArtifactData_ArtifactType_value = map[string]int32{
		"MODEL":   0,
		"METRICS": 1,
		"DATASET": 2,
		"OTHER":   3,
	}
)

Enum value maps for ArtifactData_ArtifactType.

View Source 
var (
	ArtifactByTypeRequest_ArtifactType_name = map[int32]string{
		0: "MODEL",
		1: "METRICS",
		2: "DATASET",
	}
	ArtifactByTypeRequest_ArtifactType_value = map[string]int32{
		"MODEL":   0,
		"METRICS": 1,
		"DATASET": 2,
	}
)

Enum value maps for ArtifactByTypeRequest_ArtifactType.

View Source 
var (
	MetadataSourceType_name = map[int32]string{
		0: "UNKNOWN_METADATA_SOURCE",
		1: "FAKE_METADATA_SOURCE",
		2: "MYSQL_METADATA_SOURCE",
		3: "SQLITE_METADATA_SOURCE",
	}
	MetadataSourceType_value = map[string]int32{
		"UNKNOWN_METADATA_SOURCE": 0,
		"FAKE_METADATA_SOURCE":    1,
		"MYSQL_METADATA_SOURCE":   2,
		"SQLITE_METADATA_SOURCE":  3,
	}
)

Enum value maps for MetadataSourceType.

View Source 
var (
	PropertyType_name = map[int32]string{
		0: "UNKNOWN",
		1: "INT",
		2: "DOUBLE",
		3: "STRING",
		4: "STRUCT",
	}
	PropertyType_value = map[string]int32{
		"UNKNOWN": 0,
		"INT":     1,
		"DOUBLE":  2,
		"STRING":  3,
		"STRUCT":  4,
	}
)

Enum value maps for PropertyType.

View Source 
var (
	Artifact_State_name = map[int32]string{
		0: "UNKNOWN",
		1: "PENDING",
		2: "LIVE",
		3: "MARKED_FOR_DELETION",
		4: "DELETED",
	}
	Artifact_State_value = map[string]int32{
		"UNKNOWN":             0,
		"PENDING":             1,
		"LIVE":                2,
		"MARKED_FOR_DELETION": 3,
		"DELETED":             4,
	}
)

Enum value maps for Artifact_State.

View Source 
var (
	Event_Type_name = map[int32]string{
		0: "UNKNOWN",
		1: "DECLARED_OUTPUT",
		2: "DECLARED_INPUT",
		3: "INPUT",
		4: "OUTPUT",
		5: "INTERNAL_INPUT",
		6: "INTERNAL_OUTPUT",
	}
	Event_Type_value = map[string]int32{
		"UNKNOWN":         0,
		"DECLARED_OUTPUT": 1,
		"DECLARED_INPUT":  2,
		"INPUT":           3,
		"OUTPUT":          4,
		"INTERNAL_INPUT":  5,
		"INTERNAL_OUTPUT": 6,
	}
)

Enum value maps for Event_Type.

View Source 
var (
	Execution_State_name = map[int32]string{
		0: "UNKNOWN",
		1: "NEW",
		2: "RUNNING",
		3: "COMPLETE",
		4: "FAILED",
		5: "CACHED",
		6: "CANCELED",
	}
	Execution_State_value = map[string]int32{
		"UNKNOWN":  0,
		"NEW":      1,
		"RUNNING":  2,
		"COMPLETE": 3,
		"FAILED":   4,
		"CACHED":   5,
		"CANCELED": 6,
	}
)

Enum value maps for Execution_State.

View Source 
var (
	SqliteMetadataSourceConfig_ConnectionMode_name = map[int32]string{
		0: "UNKNOWN",
		1: "READONLY",
		2: "READWRITE",
		3: "READWRITE_OPENCREATE",
	}
	SqliteMetadataSourceConfig_ConnectionMode_value = map[string]int32{
		"UNKNOWN":              0,
		"READONLY":             1,
		"READWRITE":            2,
		"READWRITE_OPENCREATE": 3,
	}
)

Enum value maps for SqliteMetadataSourceConfig_ConnectionMode.

View Source 
var (
	ListOperationOptions_OrderByField_Field_name = map[int32]string{
		0: "FIELD_UNSPECIFIED",
		1: "CREATE_TIME",
		2: "LAST_UPDATE_TIME",
		3: "ID",
	}
	ListOperationOptions_OrderByField_Field_value = map[string]int32{
		"FIELD_UNSPECIFIED": 0,
		"CREATE_TIME":       1,
		"LAST_UPDATE_TIME":  2,
		"ID":                3,
	}
)

Enum value maps for ListOperationOptions_OrderByField_Field.

View Source 
var File_artifact_registry_proto protoreflect.FileDescriptor
View Source 
var File_metadata_source_proto protoreflect.FileDescriptor
View Source 
var File_metadata_store_proto protoreflect.FileDescriptor
View Source 
var File_metadata_store_service_proto protoreflect.FileDescriptor

Functions

func RegisterMetadataStoreServiceServer 

func RegisterMetadataStoreServiceServer(s *grpc.Server, srv MetadataStoreServiceServer)

Types

type AnyArtifactStructType 

type AnyArtifactStructType struct {
	// contains filtered or unexported fields
}

Every ArtifactStruct is a member of this type.

func (*AnyArtifactStructType) Descriptor deprecated 

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

Deprecated: Use AnyArtifactStructType.ProtoReflect.Descriptor instead.

func (*AnyArtifactStructType) ProtoMessage 

func (*AnyArtifactStructType) ProtoMessage()

func (*AnyArtifactStructType) ProtoReflect 

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

func (*AnyArtifactStructType) Reset 

func (x *AnyArtifactStructType) Reset()

func (*AnyArtifactStructType) String 

func (x *AnyArtifactStructType) String() string

type Artifact 

type Artifact struct {

	// Output only. The globally unique server generated id of the artifact.
	Id *int64 `protobuf:"varint,1,opt,name=id" json:"id,omitempty"`
	// The client provided name of the artifact. This field is optional. If set,
	// it must be unique among all the artifacts of the same artifact type within
	// a database instance and cannot be changed once set.
	Name *string `protobuf:"bytes,7,opt,name=name" json:"name,omitempty"`
	// The id of an ArtifactType. This needs to be specified when an artifact is
	// created, and it cannot be changed.
	TypeId *int64 `protobuf:"varint,2,opt,name=type_id,json=typeId" json:"type_id,omitempty"`
	// Output only. The name of an ArtifactType.
	Type *string `protobuf:"bytes,8,opt,name=type" json:"type,omitempty"`
	// The uniform resource identifier of the physical artifact.
	// May be empty if there is no physical artifact.
	Uri *string `protobuf:"bytes,3,opt,name=uri" json:"uri,omitempty"`
	// Properties of the artifact.
	// Properties must be specified in the ArtifactType.
	Properties map[string]*Value `` /* 140-byte string literal not displayed */
	// User provided custom properties which are not defined by its type.
	CustomProperties map[string]*Value `` /* 176-byte string literal not displayed */
	// The state of the artifact known to the system.
	State *Artifact_State `protobuf:"varint,6,opt,name=state,enum=ml_metadata.Artifact_State" json:"state,omitempty"`
	// Output only. Create time of the artifact in millisecond since epoch.
	CreateTimeSinceEpoch *int64 `protobuf:"varint,9,opt,name=create_time_since_epoch,json=createTimeSinceEpoch" json:"create_time_since_epoch,omitempty"`
	// Output only. Last update time of the artifact since epoch in millisecond
	// since epoch.
	LastUpdateTimeSinceEpoch *int64 `` /* 134-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Artifact) Descriptor deprecated 

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

Deprecated: Use Artifact.ProtoReflect.Descriptor instead.

func (*Artifact) GetCreateTimeSinceEpoch 

func (x *Artifact) GetCreateTimeSinceEpoch() int64

func (*Artifact) GetCustomProperties 

func (x *Artifact) GetCustomProperties() map[string]*Value

func (*Artifact) GetId 

func (x *Artifact) GetId() int64

func (*Artifact) GetLastUpdateTimeSinceEpoch 

func (x *Artifact) GetLastUpdateTimeSinceEpoch() int64

func (*Artifact) GetName 

func (x *Artifact) GetName() string

func (*Artifact) GetProperties 

func (x *Artifact) GetProperties() map[string]*Value

func (*Artifact) GetState 

func (x *Artifact) GetState() Artifact_State

func (*Artifact) GetType 

func (x *Artifact) GetType() string

func (*Artifact) GetTypeId 

func (x *Artifact) GetTypeId() int64

func (*Artifact) GetUri 

func (x *Artifact) GetUri() string

func (*Artifact) ProtoMessage 

func (*Artifact) ProtoMessage()

func (*Artifact) ProtoReflect 

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

func (*Artifact) Reset 

func (x *Artifact) Reset()

func (*Artifact) String 

func (x *Artifact) String() string

type ArtifactAndType 

type ArtifactAndType struct {
	Artifact *Artifact     `protobuf:"bytes,1,opt,name=artifact" json:"artifact,omitempty"`
	Type     *ArtifactType `protobuf:"bytes,2,opt,name=type" json:"type,omitempty"`
	// contains filtered or unexported fields
}

An artifact and type pair. Part of an artifact struct.

func (*ArtifactAndType) Descriptor deprecated 

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

Deprecated: Use ArtifactAndType.ProtoReflect.Descriptor instead.

func (*ArtifactAndType) GetArtifact 

func (x *ArtifactAndType) GetArtifact() *Artifact

func (*ArtifactAndType) GetType 

func (x *ArtifactAndType) GetType() *ArtifactType

func (*ArtifactAndType) ProtoMessage 

func (*ArtifactAndType) ProtoMessage()

func (*ArtifactAndType) ProtoReflect 

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

func (*ArtifactAndType) Reset 

func (x *ArtifactAndType) Reset()

func (*ArtifactAndType) String 

func (x *ArtifactAndType) String() string

type ArtifactByTypeRequest 

type ArtifactByTypeRequest struct {
	ArtifactType ArtifactByTypeRequest_ArtifactType `` /* 156-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ArtifactByTypeRequest) Descriptor deprecated 

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

Deprecated: Use ArtifactByTypeRequest.ProtoReflect.Descriptor instead.

func (*ArtifactByTypeRequest) GetArtifactType 

func (x *ArtifactByTypeRequest) GetArtifactType() ArtifactByTypeRequest_ArtifactType

func (*ArtifactByTypeRequest) ProtoMessage 

func (*ArtifactByTypeRequest) ProtoMessage()

func (*ArtifactByTypeRequest) ProtoReflect 

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

func (*ArtifactByTypeRequest) Reset 

func (x *ArtifactByTypeRequest) Reset()

func (*ArtifactByTypeRequest) String 

func (x *ArtifactByTypeRequest) String() string

type ArtifactByTypeRequest_ArtifactType 

type ArtifactByTypeRequest_ArtifactType int32
const (
	ArtifactByTypeRequest_MODEL   ArtifactByTypeRequest_ArtifactType = 0
	ArtifactByTypeRequest_METRICS ArtifactByTypeRequest_ArtifactType = 1
	ArtifactByTypeRequest_DATASET ArtifactByTypeRequest_ArtifactType = 2
)

func (ArtifactByTypeRequest_ArtifactType) Descriptor 

func (ArtifactByTypeRequest_ArtifactType) Descriptor() protoreflect.EnumDescriptor

func (ArtifactByTypeRequest_ArtifactType) Enum 

func (x ArtifactByTypeRequest_ArtifactType) Enum() *ArtifactByTypeRequest_ArtifactType

func (ArtifactByTypeRequest_ArtifactType) EnumDescriptor deprecated 

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

Deprecated: Use ArtifactByTypeRequest_ArtifactType.Descriptor instead.

func (ArtifactByTypeRequest_ArtifactType) Number 

func (x ArtifactByTypeRequest_ArtifactType) Number() protoreflect.EnumNumber

func (ArtifactByTypeRequest_ArtifactType) String 

func (x ArtifactByTypeRequest_ArtifactType) String() string

func (ArtifactByTypeRequest_ArtifactType) Type 

func (ArtifactByTypeRequest_ArtifactType) Type() protoreflect.EnumType

type ArtifactData 

type ArtifactData struct {
	Name         string                    `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Uri          string                    `protobuf:"bytes,2,opt,name=uri,proto3" json:"uri,omitempty"`
	Version      string                    `protobuf:"bytes,3,opt,name=version,proto3" json:"version,omitempty"`
	RunId        string                    `protobuf:"bytes,4,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	Id           int64                     `protobuf:"varint,5,opt,name=id,proto3" json:"id,omitempty"`
	ArtifactType ArtifactData_ArtifactType `` /* 147-byte string literal not displayed */
	Metadata     *structpb.Struct          `protobuf:"bytes,7,opt,name=metadata,proto3,oneof" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

func (*ArtifactData) Descriptor deprecated 

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

Deprecated: Use ArtifactData.ProtoReflect.Descriptor instead.

func (*ArtifactData) GetArtifactType 

func (x *ArtifactData) GetArtifactType() ArtifactData_ArtifactType

func (*ArtifactData) GetId 

func (x *ArtifactData) GetId() int64

func (*ArtifactData) GetMetadata 

func (x *ArtifactData) GetMetadata() *structpb.Struct

func (*ArtifactData) GetName 

func (x *ArtifactData) GetName() string

func (*ArtifactData) GetRunId 

func (x *ArtifactData) GetRunId() string

func (*ArtifactData) GetUri 

func (x *ArtifactData) GetUri() string

func (*ArtifactData) GetVersion 

func (x *ArtifactData) GetVersion() string

func (*ArtifactData) ProtoMessage 

func (*ArtifactData) ProtoMessage()

func (*ArtifactData) ProtoReflect 

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

func (*ArtifactData) Reset 

func (x *ArtifactData) Reset()

func (*ArtifactData) String 

func (x *ArtifactData) String() string

type ArtifactData_ArtifactType 

type ArtifactData_ArtifactType int32
const (
	ArtifactData_MODEL   ArtifactData_ArtifactType = 0
	ArtifactData_METRICS ArtifactData_ArtifactType = 1
	ArtifactData_DATASET ArtifactData_ArtifactType = 2
	ArtifactData_OTHER   ArtifactData_ArtifactType = 3
)

func (ArtifactData_ArtifactType) Descriptor 

func (ArtifactData_ArtifactType) Descriptor() protoreflect.EnumDescriptor

func (ArtifactData_ArtifactType) Enum 

func (x ArtifactData_ArtifactType) Enum() *ArtifactData_ArtifactType

func (ArtifactData_ArtifactType) EnumDescriptor deprecated 

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

Deprecated: Use ArtifactData_ArtifactType.Descriptor instead.

func (ArtifactData_ArtifactType) Number 

func (x ArtifactData_ArtifactType) Number() protoreflect.EnumNumber

func (ArtifactData_ArtifactType) String 

func (x ArtifactData_ArtifactType) String() string

func (ArtifactData_ArtifactType) Type 

func (ArtifactData_ArtifactType) Type() protoreflect.EnumType

type ArtifactStruct 

type ArtifactStruct struct {

	// Note: an artifact struct may be empty to indicate "None" or null.
	//
	// Types that are assignable to Value:
	//	*ArtifactStruct_Artifact
	//	*ArtifactStruct_Map
	//	*ArtifactStruct_List
	Value isArtifactStruct_Value `protobuf_oneof:"value"`
	// contains filtered or unexported fields
}

An artifact struct represents the input or output of an Execution. See the more specific types referenced in the message for more details.

func (*ArtifactStruct) Descriptor deprecated 

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

Deprecated: Use ArtifactStruct.ProtoReflect.Descriptor instead.

func (*ArtifactStruct) GetArtifact 

func (x *ArtifactStruct) GetArtifact() *ArtifactAndType

func (*ArtifactStruct) GetList 

func (x *ArtifactStruct) GetList() *ArtifactStructList

func (*ArtifactStruct) GetMap 

func (x *ArtifactStruct) GetMap() *ArtifactStructMap

func (*ArtifactStruct) GetValue 

func (m *ArtifactStruct) GetValue() isArtifactStruct_Value

func (*ArtifactStruct) ProtoMessage 

func (*ArtifactStruct) ProtoMessage()

func (*ArtifactStruct) ProtoReflect 

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

func (*ArtifactStruct) Reset 

func (x *ArtifactStruct) Reset()

func (*ArtifactStruct) String 

func (x *ArtifactStruct) String() string

type ArtifactStructList 

type ArtifactStructList struct {

	// Can be represented as a JSON list of artifact structs.
	Elements []*ArtifactStruct `protobuf:"bytes,1,rep,name=elements" json:"elements,omitempty"`
	// contains filtered or unexported fields
}

An artifact struct that is a list.

func (*ArtifactStructList) Descriptor deprecated 

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

Deprecated: Use ArtifactStructList.ProtoReflect.Descriptor instead.

func (*ArtifactStructList) GetElements 

func (x *ArtifactStructList) GetElements() []*ArtifactStruct

func (*ArtifactStructList) ProtoMessage 

func (*ArtifactStructList) ProtoMessage()

func (*ArtifactStructList) ProtoReflect 

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

func (*ArtifactStructList) Reset 

func (x *ArtifactStructList) Reset()

func (*ArtifactStructList) String 

func (x *ArtifactStructList) String() string

type ArtifactStructMap 

type ArtifactStructMap struct {

	// An artifact struct that is a dictionary.
	// Can be represented as a JSON dictionary of artifact structs.
	Properties map[string]*ArtifactStruct `` /* 140-byte string literal not displayed */
	// contains filtered or unexported fields
}

A dictionary of artifact structs. Can represent a dictionary.

func (*ArtifactStructMap) Descriptor deprecated 

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

Deprecated: Use ArtifactStructMap.ProtoReflect.Descriptor instead.

func (*ArtifactStructMap) GetProperties 

func (x *ArtifactStructMap) GetProperties() map[string]*ArtifactStruct

func (*ArtifactStructMap) ProtoMessage 

func (*ArtifactStructMap) ProtoMessage()

func (*ArtifactStructMap) ProtoReflect 

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

func (*ArtifactStructMap) Reset 

func (x *ArtifactStructMap) Reset()

func (*ArtifactStructMap) String 

func (x *ArtifactStructMap) String() string

type ArtifactStructType 

type ArtifactStructType struct {

	// Types that are assignable to Kind:
	//	*ArtifactStructType_Simple
	//	*ArtifactStructType_UnionType
	//	*ArtifactStructType_Intersection
	//	*ArtifactStructType_List
	//	*ArtifactStructType_None
	//	*ArtifactStructType_Any
	//	*ArtifactStructType_Tuple
	//	*ArtifactStructType_Dict
	Kind isArtifactStructType_Kind `protobuf_oneof:"kind"`
	// contains filtered or unexported fields
}

The list of ArtifactStruct is EXPERIMENTAL and not in use yet. The type of an ArtifactStruct. An artifact struct type represents an infinite set of artifact structs. It can specify the input or output type of an ExecutionType. See the more specific types referenced in the message for more details.

func (*ArtifactStructType) Descriptor deprecated 

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

Deprecated: Use ArtifactStructType.ProtoReflect.Descriptor instead.

func (*ArtifactStructType) GetAny 

func (x *ArtifactStructType) GetAny() *AnyArtifactStructType

func (*ArtifactStructType) GetDict 

func (x *ArtifactStructType) GetDict() *DictArtifactStructType

func (*ArtifactStructType) GetIntersection 

func (x *ArtifactStructType) GetIntersection() *IntersectionArtifactStructType

func (*ArtifactStructType) GetKind 

func (m *ArtifactStructType) GetKind() isArtifactStructType_Kind

func (*ArtifactStructType) GetList 

func (x *ArtifactStructType) GetList() *ListArtifactStructType

func (*ArtifactStructType) GetNone 

func (x *ArtifactStructType) GetNone() *NoneArtifactStructType

func (*ArtifactStructType) GetSimple 

func (x *ArtifactStructType) GetSimple() *ArtifactType

func (*ArtifactStructType) GetTuple 

func (x *ArtifactStructType) GetTuple() *TupleArtifactStructType

func (*ArtifactStructType) GetUnionType 

func (x *ArtifactStructType) GetUnionType() *UnionArtifactStructType

func (*ArtifactStructType) ProtoMessage 

func (*ArtifactStructType) ProtoMessage()

func (*ArtifactStructType) ProtoReflect 

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

func (*ArtifactStructType) Reset 

func (x *ArtifactStructType) Reset()

func (*ArtifactStructType) String 

func (x *ArtifactStructType) String() string

type ArtifactStructType_Any 

type ArtifactStructType_Any struct {
	Any *AnyArtifactStructType `protobuf:"bytes,6,opt,name=any,oneof"`
}

type ArtifactStructType_Dict 

type ArtifactStructType_Dict struct {
	Dict *DictArtifactStructType `protobuf:"bytes,8,opt,name=dict,oneof"`
}

type ArtifactStructType_Intersection 

type ArtifactStructType_Intersection struct {
	Intersection *IntersectionArtifactStructType `protobuf:"bytes,3,opt,name=intersection,oneof"`
}

type ArtifactStructType_List 

type ArtifactStructType_List struct {
	List *ListArtifactStructType `protobuf:"bytes,4,opt,name=list,oneof"`
}

type ArtifactStructType_None 

type ArtifactStructType_None struct {
	None *NoneArtifactStructType `protobuf:"bytes,5,opt,name=none,oneof"`
}

type ArtifactStructType_Simple 

type ArtifactStructType_Simple struct {
	Simple *ArtifactType `protobuf:"bytes,1,opt,name=simple,oneof"` // Matches exactly this type.
}

type ArtifactStructType_Tuple 

type ArtifactStructType_Tuple struct {
	Tuple *TupleArtifactStructType `protobuf:"bytes,7,opt,name=tuple,oneof"`
}

type ArtifactStructType_UnionType 

type ArtifactStructType_UnionType struct {
	UnionType *UnionArtifactStructType `protobuf:"bytes,2,opt,name=union_type,json=unionType,oneof"`
}

type ArtifactStruct_Artifact 

type ArtifactStruct_Artifact struct {
	Artifact *ArtifactAndType `protobuf:"bytes,1,opt,name=artifact,oneof"`
}

type ArtifactStruct_List 

type ArtifactStruct_List struct {
	List *ArtifactStructList `protobuf:"bytes,3,opt,name=list,oneof"`
}

type ArtifactStruct_Map 

type ArtifactStruct_Map struct {
	Map *ArtifactStructMap `protobuf:"bytes,2,opt,name=map,oneof"`
}

type ArtifactType 

type ArtifactType struct {

	// The id of the type. 1-1 relationship between type names and IDs.
	Id *int64 `protobuf:"varint,1,opt,name=id" json:"id,omitempty"`
	// The name of the type. It must be unique among ArtifactTypes within a
	// database instance.
	Name *string `protobuf:"bytes,2,opt,name=name" json:"name,omitempty"`
	// An optional version of the type. An empty string is treated as unset.
	Version *string `protobuf:"bytes,4,opt,name=version" json:"version,omitempty"`
	// An optional description about the type.
	Description *string `protobuf:"bytes,5,opt,name=description" json:"description,omitempty"`
	// The schema of the type.
	// Properties are always optional in the artifact.
	// Properties of an artifact type can be expanded but not contracted (i.e.,
	// you can add columns but not remove them).
	Properties map[string]PropertyType `` /* 171-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ArtifactType) Descriptor deprecated 

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

Deprecated: Use ArtifactType.ProtoReflect.Descriptor instead.

func (*ArtifactType) GetDescription 

func (x *ArtifactType) GetDescription() string

func (*ArtifactType) GetId 

func (x *ArtifactType) GetId() int64

func (*ArtifactType) GetName 

func (x *ArtifactType) GetName() string

func (*ArtifactType) GetProperties 

func (x *ArtifactType) GetProperties() map[string]PropertyType

func (*ArtifactType) GetVersion 

func (x *ArtifactType) GetVersion() string

func (*ArtifactType) ProtoMessage 

func (*ArtifactType) ProtoMessage()

func (*ArtifactType) ProtoReflect 

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

func (*ArtifactType) Reset 

func (x *ArtifactType) Reset()

func (*ArtifactType) String 

func (x *ArtifactType) String() string

type Artifact_State 

type Artifact_State int32
const (
	Artifact_UNKNOWN Artifact_State = 0
	// A state indicating that the artifact may exist.
	Artifact_PENDING Artifact_State = 1
	// A state indicating that the artifact should exist, unless something
	// external to the system deletes it.
	Artifact_LIVE Artifact_State = 2
	// A state indicating that the artifact should be deleted.
	Artifact_MARKED_FOR_DELETION Artifact_State = 3
	// A state indicating that the artifact has been deleted.
	Artifact_DELETED Artifact_State = 4
)

func (Artifact_State) Descriptor 

func (Artifact_State) Descriptor() protoreflect.EnumDescriptor

func (Artifact_State) Enum 

func (x Artifact_State) Enum() *Artifact_State

func (Artifact_State) EnumDescriptor deprecated 

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

Deprecated: Use Artifact_State.Descriptor instead.

func (Artifact_State) Number 

func (x Artifact_State) Number() protoreflect.EnumNumber

func (Artifact_State) String 

func (x Artifact_State) String() string

func (Artifact_State) Type 

func (Artifact_State) Type() protoreflect.EnumType

func (*Artifact_State) UnmarshalJSON deprecated 

func (x *Artifact_State) UnmarshalJSON(b []byte) error

Deprecated: Do not use.

type ArtifactsByModelRequest 

type ArtifactsByModelRequest struct {
	ModelId int64 `protobuf:"varint,1,opt,name=model_id,json=modelId,proto3" json:"model_id,omitempty"`
	// contains filtered or unexported fields
}

func (*ArtifactsByModelRequest) Descriptor deprecated 

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

Deprecated: Use ArtifactsByModelRequest.ProtoReflect.Descriptor instead.

func (*ArtifactsByModelRequest) GetModelId 

func (x *ArtifactsByModelRequest) GetModelId() int64

func (*ArtifactsByModelRequest) ProtoMessage 

func (*ArtifactsByModelRequest) ProtoMessage()

func (*ArtifactsByModelRequest) ProtoReflect 

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

func (*ArtifactsByModelRequest) Reset 

func (x *ArtifactsByModelRequest) Reset()

func (*ArtifactsByModelRequest) String 

func (x *ArtifactsByModelRequest) String() string

type ArtifactsByRunRequest 

type ArtifactsByRunRequest struct {
	RunId string `protobuf:"bytes,1,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	// contains filtered or unexported fields
}

func (*ArtifactsByRunRequest) Descriptor deprecated 

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

Deprecated: Use ArtifactsByRunRequest.ProtoReflect.Descriptor instead.

func (*ArtifactsByRunRequest) GetRunId 

func (x *ArtifactsByRunRequest) GetRunId() string

func (*ArtifactsByRunRequest) ProtoMessage 

func (*ArtifactsByRunRequest) ProtoMessage()

func (*ArtifactsByRunRequest) ProtoReflect 

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

func (*ArtifactsByRunRequest) Reset 

func (x *ArtifactsByRunRequest) Reset()

func (*ArtifactsByRunRequest) String 

func (x *ArtifactsByRunRequest) String() string

type ArtifactsResponse 

type ArtifactsResponse struct {
	Artifacts []*ArtifactData `protobuf:"bytes,1,rep,name=artifacts,proto3" json:"artifacts,omitempty"`
	// contains filtered or unexported fields
}

func (*ArtifactsResponse) Descriptor deprecated 

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

Deprecated: Use ArtifactsResponse.ProtoReflect.Descriptor instead.

func (*ArtifactsResponse) GetArtifacts 

func (x *ArtifactsResponse) GetArtifacts() []*ArtifactData

func (*ArtifactsResponse) ProtoMessage 

func (*ArtifactsResponse) ProtoMessage()

func (*ArtifactsResponse) ProtoReflect 

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

func (*ArtifactsResponse) Reset 

func (x *ArtifactsResponse) Reset()

func (*ArtifactsResponse) String 

func (x *ArtifactsResponse) String() string

type Association 

type Association struct {
	ExecutionId *int64 `protobuf:"varint,1,opt,name=execution_id,json=executionId" json:"execution_id,omitempty"`
	ContextId   *int64 `protobuf:"varint,2,opt,name=context_id,json=contextId" json:"context_id,omitempty"`
	// contains filtered or unexported fields
}

the Association edges between Context and Execution instances.

func (*Association) Descriptor deprecated 

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

Deprecated: Use Association.ProtoReflect.Descriptor instead.

func (*Association) GetContextId 

func (x *Association) GetContextId() int64

func (*Association) GetExecutionId 

func (x *Association) GetExecutionId() int64

func (*Association) ProtoMessage 

func (*Association) ProtoMessage()

func (*Association) ProtoReflect 

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

func (*Association) Reset 

func (x *Association) Reset()

func (*Association) String 

func (x *Association) String() string

type Attribution 

type Attribution struct {
	ArtifactId *int64 `protobuf:"varint,1,opt,name=artifact_id,json=artifactId" json:"artifact_id,omitempty"`
	ContextId  *int64 `protobuf:"varint,2,opt,name=context_id,json=contextId" json:"context_id,omitempty"`
	// contains filtered or unexported fields
}

the Attribution edges between Context and Artifact instances.

func (*Attribution) Descriptor deprecated 

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

Deprecated: Use Attribution.ProtoReflect.Descriptor instead.

func (*Attribution) GetArtifactId 

func (x *Attribution) GetArtifactId() int64

func (*Attribution) GetContextId 

func (x *Attribution) GetContextId() int64

func (*Attribution) ProtoMessage 

func (*Attribution) ProtoMessage()

func (*Attribution) ProtoReflect 

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

func (*Attribution) Reset 

func (x *Attribution) Reset()

func (*Attribution) String 

func (x *Attribution) String() string

type ConnectionConfig 

type ConnectionConfig struct {

	// Configuration for a new connection.
	//
	// Types that are assignable to Config:
	//	*ConnectionConfig_FakeDatabase
	//	*ConnectionConfig_Mysql
	//	*ConnectionConfig_Sqlite
	Config isConnectionConfig_Config `protobuf_oneof:"config"`
	// Options for overwriting the default retry setting when MLMD transactions
	// returning Aborted error.
	// The setting is currently available for python client library only.
	// TODO(b/154862807) set the setting in transaction executor.
	RetryOptions *RetryOptions `protobuf:"bytes,4,opt,name=retry_options,json=retryOptions" json:"retry_options,omitempty"`
	// contains filtered or unexported fields
}

func (*ConnectionConfig) Descriptor deprecated 

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

Deprecated: Use ConnectionConfig.ProtoReflect.Descriptor instead.

func (*ConnectionConfig) GetConfig 

func (m *ConnectionConfig) GetConfig() isConnectionConfig_Config

func (*ConnectionConfig) GetFakeDatabase 

func (x *ConnectionConfig) GetFakeDatabase() *FakeDatabaseConfig

func (*ConnectionConfig) GetMysql 

func (x *ConnectionConfig) GetMysql() *MySQLDatabaseConfig

func (*ConnectionConfig) GetRetryOptions 

func (x *ConnectionConfig) GetRetryOptions() *RetryOptions

func (*ConnectionConfig) GetSqlite 

func (x *ConnectionConfig) GetSqlite() *SqliteMetadataSourceConfig

func (*ConnectionConfig) ProtoMessage 

func (*ConnectionConfig) ProtoMessage()

func (*ConnectionConfig) ProtoReflect 

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

func (*ConnectionConfig) Reset 

func (x *ConnectionConfig) Reset()

func (*ConnectionConfig) String 

func (x *ConnectionConfig) String() string

type ConnectionConfig_FakeDatabase 

type ConnectionConfig_FakeDatabase struct {
	FakeDatabase *FakeDatabaseConfig `protobuf:"bytes,1,opt,name=fake_database,json=fakeDatabase,oneof"`
}

type ConnectionConfig_Mysql 

type ConnectionConfig_Mysql struct {
	Mysql *MySQLDatabaseConfig `protobuf:"bytes,2,opt,name=mysql,oneof"`
}

type ConnectionConfig_Sqlite 

type ConnectionConfig_Sqlite struct {
	Sqlite *SqliteMetadataSourceConfig `protobuf:"bytes,3,opt,name=sqlite,oneof"`
}

type Context 

type Context struct {

	// Output Only. The globally unique server generated id of the context.
	Id *int64 `protobuf:"varint,1,opt,name=id" json:"id,omitempty"`
	// The client provided name of the context. It must be unique within a
	// database instance.
	Name *string `protobuf:"bytes,3,opt,name=name" json:"name,omitempty"`
	// The id of a ContextType. This needs to be specified when a context is
	// created, and it cannot be changed.
	TypeId *int64 `protobuf:"varint,2,opt,name=type_id,json=typeId" json:"type_id,omitempty"`
	// Output only. The name of a ContextType.
	Type *string `protobuf:"bytes,6,opt,name=type" json:"type,omitempty"`
	// Values of the properties, which must be specified in the ContextType.
	Properties map[string]*Value `` /* 140-byte string literal not displayed */
	// User provided custom properties which are not defined by its type.
	CustomProperties map[string]*Value `` /* 176-byte string literal not displayed */
	// Output only. Create time of the context in millisecond since epoch.
	CreateTimeSinceEpoch *int64 `protobuf:"varint,7,opt,name=create_time_since_epoch,json=createTimeSinceEpoch" json:"create_time_since_epoch,omitempty"`
	// Output only. Last update time of the context in millisecond since epoch.
	LastUpdateTimeSinceEpoch *int64 `` /* 133-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Context) Descriptor deprecated 

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

Deprecated: Use Context.ProtoReflect.Descriptor instead.

func (*Context) GetCreateTimeSinceEpoch 

func (x *Context) GetCreateTimeSinceEpoch() int64

func (*Context) GetCustomProperties 

func (x *Context) GetCustomProperties() map[string]*Value

func (*Context) GetId 

func (x *Context) GetId() int64

func (*Context) GetLastUpdateTimeSinceEpoch 

func (x *Context) GetLastUpdateTimeSinceEpoch() int64

func (*Context) GetName 

func (x *Context) GetName() string

func (*Context) GetProperties 

func (x *Context) GetProperties() map[string]*Value

func (*Context) GetType 

func (x *Context) GetType() string

func (*Context) GetTypeId 

func (x *Context) GetTypeId() int64

func (*Context) ProtoMessage 

func (*Context) ProtoMessage()

func (*Context) ProtoReflect 

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

func (*Context) Reset 

func (x *Context) Reset()

func (*Context) String 

func (x *Context) String() string

type ContextType 

type ContextType struct {

	// The id of the type. 1-1 relationship between type names and IDs.
	Id *int64 `protobuf:"varint,1,opt,name=id" json:"id,omitempty"`
	// The name of the type, e.g., Pipeline, Task, Session, User, etc. It must be
	// unique among ContextTypes within a database instance.
	Name *string `protobuf:"bytes,2,opt,name=name" json:"name,omitempty"`
	// An optional version of the type. An empty string is treated as unset.
	Version *string `protobuf:"bytes,4,opt,name=version" json:"version,omitempty"`
	// An optional description about the type.
	Description *string `protobuf:"bytes,5,opt,name=description" json:"description,omitempty"`
	// The schema of the type, e.g., name: string, owner: string
	// Properties are always optional in the context.
	// Properties of an context type can be expanded but not contracted (i.e.,
	// you can add columns but not remove them).
	Properties map[string]PropertyType `` /* 171-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ContextType) Descriptor deprecated 

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

Deprecated: Use ContextType.ProtoReflect.Descriptor instead.

func (*ContextType) GetDescription 

func (x *ContextType) GetDescription() string

func (*ContextType) GetId 

func (x *ContextType) GetId() int64

func (*ContextType) GetName 

func (x *ContextType) GetName() string

func (*ContextType) GetProperties 

func (x *ContextType) GetProperties() map[string]PropertyType

func (*ContextType) GetVersion 

func (x *ContextType) GetVersion() string

func (*ContextType) ProtoMessage 

func (*ContextType) ProtoMessage()

func (*ContextType) ProtoReflect 

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

func (*ContextType) Reset 

func (x *ContextType) Reset()

func (*ContextType) String 

func (x *ContextType) String() string

type DictArtifactStructType 

type DictArtifactStructType struct {

	// Underlying properties for the type.
	Properties map[string]*ArtifactStructType `` /* 140-byte string literal not displayed */
	// If true, then if properties["foo"] can be None, then that key is not
	// required.
	NoneTypeNotRequired *bool `protobuf:"varint,2,opt,name=none_type_not_required,json=noneTypeNotRequired" json:"none_type_not_required,omitempty"`
	// Extra keys are allowed that are not specified in properties. These
	// keys must have the type specified below.
	// If this is not specified, then extra properties are not allowed.
	ExtraPropertiesType *ArtifactStructType `protobuf:"bytes,3,opt,name=extra_properties_type,json=extraPropertiesType" json:"extra_properties_type,omitempty"`
	// contains filtered or unexported fields
}

A artifact struct type that represents a record or struct-like dictionary. ArtifactStruct would be map (i.e. ArtifactStructMap)

func (*DictArtifactStructType) Descriptor deprecated 

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

Deprecated: Use DictArtifactStructType.ProtoReflect.Descriptor instead.

func (*DictArtifactStructType) GetExtraPropertiesType 

func (x *DictArtifactStructType) GetExtraPropertiesType() *ArtifactStructType

func (*DictArtifactStructType) GetNoneTypeNotRequired 

func (x *DictArtifactStructType) GetNoneTypeNotRequired() bool

func (*DictArtifactStructType) GetProperties 

func (x *DictArtifactStructType) GetProperties() map[string]*ArtifactStructType

func (*DictArtifactStructType) ProtoMessage 

func (*DictArtifactStructType) ProtoMessage()

func (*DictArtifactStructType) ProtoReflect 

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

func (*DictArtifactStructType) Reset 

func (x *DictArtifactStructType) Reset()

func (*DictArtifactStructType) String 

func (x *DictArtifactStructType) String() string

type Event 

type Event struct {

	// The artifact id is required for an event, and should refer to an
	// existing artifact.
	ArtifactId *int64 `protobuf:"varint,1,opt,name=artifact_id,json=artifactId" json:"artifact_id,omitempty"`
	// The execution_id is required for an event, and should refer to an
	// existing execution.
	ExecutionId *int64 `protobuf:"varint,2,opt,name=execution_id,json=executionId" json:"execution_id,omitempty"`
	// The path in an artifact struct, or the name of an artifact.
	Path *Event_Path `protobuf:"bytes,3,opt,name=path" json:"path,omitempty"`
	// The type of an event.
	Type *Event_Type `protobuf:"varint,4,opt,name=type,enum=ml_metadata.Event_Type" json:"type,omitempty"`
	// Time the event occurred
	// Epoch is Jan 1, 1970, UTC
	MillisecondsSinceEpoch *int64 `protobuf:"varint,5,opt,name=milliseconds_since_epoch,json=millisecondsSinceEpoch" json:"milliseconds_since_epoch,omitempty"`
	// contains filtered or unexported fields
}

An event represents a relationship between an artifact and an execution. There are different kinds of events, relating to both input and output, as well as how they are used by the mlmd powered system. For example, the DECLARED_INPUT and DECLARED_OUTPUT events are part of the signature of an execution. For example, consider: 

my_result = my_execution({"data":[3,7],"schema":8})

Where 3, 7, and 8 are artifact_ids, Assuming execution_id of my_execution is 12 and artifact_id of my_result is 15, the events are: 

{
    artifact_id:3,
    execution_id: 12,
    type:DECLARED_INPUT,
    path:{step:[{"key":"data"},{"index":0}]}
}
{
    artifact_id:7,
    execution_id: 12,
    type:DECLARED_INPUT,
    path:{step:[{"key":"data"},{"index":1}]}
}
{
    artifact_id:8,
    execution_id: 12,
    type:DECLARED_INPUT,
    path:{step:[{"key":"schema"}]}
}
{
    artifact_id:15,
    execution_id: 12,
    type:DECLARED_OUTPUT,
    path:{step:[{"key":"my_result"}]}
}

Other event types include INPUT/OUTPUT and INTERNAL_INPUT/_OUTPUT.

  • The INPUT/OUTPUT is an event that actually reads/writes an artifact by an execution. The input/output artifacts may not declared in the signature, For example, the trainer may output multiple caches of the parameters (as an OUTPUT), then finally write the SavedModel as a DECLARED_OUTPUT.
  • The INTERNAL_INPUT/_OUTPUT are event types which are only meaningful to an orchestration system to keep track of the details for later debugging. For example, a fork happened conditioning on an artifact, then an execution is triggered, such fork implementating may need to log the read and write of artifacts and may not be worth displaying to the users.

For instance, in the above example, 

my_result = my_execution({"data":[3,7],"schema":8})

there is another execution (id: 15), which represents a `garbage_collection` step in an orchestration system 

gc_result = garbage_collection(my_result)

that cleans `my_result` if needed. The details should be invisible to the end users and lineage tracking. The orchestrator can emit following events: 

{
    artifact_id: 15,
    execution_id: 15,
    type:INTERNAL_INPUT,
}
{
    artifact_id:16,  // New artifact containing the GC job result.
    execution_id: 15,
    type:INTERNAL_OUTPUT,
    path:{step:[{"key":"gc_result"}]}
}

func (*Event) Descriptor deprecated 

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

Deprecated: Use Event.ProtoReflect.Descriptor instead.

func (*Event) GetArtifactId 

func (x *Event) GetArtifactId() int64

func (*Event) GetExecutionId 

func (x *Event) GetExecutionId() int64

func (*Event) GetMillisecondsSinceEpoch 

func (x *Event) GetMillisecondsSinceEpoch() int64

func (*Event) GetPath 

func (x *Event) GetPath() *Event_Path

func (*Event) GetType 

func (x *Event) GetType() Event_Type

func (*Event) ProtoMessage 

func (*Event) ProtoMessage()

func (*Event) ProtoReflect 

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

func (*Event) Reset 

func (x *Event) Reset()

func (*Event) String 

func (x *Event) String() string

type Event_Path 

type Event_Path struct {

	// A simple path (e.g. {step{key:"foo"}}) can name an artifact in the
	// context of an execution.
	Steps []*Event_Path_Step `protobuf:"bytes,1,rep,name=steps" json:"steps,omitempty"`
	// contains filtered or unexported fields
}

A simple path (e.g. {step{key:"foo"}}) can name an artifact in the context of an execution.

func (*Event_Path) Descriptor deprecated 

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

Deprecated: Use Event_Path.ProtoReflect.Descriptor instead.

func (*Event_Path) GetSteps 

func (x *Event_Path) GetSteps() []*Event_Path_Step

func (*Event_Path) ProtoMessage 

func (*Event_Path) ProtoMessage()

func (*Event_Path) ProtoReflect 

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

func (*Event_Path) Reset 

func (x *Event_Path) Reset()

func (*Event_Path) String 

func (x *Event_Path) String() string

type Event_Path_Step 

type Event_Path_Step struct {

	// Types that are assignable to Value:
	//	*Event_Path_Step_Index
	//	*Event_Path_Step_Key
	Value isEvent_Path_Step_Value `protobuf_oneof:"value"`
	// contains filtered or unexported fields
}

func (*Event_Path_Step) Descriptor deprecated 

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

Deprecated: Use Event_Path_Step.ProtoReflect.Descriptor instead.

func (*Event_Path_Step) GetIndex 

func (x *Event_Path_Step) GetIndex() int64

func (*Event_Path_Step) GetKey 

func (x *Event_Path_Step) GetKey() string

func (*Event_Path_Step) GetValue 

func (m *Event_Path_Step) GetValue() isEvent_Path_Step_Value

func (*Event_Path_Step) ProtoMessage 

func (*Event_Path_Step) ProtoMessage()

func (*Event_Path_Step) ProtoReflect 

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

func (*Event_Path_Step) Reset 

func (x *Event_Path_Step) Reset()

func (*Event_Path_Step) String 

func (x *Event_Path_Step) String() string

type Event_Path_Step_Index 

type Event_Path_Step_Index struct {
	Index int64 `protobuf:"varint,1,opt,name=index,oneof"`
}

type Event_Path_Step_Key 

type Event_Path_Step_Key struct {
	Key string `protobuf:"bytes,2,opt,name=key,oneof"`
}

type Event_Type 

type Event_Type int32

Events distinguish between an artifact that is written by the execution (possibly as a cache), versus artifacts that are part of the declared output of the Execution. For more information on what DECLARED_ means, see the comment on the message. 

const (
	Event_UNKNOWN         Event_Type = 0
	Event_DECLARED_OUTPUT Event_Type = 1 // A declared output of the execution.
	Event_DECLARED_INPUT  Event_Type = 2 // A declared input of the execution.
	Event_INPUT           Event_Type = 3 // An input of the execution.
	Event_OUTPUT          Event_Type = 4 // An output of the execution.
	Event_INTERNAL_INPUT  Event_Type = 5 // An internal input of the execution.
	Event_INTERNAL_OUTPUT Event_Type = 6 // An internal output of the execution.
)

func (Event_Type) Descriptor 

func (Event_Type) Descriptor() protoreflect.EnumDescriptor

func (Event_Type) Enum 

func (x Event_Type) Enum() *Event_Type

func (Event_Type) EnumDescriptor deprecated 

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

Deprecated: Use Event_Type.Descriptor instead.

func (Event_Type) Number 

func (x Event_Type) Number() protoreflect.EnumNumber

func (Event_Type) String 

func (x Event_Type) String() string

func (Event_Type) Type 

func (Event_Type) Type() protoreflect.EnumType

func (*Event_Type) UnmarshalJSON deprecated 

func (x *Event_Type) UnmarshalJSON(b []byte) error

Deprecated: Do not use.

type Execution 

type Execution struct {

	// Output only. The globally unique server generated id of the execution.
	Id *int64 `protobuf:"varint,1,opt,name=id" json:"id,omitempty"`
	// The client provided name of the execution. This field is optional. If set,
	// it must be unique among all the executions of the same artifact type within
	// a database instance and cannot be changed once set.
	Name *string `protobuf:"bytes,6,opt,name=name" json:"name,omitempty"`
	// The id of an ExecutionType. This needs to be specified when an execution is
	// created, and it cannot be changed.
	// The id of an ExecutionType.
	TypeId *int64 `protobuf:"varint,2,opt,name=type_id,json=typeId" json:"type_id,omitempty"`
	// Output only. The name of an ExecutionType.
	Type *string `protobuf:"bytes,7,opt,name=type" json:"type,omitempty"`
	// The last known state of an execution in the system.
	LastKnownState *Execution_State `` /* 132-byte string literal not displayed */
	// Properties of the Execution.
	// Properties must be specified in the ExecutionType.
	Properties map[string]*Value `` /* 140-byte string literal not displayed */
	// User provided custom properties which are not defined by its type.
	CustomProperties map[string]*Value `` /* 176-byte string literal not displayed */
	// Output only. Create time of the execution in millisecond since epoch.
	CreateTimeSinceEpoch *int64 `protobuf:"varint,8,opt,name=create_time_since_epoch,json=createTimeSinceEpoch" json:"create_time_since_epoch,omitempty"`
	// Output only. Last update time of the execution in millisecond since epoch.
	LastUpdateTimeSinceEpoch *int64 `` /* 133-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Execution) Descriptor deprecated 

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

Deprecated: Use Execution.ProtoReflect.Descriptor instead.

func (*Execution) GetCreateTimeSinceEpoch 

func (x *Execution) GetCreateTimeSinceEpoch() int64

func (*Execution) GetCustomProperties 

func (x *Execution) GetCustomProperties() map[string]*Value

func (*Execution) GetId 

func (x *Execution) GetId() int64

func (*Execution) GetLastKnownState 

func (x *Execution) GetLastKnownState() Execution_State

func (*Execution) GetLastUpdateTimeSinceEpoch 

func (x *Execution) GetLastUpdateTimeSinceEpoch() int64

func (*Execution) GetName 

func (x *Execution) GetName() string

func (*Execution) GetProperties 

func (x *Execution) GetProperties() map[string]*Value

func (*Execution) GetType 

func (x *Execution) GetType() string

func (*Execution) GetTypeId 

func (x *Execution) GetTypeId() int64

func (*Execution) ProtoMessage 

func (*Execution) ProtoMessage()

func (*Execution) ProtoReflect 

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

func (*Execution) Reset 

func (x *Execution) Reset()

func (*Execution) String 

func (x *Execution) String() string

type ExecutionType 

type ExecutionType struct {

	// The id of the type. 1-1 relationship between type names and IDs.
	Id *int64 `protobuf:"varint,1,opt,name=id" json:"id,omitempty"`
	// The name of the type. It must be unique among ExecutionTypes within a
	// database instance.
	Name *string `protobuf:"bytes,2,opt,name=name" json:"name,omitempty"`
	// An optional version of the type. An empty string is treated as unset.
	Version *string `protobuf:"bytes,6,opt,name=version" json:"version,omitempty"`
	// An optional description about the type.
	Description *string `protobuf:"bytes,7,opt,name=description" json:"description,omitempty"`
	// The schema of the type.
	// Properties are always optional in the execution.
	Properties map[string]PropertyType `` /* 171-byte string literal not displayed */
	// The ArtifactStructType of the input.
	// For example: {
	//     "dict":{
	//        "properties":{
	//          "schema":{
	//            "union_type":{
	//              "none":{},
	//              "simple":{...schema type...}
	//             },
	//          },
	//          "data":{
	//            "simple":{...data_type...}
	//          }
	//       }
	//     }
	// }
	// That would be an optional schema field with a required data field.
	InputType *ArtifactStructType `protobuf:"bytes,4,opt,name=input_type,json=inputType" json:"input_type,omitempty"`
	// The ArtifactStructType of the output.
	// For example {"simple":{...stats gen output type...}}
	OutputType *ArtifactStructType `protobuf:"bytes,5,opt,name=output_type,json=outputType" json:"output_type,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecutionType) Descriptor deprecated 

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

Deprecated: Use ExecutionType.ProtoReflect.Descriptor instead.

func (*ExecutionType) GetDescription 

func (x *ExecutionType) GetDescription() string

func (*ExecutionType) GetId 

func (x *ExecutionType) GetId() int64

func (*ExecutionType) GetInputType 

func (x *ExecutionType) GetInputType() *ArtifactStructType

func (*ExecutionType) GetName 

func (x *ExecutionType) GetName() string

func (*ExecutionType) GetOutputType 

func (x *ExecutionType) GetOutputType() *ArtifactStructType

func (*ExecutionType) GetProperties 

func (x *ExecutionType) GetProperties() map[string]PropertyType

func (*ExecutionType) GetVersion 

func (x *ExecutionType) GetVersion() string

func (*ExecutionType) ProtoMessage 

func (*ExecutionType) ProtoMessage()

func (*ExecutionType) ProtoReflect 

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

func (*ExecutionType) Reset 

func (x *ExecutionType) Reset()

func (*ExecutionType) String 

func (x *ExecutionType) String() string

type Execution_State 

type Execution_State int32

The state of the Execution. The state transitions are 

NEW -> RUNNING -> COMPLETE | CACHED | FAILED | CANCELED

CACHED means the execution is skipped due to cached results. CANCELED means the execution is skipped due to precondition not met. It is different from CACHED in that a CANCELED execution will not have any event associated with it. It is different from FAILED in that there is no unexpected error happened and it is regarded as a normal state. 

const (
	Execution_UNKNOWN  Execution_State = 0
	Execution_NEW      Execution_State = 1
	Execution_RUNNING  Execution_State = 2
	Execution_COMPLETE Execution_State = 3
	Execution_FAILED   Execution_State = 4
	Execution_CACHED   Execution_State = 5
	Execution_CANCELED Execution_State = 6
)

func (Execution_State) Descriptor 

func (Execution_State) Descriptor() protoreflect.EnumDescriptor

func (Execution_State) Enum 

func (x Execution_State) Enum() *Execution_State

func (Execution_State) EnumDescriptor deprecated 

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

Deprecated: Use Execution_State.Descriptor instead.

func (Execution_State) Number 

func (x Execution_State) Number() protoreflect.EnumNumber

func (Execution_State) String 

func (x Execution_State) String() string

func (Execution_State) Type 

func (Execution_State) Type() protoreflect.EnumType

func (*Execution_State) UnmarshalJSON deprecated 

func (x *Execution_State) UnmarshalJSON(b []byte) error

Deprecated: Do not use.

type FakeDatabaseConfig 

type FakeDatabaseConfig struct {
	// contains filtered or unexported fields
}

Configuration for a "fake" database. This database is an in-memory SQLite database that lives only as long as the associated object lives.

func (*FakeDatabaseConfig) Descriptor deprecated 

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

Deprecated: Use FakeDatabaseConfig.ProtoReflect.Descriptor instead.

func (*FakeDatabaseConfig) ProtoMessage 

func (*FakeDatabaseConfig) ProtoMessage()

func (*FakeDatabaseConfig) ProtoReflect 

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

func (*FakeDatabaseConfig) Reset 

func (x *FakeDatabaseConfig) Reset()

func (*FakeDatabaseConfig) String 

func (x *FakeDatabaseConfig) String() string

type GetArtifactByTypeAndNameRequest 

type GetArtifactByTypeAndNameRequest struct {
	TypeName *string `protobuf:"bytes,1,opt,name=type_name,json=typeName" json:"type_name,omitempty"`
	// If not set, it looks for the type with type_name and artifact_name with
	// default type_version.
	TypeVersion  *string `protobuf:"bytes,3,opt,name=type_version,json=typeVersion" json:"type_version,omitempty"`
	ArtifactName *string `protobuf:"bytes,2,opt,name=artifact_name,json=artifactName" json:"artifact_name,omitempty"`
	// contains filtered or unexported fields
}

func (*GetArtifactByTypeAndNameRequest) Descriptor deprecated 

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

Deprecated: Use GetArtifactByTypeAndNameRequest.ProtoReflect.Descriptor instead.

func (*GetArtifactByTypeAndNameRequest) GetArtifactName 

func (x *GetArtifactByTypeAndNameRequest) GetArtifactName() string

func (*GetArtifactByTypeAndNameRequest) GetTypeName 

func (x *GetArtifactByTypeAndNameRequest) GetTypeName() string

func (*GetArtifactByTypeAndNameRequest) GetTypeVersion 

func (x *GetArtifactByTypeAndNameRequest) GetTypeVersion() string

func (*GetArtifactByTypeAndNameRequest) ProtoMessage 

func (*GetArtifactByTypeAndNameRequest) ProtoMessage()

func (*GetArtifactByTypeAndNameRequest) ProtoReflect 

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

func (*GetArtifactByTypeAndNameRequest) Reset 

func (x *GetArtifactByTypeAndNameRequest) Reset()

func (*GetArtifactByTypeAndNameRequest) String 

func (x *GetArtifactByTypeAndNameRequest) String() string

type GetArtifactByTypeAndNameResponse 

type GetArtifactByTypeAndNameResponse struct {
	Artifact *Artifact `protobuf:"bytes,1,opt,name=artifact" json:"artifact,omitempty"`
	// contains filtered or unexported fields
}

func (*GetArtifactByTypeAndNameResponse) Descriptor deprecated 

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

Deprecated: Use GetArtifactByTypeAndNameResponse.ProtoReflect.Descriptor instead.

func (*GetArtifactByTypeAndNameResponse) GetArtifact 

func (x *GetArtifactByTypeAndNameResponse) GetArtifact() *Artifact

func (*GetArtifactByTypeAndNameResponse) ProtoMessage 

func (*GetArtifactByTypeAndNameResponse) ProtoMessage()

func (*GetArtifactByTypeAndNameResponse) ProtoReflect 

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

func (*GetArtifactByTypeAndNameResponse) Reset 

func (x *GetArtifactByTypeAndNameResponse) Reset()

func (*GetArtifactByTypeAndNameResponse) String 

func (x *GetArtifactByTypeAndNameResponse) String() string

type GetArtifactTypeRequest 

type GetArtifactTypeRequest struct {
	TypeName *string `protobuf:"bytes,1,opt,name=type_name,json=typeName" json:"type_name,omitempty"`
	// If not set, it looks for the type with type_name with default type_version.
	TypeVersion *string `protobuf:"bytes,2,opt,name=type_version,json=typeVersion" json:"type_version,omitempty"`
	// contains filtered or unexported fields
}

func (*GetArtifactTypeRequest) Descriptor deprecated 

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

Deprecated: Use GetArtifactTypeRequest.ProtoReflect.Descriptor instead.

func (*GetArtifactTypeRequest) GetTypeName 

func (x *GetArtifactTypeRequest) GetTypeName() string

func (*GetArtifactTypeRequest) GetTypeVersion 

func (x *GetArtifactTypeRequest) GetTypeVersion() string

func (*GetArtifactTypeRequest) ProtoMessage 

func (*GetArtifactTypeRequest) ProtoMessage()

func (*GetArtifactTypeRequest) ProtoReflect 

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

func (*GetArtifactTypeRequest) Reset 

func (x *GetArtifactTypeRequest) Reset()

func (*GetArtifactTypeRequest) String 

func (x *GetArtifactTypeRequest) String() string

type GetArtifactTypeResponse 

type GetArtifactTypeResponse struct {

	// Gets an artifact type, or clear if it does not exist.
	ArtifactType *ArtifactType `protobuf:"bytes,1,opt,name=artifact_type,json=artifactType" json:"artifact_type,omitempty"`
	// contains filtered or unexported fields
}

func (*GetArtifactTypeResponse) Descriptor deprecated 

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

Deprecated: Use GetArtifactTypeResponse.ProtoReflect.Descriptor instead.

func (*GetArtifactTypeResponse) GetArtifactType 

func (x *GetArtifactTypeResponse) GetArtifactType() *ArtifactType

func (*GetArtifactTypeResponse) ProtoMessage 

func (*GetArtifactTypeResponse) ProtoMessage()

func (*GetArtifactTypeResponse) ProtoReflect 

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

func (*GetArtifactTypeResponse) Reset 

func (x *GetArtifactTypeResponse) Reset()

func (*GetArtifactTypeResponse) String 

func (x *GetArtifactTypeResponse) String() string

type GetArtifactTypesByIDRequest 

type GetArtifactTypesByIDRequest struct {
	TypeIds []int64 `protobuf:"varint,1,rep,name=type_ids,json=typeIds" json:"type_ids,omitempty"`
	// contains filtered or unexported fields
}

func (*GetArtifactTypesByIDRequest) Descriptor deprecated 

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

Deprecated: Use GetArtifactTypesByIDRequest.ProtoReflect.Descriptor instead.

func (*GetArtifactTypesByIDRequest) GetTypeIds 

func (x *GetArtifactTypesByIDRequest) GetTypeIds() []int64

func (*GetArtifactTypesByIDRequest) ProtoMessage 

func (*GetArtifactTypesByIDRequest) ProtoMessage()

func (*GetArtifactTypesByIDRequest) ProtoReflect 

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

func (*GetArtifactTypesByIDRequest) Reset 

func (x *GetArtifactTypesByIDRequest) Reset()

func (*GetArtifactTypesByIDRequest) String 

func (x *GetArtifactTypesByIDRequest) String() string

type GetArtifactTypesByIDResponse 

type GetArtifactTypesByIDResponse struct {

	// The result is not index-aligned: if an id is not found, it is not
	// returned.
	ArtifactTypes []*ArtifactType `protobuf:"bytes,1,rep,name=artifact_types,json=artifactTypes" json:"artifact_types,omitempty"`
	// contains filtered or unexported fields
}

func (*GetArtifactTypesByIDResponse) Descriptor deprecated 

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

Deprecated: Use GetArtifactTypesByIDResponse.ProtoReflect.Descriptor instead.

func (*GetArtifactTypesByIDResponse) GetArtifactTypes 

func (x *GetArtifactTypesByIDResponse) GetArtifactTypes() []*ArtifactType

func (*GetArtifactTypesByIDResponse) ProtoMessage 

func (*GetArtifactTypesByIDResponse) ProtoMessage()

func (*GetArtifactTypesByIDResponse) ProtoReflect 

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

func (*GetArtifactTypesByIDResponse) Reset 

func (x *GetArtifactTypesByIDResponse) Reset()

func (*GetArtifactTypesByIDResponse) String 

func (x *GetArtifactTypesByIDResponse) String() string

type GetArtifactTypesRequest 

type GetArtifactTypesRequest struct {
	// contains filtered or unexported fields
}

func (*GetArtifactTypesRequest) Descriptor deprecated 

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

Deprecated: Use GetArtifactTypesRequest.ProtoReflect.Descriptor instead.

func (*GetArtifactTypesRequest) ProtoMessage 

func (*GetArtifactTypesRequest) ProtoMessage()

func (*GetArtifactTypesRequest) ProtoReflect 

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

func (*GetArtifactTypesRequest) Reset 

func (x *GetArtifactTypesRequest) Reset()

func (*GetArtifactTypesRequest) String 

func (x *GetArtifactTypesRequest) String() string

type GetArtifactTypesResponse 

type GetArtifactTypesResponse struct {
	ArtifactTypes []*ArtifactType `protobuf:"bytes,1,rep,name=artifact_types,json=artifactTypes" json:"artifact_types,omitempty"`
	// contains filtered or unexported fields
}

func (*GetArtifactTypesResponse) Descriptor deprecated 

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

Deprecated: Use GetArtifactTypesResponse.ProtoReflect.Descriptor instead.

func (*GetArtifactTypesResponse) GetArtifactTypes 

func (x *GetArtifactTypesResponse) GetArtifactTypes() []*ArtifactType

func (*GetArtifactTypesResponse) ProtoMessage 

func (*GetArtifactTypesResponse) ProtoMessage()

func (*GetArtifactTypesResponse) ProtoReflect 

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

func (*GetArtifactTypesResponse) Reset 

func (x *GetArtifactTypesResponse) Reset()

func (*GetArtifactTypesResponse) String 

func (x *GetArtifactTypesResponse) String() string

type GetArtifactsByContextRequest 

type GetArtifactsByContextRequest struct {
	ContextId *int64 `protobuf:"varint,1,opt,name=context_id,json=contextId" json:"context_id,omitempty"`
	// Specify List options.
	// Currently supports:
	//   1. Field to order the results.
	//   2. Page size.
	Options *ListOperationOptions `protobuf:"bytes,2,opt,name=options" json:"options,omitempty"`
	// contains filtered or unexported fields
}

func (*GetArtifactsByContextRequest) Descriptor deprecated 

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

Deprecated: Use GetArtifactsByContextRequest.ProtoReflect.Descriptor instead.

func (*GetArtifactsByContextRequest) GetContextId 

func (x *GetArtifactsByContextRequest) GetContextId() int64

func (*GetArtifactsByContextRequest) GetOptions 

func (x *GetArtifactsByContextRequest) GetOptions() *ListOperationOptions

func (*GetArtifactsByContextRequest) ProtoMessage 

func (*GetArtifactsByContextRequest) ProtoMessage()

func (*GetArtifactsByContextRequest) ProtoReflect 

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

func (*GetArtifactsByContextRequest) Reset 

func (x *GetArtifactsByContextRequest) Reset()

func (*GetArtifactsByContextRequest) String 

func (x *GetArtifactsByContextRequest) String() string

type GetArtifactsByContextResponse 

type GetArtifactsByContextResponse struct {
	Artifacts []*Artifact `protobuf:"bytes,1,rep,name=artifacts" json:"artifacts,omitempty"`
	// Token to use to retrieve next page of results if list options are used in
	// the request.
	NextPageToken *string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken" json:"next_page_token,omitempty"`
	// contains filtered or unexported fields
}

func (*GetArtifactsByContextResponse) Descriptor deprecated 

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

Deprecated: Use GetArtifactsByContextResponse.ProtoReflect.Descriptor instead.

func (*GetArtifactsByContextResponse) GetArtifacts 

func (x *GetArtifactsByContextResponse) GetArtifacts() []*Artifact

func (*GetArtifactsByContextResponse) GetNextPageToken 

func (x *GetArtifactsByContextResponse) GetNextPageToken() string

func (*GetArtifactsByContextResponse) ProtoMessage 

func (*GetArtifactsByContextResponse) ProtoMessage()

func (*GetArtifactsByContextResponse) ProtoReflect 

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

func (*GetArtifactsByContextResponse) Reset 

func (x *GetArtifactsByContextResponse) Reset()

func (*GetArtifactsByContextResponse) String 

func (x *GetArtifactsByContextResponse) String() string

type GetArtifactsByIDRequest 

type GetArtifactsByIDRequest struct {

	// A list of artifact ids to retrieve.
	ArtifactIds []int64 `protobuf:"varint,1,rep,name=artifact_ids,json=artifactIds" json:"artifact_ids,omitempty"`
	// contains filtered or unexported fields
}

func (*GetArtifactsByIDRequest) Descriptor deprecated 

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

Deprecated: Use GetArtifactsByIDRequest.ProtoReflect.Descriptor instead.

func (*GetArtifactsByIDRequest) GetArtifactIds 

func (x *GetArtifactsByIDRequest) GetArtifactIds() []int64

func (*GetArtifactsByIDRequest) ProtoMessage 

func (*GetArtifactsByIDRequest) ProtoMessage()

func (*GetArtifactsByIDRequest) ProtoReflect 

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

func (*GetArtifactsByIDRequest) Reset 

func (x *GetArtifactsByIDRequest) Reset()

func (*GetArtifactsByIDRequest) String 

func (x *GetArtifactsByIDRequest) String() string

type GetArtifactsByIDResponse 

type GetArtifactsByIDResponse struct {

	// Artifacts with matching ids.
	// This is not index-aligned: if an id is not found, it is not
	Artifacts []*Artifact `protobuf:"bytes,1,rep,name=artifacts" json:"artifacts,omitempty"`
	// contains filtered or unexported fields
}

func (*GetArtifactsByIDResponse) Descriptor deprecated 

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

Deprecated: Use GetArtifactsByIDResponse.ProtoReflect.Descriptor instead.

func (*GetArtifactsByIDResponse) GetArtifacts 

func (x *GetArtifactsByIDResponse) GetArtifacts() []*Artifact

func (*GetArtifactsByIDResponse) ProtoMessage 

func (*GetArtifactsByIDResponse) ProtoMessage()

func (*GetArtifactsByIDResponse) ProtoReflect 

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

func (*GetArtifactsByIDResponse) Reset 

func (x *GetArtifactsByIDResponse) Reset()

func (*GetArtifactsByIDResponse) String 

func (x *GetArtifactsByIDResponse) String() string

type GetArtifactsByTypeRequest 

type GetArtifactsByTypeRequest struct {
	TypeName *string `protobuf:"bytes,1,opt,name=type_name,json=typeName" json:"type_name,omitempty"`
	// If not set, it looks for the type with type_name with default type_version.
	TypeVersion *string `protobuf:"bytes,2,opt,name=type_version,json=typeVersion" json:"type_version,omitempty"`
	// contains filtered or unexported fields
}

func (*GetArtifactsByTypeRequest) Descriptor deprecated 

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

Deprecated: Use GetArtifactsByTypeRequest.ProtoReflect.Descriptor instead.

func (*GetArtifactsByTypeRequest) GetTypeName 

func (x *GetArtifactsByTypeRequest) GetTypeName() string

func (*GetArtifactsByTypeRequest) GetTypeVersion 

func (x *GetArtifactsByTypeRequest) GetTypeVersion() string

func (*GetArtifactsByTypeRequest) ProtoMessage 

func (*GetArtifactsByTypeRequest) ProtoMessage()

func (*GetArtifactsByTypeRequest) ProtoReflect 

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

func (*GetArtifactsByTypeRequest) Reset 

func (x *GetArtifactsByTypeRequest) Reset()

func (*GetArtifactsByTypeRequest) String 

func (x *GetArtifactsByTypeRequest) String() string

type GetArtifactsByTypeResponse 

type GetArtifactsByTypeResponse struct {
	Artifacts []*Artifact `protobuf:"bytes,1,rep,name=artifacts" json:"artifacts,omitempty"`
	// contains filtered or unexported fields
}

func (*GetArtifactsByTypeResponse) Descriptor deprecated 

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

Deprecated: Use GetArtifactsByTypeResponse.ProtoReflect.Descriptor instead.

func (*GetArtifactsByTypeResponse) GetArtifacts 

func (x *GetArtifactsByTypeResponse) GetArtifacts() []*Artifact

func (*GetArtifactsByTypeResponse) ProtoMessage 

func (*GetArtifactsByTypeResponse) ProtoMessage()

func (*GetArtifactsByTypeResponse) ProtoReflect 

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

func (*GetArtifactsByTypeResponse) Reset 

func (x *GetArtifactsByTypeResponse) Reset()

func (*GetArtifactsByTypeResponse) String 

func (x *GetArtifactsByTypeResponse) String() string

type GetArtifactsByURIRequest 

type GetArtifactsByURIRequest struct {

	// A list of artifact uris to retrieve.
	Uris []string `protobuf:"bytes,2,rep,name=uris" json:"uris,omitempty"`
	// contains filtered or unexported fields
}

func (*GetArtifactsByURIRequest) Descriptor deprecated 

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

Deprecated: Use GetArtifactsByURIRequest.ProtoReflect.Descriptor instead.

func (*GetArtifactsByURIRequest) GetUris 

func (x *GetArtifactsByURIRequest) GetUris() []string

func (*GetArtifactsByURIRequest) ProtoMessage 

func (*GetArtifactsByURIRequest) ProtoMessage()

func (*GetArtifactsByURIRequest) ProtoReflect 

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

func (*GetArtifactsByURIRequest) Reset 

func (x *GetArtifactsByURIRequest) Reset()

func (*GetArtifactsByURIRequest) String 

func (x *GetArtifactsByURIRequest) String() string

type GetArtifactsByURIResponse 

type GetArtifactsByURIResponse struct {
	Artifacts []*Artifact `protobuf:"bytes,1,rep,name=artifacts" json:"artifacts,omitempty"`
	// contains filtered or unexported fields
}

func (*GetArtifactsByURIResponse) Descriptor deprecated 

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

Deprecated: Use GetArtifactsByURIResponse.ProtoReflect.Descriptor instead.

func (*GetArtifactsByURIResponse) GetArtifacts 

func (x *GetArtifactsByURIResponse) GetArtifacts() []*Artifact

func (*GetArtifactsByURIResponse) ProtoMessage 

func (*GetArtifactsByURIResponse) ProtoMessage()

func (*GetArtifactsByURIResponse) ProtoReflect 

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

func (*GetArtifactsByURIResponse) Reset 

func (x *GetArtifactsByURIResponse) Reset()

func (*GetArtifactsByURIResponse) String 

func (x *GetArtifactsByURIResponse) String() string

type GetArtifactsRequest 

type GetArtifactsRequest struct {

	// Specify options.
	// Currently supports:
	//   1. Field to order the results.
	//   2. Page size.
	Options *ListOperationOptions `protobuf:"bytes,1,opt,name=options" json:"options,omitempty"`
	// contains filtered or unexported fields
}

Request to retrieve Artifacts using List options. If option is not specified then all Artifacts are returned.

func (*GetArtifactsRequest) Descriptor deprecated 

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

Deprecated: Use GetArtifactsRequest.ProtoReflect.Descriptor instead.

func (*GetArtifactsRequest) GetOptions 

func (x *GetArtifactsRequest) GetOptions() *ListOperationOptions

func (*GetArtifactsRequest) ProtoMessage 

func (*GetArtifactsRequest) ProtoMessage()

func (*GetArtifactsRequest) ProtoReflect 

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

func (*GetArtifactsRequest) Reset 

func (x *GetArtifactsRequest) Reset()

func (*GetArtifactsRequest) String 

func (x *GetArtifactsRequest) String() string

type GetArtifactsResponse 

type GetArtifactsResponse struct {

	// Returned artifacts.
	Artifacts []*Artifact `protobuf:"bytes,1,rep,name=artifacts" json:"artifacts,omitempty"`
	// Token to use to retrieve next page of results if list options are used in
	// the request.
	NextPageToken *string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken" json:"next_page_token,omitempty"`
	// contains filtered or unexported fields
}

func (*GetArtifactsResponse) Descriptor deprecated 

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

Deprecated: Use GetArtifactsResponse.ProtoReflect.Descriptor instead.

func (*GetArtifactsResponse) GetArtifacts 

func (x *GetArtifactsResponse) GetArtifacts() []*Artifact

func (*GetArtifactsResponse) GetNextPageToken 

func (x *GetArtifactsResponse) GetNextPageToken() string

func (*GetArtifactsResponse) ProtoMessage 

func (*GetArtifactsResponse) ProtoMessage()

func (*GetArtifactsResponse) ProtoReflect 

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

func (*GetArtifactsResponse) Reset 

func (x *GetArtifactsResponse) Reset()

func (*GetArtifactsResponse) String 

func (x *GetArtifactsResponse) String() string

type GetChildrenContextsByContextRequest 

type GetChildrenContextsByContextRequest struct {
	ContextId *int64 `protobuf:"varint,1,opt,name=context_id,json=contextId" json:"context_id,omitempty"`
	// contains filtered or unexported fields
}

func (*GetChildrenContextsByContextRequest) Descriptor deprecated 

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

Deprecated: Use GetChildrenContextsByContextRequest.ProtoReflect.Descriptor instead.

func (*GetChildrenContextsByContextRequest) GetContextId 

func (x *GetChildrenContextsByContextRequest) GetContextId() int64

func (*GetChildrenContextsByContextRequest) ProtoMessage 

func (*GetChildrenContextsByContextRequest) ProtoMessage()

func (*GetChildrenContextsByContextRequest) ProtoReflect 

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

func (*GetChildrenContextsByContextRequest) Reset 

func (x *GetChildrenContextsByContextRequest) Reset()

func (*GetChildrenContextsByContextRequest) String 

func (x *GetChildrenContextsByContextRequest) String() string

type GetChildrenContextsByContextResponse 

type GetChildrenContextsByContextResponse struct {
	Contexts []*Context `protobuf:"bytes,1,rep,name=contexts" json:"contexts,omitempty"`
	// contains filtered or unexported fields
}

func (*GetChildrenContextsByContextResponse) Descriptor deprecated 

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

Deprecated: Use GetChildrenContextsByContextResponse.ProtoReflect.Descriptor instead.

func (*GetChildrenContextsByContextResponse) GetContexts 

func (x *GetChildrenContextsByContextResponse) GetContexts() []*Context

func (*GetChildrenContextsByContextResponse) ProtoMessage 

func (*GetChildrenContextsByContextResponse) ProtoMessage()

func (*GetChildrenContextsByContextResponse) ProtoReflect 

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

func (*GetChildrenContextsByContextResponse) Reset 

func (x *GetChildrenContextsByContextResponse) Reset()

func (*GetChildrenContextsByContextResponse) String 

func (x *GetChildrenContextsByContextResponse) String() string

type GetContextByTypeAndNameRequest 

type GetContextByTypeAndNameRequest struct {
	TypeName *string `protobuf:"bytes,1,opt,name=type_name,json=typeName" json:"type_name,omitempty"`
	// If not set, it looks for the type with type_name and context_name with
	// default type_version.
	TypeVersion *string `protobuf:"bytes,3,opt,name=type_version,json=typeVersion" json:"type_version,omitempty"`
	ContextName *string `protobuf:"bytes,2,opt,name=context_name,json=contextName" json:"context_name,omitempty"`
	// contains filtered or unexported fields
}

func (*GetContextByTypeAndNameRequest) Descriptor deprecated 

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

Deprecated: Use GetContextByTypeAndNameRequest.ProtoReflect.Descriptor instead.

func (*GetContextByTypeAndNameRequest) GetContextName 

func (x *GetContextByTypeAndNameRequest) GetContextName() string

func (*GetContextByTypeAndNameRequest) GetTypeName 

func (x *GetContextByTypeAndNameRequest) GetTypeName() string

func (*GetContextByTypeAndNameRequest) GetTypeVersion 

func (x *GetContextByTypeAndNameRequest) GetTypeVersion() string

func (*GetContextByTypeAndNameRequest) ProtoMessage 

func (*GetContextByTypeAndNameRequest) ProtoMessage()

func (*GetContextByTypeAndNameRequest) ProtoReflect 

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

func (*GetContextByTypeAndNameRequest) Reset 

func (x *GetContextByTypeAndNameRequest) Reset()

func (*GetContextByTypeAndNameRequest) String 

func (x *GetContextByTypeAndNameRequest) String() string

type GetContextByTypeAndNameResponse 

type GetContextByTypeAndNameResponse struct {
	Context *Context `protobuf:"bytes,1,opt,name=context" json:"context,omitempty"`
	// contains filtered or unexported fields
}

func (*GetContextByTypeAndNameResponse) Descriptor deprecated 

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

Deprecated: Use GetContextByTypeAndNameResponse.ProtoReflect.Descriptor instead.

func (*GetContextByTypeAndNameResponse) GetContext 

func (x *GetContextByTypeAndNameResponse) GetContext() *Context

func (*GetContextByTypeAndNameResponse) ProtoMessage 

func (*GetContextByTypeAndNameResponse) ProtoMessage()

func (*GetContextByTypeAndNameResponse) ProtoReflect 

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

func (*GetContextByTypeAndNameResponse) Reset 

func (x *GetContextByTypeAndNameResponse) Reset()

func (*GetContextByTypeAndNameResponse) String 

func (x *GetContextByTypeAndNameResponse) String() string

type GetContextTypeRequest 

type GetContextTypeRequest struct {
	TypeName *string `protobuf:"bytes,1,opt,name=type_name,json=typeName" json:"type_name,omitempty"`
	// If not set, it looks for the type with type_name with default type_version.
	TypeVersion *string `protobuf:"bytes,2,opt,name=type_version,json=typeVersion" json:"type_version,omitempty"`
	// contains filtered or unexported fields
}

func (*GetContextTypeRequest) Descriptor deprecated 

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

Deprecated: Use GetContextTypeRequest.ProtoReflect.Descriptor instead.

func (*GetContextTypeRequest) GetTypeName 

func (x *GetContextTypeRequest) GetTypeName() string

func (*GetContextTypeRequest) GetTypeVersion 

func (x *GetContextTypeRequest) GetTypeVersion() string

func (*GetContextTypeRequest) ProtoMessage 

func (*GetContextTypeRequest) ProtoMessage()

func (*GetContextTypeRequest) ProtoReflect 

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

func (*GetContextTypeRequest) Reset 

func (x *GetContextTypeRequest) Reset()

func (*GetContextTypeRequest) String 

func (x *GetContextTypeRequest) String() string

type GetContextTypeResponse 

type GetContextTypeResponse struct {

	// Gets a context type, or clear if it does not exist.
	ContextType *ContextType `protobuf:"bytes,1,opt,name=context_type,json=contextType" json:"context_type,omitempty"`
	// contains filtered or unexported fields
}

func (*GetContextTypeResponse) Descriptor deprecated 

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

Deprecated: Use GetContextTypeResponse.ProtoReflect.Descriptor instead.

func (*GetContextTypeResponse) GetContextType 

func (x *GetContextTypeResponse) GetContextType() *ContextType

func (*GetContextTypeResponse) ProtoMessage 

func (*GetContextTypeResponse) ProtoMessage()

func (*GetContextTypeResponse) ProtoReflect 

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

func (*GetContextTypeResponse) Reset 

func (x *GetContextTypeResponse) Reset()

func (*GetContextTypeResponse) String 

func (x *GetContextTypeResponse) String() string

type GetContextTypesByIDRequest 

type GetContextTypesByIDRequest struct {
	TypeIds []int64 `protobuf:"varint,1,rep,name=type_ids,json=typeIds" json:"type_ids,omitempty"`
	// contains filtered or unexported fields
}

func (*GetContextTypesByIDRequest) Descriptor deprecated 

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

Deprecated: Use GetContextTypesByIDRequest.ProtoReflect.Descriptor instead.

func (*GetContextTypesByIDRequest) GetTypeIds 

func (x *GetContextTypesByIDRequest) GetTypeIds() []int64

func (*GetContextTypesByIDRequest) ProtoMessage 

func (*GetContextTypesByIDRequest) ProtoMessage()

func (*GetContextTypesByIDRequest) ProtoReflect 

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

func (*GetContextTypesByIDRequest) Reset 

func (x *GetContextTypesByIDRequest) Reset()

func (*GetContextTypesByIDRequest) String 

func (x *GetContextTypesByIDRequest) String() string

type GetContextTypesByIDResponse 

type GetContextTypesByIDResponse struct {

	// The result is not index-aligned: if an id is not found, it is not
	// returned.
	ContextTypes []*ContextType `protobuf:"bytes,1,rep,name=context_types,json=contextTypes" json:"context_types,omitempty"`
	// contains filtered or unexported fields
}

func (*GetContextTypesByIDResponse) Descriptor deprecated 

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

Deprecated: Use GetContextTypesByIDResponse.ProtoReflect.Descriptor instead.

func (*GetContextTypesByIDResponse) GetContextTypes 

func (x *GetContextTypesByIDResponse) GetContextTypes() []*ContextType

func (*GetContextTypesByIDResponse) ProtoMessage 

func (*GetContextTypesByIDResponse) ProtoMessage()

func (*GetContextTypesByIDResponse) ProtoReflect 

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

func (*GetContextTypesByIDResponse) Reset 

func (x *GetContextTypesByIDResponse) Reset()

func (*GetContextTypesByIDResponse) String 

func (x *GetContextTypesByIDResponse) String() string

type GetContextTypesRequest 

type GetContextTypesRequest struct {
	// contains filtered or unexported fields
}

func (*GetContextTypesRequest) Descriptor deprecated 

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

Deprecated: Use GetContextTypesRequest.ProtoReflect.Descriptor instead.

func (*GetContextTypesRequest) ProtoMessage 

func (*GetContextTypesRequest) ProtoMessage()

func (*GetContextTypesRequest) ProtoReflect 

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

func (*GetContextTypesRequest) Reset 

func (x *GetContextTypesRequest) Reset()

func (*GetContextTypesRequest) String 

func (x *GetContextTypesRequest) String() string

type GetContextTypesResponse 

type GetContextTypesResponse struct {
	ContextTypes []*ContextType `protobuf:"bytes,1,rep,name=context_types,json=contextTypes" json:"context_types,omitempty"`
	// contains filtered or unexported fields
}

func (*GetContextTypesResponse) Descriptor deprecated 

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

Deprecated: Use GetContextTypesResponse.ProtoReflect.Descriptor instead.

func (*GetContextTypesResponse) GetContextTypes 

func (x *GetContextTypesResponse) GetContextTypes() []*ContextType

func (*GetContextTypesResponse) ProtoMessage 

func (*GetContextTypesResponse) ProtoMessage()

func (*GetContextTypesResponse) ProtoReflect 

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

func (*GetContextTypesResponse) Reset 

func (x *GetContextTypesResponse) Reset()

func (*GetContextTypesResponse) String 

func (x *GetContextTypesResponse) String() string

type GetContextsByArtifactRequest 

type GetContextsByArtifactRequest struct {
	ArtifactId *int64 `protobuf:"varint,1,opt,name=artifact_id,json=artifactId" json:"artifact_id,omitempty"`
	// contains filtered or unexported fields
}

func (*GetContextsByArtifactRequest) Descriptor deprecated 

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

Deprecated: Use GetContextsByArtifactRequest.ProtoReflect.Descriptor instead.

func (*GetContextsByArtifactRequest) GetArtifactId 

func (x *GetContextsByArtifactRequest) GetArtifactId() int64

func (*GetContextsByArtifactRequest) ProtoMessage 

func (*GetContextsByArtifactRequest) ProtoMessage()

func (*GetContextsByArtifactRequest) ProtoReflect 

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

func (*GetContextsByArtifactRequest) Reset 

func (x *GetContextsByArtifactRequest) Reset()

func (*GetContextsByArtifactRequest) String 

func (x *GetContextsByArtifactRequest) String() string

type GetContextsByArtifactResponse 

type GetContextsByArtifactResponse struct {
	Contexts []*Context `protobuf:"bytes,1,rep,name=contexts" json:"contexts,omitempty"`
	// contains filtered or unexported fields
}

func (*GetContextsByArtifactResponse) Descriptor deprecated 

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

Deprecated: Use GetContextsByArtifactResponse.ProtoReflect.Descriptor instead.

func (*GetContextsByArtifactResponse) GetContexts 

func (x *GetContextsByArtifactResponse) GetContexts() []*Context

func (*GetContextsByArtifactResponse) ProtoMessage 

func (*GetContextsByArtifactResponse) ProtoMessage()

func (*GetContextsByArtifactResponse) ProtoReflect 

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

func (*GetContextsByArtifactResponse) Reset 

func (x *GetContextsByArtifactResponse) Reset()

func (*GetContextsByArtifactResponse) String 

func (x *GetContextsByArtifactResponse) String() string

type GetContextsByExecutionRequest 

type GetContextsByExecutionRequest struct {
	ExecutionId *int64 `protobuf:"varint,1,opt,name=execution_id,json=executionId" json:"execution_id,omitempty"`
	// contains filtered or unexported fields
}

func (*GetContextsByExecutionRequest) Descriptor deprecated 

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

Deprecated: Use GetContextsByExecutionRequest.ProtoReflect.Descriptor instead.

func (*GetContextsByExecutionRequest) GetExecutionId 

func (x *GetContextsByExecutionRequest) GetExecutionId() int64

func (*GetContextsByExecutionRequest) ProtoMessage 

func (*GetContextsByExecutionRequest) ProtoMessage()

func (*GetContextsByExecutionRequest) ProtoReflect 

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

func (*GetContextsByExecutionRequest) Reset 

func (x *GetContextsByExecutionRequest) Reset()

func (*GetContextsByExecutionRequest) String 

func (x *GetContextsByExecutionRequest) String() string

type GetContextsByExecutionResponse 

type GetContextsByExecutionResponse struct {
	Contexts []*Context `protobuf:"bytes,1,rep,name=contexts" json:"contexts,omitempty"`
	// contains filtered or unexported fields
}

func (*GetContextsByExecutionResponse) Descriptor deprecated 

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

Deprecated: Use GetContextsByExecutionResponse.ProtoReflect.Descriptor instead.

func (*GetContextsByExecutionResponse) GetContexts 

func (x *GetContextsByExecutionResponse) GetContexts() []*Context

func (*GetContextsByExecutionResponse) ProtoMessage 

func (*GetContextsByExecutionResponse) ProtoMessage()

func (*GetContextsByExecutionResponse) ProtoReflect 

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

func (*GetContextsByExecutionResponse) Reset 

func (x *GetContextsByExecutionResponse) Reset()

func (*GetContextsByExecutionResponse) String 

func (x *GetContextsByExecutionResponse) String() string

type GetContextsByIDRequest 

type GetContextsByIDRequest struct {

	// A list of context ids to retrieve.
	ContextIds []int64 `protobuf:"varint,1,rep,name=context_ids,json=contextIds" json:"context_ids,omitempty"`
	// contains filtered or unexported fields
}

func (*GetContextsByIDRequest) Descriptor deprecated 

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

Deprecated: Use GetContextsByIDRequest.ProtoReflect.Descriptor instead.

func (*GetContextsByIDRequest) GetContextIds 

func (x *GetContextsByIDRequest) GetContextIds() []int64

func (*GetContextsByIDRequest) ProtoMessage 

func (*GetContextsByIDRequest) ProtoMessage()

func (*GetContextsByIDRequest) ProtoReflect 

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

func (*GetContextsByIDRequest) Reset 

func (x *GetContextsByIDRequest) Reset()

func (*GetContextsByIDRequest) String 

func (x *GetContextsByIDRequest) String() string

type GetContextsByIDResponse 

type GetContextsByIDResponse struct {

	// The result is not index-aligned: if an id is not found, it is not
	// returned.
	Contexts []*Context `protobuf:"bytes,1,rep,name=contexts" json:"contexts,omitempty"`
	// contains filtered or unexported fields
}

func (*GetContextsByIDResponse) Descriptor deprecated 

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

Deprecated: Use GetContextsByIDResponse.ProtoReflect.Descriptor instead.

func (*GetContextsByIDResponse) GetContexts 

func (x *GetContextsByIDResponse) GetContexts() []*Context

func (*GetContextsByIDResponse) ProtoMessage 

func (*GetContextsByIDResponse) ProtoMessage()

func (*GetContextsByIDResponse) ProtoReflect 

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

func (*GetContextsByIDResponse) Reset 

func (x *GetContextsByIDResponse) Reset()

func (*GetContextsByIDResponse) String 

func (x *GetContextsByIDResponse) String() string

type GetContextsByTypeRequest 

type GetContextsByTypeRequest struct {
	TypeName *string `protobuf:"bytes,1,opt,name=type_name,json=typeName" json:"type_name,omitempty"`
	// Specify options.
	// Currently supports:
	//   1. Field to order the results.
	//   2. Page size.
	Options *ListOperationOptions `protobuf:"bytes,2,opt,name=options" json:"options,omitempty"`
	// If not set, it looks for the type with type_name and options with default
	// type_version.
	TypeVersion *string `protobuf:"bytes,3,opt,name=type_version,json=typeVersion" json:"type_version,omitempty"`
	// contains filtered or unexported fields
}

func (*GetContextsByTypeRequest) Descriptor deprecated 

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

Deprecated: Use GetContextsByTypeRequest.ProtoReflect.Descriptor instead.

func (*GetContextsByTypeRequest) GetOptions 

func (x *GetContextsByTypeRequest) GetOptions() *ListOperationOptions

func (*GetContextsByTypeRequest) GetTypeName 

func (x *GetContextsByTypeRequest) GetTypeName() string

func (*GetContextsByTypeRequest) GetTypeVersion 

func (x *GetContextsByTypeRequest) GetTypeVersion() string

func (*GetContextsByTypeRequest) ProtoMessage 

func (*GetContextsByTypeRequest) ProtoMessage()

func (*GetContextsByTypeRequest) ProtoReflect 

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

func (*GetContextsByTypeRequest) Reset 

func (x *GetContextsByTypeRequest) Reset()

func (*GetContextsByTypeRequest) String 

func (x *GetContextsByTypeRequest) String() string

type GetContextsByTypeResponse 

type GetContextsByTypeResponse struct {
	Contexts []*Context `protobuf:"bytes,1,rep,name=contexts" json:"contexts,omitempty"`
	// Token to use to retrieve next page of results if list options are used in
	// the request.
	NextPageToken *string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken" json:"next_page_token,omitempty"`
	// contains filtered or unexported fields
}

func (*GetContextsByTypeResponse) Descriptor deprecated 

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

Deprecated: Use GetContextsByTypeResponse.ProtoReflect.Descriptor instead.

func (*GetContextsByTypeResponse) GetContexts 

func (x *GetContextsByTypeResponse) GetContexts() []*Context

func (*GetContextsByTypeResponse) GetNextPageToken 

func (x *GetContextsByTypeResponse) GetNextPageToken() string

func (*GetContextsByTypeResponse) ProtoMessage 

func (*GetContextsByTypeResponse) ProtoMessage()

func (*GetContextsByTypeResponse) ProtoReflect 

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

func (*GetContextsByTypeResponse) Reset 

func (x *GetContextsByTypeResponse) Reset()

func (*GetContextsByTypeResponse) String 

func (x *GetContextsByTypeResponse) String() string

type GetContextsRequest 

type GetContextsRequest struct {

	// Specify options.
	// Currently supports:
	//   1. Field to order the results.
	//   2. Page size.
	Options *ListOperationOptions `protobuf:"bytes,1,opt,name=options" json:"options,omitempty"`
	// contains filtered or unexported fields
}

Request to retrieve Contexts using List options. If option is not specified then all Contexts are returned.

func (*GetContextsRequest) Descriptor deprecated 

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

Deprecated: Use GetContextsRequest.ProtoReflect.Descriptor instead.

func (*GetContextsRequest) GetOptions 

func (x *GetContextsRequest) GetOptions() *ListOperationOptions

func (*GetContextsRequest) ProtoMessage 

func (*GetContextsRequest) ProtoMessage()

func (*GetContextsRequest) ProtoReflect 

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

func (*GetContextsRequest) Reset 

func (x *GetContextsRequest) Reset()

func (*GetContextsRequest) String 

func (x *GetContextsRequest) String() string

type GetContextsResponse 

type GetContextsResponse struct {

	// Returned contexts.
	Contexts []*Context `protobuf:"bytes,1,rep,name=contexts" json:"contexts,omitempty"`
	// Token to use to retrieve next page of results if list options are used in
	// the request.
	NextPageToken *string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken" json:"next_page_token,omitempty"`
	// contains filtered or unexported fields
}

func (*GetContextsResponse) Descriptor deprecated 

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

Deprecated: Use GetContextsResponse.ProtoReflect.Descriptor instead.

func (*GetContextsResponse) GetContexts 

func (x *GetContextsResponse) GetContexts() []*Context

func (*GetContextsResponse) GetNextPageToken 

func (x *GetContextsResponse) GetNextPageToken() string

func (*GetContextsResponse) ProtoMessage 

func (*GetContextsResponse) ProtoMessage()

func (*GetContextsResponse) ProtoReflect 

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

func (*GetContextsResponse) Reset 

func (x *GetContextsResponse) Reset()

func (*GetContextsResponse) String 

func (x *GetContextsResponse) String() string

type GetEventsByArtifactIDsRequest 

type GetEventsByArtifactIDsRequest struct {
	ArtifactIds []int64 `protobuf:"varint,1,rep,name=artifact_ids,json=artifactIds" json:"artifact_ids,omitempty"`
	// contains filtered or unexported fields
}

func (*GetEventsByArtifactIDsRequest) Descriptor deprecated 

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

Deprecated: Use GetEventsByArtifactIDsRequest.ProtoReflect.Descriptor instead.

func (*GetEventsByArtifactIDsRequest) GetArtifactIds 

func (x *GetEventsByArtifactIDsRequest) GetArtifactIds() []int64

func (*GetEventsByArtifactIDsRequest) ProtoMessage 

func (*GetEventsByArtifactIDsRequest) ProtoMessage()

func (*GetEventsByArtifactIDsRequest) ProtoReflect 

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

func (*GetEventsByArtifactIDsRequest) Reset 

func (x *GetEventsByArtifactIDsRequest) Reset()

func (*GetEventsByArtifactIDsRequest) String 

func (x *GetEventsByArtifactIDsRequest) String() string

type GetEventsByArtifactIDsResponse 

type GetEventsByArtifactIDsResponse struct {
	Events []*Event `protobuf:"bytes,1,rep,name=events" json:"events,omitempty"`
	// contains filtered or unexported fields
}

func (*GetEventsByArtifactIDsResponse) Descriptor deprecated 

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

Deprecated: Use GetEventsByArtifactIDsResponse.ProtoReflect.Descriptor instead.

func (*GetEventsByArtifactIDsResponse) GetEvents 

func (x *GetEventsByArtifactIDsResponse) GetEvents() []*Event

func (*GetEventsByArtifactIDsResponse) ProtoMessage 

func (*GetEventsByArtifactIDsResponse) ProtoMessage()

func (*GetEventsByArtifactIDsResponse) ProtoReflect 

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

func (*GetEventsByArtifactIDsResponse) Reset 

func (x *GetEventsByArtifactIDsResponse) Reset()

func (*GetEventsByArtifactIDsResponse) String 

func (x *GetEventsByArtifactIDsResponse) String() string

type GetEventsByExecutionIDsRequest 

type GetEventsByExecutionIDsRequest struct {
	ExecutionIds []int64 `protobuf:"varint,1,rep,name=execution_ids,json=executionIds" json:"execution_ids,omitempty"`
	// contains filtered or unexported fields
}

Gets all events with matching execution ids.

func (*GetEventsByExecutionIDsRequest) Descriptor deprecated 

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

Deprecated: Use GetEventsByExecutionIDsRequest.ProtoReflect.Descriptor instead.

func (*GetEventsByExecutionIDsRequest) GetExecutionIds 

func (x *GetEventsByExecutionIDsRequest) GetExecutionIds() []int64

func (*GetEventsByExecutionIDsRequest) ProtoMessage 

func (*GetEventsByExecutionIDsRequest) ProtoMessage()

func (*GetEventsByExecutionIDsRequest) ProtoReflect 

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

func (*GetEventsByExecutionIDsRequest) Reset 

func (x *GetEventsByExecutionIDsRequest) Reset()

func (*GetEventsByExecutionIDsRequest) String 

func (x *GetEventsByExecutionIDsRequest) String() string

type GetEventsByExecutionIDsResponse 

type GetEventsByExecutionIDsResponse struct {
	Events []*Event `protobuf:"bytes,1,rep,name=events" json:"events,omitempty"`
	// contains filtered or unexported fields
}

func (*GetEventsByExecutionIDsResponse) Descriptor deprecated 

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

Deprecated: Use GetEventsByExecutionIDsResponse.ProtoReflect.Descriptor instead.

func (*GetEventsByExecutionIDsResponse) GetEvents 

func (x *GetEventsByExecutionIDsResponse) GetEvents() []*Event

func (*GetEventsByExecutionIDsResponse) ProtoMessage 

func (*GetEventsByExecutionIDsResponse) ProtoMessage()

func (*GetEventsByExecutionIDsResponse) ProtoReflect 

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

func (*GetEventsByExecutionIDsResponse) Reset 

func (x *GetEventsByExecutionIDsResponse) Reset()

func (*GetEventsByExecutionIDsResponse) String 

func (x *GetEventsByExecutionIDsResponse) String() string

type GetExecutionByTypeAndNameRequest 

type GetExecutionByTypeAndNameRequest struct {
	TypeName *string `protobuf:"bytes,1,opt,name=type_name,json=typeName" json:"type_name,omitempty"`
	// If not set, it looks for the type with type_name and execution_name with
	// default type_version.
	TypeVersion   *string `protobuf:"bytes,3,opt,name=type_version,json=typeVersion" json:"type_version,omitempty"`
	ExecutionName *string `protobuf:"bytes,2,opt,name=execution_name,json=executionName" json:"execution_name,omitempty"`
	// contains filtered or unexported fields
}

func (*GetExecutionByTypeAndNameRequest) Descriptor deprecated 

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

Deprecated: Use GetExecutionByTypeAndNameRequest.ProtoReflect.Descriptor instead.

func (*GetExecutionByTypeAndNameRequest) GetExecutionName 

func (x *GetExecutionByTypeAndNameRequest) GetExecutionName() string

func (*GetExecutionByTypeAndNameRequest) GetTypeName 

func (x *GetExecutionByTypeAndNameRequest) GetTypeName() string

func (*GetExecutionByTypeAndNameRequest) GetTypeVersion 

func (x *GetExecutionByTypeAndNameRequest) GetTypeVersion() string

func (*GetExecutionByTypeAndNameRequest) ProtoMessage 

func (*GetExecutionByTypeAndNameRequest) ProtoMessage()

func (*GetExecutionByTypeAndNameRequest) ProtoReflect 

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

func (*GetExecutionByTypeAndNameRequest) Reset 

func (x *GetExecutionByTypeAndNameRequest) Reset()

func (*GetExecutionByTypeAndNameRequest) String 

func (x *GetExecutionByTypeAndNameRequest) String() string

type GetExecutionByTypeAndNameResponse 

type GetExecutionByTypeAndNameResponse struct {
	Execution *Execution `protobuf:"bytes,1,opt,name=execution" json:"execution,omitempty"`
	// contains filtered or unexported fields
}

func (*GetExecutionByTypeAndNameResponse) Descriptor deprecated 

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

Deprecated: Use GetExecutionByTypeAndNameResponse.ProtoReflect.Descriptor instead.

func (*GetExecutionByTypeAndNameResponse) GetExecution 

func (x *GetExecutionByTypeAndNameResponse) GetExecution() *Execution

func (*GetExecutionByTypeAndNameResponse) ProtoMessage 

func (*GetExecutionByTypeAndNameResponse) ProtoMessage()

func (*GetExecutionByTypeAndNameResponse) ProtoReflect 

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

func (*GetExecutionByTypeAndNameResponse) Reset 

func (x *GetExecutionByTypeAndNameResponse) Reset()

func (*GetExecutionByTypeAndNameResponse) String 

func (x *GetExecutionByTypeAndNameResponse) String() string

type GetExecutionTypeRequest 

type GetExecutionTypeRequest struct {
	TypeName *string `protobuf:"bytes,1,opt,name=type_name,json=typeName" json:"type_name,omitempty"`
	// If not set, it looks for the type with type_name with default type_version.
	TypeVersion *string `protobuf:"bytes,2,opt,name=type_version,json=typeVersion" json:"type_version,omitempty"`
	// contains filtered or unexported fields
}

func (*GetExecutionTypeRequest) Descriptor deprecated 

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

Deprecated: Use GetExecutionTypeRequest.ProtoReflect.Descriptor instead.

func (*GetExecutionTypeRequest) GetTypeName 

func (x *GetExecutionTypeRequest) GetTypeName() string

func (*GetExecutionTypeRequest) GetTypeVersion 

func (x *GetExecutionTypeRequest) GetTypeVersion() string

func (*GetExecutionTypeRequest) ProtoMessage 

func (*GetExecutionTypeRequest) ProtoMessage()

func (*GetExecutionTypeRequest) ProtoReflect 

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

func (*GetExecutionTypeRequest) Reset 

func (x *GetExecutionTypeRequest) Reset()

func (*GetExecutionTypeRequest) String 

func (x *GetExecutionTypeRequest) String() string

type GetExecutionTypeResponse 

type GetExecutionTypeResponse struct {

	// Gets an execution type, or clear if it does not exist.
	ExecutionType *ExecutionType `protobuf:"bytes,1,opt,name=execution_type,json=executionType" json:"execution_type,omitempty"`
	// contains filtered or unexported fields
}

func (*GetExecutionTypeResponse) Descriptor deprecated 

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

Deprecated: Use GetExecutionTypeResponse.ProtoReflect.Descriptor instead.

func (*GetExecutionTypeResponse) GetExecutionType 

func (x *GetExecutionTypeResponse) GetExecutionType() *ExecutionType

func (*GetExecutionTypeResponse) ProtoMessage 

func (*GetExecutionTypeResponse) ProtoMessage()

func (*GetExecutionTypeResponse) ProtoReflect 

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

func (*GetExecutionTypeResponse) Reset 

func (x *GetExecutionTypeResponse) Reset()

func (*GetExecutionTypeResponse) String 

func (x *GetExecutionTypeResponse) String() string

type GetExecutionTypesByIDRequest 

type GetExecutionTypesByIDRequest struct {
	TypeIds []int64 `protobuf:"varint,1,rep,name=type_ids,json=typeIds" json:"type_ids,omitempty"`
	// contains filtered or unexported fields
}

func (*GetExecutionTypesByIDRequest) Descriptor deprecated 

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

Deprecated: Use GetExecutionTypesByIDRequest.ProtoReflect.Descriptor instead.

func (*GetExecutionTypesByIDRequest) GetTypeIds 

func (x *GetExecutionTypesByIDRequest) GetTypeIds() []int64

func (*GetExecutionTypesByIDRequest) ProtoMessage 

func (*GetExecutionTypesByIDRequest) ProtoMessage()

func (*GetExecutionTypesByIDRequest) ProtoReflect 

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

func (*GetExecutionTypesByIDRequest) Reset 

func (x *GetExecutionTypesByIDRequest) Reset()

func (*GetExecutionTypesByIDRequest) String 

func (x *GetExecutionTypesByIDRequest) String() string

type GetExecutionTypesByIDResponse 

type GetExecutionTypesByIDResponse struct {

	// The result is not index-aligned: if an id is not found, it is not
	// returned.
	ExecutionTypes []*ExecutionType `protobuf:"bytes,1,rep,name=execution_types,json=executionTypes" json:"execution_types,omitempty"`
	// contains filtered or unexported fields
}

func (*GetExecutionTypesByIDResponse) Descriptor deprecated 

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

Deprecated: Use GetExecutionTypesByIDResponse.ProtoReflect.Descriptor instead.

func (*GetExecutionTypesByIDResponse) GetExecutionTypes 

func (x *GetExecutionTypesByIDResponse) GetExecutionTypes() []*ExecutionType

func (*GetExecutionTypesByIDResponse) ProtoMessage 

func (*GetExecutionTypesByIDResponse) ProtoMessage()

func (*GetExecutionTypesByIDResponse) ProtoReflect 

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

func (*GetExecutionTypesByIDResponse) Reset 

func (x *GetExecutionTypesByIDResponse) Reset()

func (*GetExecutionTypesByIDResponse) String 

func (x *GetExecutionTypesByIDResponse) String() string

type GetExecutionTypesRequest 

type GetExecutionTypesRequest struct {
	// contains filtered or unexported fields
}

func (*GetExecutionTypesRequest) Descriptor deprecated 

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

Deprecated: Use GetExecutionTypesRequest.ProtoReflect.Descriptor instead.

func (*GetExecutionTypesRequest) ProtoMessage 

func (*GetExecutionTypesRequest) ProtoMessage()

func (*GetExecutionTypesRequest) ProtoReflect 

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

func (*GetExecutionTypesRequest) Reset 

func (x *GetExecutionTypesRequest) Reset()

func (*GetExecutionTypesRequest) String 

func (x *GetExecutionTypesRequest) String() string

type GetExecutionTypesResponse 

type GetExecutionTypesResponse struct {
	ExecutionTypes []*ExecutionType `protobuf:"bytes,1,rep,name=execution_types,json=executionTypes" json:"execution_types,omitempty"`
	// contains filtered or unexported fields
}

func (*GetExecutionTypesResponse) Descriptor deprecated 

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

Deprecated: Use GetExecutionTypesResponse.ProtoReflect.Descriptor instead.

func (*GetExecutionTypesResponse) GetExecutionTypes 

func (x *GetExecutionTypesResponse) GetExecutionTypes() []*ExecutionType

func (*GetExecutionTypesResponse) ProtoMessage 

func (*GetExecutionTypesResponse) ProtoMessage()

func (*GetExecutionTypesResponse) ProtoReflect 

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

func (*GetExecutionTypesResponse) Reset 

func (x *GetExecutionTypesResponse) Reset()

func (*GetExecutionTypesResponse) String 

func (x *GetExecutionTypesResponse) String() string

type GetExecutionsByContextRequest 

type GetExecutionsByContextRequest struct {
	ContextId *int64 `protobuf:"varint,1,opt,name=context_id,json=contextId" json:"context_id,omitempty"`
	// Specify List options.
	// Currently supports:
	//   1. Field to order the results.
	//   2. Page size.
	Options *ListOperationOptions `protobuf:"bytes,2,opt,name=options" json:"options,omitempty"`
	// contains filtered or unexported fields
}

func (*GetExecutionsByContextRequest) Descriptor deprecated 

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

Deprecated: Use GetExecutionsByContextRequest.ProtoReflect.Descriptor instead.

func (*GetExecutionsByContextRequest) GetContextId 

func (x *GetExecutionsByContextRequest) GetContextId() int64

func (*GetExecutionsByContextRequest) GetOptions 

func (x *GetExecutionsByContextRequest) GetOptions() *ListOperationOptions

func (*GetExecutionsByContextRequest) ProtoMessage 

func (*GetExecutionsByContextRequest) ProtoMessage()

func (*GetExecutionsByContextRequest) ProtoReflect 

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

func (*GetExecutionsByContextRequest) Reset 

func (x *GetExecutionsByContextRequest) Reset()

func (*GetExecutionsByContextRequest) String 

func (x *GetExecutionsByContextRequest) String() string

type GetExecutionsByContextResponse 

type GetExecutionsByContextResponse struct {
	Executions []*Execution `protobuf:"bytes,1,rep,name=executions" json:"executions,omitempty"`
	// Token to use to retrieve next page of results if list options are used in
	// the request.
	NextPageToken *string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken" json:"next_page_token,omitempty"`
	// contains filtered or unexported fields
}

func (*GetExecutionsByContextResponse) Descriptor deprecated 

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

Deprecated: Use GetExecutionsByContextResponse.ProtoReflect.Descriptor instead.

func (*GetExecutionsByContextResponse) GetExecutions 

func (x *GetExecutionsByContextResponse) GetExecutions() []*Execution

func (*GetExecutionsByContextResponse) GetNextPageToken 

func (x *GetExecutionsByContextResponse) GetNextPageToken() string

func (*GetExecutionsByContextResponse) ProtoMessage 

func (*GetExecutionsByContextResponse) ProtoMessage()

func (*GetExecutionsByContextResponse) ProtoReflect 

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

func (*GetExecutionsByContextResponse) Reset 

func (x *GetExecutionsByContextResponse) Reset()

func (*GetExecutionsByContextResponse) String 

func (x *GetExecutionsByContextResponse) String() string

type GetExecutionsByIDRequest 

type GetExecutionsByIDRequest struct {

	// A list of execution ids to retrieve.
	ExecutionIds []int64 `protobuf:"varint,1,rep,name=execution_ids,json=executionIds" json:"execution_ids,omitempty"`
	// contains filtered or unexported fields
}

func (*GetExecutionsByIDRequest) Descriptor deprecated 

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

Deprecated: Use GetExecutionsByIDRequest.ProtoReflect.Descriptor instead.

func (*GetExecutionsByIDRequest) GetExecutionIds 

func (x *GetExecutionsByIDRequest) GetExecutionIds() []int64

func (*GetExecutionsByIDRequest) ProtoMessage 

func (*GetExecutionsByIDRequest) ProtoMessage()

func (*GetExecutionsByIDRequest) ProtoReflect 

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

func (*GetExecutionsByIDRequest) Reset 

func (x *GetExecutionsByIDRequest) Reset()

func (*GetExecutionsByIDRequest) String 

func (x *GetExecutionsByIDRequest) String() string

type GetExecutionsByIDResponse 

type GetExecutionsByIDResponse struct {

	// The result is not index-aligned: if an id is not found, it is not
	// returned.
	Executions []*Execution `protobuf:"bytes,1,rep,name=executions" json:"executions,omitempty"`
	// contains filtered or unexported fields
}

func (*GetExecutionsByIDResponse) Descriptor deprecated 

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

Deprecated: Use GetExecutionsByIDResponse.ProtoReflect.Descriptor instead.

func (*GetExecutionsByIDResponse) GetExecutions 

func (x *GetExecutionsByIDResponse) GetExecutions() []*Execution

func (*GetExecutionsByIDResponse) ProtoMessage 

func (*GetExecutionsByIDResponse) ProtoMessage()

func (*GetExecutionsByIDResponse) ProtoReflect 

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

func (*GetExecutionsByIDResponse) Reset 

func (x *GetExecutionsByIDResponse) Reset()

func (*GetExecutionsByIDResponse) String 

func (x *GetExecutionsByIDResponse) String() string

type GetExecutionsByTypeRequest 

type GetExecutionsByTypeRequest struct {
	TypeName *string `protobuf:"bytes,1,opt,name=type_name,json=typeName" json:"type_name,omitempty"`
	// If not set, it looks for the type with type_name with default type_version.
	TypeVersion *string `protobuf:"bytes,2,opt,name=type_version,json=typeVersion" json:"type_version,omitempty"`
	// contains filtered or unexported fields
}

func (*GetExecutionsByTypeRequest) Descriptor deprecated 

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

Deprecated: Use GetExecutionsByTypeRequest.ProtoReflect.Descriptor instead.

func (*GetExecutionsByTypeRequest) GetTypeName 

func (x *GetExecutionsByTypeRequest) GetTypeName() string

func (*GetExecutionsByTypeRequest) GetTypeVersion 

func (x *GetExecutionsByTypeRequest) GetTypeVersion() string

func (*GetExecutionsByTypeRequest) ProtoMessage 

func (*GetExecutionsByTypeRequest) ProtoMessage()

func (*GetExecutionsByTypeRequest) ProtoReflect 

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

func (*GetExecutionsByTypeRequest) Reset 

func (x *GetExecutionsByTypeRequest) Reset()

func (*GetExecutionsByTypeRequest) String 

func (x *GetExecutionsByTypeRequest) String() string

type GetExecutionsByTypeResponse 

type GetExecutionsByTypeResponse struct {
	Executions []*Execution `protobuf:"bytes,1,rep,name=executions" json:"executions,omitempty"`
	// contains filtered or unexported fields
}

func (*GetExecutionsByTypeResponse) Descriptor deprecated 

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

Deprecated: Use GetExecutionsByTypeResponse.ProtoReflect.Descriptor instead.

func (*GetExecutionsByTypeResponse) GetExecutions 

func (x *GetExecutionsByTypeResponse) GetExecutions() []*Execution

func (*GetExecutionsByTypeResponse) ProtoMessage 

func (*GetExecutionsByTypeResponse) ProtoMessage()

func (*GetExecutionsByTypeResponse) ProtoReflect 

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

func (*GetExecutionsByTypeResponse) Reset 

func (x *GetExecutionsByTypeResponse) Reset()

func (*GetExecutionsByTypeResponse) String 

func (x *GetExecutionsByTypeResponse) String() string

type GetExecutionsRequest 

type GetExecutionsRequest struct {

	// Specify options.
	// Currently supports:
	//   1. Field to order the results.
	//   2. Page size.
	Options *ListOperationOptions `protobuf:"bytes,1,opt,name=options" json:"options,omitempty"`
	// contains filtered or unexported fields
}

Request to retrieve Executions using List options. If option is not specified then all Executions are returned.

func (*GetExecutionsRequest) Descriptor deprecated 

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

Deprecated: Use GetExecutionsRequest.ProtoReflect.Descriptor instead.

func (*GetExecutionsRequest) GetOptions 

func (x *GetExecutionsRequest) GetOptions() *ListOperationOptions

func (*GetExecutionsRequest) ProtoMessage 

func (*GetExecutionsRequest) ProtoMessage()

func (*GetExecutionsRequest) ProtoReflect 

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

func (*GetExecutionsRequest) Reset 

func (x *GetExecutionsRequest) Reset()

func (*GetExecutionsRequest) String 

func (x *GetExecutionsRequest) String() string

type GetExecutionsResponse 

type GetExecutionsResponse struct {

	// Returned executions.
	Executions []*Execution `protobuf:"bytes,1,rep,name=executions" json:"executions,omitempty"`
	// Token to use to retrieve next page of results if list options are used in
	// the request.
	NextPageToken *string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken" json:"next_page_token,omitempty"`
	// contains filtered or unexported fields
}

func (*GetExecutionsResponse) Descriptor deprecated 

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

Deprecated: Use GetExecutionsResponse.ProtoReflect.Descriptor instead.

func (*GetExecutionsResponse) GetExecutions 

func (x *GetExecutionsResponse) GetExecutions() []*Execution

func (*GetExecutionsResponse) GetNextPageToken 

func (x *GetExecutionsResponse) GetNextPageToken() string

func (*GetExecutionsResponse) ProtoMessage 

func (*GetExecutionsResponse) ProtoMessage()

func (*GetExecutionsResponse) ProtoReflect 

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

func (*GetExecutionsResponse) Reset 

func (x *GetExecutionsResponse) Reset()

func (*GetExecutionsResponse) String 

func (x *GetExecutionsResponse) String() string

type GetParentContextsByContextRequest 

type GetParentContextsByContextRequest struct {
	ContextId *int64 `protobuf:"varint,1,opt,name=context_id,json=contextId" json:"context_id,omitempty"`
	// contains filtered or unexported fields
}

func (*GetParentContextsByContextRequest) Descriptor deprecated 

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

Deprecated: Use GetParentContextsByContextRequest.ProtoReflect.Descriptor instead.

func (*GetParentContextsByContextRequest) GetContextId 

func (x *GetParentContextsByContextRequest) GetContextId() int64

func (*GetParentContextsByContextRequest) ProtoMessage 

func (*GetParentContextsByContextRequest) ProtoMessage()

func (*GetParentContextsByContextRequest) ProtoReflect 

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

func (*GetParentContextsByContextRequest) Reset 

func (x *GetParentContextsByContextRequest) Reset()

func (*GetParentContextsByContextRequest) String 

func (x *GetParentContextsByContextRequest) String() string

type GetParentContextsByContextResponse 

type GetParentContextsByContextResponse struct {
	Contexts []*Context `protobuf:"bytes,1,rep,name=contexts" json:"contexts,omitempty"`
	// contains filtered or unexported fields
}

func (*GetParentContextsByContextResponse) Descriptor deprecated 

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

Deprecated: Use GetParentContextsByContextResponse.ProtoReflect.Descriptor instead.

func (*GetParentContextsByContextResponse) GetContexts 

func (x *GetParentContextsByContextResponse) GetContexts() []*Context

func (*GetParentContextsByContextResponse) ProtoMessage 

func (*GetParentContextsByContextResponse) ProtoMessage()

func (*GetParentContextsByContextResponse) ProtoReflect 

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

func (*GetParentContextsByContextResponse) Reset 

func (x *GetParentContextsByContextResponse) Reset()

func (*GetParentContextsByContextResponse) String 

func (x *GetParentContextsByContextResponse) String() string

type GrpcChannelArguments 

type GrpcChannelArguments struct {

	// Maximum message length in bytes per response that the channel can receive.
	MaxReceiveMessageLength *int64 `` /* 128-byte string literal not displayed */
	// contains filtered or unexported fields
}

A list of supported GRPC arguments defined in: https://grpc.github.io/grpc/core/group__grpc__arg__keys.html

func (*GrpcChannelArguments) Descriptor deprecated 

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

Deprecated: Use GrpcChannelArguments.ProtoReflect.Descriptor instead.

func (*GrpcChannelArguments) GetMaxReceiveMessageLength 

func (x *GrpcChannelArguments) GetMaxReceiveMessageLength() int64

func (*GrpcChannelArguments) ProtoMessage 

func (*GrpcChannelArguments) ProtoMessage()

func (*GrpcChannelArguments) ProtoReflect 

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

func (*GrpcChannelArguments) Reset 

func (x *GrpcChannelArguments) Reset()

func (*GrpcChannelArguments) String 

func (x *GrpcChannelArguments) String() string

type IntersectionArtifactStructType 

type IntersectionArtifactStructType struct {
	Constraints []*ArtifactStructType `protobuf:"bytes,1,rep,name=constraints" json:"constraints,omitempty"`
	// contains filtered or unexported fields
}

A member of this type must satisfy all constraints. This primarily useful not as an end-user type, but something calculated as an intermediate type in the system.

For example, suppose you have a method: def infer_my_input_type(a): # try to infer the input type of this method. 

use_in_method_x(a) # with input type x_input
use_in_method_y(a) # with input type y_input

Given this information, you know that infer_my_input_type has type {"intersection":{"constraints":[x_input, y_input]}}.

IntersectionArtifactStructType intersection_type = {"constraints":[ 

{"dict":{"properties":{"schema":{"any":{}}},
         "extra_properties":{"any":{}}}},
{"dict":{"properties":{"data":{"any":{}}},
         "extra_properties":{"any":{}}}}]}

Since the first constraint requires the dictionary to have a schema property, and the second constraint requires it to have a data property, this is equivalent to: ArtifactStructType other_type = 

{"dict":{"properties":{"schema":{"any":{}},"data":{"any":{}}}},
 "extra_properties":{"any":{}}}

func (*IntersectionArtifactStructType) Descriptor deprecated 

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

Deprecated: Use IntersectionArtifactStructType.ProtoReflect.Descriptor instead.

func (*IntersectionArtifactStructType) GetConstraints 

func (x *IntersectionArtifactStructType) GetConstraints() []*ArtifactStructType

func (*IntersectionArtifactStructType) ProtoMessage 

func (*IntersectionArtifactStructType) ProtoMessage()

func (*IntersectionArtifactStructType) ProtoReflect 

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

func (*IntersectionArtifactStructType) Reset 

func (x *IntersectionArtifactStructType) Reset()

func (*IntersectionArtifactStructType) String 

func (x *IntersectionArtifactStructType) String() string

type LineageGraph 

type LineageGraph struct {

	// extracted types
	ArtifactTypes  []*ArtifactType  `protobuf:"bytes,1,rep,name=artifact_types,json=artifactTypes" json:"artifact_types,omitempty"`
	ExecutionTypes []*ExecutionType `protobuf:"bytes,2,rep,name=execution_types,json=executionTypes" json:"execution_types,omitempty"`
	ContextTypes   []*ContextType   `protobuf:"bytes,3,rep,name=context_types,json=contextTypes" json:"context_types,omitempty"`
	// extracted nodes
	Artifacts  []*Artifact  `protobuf:"bytes,4,rep,name=artifacts" json:"artifacts,omitempty"`
	Executions []*Execution `protobuf:"bytes,5,rep,name=executions" json:"executions,omitempty"`
	Contexts   []*Context   `protobuf:"bytes,6,rep,name=contexts" json:"contexts,omitempty"`
	// extracted edges
	Events       []*Event       `protobuf:"bytes,7,rep,name=events" json:"events,omitempty"`
	Attributions []*Attribution `protobuf:"bytes,8,rep,name=attributions" json:"attributions,omitempty"`
	Associations []*Association `protobuf:"bytes,9,rep,name=associations" json:"associations,omitempty"`
	// contains filtered or unexported fields
}

A self-contained provenance (sub)graph representation consists of MLMD nodes and their relationships. It is used to represent the query results from the persistent backend (e.g., lineage about a node, reachability of two nodes).

func (*LineageGraph) Descriptor deprecated 

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

Deprecated: Use LineageGraph.ProtoReflect.Descriptor instead.

func (*LineageGraph) GetArtifactTypes 

func (x *LineageGraph) GetArtifactTypes() []*ArtifactType

func (*LineageGraph) GetArtifacts 

func (x *LineageGraph) GetArtifacts() []*Artifact

func (*LineageGraph) GetAssociations 

func (x *LineageGraph) GetAssociations() []*Association

func (*LineageGraph) GetAttributions 

func (x *LineageGraph) GetAttributions() []*Attribution

func (*LineageGraph) GetContextTypes 

func (x *LineageGraph) GetContextTypes() []*ContextType

func (*LineageGraph) GetContexts 

func (x *LineageGraph) GetContexts() []*Context

func (*LineageGraph) GetEvents 

func (x *LineageGraph) GetEvents() []*Event

func (*LineageGraph) GetExecutionTypes 

func (x *LineageGraph) GetExecutionTypes() []*ExecutionType

func (*LineageGraph) GetExecutions 

func (x *LineageGraph) GetExecutions() []*Execution

func (*LineageGraph) ProtoMessage 

func (*LineageGraph) ProtoMessage()

func (*LineageGraph) ProtoReflect 

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

func (*LineageGraph) Reset 

func (x *LineageGraph) Reset()

func (*LineageGraph) String 

func (x *LineageGraph) String() string

type ListArtifactStructType 

type ListArtifactStructType struct {

	// Every entry in the list must be of this type.
	// Note: if this type is Any, then the list can have arbitrary elements.
	Element *ArtifactStructType `protobuf:"bytes,1,opt,name=element" json:"element,omitempty"`
	// contains filtered or unexported fields
}

Represents an ArtifactStruct list type with homogeneous elements.

func (*ListArtifactStructType) Descriptor deprecated 

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

Deprecated: Use ListArtifactStructType.ProtoReflect.Descriptor instead.

func (*ListArtifactStructType) GetElement 

func (x *ListArtifactStructType) GetElement() *ArtifactStructType

func (*ListArtifactStructType) ProtoMessage 

func (*ListArtifactStructType) ProtoMessage()

func (*ListArtifactStructType) ProtoReflect 

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

func (*ListArtifactStructType) Reset 

func (x *ListArtifactStructType) Reset()

func (*ListArtifactStructType) String 

func (x *ListArtifactStructType) String() string

type ListOperationNextPageToken 

type ListOperationNextPageToken struct {

	// Id offset within the resultset to start next page.
	// Id offset is returned as Id is the unique field used to break ties for
	// fields that might have duplicate entries, e.g. there could be two
	// resources with same create_time. In such cases to  break the tie in
	// ordering, id offset is used.
	// This field is currently only set whe order_by field is CREATE_TIME.
	IdOffset *int64 `protobuf:"varint,1,opt,name=id_offset,json=idOffset" json:"id_offset,omitempty"`
	// Offset value of the order by field. If ID is used this value is same as
	// id_offset.
	FieldOffset *int64 `protobuf:"varint,2,opt,name=field_offset,json=fieldOffset" json:"field_offset,omitempty"`
	// Options set in the first call to ListOperation. This ensures that if
	// next_page_token is set by the caller then ListPipelineJobs API will always
	// use options set in the first call.
	SetOptions *ListOperationOptions `protobuf:"bytes,3,opt,name=set_options,json=setOptions" json:"set_options,omitempty"`
	// List of ids that have the same order_by field values. This is used to
	// ensure List Operation does not return duplicate entries for nodes that have
	// the same order_by field value.
	// This field is currently only set whe order_by field is LAST_UPDATE_TIME.
	ListedIds []int64 `protobuf:"varint,4,rep,name=listed_ids,json=listedIds" json:"listed_ids,omitempty"`
	// contains filtered or unexported fields
}

Encapsulates information to identify the next page of resources in ListOperation.

func (*ListOperationNextPageToken) Descriptor deprecated 

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

Deprecated: Use ListOperationNextPageToken.ProtoReflect.Descriptor instead.

func (*ListOperationNextPageToken) GetFieldOffset 

func (x *ListOperationNextPageToken) GetFieldOffset() int64

func (*ListOperationNextPageToken) GetIdOffset 

func (x *ListOperationNextPageToken) GetIdOffset() int64

func (*ListOperationNextPageToken) GetListedIds 

func (x *ListOperationNextPageToken) GetListedIds() []int64

func (*ListOperationNextPageToken) GetSetOptions 

func (x *ListOperationNextPageToken) GetSetOptions() *ListOperationOptions

func (*ListOperationNextPageToken) ProtoMessage 

func (*ListOperationNextPageToken) ProtoMessage()

func (*ListOperationNextPageToken) ProtoReflect 

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

func (*ListOperationNextPageToken) Reset 

func (x *ListOperationNextPageToken) Reset()

func (*ListOperationNextPageToken) String 

func (x *ListOperationNextPageToken) String() string

type ListOperationOptions 

type ListOperationOptions struct {

	// Max number of resources to return in the result. A value of zero or less
	// results in a InvalidArgumentError.
	// The API implementation also enforces an upper-bound of 100, and picks the
	// minimum between this value and the one specified here.
	MaxResultSize *int32 `protobuf:"varint,1,opt,name=max_result_size,json=maxResultSize,def=20" json:"max_result_size,omitempty"`
	// Ordering field.
	OrderByField *ListOperationOptions_OrderByField `protobuf:"bytes,2,opt,name=order_by_field,json=orderByField" json:"order_by_field,omitempty"`
	// Identifies the next page of results.
	NextPageToken *string `protobuf:"bytes,3,opt,name=next_page_token,json=nextPageToken" json:"next_page_token,omitempty"`
	// contains filtered or unexported fields
}

ListOperationOptions represents the set of options and predicates to be used for List operations on Artifacts, Executions and Contexts.

func (*ListOperationOptions) Descriptor deprecated 

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

Deprecated: Use ListOperationOptions.ProtoReflect.Descriptor instead.

func (*ListOperationOptions) GetMaxResultSize 

func (x *ListOperationOptions) GetMaxResultSize() int32

func (*ListOperationOptions) GetNextPageToken 

func (x *ListOperationOptions) GetNextPageToken() string

func (*ListOperationOptions) GetOrderByField 

func (x *ListOperationOptions) GetOrderByField() *ListOperationOptions_OrderByField

func (*ListOperationOptions) ProtoMessage 

func (*ListOperationOptions) ProtoMessage()

func (*ListOperationOptions) ProtoReflect 

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

func (*ListOperationOptions) Reset 

func (x *ListOperationOptions) Reset()

func (*ListOperationOptions) String 

func (x *ListOperationOptions) String() string

type ListOperationOptions_OrderByField 

type ListOperationOptions_OrderByField struct {

	// Field to order.
	Field *ListOperationOptions_OrderByField_Field `protobuf:"varint,1,opt,name=field,enum=ml_metadata.ListOperationOptions_OrderByField_Field,def=3" json:"field,omitempty"`
	// Direction of ordering.
	IsAsc *bool `protobuf:"varint,2,opt,name=is_asc,json=isAsc,def=1" json:"is_asc,omitempty"`
	// contains filtered or unexported fields
}

func (*ListOperationOptions_OrderByField) Descriptor deprecated 

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

Deprecated: Use ListOperationOptions_OrderByField.ProtoReflect.Descriptor instead.

func (*ListOperationOptions_OrderByField) GetField 

func (x *ListOperationOptions_OrderByField) GetField() ListOperationOptions_OrderByField_Field

func (*ListOperationOptions_OrderByField) GetIsAsc 

func (x *ListOperationOptions_OrderByField) GetIsAsc() bool

func (*ListOperationOptions_OrderByField) ProtoMessage 

func (*ListOperationOptions_OrderByField) ProtoMessage()

func (*ListOperationOptions_OrderByField) ProtoReflect 

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

func (*ListOperationOptions_OrderByField) Reset 

func (x *ListOperationOptions_OrderByField) Reset()

func (*ListOperationOptions_OrderByField) String 

func (x *ListOperationOptions_OrderByField) String() string

type ListOperationOptions_OrderByField_Field 

type ListOperationOptions_OrderByField_Field int32

Supported fields for Ordering. 

const (
	ListOperationOptions_OrderByField_FIELD_UNSPECIFIED ListOperationOptions_OrderByField_Field = 0
	ListOperationOptions_OrderByField_CREATE_TIME       ListOperationOptions_OrderByField_Field = 1
	ListOperationOptions_OrderByField_LAST_UPDATE_TIME  ListOperationOptions_OrderByField_Field = 2
	ListOperationOptions_OrderByField_ID                ListOperationOptions_OrderByField_Field = 3
)

func (ListOperationOptions_OrderByField_Field) Descriptor 

func (ListOperationOptions_OrderByField_Field) Descriptor() protoreflect.EnumDescriptor

func (ListOperationOptions_OrderByField_Field) Enum 

func (x ListOperationOptions_OrderByField_Field) Enum() *ListOperationOptions_OrderByField_Field

func (ListOperationOptions_OrderByField_Field) EnumDescriptor deprecated 

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

Deprecated: Use ListOperationOptions_OrderByField_Field.Descriptor instead.

func (ListOperationOptions_OrderByField_Field) Number 

func (x ListOperationOptions_OrderByField_Field) Number() protoreflect.EnumNumber

func (ListOperationOptions_OrderByField_Field) String 

func (x ListOperationOptions_OrderByField_Field) String() string

func (ListOperationOptions_OrderByField_Field) Type 

func (ListOperationOptions_OrderByField_Field) Type() protoreflect.EnumType

func (*ListOperationOptions_OrderByField_Field) UnmarshalJSON deprecated 

func (x *ListOperationOptions_OrderByField_Field) UnmarshalJSON(b []byte) error

Deprecated: Do not use.

type MLArtifact 

type MLArtifact struct {
	Ids []int64 `protobuf:"varint,1,rep,packed,name=ids,proto3" json:"ids,omitempty"`
	// contains filtered or unexported fields
}

func (*MLArtifact) Descriptor deprecated 

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

Deprecated: Use MLArtifact.ProtoReflect.Descriptor instead.

func (*MLArtifact) GetIds 

func (x *MLArtifact) GetIds() []int64

func (*MLArtifact) ProtoMessage 

func (*MLArtifact) ProtoMessage()

func (*MLArtifact) ProtoReflect 

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

func (*MLArtifact) Reset 

func (x *MLArtifact) Reset()

func (*MLArtifact) String 

func (x *MLArtifact) String() string

type MetadataSourceQueryConfig 

type MetadataSourceQueryConfig struct {

	// the type of the metadata source
	MetadataSourceType MetadataSourceType `` /* 154-byte string literal not displayed */
	// Drops the Type table.
	DropTypeTable *MetadataSourceQueryConfig_TemplateQuery `protobuf:"bytes,3,opt,name=drop_type_table,json=dropTypeTable,proto3" json:"drop_type_table,omitempty"`
	// Creates the Type table.
	CreateTypeTable *MetadataSourceQueryConfig_TemplateQuery `protobuf:"bytes,4,opt,name=create_type_table,json=createTypeTable,proto3" json:"create_type_table,omitempty"`
	// Checks the existence of the Type table.
	CheckTypeTable *MetadataSourceQueryConfig_TemplateQuery `protobuf:"bytes,44,opt,name=check_type_table,json=checkTypeTable,proto3" json:"check_type_table,omitempty"`
	// Inserts an artifact type into the Type table. It has 3 parameters.
	// $0 is the name
	// $1 is the version
	// $2 is the description
	InsertArtifactType *MetadataSourceQueryConfig_TemplateQuery `protobuf:"bytes,54,opt,name=insert_artifact_type,json=insertArtifactType,proto3" json:"insert_artifact_type,omitempty"`
	// Inserts an execution type into the Type table. It has 3 parameters.
	// $0 is the type name
	// $1 is the version
	// $2 is the description
	// $3 is the input_type serialized as JSON or null.
	// $4 is the output_type serialized as JSON or null.
	InsertExecutionType *MetadataSourceQueryConfig_TemplateQuery `protobuf:"bytes,55,opt,name=insert_execution_type,json=insertExecutionType,proto3" json:"insert_execution_type,omitempty"`
	// Inserts a context type into the Type table. It has 1 parameter.
	// $0 is the type name
	// $1 is the version
	// $2 is the description
	InsertContextType *MetadataSourceQueryConfig_TemplateQuery `protobuf:"bytes,58,opt,name=insert_context_type,json=insertContextType,proto3" json:"insert_context_type,omitempty"`
	// Queries a type by its type id. It has 2 parameter.
	// $0 is the type id
	// $1 is the is_artifact_type
	SelectTypeById *MetadataSourceQueryConfig_TemplateQuery `protobuf:"bytes,6,opt,name=select_type_by_id,json=selectTypeById,proto3" json:"select_type_by_id,omitempty"`
	// Queries a type by its type name. It has 2 parameters.
	// $0 is the type name
	// $1 is the type_kind
	SelectTypeByName *MetadataSourceQueryConfig_TemplateQuery `protobuf:"bytes,20,opt,name=select_type_by_name,json=selectTypeByName,proto3" json:"select_type_by_name,omitempty"`
	// Queries a type by its type name and version. It has 3 parameters.
	// $0 is the type name
	// $1 is the type version
	// $2 is the type_kind
	SelectTypeByNameAndVersion *MetadataSourceQueryConfig_TemplateQuery `` /* 149-byte string literal not displayed */
	// Queries for all type instances. It has 1 parameter.
	// $0 is the is_artifact_type
	SelectAllTypes *MetadataSourceQueryConfig_TemplateQuery `protobuf:"bytes,57,opt,name=select_all_types,json=selectAllTypes,proto3" json:"select_all_types,omitempty"`
	// Drops the ParentType table.
	DropParentTypeTable *MetadataSourceQueryConfig_TemplateQuery `protobuf:"bytes,99,opt,name=drop_parent_type_table,json=dropParentTypeTable,proto3" json:"drop_parent_type_table,omitempty"`
	// Creates the ParentType table.
	CreateParentTypeTable *MetadataSourceQueryConfig_TemplateQuery `` /* 130-byte string literal not displayed */
	// Checks the existence of the ParentType table.
	CheckParentTypeTable *MetadataSourceQueryConfig_TemplateQuery `` /* 127-byte string literal not displayed */
	// Inserts a parent type into the ParentType table. It has 2 parameters:
	// $0 is the type_id
	// $1 is the parent_type_id
	InsertParentType *MetadataSourceQueryConfig_TemplateQuery `protobuf:"bytes,109,opt,name=insert_parent_type,json=insertParentType,proto3" json:"insert_parent_type,omitempty"`
	// Queries parent types from the ParentType table by type_id.
	// It has 1 parameter.
	// $0 is the type_id
	SelectParentTypeByTypeId *MetadataSourceQueryConfig_TemplateQuery `` /* 143-byte string literal not displayed */
	// Drops the TypeProperty table.
	DropTypePropertyTable *MetadataSourceQueryConfig_TemplateQuery `` /* 128-byte string literal not displayed */
	// Creates the TypeProperty table.
	CreateTypePropertyTable *MetadataSourceQueryConfig_TemplateQuery `` /* 134-byte string literal not displayed */
	// Checks the existence of the TypeProperty table.
	CheckTypePropertyTable *MetadataSourceQueryConfig_TemplateQuery `` /* 132-byte string literal not displayed */
	// Inserts a property of a type into the TypeProperty table. It has 3
	// parameters.
	// $0 is the type_id
	// $1 is the name of the property
	// $2 is the data_type of the property
	InsertTypeProperty *MetadataSourceQueryConfig_TemplateQuery `protobuf:"bytes,9,opt,name=insert_type_property,json=insertTypeProperty,proto3" json:"insert_type_property,omitempty"`
	// Queries properties of a type from the TypeProperty table by the type_id
	// Returns a list of properties (name, data_type). It has 1 parameter.
	// $0 is the type_id
	SelectPropertyByTypeId *MetadataSourceQueryConfig_TemplateQuery `` /* 134-byte string literal not displayed */
	// Queries the last inserted id.
	SelectLastInsertId *MetadataSourceQueryConfig_TemplateQuery `protobuf:"bytes,11,opt,name=select_last_insert_id,json=selectLastInsertId,proto3" json:"select_last_insert_id,omitempty"`
	// Drops the Artifact table.
	DropArtifactTable *MetadataSourceQueryConfig_TemplateQuery `protobuf:"bytes,12,opt,name=drop_artifact_table,json=dropArtifactTable,proto3" json:"drop_artifact_table,omitempty"`
	// Creates the Artifact table.
	CreateArtifactTable *MetadataSourceQueryConfig_TemplateQuery `protobuf:"bytes,13,opt,name=create_artifact_table,json=createArtifactTable,proto3" json:"create_artifact_table,omitempty"`
	// Checks the existence of the Artifact table.
	CheckArtifactTable *MetadataSourceQueryConfig_TemplateQuery `protobuf:"bytes,46,opt,name=check_artifact_table,json=checkArtifactTable,proto3" json:"check_artifact_table,omitempty"`
	// Inserts an artifact into the Artifact table. It has 5 parameters.
	// $0 is the type_id
	// $1 is the uri of the Artifact
	// $2 is the name of the Artifact
	// $3 is the create_time_since_epoch of the Artifact
	// $4 is the last_update_time_since_epoch of the Artifact
	InsertArtifact *MetadataSourceQueryConfig_TemplateQuery `protobuf:"bytes,14,opt,name=insert_artifact,json=insertArtifact,proto3" json:"insert_artifact,omitempty"`
	// Queries an artifact from the Artifact table by its id. It has 1 parameter.
	// $0 is the artifact_id
	SelectArtifactById *MetadataSourceQueryConfig_TemplateQuery `protobuf:"bytes,15,opt,name=select_artifact_by_id,json=selectArtifactById,proto3" json:"select_artifact_by_id,omitempty"`
	// Queries an artifact from the Artifact table by its name and type id.
	// It has 2 parameter.
	// $0 is the type_id
	// $1 is the name of the Artifact
	SelectArtifactByTypeIdAndName *MetadataSourceQueryConfig_TemplateQuery `` /* 159-byte string literal not displayed */
	// Queries an artifact from the Artifact table by its type_id. It has 1
	// parameter.
	// $0 is the artifact_type_id
	SelectArtifactsByTypeId *MetadataSourceQueryConfig_TemplateQuery `` /* 137-byte string literal not displayed */
	// Queries an artifact from the Artifact table by its uri. It has 1 parameter.
	// $0 is the uri
	SelectArtifactsByUri *MetadataSourceQueryConfig_TemplateQuery `` /* 126-byte string literal not displayed */
	// Updates an artifact in the Artifact table. It has 4 parameters.
	// $0 is the existing artifact id
	// $1 is the type_id
	// $2 is the uri of the Artifact
	// $3 is the last_update_time_since_epoch of the Artifact
	UpdateArtifact *MetadataSourceQueryConfig_TemplateQuery `protobuf:"bytes,21,opt,name=update_artifact,json=updateArtifact,proto3" json:"update_artifact,omitempty"`
	// Drops the ArtifactProperty table.
	DropArtifactPropertyTable *MetadataSourceQueryConfig_TemplateQuery `` /* 141-byte string literal not displayed */
	// Creates the ArtifactProperty table.
	CreateArtifactPropertyTable *MetadataSourceQueryConfig_TemplateQuery `` /* 147-byte string literal not displayed */
	// Checks the existence of the ArtifactProperty table.
	CheckArtifactPropertyTable *MetadataSourceQueryConfig_TemplateQuery `` /* 144-byte string literal not displayed */
	// Insert a property of an artifact from the ArtifactProperty table. It has 5
	// parameters.
	// $0 is the property data type
	// $1 is the artifact_id
	// $2 is the name of the artifact property
	// $3 is the flag to indicate whether it is a custom property
	// $4 is the value of the property
	InsertArtifactProperty *MetadataSourceQueryConfig_TemplateQuery `` /* 130-byte string literal not displayed */
	// Queries properties of an artifact from the ArtifactProperty table by the
	// artifact id. It has 1 parameter.
	// $0 is the artifact_id
	SelectArtifactPropertyByArtifactId *MetadataSourceQueryConfig_TemplateQuery `` /* 172-byte string literal not displayed */
	// Updates a property of an artifact in the ArtifactProperty table. It has 4
	// parameters.
	// $0 is the property data type
	// $1 is the value of the property
	// $2 is the artifact_id
	// $3 is the name of the artifact property
	UpdateArtifactProperty *MetadataSourceQueryConfig_TemplateQuery `` /* 130-byte string literal not displayed */
	// Deletes a property of an artifact. It has 2 parameters.
	// $0 is the artifact_id
	// $1 is the name of the artifact property
	DeleteArtifactProperty *MetadataSourceQueryConfig_TemplateQuery `` /* 130-byte string literal not displayed */
	// Drops the Execution table.
	DropExecutionTable *MetadataSourceQueryConfig_TemplateQuery `protobuf:"bytes,24,opt,name=drop_execution_table,json=dropExecutionTable,proto3" json:"drop_execution_table,omitempty"`
	// Creates the Execution table.
	CreateExecutionTable *MetadataSourceQueryConfig_TemplateQuery `protobuf:"bytes,25,opt,name=create_execution_table,json=createExecutionTable,proto3" json:"create_execution_table,omitempty"`
	// Checks the existence of the Execution table.
	CheckExecutionTable *MetadataSourceQueryConfig_TemplateQuery `protobuf:"bytes,48,opt,name=check_execution_table,json=checkExecutionTable,proto3" json:"check_execution_table,omitempty"`
	// Inserts an execution into the Execution table. It has 4 parameter.
	// $0 is the type_id
	// $1 is the name of the execution
	// $2 is the create_time_since_epoch of the execution
	// $3 is the last_update_time_since_epoch of the execution
	InsertExecution *MetadataSourceQueryConfig_TemplateQuery `protobuf:"bytes,28,opt,name=insert_execution,json=insertExecution,proto3" json:"insert_execution,omitempty"`
	// Queries an execution from the Execution table by its id. It has 1
	// parameter.
	// $0 is the execution_id
	SelectExecutionById *MetadataSourceQueryConfig_TemplateQuery `protobuf:"bytes,29,opt,name=select_execution_by_id,json=selectExecutionById,proto3" json:"select_execution_by_id,omitempty"`
	// Queries an execution from the Execution table by its name and type id.
	// It has 2 parameters.
	// $0 is the type_id
	// $1 is the name
	SelectExecutionByTypeIdAndName *MetadataSourceQueryConfig_TemplateQuery `` /* 162-byte string literal not displayed */
	// Queries an execution from the Execution table by its type_id. It has 1
	// parameter.
	// $0 is the execution_type_id
	SelectExecutionsByTypeId *MetadataSourceQueryConfig_TemplateQuery `` /* 140-byte string literal not displayed */
	// Updates an execution in the Execution table. It has 3 parameters.
	// $0 is the existing execution id
	// $1 is the type_id
	// $2 is the last_update_time_since_epoch of the execution
	UpdateExecution *MetadataSourceQueryConfig_TemplateQuery `protobuf:"bytes,34,opt,name=update_execution,json=updateExecution,proto3" json:"update_execution,omitempty"`
	// Drops the ExecutionProperty table.
	DropExecutionPropertyTable *MetadataSourceQueryConfig_TemplateQuery `` /* 144-byte string literal not displayed */
	// Creates the ExecutionProperty table.
	CreateExecutionPropertyTable *MetadataSourceQueryConfig_TemplateQuery `` /* 150-byte string literal not displayed */
	// Checks the existence of the ExecutionProperty table.
	CheckExecutionPropertyTable *MetadataSourceQueryConfig_TemplateQuery `` /* 147-byte string literal not displayed */
	// Insert a property of an execution from the ExecutionProperty table. It has
	// 5 parameters.
	// $0 is the property data type
	// $1 is the execution_id
	// $2 is the name of the execution property
	// $3 is the flag to indicate whether it is a custom property
	// $4 is the value of the property
	InsertExecutionProperty *MetadataSourceQueryConfig_TemplateQuery `` /* 133-byte string literal not displayed */
	// Queries properties of an execution from the ExecutionProperty table by the
	// execution id. It has 1 parameter.
	// $0 is the execution_id
	SelectExecutionPropertyByExecutionId *MetadataSourceQueryConfig_TemplateQuery `` /* 178-byte string literal not displayed */
	// Updates a property of an execution in the ExecutionProperty table. It has 4
	// parameters.
	// $0 is the property data type
	// $1 is the value of the property
	// $2 is the execution_id
	// $3 is the name of the execution property
	UpdateExecutionProperty *MetadataSourceQueryConfig_TemplateQuery `` /* 133-byte string literal not displayed */
	// Deletes a property of an execution. It has 2 parameters.
	// $0 is the execution_id
	// $1 is the name of the execution property
	DeleteExecutionProperty *MetadataSourceQueryConfig_TemplateQuery `` /* 133-byte string literal not displayed */
	// Drops the Context table.
	DropContextTable *MetadataSourceQueryConfig_TemplateQuery `protobuf:"bytes,67,opt,name=drop_context_table,json=dropContextTable,proto3" json:"drop_context_table,omitempty"`
	// Creates the Context table.
	CreateContextTable *MetadataSourceQueryConfig_TemplateQuery `protobuf:"bytes,68,opt,name=create_context_table,json=createContextTable,proto3" json:"create_context_table,omitempty"`
	// Checks the existence of the Context table.
	CheckContextTable *MetadataSourceQueryConfig_TemplateQuery `protobuf:"bytes,69,opt,name=check_context_table,json=checkContextTable,proto3" json:"check_context_table,omitempty"`
	// Inserts a context into the Context table. It has 4 parameters.
	// $0 is the type_id
	// $1 is the name of the Context
	// $2 is the create_time_since_epoch of the Context
	// $3 is the last_update_time_since_epoch of the Context
	InsertContext *MetadataSourceQueryConfig_TemplateQuery `protobuf:"bytes,70,opt,name=insert_context,json=insertContext,proto3" json:"insert_context,omitempty"`
	// Queries a context from the Context table by its id. It has 1 parameter.
	// $0 is the context_id
	SelectContextById *MetadataSourceQueryConfig_TemplateQuery `protobuf:"bytes,71,opt,name=select_context_by_id,json=selectContextById,proto3" json:"select_context_by_id,omitempty"`
	// Queries a context from the Context table by its type_id. It has 1
	// parameter.
	// $0 is the context_type_id
	SelectContextsByTypeId *MetadataSourceQueryConfig_TemplateQuery `` /* 134-byte string literal not displayed */
	// Queries a context from the Context table by its type_id and name. It has 2
	// parameters.
	// $0 is the context_type_id
	// $1 is the context_name
	SelectContextByTypeIdAndName *MetadataSourceQueryConfig_TemplateQuery `` /* 156-byte string literal not displayed */
	// Updates a context in the Context table. It has 4 parameters.
	// $0 is the existing context id
	// $1 is the type_id
	// $2 is the name of the Context
	// $3 is the last_update_time_since_epoch of the Context
	UpdateContext *MetadataSourceQueryConfig_TemplateQuery `protobuf:"bytes,73,opt,name=update_context,json=updateContext,proto3" json:"update_context,omitempty"`
	// Drops the ContextProperty table.
	DropContextPropertyTable *MetadataSourceQueryConfig_TemplateQuery `` /* 138-byte string literal not displayed */
	// Creates the ContextProperty table.
	CreateContextPropertyTable *MetadataSourceQueryConfig_TemplateQuery `` /* 144-byte string literal not displayed */
	// Checks the existence of the ContextProperty table.
	CheckContextPropertyTable *MetadataSourceQueryConfig_TemplateQuery `` /* 141-byte string literal not displayed */
	// Insert a property of a context from the ContextProperty table. It has 5
	// parameters.
	// $0 is the property data type
	// $1 is the context_id
	// $2 is the name of the context property
	// $3 is the flag to indicate whether it is a custom property
	// $4 is the value of the property
	InsertContextProperty *MetadataSourceQueryConfig_TemplateQuery `` /* 127-byte string literal not displayed */
	// Queries properties of a context from the ContextProperty table by the
	// context id. It has 1 parameter.
	// $0 is the context_id
	SelectContextPropertyByContextId *MetadataSourceQueryConfig_TemplateQuery `` /* 166-byte string literal not displayed */
	// Updates a property of a context in the ContextProperty table. It has 4
	// parameters.
	// $0 is the property data type
	// $1 is the value of the property
	// $2 is the context_id
	// $3 is the name of the context property
	UpdateContextProperty *MetadataSourceQueryConfig_TemplateQuery `` /* 127-byte string literal not displayed */
	// Deletes a property of a context. It has 2 parameters.
	// $0 is the context_id
	// $1 is the name of the context property
	DeleteContextProperty *MetadataSourceQueryConfig_TemplateQuery `` /* 127-byte string literal not displayed */
	// Drops the ParentContext table.
	DropParentContextTable *MetadataSourceQueryConfig_TemplateQuery `` /* 133-byte string literal not displayed */
	// Creates the ParentContext table.
	CreateParentContextTable *MetadataSourceQueryConfig_TemplateQuery `` /* 139-byte string literal not displayed */
	// Checks the existence of the ParentContext table.
	CheckParentContextTable *MetadataSourceQueryConfig_TemplateQuery `` /* 136-byte string literal not displayed */
	// Inserts a parent context into the ParentContext table. It has 2 parameters:
	// $0 is the context_id
	// $1 is the parent_context_id
	InsertParentContext *MetadataSourceQueryConfig_TemplateQuery `protobuf:"bytes,106,opt,name=insert_parent_context,json=insertParentContext,proto3" json:"insert_parent_context,omitempty"`
	// Queries parent contexts from the ParentContext table by context_id.
	// It has 1 parameter.
	// $0 is the context_id
	SelectParentContextByContextId *MetadataSourceQueryConfig_TemplateQuery `` /* 161-byte string literal not displayed */
	// Queries parent contexts from the ParentContext table by parent_context_id.
	// It has 1 parameter.
	// $0 is the parent_context_id
	SelectParentContextByParentContextId *MetadataSourceQueryConfig_TemplateQuery `` /* 181-byte string literal not displayed */
	// Drops the Event table.
	DropEventTable *MetadataSourceQueryConfig_TemplateQuery `protobuf:"bytes,35,opt,name=drop_event_table,json=dropEventTable,proto3" json:"drop_event_table,omitempty"`
	// Creates the Event table.
	CreateEventTable *MetadataSourceQueryConfig_TemplateQuery `protobuf:"bytes,36,opt,name=create_event_table,json=createEventTable,proto3" json:"create_event_table,omitempty"`
	// Checks the existence of the Event table.
	CheckEventTable *MetadataSourceQueryConfig_TemplateQuery `protobuf:"bytes,50,opt,name=check_event_table,json=checkEventTable,proto3" json:"check_event_table,omitempty"`
	// Inserts an event into the Event table. It has 4 parameters.
	// $0 is the artifact_id
	// $1 is the execution_id
	// $2 is the event type
	// $3 is the event time
	InsertEvent *MetadataSourceQueryConfig_TemplateQuery `protobuf:"bytes,37,opt,name=insert_event,json=insertEvent,proto3" json:"insert_event,omitempty"`
	// Queries events from the Event table by a collection of artifact ids. It has
	// 1 parameter.
	// $0 is the collection string of artifact ids joined by ", ".
	SelectEventByArtifactIds *MetadataSourceQueryConfig_TemplateQuery `` /* 140-byte string literal not displayed */
	// Queries events from the Event table by a collection of execution ids. It
	// has 1 parameter.
	// $0 is the collection string of execution ids joined by ", ".
	SelectEventByExecutionIds *MetadataSourceQueryConfig_TemplateQuery `` /* 143-byte string literal not displayed */
	// Drops the EventPath table.
	DropEventPathTable *MetadataSourceQueryConfig_TemplateQuery `protobuf:"bytes,40,opt,name=drop_event_path_table,json=dropEventPathTable,proto3" json:"drop_event_path_table,omitempty"`
	// Creates the EventPath table.
	CreateEventPathTable *MetadataSourceQueryConfig_TemplateQuery `` /* 126-byte string literal not displayed */
	// Checks the existence of the EventPath table.
	CheckEventPathTable *MetadataSourceQueryConfig_TemplateQuery `protobuf:"bytes,51,opt,name=check_event_path_table,json=checkEventPathTable,proto3" json:"check_event_path_table,omitempty"`
	// Inserts a path into the EventPath table. It has 4 parameters
	// $0 is the event_id
	// $1 is the step value case, either index or key
	// $2 is the is_index_step indicates the step value case
	// $3 is the value of the step
	InsertEventPath *MetadataSourceQueryConfig_TemplateQuery `protobuf:"bytes,42,opt,name=insert_event_path,json=insertEventPath,proto3" json:"insert_event_path,omitempty"`
	// Queries paths from the EventPath table by a collection of event ids. It has
	// 1 parameter.
	// $0 is the collection string of event ids joined by ", ".
	SelectEventPathByEventIds *MetadataSourceQueryConfig_TemplateQuery `` /* 145-byte string literal not displayed */
	// Drops the Association table.
	DropAssociationTable *MetadataSourceQueryConfig_TemplateQuery `protobuf:"bytes,81,opt,name=drop_association_table,json=dropAssociationTable,proto3" json:"drop_association_table,omitempty"`
	// Creates the Association table.
	CreateAssociationTable *MetadataSourceQueryConfig_TemplateQuery `` /* 130-byte string literal not displayed */
	// Checks the existence of the Association table.
	CheckAssociationTable *MetadataSourceQueryConfig_TemplateQuery `` /* 127-byte string literal not displayed */
	// Inserts an association into the Association table. It has 2 parameters.
	// $0 is the context_id
	// $1 is the execution_id
	InsertAssociation *MetadataSourceQueryConfig_TemplateQuery `protobuf:"bytes,84,opt,name=insert_association,json=insertAssociation,proto3" json:"insert_association,omitempty"`
	// Queries association from the Association table by its context id.
	// It has 1 parameter.
	// $0 is the context_id
	SelectAssociationByContextId *MetadataSourceQueryConfig_TemplateQuery `` /* 152-byte string literal not displayed */
	// Queries association from the Association table by its execution id.
	// It has 1 parameter.
	// $0 is the execution_id
	SelectAssociationByExecutionId *MetadataSourceQueryConfig_TemplateQuery `` /* 158-byte string literal not displayed */
	// Drops the Attribution table.
	DropAttributionTable *MetadataSourceQueryConfig_TemplateQuery `protobuf:"bytes,87,opt,name=drop_attribution_table,json=dropAttributionTable,proto3" json:"drop_attribution_table,omitempty"`
	// Creates the Attribution table.
	CreateAttributionTable *MetadataSourceQueryConfig_TemplateQuery `` /* 130-byte string literal not displayed */
	// Checks the existence of the Attribution table.
	CheckAttributionTable *MetadataSourceQueryConfig_TemplateQuery `` /* 127-byte string literal not displayed */
	// Inserts an attribution into the Attribution table. It has 2 parameters.
	// $0 is the context_id
	// $1 is the artifact_id
	InsertAttribution *MetadataSourceQueryConfig_TemplateQuery `protobuf:"bytes,90,opt,name=insert_attribution,json=insertAttribution,proto3" json:"insert_attribution,omitempty"`
	// Queries attribution from the Attribution table by its context id.
	// It has 1 parameter.
	// $0 is the context_id
	SelectAttributionByContextId *MetadataSourceQueryConfig_TemplateQuery `` /* 152-byte string literal not displayed */
	// Queries attribution from the Attribution table by its artifact id.
	// It has 1 parameter.
	// $0 is the artifact_id
	SelectAttributionByArtifactId *MetadataSourceQueryConfig_TemplateQuery `` /* 155-byte string literal not displayed */
	// Drops the MLMDEnv table.
	DropMlmdEnvTable *MetadataSourceQueryConfig_TemplateQuery `protobuf:"bytes,60,opt,name=drop_mlmd_env_table,json=dropMlmdEnvTable,proto3" json:"drop_mlmd_env_table,omitempty"`
	// Creates the MLMDEnv table.
	CreateMlmdEnvTable *MetadataSourceQueryConfig_TemplateQuery `protobuf:"bytes,61,opt,name=create_mlmd_env_table,json=createMlmdEnvTable,proto3" json:"create_mlmd_env_table,omitempty"`
	// The version of the current query config. Increase the version by 1 in any
	// CL that includes physical schema changes and provides a migration function
	// that uses a list migration queries. The database stores it to indicate the
	// current database version. When metadata source creates, it compares the
	// given `schema_version` in query config with the `schema_version` stored in
	// the database, and migrate the database if needed.
	SchemaVersion int64 `protobuf:"varint,59,opt,name=schema_version,json=schemaVersion,proto3" json:"schema_version,omitempty"`
	// Checks the MLMDEnv table and query the schema version.
	// At MLMD release v0.13.2, by default it is v0.
	CheckMlmdEnvTable *MetadataSourceQueryConfig_TemplateQuery `protobuf:"bytes,63,opt,name=check_mlmd_env_table,json=checkMlmdEnvTable,proto3" json:"check_mlmd_env_table,omitempty"`
	// Insert schema_version.
	// $0 is the schema_version
	InsertSchemaVersion *MetadataSourceQueryConfig_TemplateQuery `protobuf:"bytes,66,opt,name=insert_schema_version,json=insertSchemaVersion,proto3" json:"insert_schema_version,omitempty"`
	// Update schema_version
	// $0 is the schema_version
	UpdateSchemaVersion *MetadataSourceQueryConfig_TemplateQuery `protobuf:"bytes,64,opt,name=update_schema_version,json=updateSchemaVersion,proto3" json:"update_schema_version,omitempty"`
	// Check the database is a valid database produced by 0.13.2 MLMD release.
	// The schema version and migration are introduced after that release.
	CheckTablesInV0_13_2 *MetadataSourceQueryConfig_TemplateQuery `protobuf:"bytes,65,opt,name=check_tables_in_v0_13_2,json=checkTablesInV0132,proto3" json:"check_tables_in_v0_13_2,omitempty"`
	// A list of secondary indices to be applied on the current schema. This is
	// intended for indices that cover multiple columns or which cannot be
	// created as part of table DDL statements.
	SecondaryIndices []*MetadataSourceQueryConfig_TemplateQuery `protobuf:"bytes,105,rep,name=secondary_indices,json=secondaryIndices,proto3" json:"secondary_indices,omitempty"`
	// Each metadata source should provides migration schemes, each of which
	// defines the schema change details for a particular `schema_version` (sv_i).
	// When a migration procedure wants to upgrade to sv_i, it looks for the
	// MigrationScheme with sv_i as map key.
	MigrationSchemes map[int64]*MetadataSourceQueryConfig_MigrationScheme `` /* 199-byte string literal not displayed */
	// contains filtered or unexported fields
}

A config includes a set of SQL queries and the type of metadata source. It is used by MetadataAccessObject to init backend and issue queries. Next ID: 112

func (*MetadataSourceQueryConfig) Descriptor deprecated 

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

Deprecated: Use MetadataSourceQueryConfig.ProtoReflect.Descriptor instead.

func (*MetadataSourceQueryConfig) GetCheckArtifactPropertyTable 

func (x *MetadataSourceQueryConfig) GetCheckArtifactPropertyTable() *MetadataSourceQueryConfig_TemplateQuery

func (*MetadataSourceQueryConfig) GetCheckArtifactTable 

func (x *MetadataSourceQueryConfig) GetCheckArtifactTable() *MetadataSourceQueryConfig_TemplateQuery

func (*MetadataSourceQueryConfig) GetCheckAssociationTable 

func (x *MetadataSourceQueryConfig) GetCheckAssociationTable() *MetadataSourceQueryConfig_TemplateQuery

func (*MetadataSourceQueryConfig) GetCheckAttributionTable 

func (x *MetadataSourceQueryConfig) GetCheckAttributionTable() *MetadataSourceQueryConfig_TemplateQuery

func (*MetadataSourceQueryConfig) GetCheckContextPropertyTable 

func (x *MetadataSourceQueryConfig) GetCheckContextPropertyTable() *MetadataSourceQueryConfig_TemplateQuery

func (*MetadataSourceQueryConfig) GetCheckContextTable 

func (x *MetadataSourceQueryConfig) GetCheckContextTable() *MetadataSourceQueryConfig_TemplateQuery

func (*MetadataSourceQueryConfig) GetCheckEventPathTable 

func (x *MetadataSourceQueryConfig) GetCheckEventPathTable() *MetadataSourceQueryConfig_TemplateQuery

func (*MetadataSourceQueryConfig) GetCheckEventTable 

func (x *MetadataSourceQueryConfig) GetCheckEventTable() *MetadataSourceQueryConfig_TemplateQuery

func (*MetadataSourceQueryConfig) GetCheckExecutionPropertyTable 

func (x *MetadataSourceQueryConfig) GetCheckExecutionPropertyTable() *MetadataSourceQueryConfig_TemplateQuery

func (*MetadataSourceQueryConfig) GetCheckExecutionTable 

func (x *MetadataSourceQueryConfig) GetCheckExecutionTable() *MetadataSourceQueryConfig_TemplateQuery

func (*MetadataSourceQueryConfig) GetCheckMlmdEnvTable 

func (x *MetadataSourceQueryConfig) GetCheckMlmdEnvTable() *MetadataSourceQueryConfig_TemplateQuery

func (*MetadataSourceQueryConfig) GetCheckParentContextTable 

func (x *MetadataSourceQueryConfig) GetCheckParentContextTable() *MetadataSourceQueryConfig_TemplateQuery

func (*MetadataSourceQueryConfig) GetCheckParentTypeTable 

func (x *MetadataSourceQueryConfig) GetCheckParentTypeTable() *MetadataSourceQueryConfig_TemplateQuery

func (*MetadataSourceQueryConfig) GetCheckTablesInV0_13_2 

func (x *MetadataSourceQueryConfig) GetCheckTablesInV0_13_2() *MetadataSourceQueryConfig_TemplateQuery

func (*MetadataSourceQueryConfig) GetCheckTypePropertyTable 

func (x *MetadataSourceQueryConfig) GetCheckTypePropertyTable() *MetadataSourceQueryConfig_TemplateQuery

func (*MetadataSourceQueryConfig) GetCheckTypeTable 

func (x *MetadataSourceQueryConfig) GetCheckTypeTable() *MetadataSourceQueryConfig_TemplateQuery

func (*MetadataSourceQueryConfig) GetCreateArtifactPropertyTable 

func (x *MetadataSourceQueryConfig) GetCreateArtifactPropertyTable() *MetadataSourceQueryConfig_TemplateQuery

func (*MetadataSourceQueryConfig) GetCreateArtifactTable 

func (x *MetadataSourceQueryConfig) GetCreateArtifactTable() *MetadataSourceQueryConfig_TemplateQuery

func (*MetadataSourceQueryConfig) GetCreateAssociationTable 

func (x *MetadataSourceQueryConfig) GetCreateAssociationTable() *MetadataSourceQueryConfig_TemplateQuery

func (*MetadataSourceQueryConfig) GetCreateAttributionTable 

func (x *MetadataSourceQueryConfig) GetCreateAttributionTable() *MetadataSourceQueryConfig_TemplateQuery

func (*MetadataSourceQueryConfig) GetCreateContextPropertyTable 

func (x *MetadataSourceQueryConfig) GetCreateContextPropertyTable() *MetadataSourceQueryConfig_TemplateQuery

func (*MetadataSourceQueryConfig) GetCreateContextTable 

func (x *MetadataSourceQueryConfig) GetCreateContextTable() *MetadataSourceQueryConfig_TemplateQuery

func (*MetadataSourceQueryConfig) GetCreateEventPathTable 

func (x *MetadataSourceQueryConfig) GetCreateEventPathTable() *MetadataSourceQueryConfig_TemplateQuery

func (*MetadataSourceQueryConfig) GetCreateEventTable 

func (x *MetadataSourceQueryConfig) GetCreateEventTable() *MetadataSourceQueryConfig_TemplateQuery

func (*MetadataSourceQueryConfig) GetCreateExecutionPropertyTable 

func (x *MetadataSourceQueryConfig) GetCreateExecutionPropertyTable() *MetadataSourceQueryConfig_TemplateQuery

func (*MetadataSourceQueryConfig) GetCreateExecutionTable 

func (x *MetadataSourceQueryConfig) GetCreateExecutionTable() *MetadataSourceQueryConfig_TemplateQuery

func (*MetadataSourceQueryConfig) GetCreateMlmdEnvTable 

func (x *MetadataSourceQueryConfig) GetCreateMlmdEnvTable() *MetadataSourceQueryConfig_TemplateQuery

func (*MetadataSourceQueryConfig) GetCreateParentContextTable 

func (x *MetadataSourceQueryConfig) GetCreateParentContextTable() *MetadataSourceQueryConfig_TemplateQuery

func (*MetadataSourceQueryConfig) GetCreateParentTypeTable 

func (x *MetadataSourceQueryConfig) GetCreateParentTypeTable() *MetadataSourceQueryConfig_TemplateQuery

func (*MetadataSourceQueryConfig) GetCreateTypePropertyTable 

func (x *MetadataSourceQueryConfig) GetCreateTypePropertyTable() *MetadataSourceQueryConfig_TemplateQuery

func (*MetadataSourceQueryConfig) GetCreateTypeTable 

func (x *MetadataSourceQueryConfig) GetCreateTypeTable() *MetadataSourceQueryConfig_TemplateQuery

func (*MetadataSourceQueryConfig) GetDeleteArtifactProperty 

func (x *MetadataSourceQueryConfig) GetDeleteArtifactProperty() *MetadataSourceQueryConfig_TemplateQuery

func (*MetadataSourceQueryConfig) GetDeleteContextProperty 

func (x *MetadataSourceQueryConfig) GetDeleteContextProperty() *MetadataSourceQueryConfig_TemplateQuery

func (*MetadataSourceQueryConfig) GetDeleteExecutionProperty 

func (x *MetadataSourceQueryConfig) GetDeleteExecutionProperty() *MetadataSourceQueryConfig_TemplateQuery

func (*MetadataSourceQueryConfig) GetDropArtifactPropertyTable 

func (x *MetadataSourceQueryConfig) GetDropArtifactPropertyTable() *MetadataSourceQueryConfig_TemplateQuery

func (*MetadataSourceQueryConfig) GetDropArtifactTable 

func (x *MetadataSourceQueryConfig) GetDropArtifactTable() *MetadataSourceQueryConfig_TemplateQuery

func (*MetadataSourceQueryConfig) GetDropAssociationTable 

func (x *MetadataSourceQueryConfig) GetDropAssociationTable() *MetadataSourceQueryConfig_TemplateQuery

func (*MetadataSourceQueryConfig) GetDropAttributionTable 

func (x *MetadataSourceQueryConfig) GetDropAttributionTable() *MetadataSourceQueryConfig_TemplateQuery

func (*MetadataSourceQueryConfig) GetDropContextPropertyTable 

func (x *MetadataSourceQueryConfig) GetDropContextPropertyTable() *MetadataSourceQueryConfig_TemplateQuery

func (*MetadataSourceQueryConfig) GetDropContextTable 

func (x *MetadataSourceQueryConfig) GetDropContextTable() *MetadataSourceQueryConfig_TemplateQuery

func (*MetadataSourceQueryConfig) GetDropEventPathTable 

func (x *MetadataSourceQueryConfig) GetDropEventPathTable() *MetadataSourceQueryConfig_TemplateQuery

func (*MetadataSourceQueryConfig) GetDropEventTable 

func (x *MetadataSourceQueryConfig) GetDropEventTable() *MetadataSourceQueryConfig_TemplateQuery

func (*MetadataSourceQueryConfig) GetDropExecutionPropertyTable 

func (x *MetadataSourceQueryConfig) GetDropExecutionPropertyTable() *MetadataSourceQueryConfig_TemplateQuery

func (*MetadataSourceQueryConfig) GetDropExecutionTable 

func (x *MetadataSourceQueryConfig) GetDropExecutionTable() *MetadataSourceQueryConfig_TemplateQuery

func (*MetadataSourceQueryConfig) GetDropMlmdEnvTable 

func (x *MetadataSourceQueryConfig) GetDropMlmdEnvTable() *MetadataSourceQueryConfig_TemplateQuery

func (*MetadataSourceQueryConfig) GetDropParentContextTable 

func (x *MetadataSourceQueryConfig) GetDropParentContextTable() *MetadataSourceQueryConfig_TemplateQuery

func (*MetadataSourceQueryConfig) GetDropParentTypeTable 

func (x *MetadataSourceQueryConfig) GetDropParentTypeTable() *MetadataSourceQueryConfig_TemplateQuery

func (*MetadataSourceQueryConfig) GetDropTypePropertyTable 

func (x *MetadataSourceQueryConfig) GetDropTypePropertyTable() *MetadataSourceQueryConfig_TemplateQuery

func (*MetadataSourceQueryConfig) GetDropTypeTable 

func (x *MetadataSourceQueryConfig) GetDropTypeTable() *MetadataSourceQueryConfig_TemplateQuery

func (*MetadataSourceQueryConfig) GetInsertArtifact 

func (x *MetadataSourceQueryConfig) GetInsertArtifact() *MetadataSourceQueryConfig_TemplateQuery

func (*MetadataSourceQueryConfig) GetInsertArtifactProperty 

func (x *MetadataSourceQueryConfig) GetInsertArtifactProperty() *MetadataSourceQueryConfig_TemplateQuery

func (*MetadataSourceQueryConfig) GetInsertArtifactType 

func (x *MetadataSourceQueryConfig) GetInsertArtifactType() *MetadataSourceQueryConfig_TemplateQuery

func (*MetadataSourceQueryConfig) GetInsertAssociation 

func (x *MetadataSourceQueryConfig) GetInsertAssociation() *MetadataSourceQueryConfig_TemplateQuery

func (*MetadataSourceQueryConfig) GetInsertAttribution 

func (x *MetadataSourceQueryConfig) GetInsertAttribution() *MetadataSourceQueryConfig_TemplateQuery

func (*MetadataSourceQueryConfig) GetInsertContext 

func (x *MetadataSourceQueryConfig) GetInsertContext() *MetadataSourceQueryConfig_TemplateQuery

func (*MetadataSourceQueryConfig) GetInsertContextProperty 

func (x *MetadataSourceQueryConfig) GetInsertContextProperty() *MetadataSourceQueryConfig_TemplateQuery

func (*MetadataSourceQueryConfig) GetInsertContextType 

func (x *MetadataSourceQueryConfig) GetInsertContextType() *MetadataSourceQueryConfig_TemplateQuery

func (*MetadataSourceQueryConfig) GetInsertEvent 

func (x *MetadataSourceQueryConfig) GetInsertEvent() *MetadataSourceQueryConfig_TemplateQuery

func (*MetadataSourceQueryConfig) GetInsertEventPath 

func (x *MetadataSourceQueryConfig) GetInsertEventPath() *MetadataSourceQueryConfig_TemplateQuery

func (*MetadataSourceQueryConfig) GetInsertExecution 

func (x *MetadataSourceQueryConfig) GetInsertExecution() *MetadataSourceQueryConfig_TemplateQuery

func (*MetadataSourceQueryConfig) GetInsertExecutionProperty 

func (x *MetadataSourceQueryConfig) GetInsertExecutionProperty() *MetadataSourceQueryConfig_TemplateQuery

func (*MetadataSourceQueryConfig) GetInsertExecutionType 

func (x *MetadataSourceQueryConfig) GetInsertExecutionType() *MetadataSourceQueryConfig_TemplateQuery

func (*MetadataSourceQueryConfig) GetInsertParentContext 

func (x *MetadataSourceQueryConfig) GetInsertParentContext() *MetadataSourceQueryConfig_TemplateQuery

func (*MetadataSourceQueryConfig) GetInsertParentType 

func (x *MetadataSourceQueryConfig) GetInsertParentType() *MetadataSourceQueryConfig_TemplateQuery

func (*MetadataSourceQueryConfig) GetInsertSchemaVersion 

func (x *MetadataSourceQueryConfig) GetInsertSchemaVersion() *MetadataSourceQueryConfig_TemplateQuery

func (*MetadataSourceQueryConfig) GetInsertTypeProperty 

func (x *MetadataSourceQueryConfig) GetInsertTypeProperty() *MetadataSourceQueryConfig_TemplateQuery

func (*MetadataSourceQueryConfig) GetMetadataSourceType 

func (x *MetadataSourceQueryConfig) GetMetadataSourceType() MetadataSourceType

func (*MetadataSourceQueryConfig) GetMigrationSchemes 

func (x *MetadataSourceQueryConfig) GetMigrationSchemes() map[int64]*MetadataSourceQueryConfig_MigrationScheme

func (*MetadataSourceQueryConfig) GetSchemaVersion 

func (x *MetadataSourceQueryConfig) GetSchemaVersion() int64

func (*MetadataSourceQueryConfig) GetSecondaryIndices 

func (x *MetadataSourceQueryConfig) GetSecondaryIndices() []*MetadataSourceQueryConfig_TemplateQuery

func (*MetadataSourceQueryConfig) GetSelectAllTypes 

func (x *MetadataSourceQueryConfig) GetSelectAllTypes() *MetadataSourceQueryConfig_TemplateQuery

func (*MetadataSourceQueryConfig) GetSelectArtifactById 

func (x *MetadataSourceQueryConfig) GetSelectArtifactById() *MetadataSourceQueryConfig_TemplateQuery

func (*MetadataSourceQueryConfig) GetSelectArtifactByTypeIdAndName 

func (x *MetadataSourceQueryConfig) GetSelectArtifactByTypeIdAndName() *MetadataSourceQueryConfig_TemplateQuery

func (*MetadataSourceQueryConfig) GetSelectArtifactPropertyByArtifactId 

func (x *MetadataSourceQueryConfig) GetSelectArtifactPropertyByArtifactId() *MetadataSourceQueryConfig_TemplateQuery

func (*MetadataSourceQueryConfig) GetSelectArtifactsByTypeId 

func (x *MetadataSourceQueryConfig) GetSelectArtifactsByTypeId() *MetadataSourceQueryConfig_TemplateQuery

func (*MetadataSourceQueryConfig) GetSelectArtifactsByUri 

func (x *MetadataSourceQueryConfig) GetSelectArtifactsByUri() *MetadataSourceQueryConfig_TemplateQuery

func (*MetadataSourceQueryConfig) GetSelectAssociationByContextId 

func (x *MetadataSourceQueryConfig) GetSelectAssociationByContextId() *MetadataSourceQueryConfig_TemplateQuery

func (*MetadataSourceQueryConfig) GetSelectAssociationByExecutionId 

func (x *MetadataSourceQueryConfig) GetSelectAssociationByExecutionId() *MetadataSourceQueryConfig_TemplateQuery

func (*MetadataSourceQueryConfig) GetSelectAttributionByArtifactId 

func (x *MetadataSourceQueryConfig) GetSelectAttributionByArtifactId() *MetadataSourceQueryConfig_TemplateQuery

func (*MetadataSourceQueryConfig) GetSelectAttributionByContextId 

func (x *MetadataSourceQueryConfig) GetSelectAttributionByContextId() *MetadataSourceQueryConfig_TemplateQuery

func (*MetadataSourceQueryConfig) GetSelectContextById 

func (x *MetadataSourceQueryConfig) GetSelectContextById() *MetadataSourceQueryConfig_TemplateQuery

func (*MetadataSourceQueryConfig) GetSelectContextByTypeIdAndName 

func (x *MetadataSourceQueryConfig) GetSelectContextByTypeIdAndName() *MetadataSourceQueryConfig_TemplateQuery

func (*MetadataSourceQueryConfig) GetSelectContextPropertyByContextId 

func (x *MetadataSourceQueryConfig) GetSelectContextPropertyByContextId() *MetadataSourceQueryConfig_TemplateQuery

func (*MetadataSourceQueryConfig) GetSelectContextsByTypeId 

func (x *MetadataSourceQueryConfig) GetSelectContextsByTypeId() *MetadataSourceQueryConfig_TemplateQuery

func (*MetadataSourceQueryConfig) GetSelectEventByArtifactIds 

func (x *MetadataSourceQueryConfig) GetSelectEventByArtifactIds() *MetadataSourceQueryConfig_TemplateQuery

func (*MetadataSourceQueryConfig) GetSelectEventByExecutionIds 

func (x *MetadataSourceQueryConfig) GetSelectEventByExecutionIds() *MetadataSourceQueryConfig_TemplateQuery

func (*MetadataSourceQueryConfig) GetSelectEventPathByEventIds 

func (x *MetadataSourceQueryConfig) GetSelectEventPathByEventIds() *MetadataSourceQueryConfig_TemplateQuery

func (*MetadataSourceQueryConfig) GetSelectExecutionById 

func (x *MetadataSourceQueryConfig) GetSelectExecutionById() *MetadataSourceQueryConfig_TemplateQuery

func (*MetadataSourceQueryConfig) GetSelectExecutionByTypeIdAndName 

func (x *MetadataSourceQueryConfig) GetSelectExecutionByTypeIdAndName() *MetadataSourceQueryConfig_TemplateQuery

func (*MetadataSourceQueryConfig) GetSelectExecutionPropertyByExecutionId 

func (x *MetadataSourceQueryConfig) GetSelectExecutionPropertyByExecutionId() *MetadataSourceQueryConfig_TemplateQuery

func (*MetadataSourceQueryConfig) GetSelectExecutionsByTypeId 

func (x *MetadataSourceQueryConfig) GetSelectExecutionsByTypeId() *MetadataSourceQueryConfig_TemplateQuery

func (*MetadataSourceQueryConfig) GetSelectLastInsertId 

func (x *MetadataSourceQueryConfig) GetSelectLastInsertId() *MetadataSourceQueryConfig_TemplateQuery

func (*MetadataSourceQueryConfig) GetSelectParentContextByContextId 

func (x *MetadataSourceQueryConfig) GetSelectParentContextByContextId() *MetadataSourceQueryConfig_TemplateQuery

func (*MetadataSourceQueryConfig) GetSelectParentContextByParentContextId 

func (x *MetadataSourceQueryConfig) GetSelectParentContextByParentContextId() *MetadataSourceQueryConfig_TemplateQuery

func (*MetadataSourceQueryConfig) GetSelectParentTypeByTypeId 

func (x *MetadataSourceQueryConfig) GetSelectParentTypeByTypeId() *MetadataSourceQueryConfig_TemplateQuery

func (*MetadataSourceQueryConfig) GetSelectPropertyByTypeId 

func (x *MetadataSourceQueryConfig) GetSelectPropertyByTypeId() *MetadataSourceQueryConfig_TemplateQuery

func (*MetadataSourceQueryConfig) GetSelectTypeById 

func (x *MetadataSourceQueryConfig) GetSelectTypeById() *MetadataSourceQueryConfig_TemplateQuery

func (*MetadataSourceQueryConfig) GetSelectTypeByName 

func (x *MetadataSourceQueryConfig) GetSelectTypeByName() *MetadataSourceQueryConfig_TemplateQuery

func (*MetadataSourceQueryConfig) GetSelectTypeByNameAndVersion 

func (x *MetadataSourceQueryConfig) GetSelectTypeByNameAndVersion() *MetadataSourceQueryConfig_TemplateQuery

func (*MetadataSourceQueryConfig) GetUpdateArtifact 

func (x *MetadataSourceQueryConfig) GetUpdateArtifact() *MetadataSourceQueryConfig_TemplateQuery

func (*MetadataSourceQueryConfig) GetUpdateArtifactProperty 

func (x *MetadataSourceQueryConfig) GetUpdateArtifactProperty() *MetadataSourceQueryConfig_TemplateQuery

func (*MetadataSourceQueryConfig) GetUpdateContext 

func (x *MetadataSourceQueryConfig) GetUpdateContext() *MetadataSourceQueryConfig_TemplateQuery

func (*MetadataSourceQueryConfig) GetUpdateContextProperty 

func (x *MetadataSourceQueryConfig) GetUpdateContextProperty() *MetadataSourceQueryConfig_TemplateQuery

func (*MetadataSourceQueryConfig) GetUpdateExecution 

func (x *MetadataSourceQueryConfig) GetUpdateExecution() *MetadataSourceQueryConfig_TemplateQuery

func (*MetadataSourceQueryConfig) GetUpdateExecutionProperty 

func (x *MetadataSourceQueryConfig) GetUpdateExecutionProperty() *MetadataSourceQueryConfig_TemplateQuery

func (*MetadataSourceQueryConfig) GetUpdateSchemaVersion 

func (x *MetadataSourceQueryConfig) GetUpdateSchemaVersion() *MetadataSourceQueryConfig_TemplateQuery

func (*MetadataSourceQueryConfig) ProtoMessage 

func (*MetadataSourceQueryConfig) ProtoMessage()

func (*MetadataSourceQueryConfig) ProtoReflect 

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

func (*MetadataSourceQueryConfig) Reset 

func (x *MetadataSourceQueryConfig) Reset()

func (*MetadataSourceQueryConfig) String 

func (x *MetadataSourceQueryConfig) String() string

type MetadataSourceQueryConfig_MigrationScheme 

type MetadataSourceQueryConfig_MigrationScheme struct {

	// Sequence of queries to increase the schema version by 1.
	UpgradeQueries []*MetadataSourceQueryConfig_TemplateQuery `protobuf:"bytes,1,rep,name=upgrade_queries,json=upgradeQueries,proto3" json:"upgrade_queries,omitempty"`
	// Sequence of queries to decrease the schema version by 1.
	DowngradeQueries []*MetadataSourceQueryConfig_TemplateQuery `protobuf:"bytes,3,rep,name=downgrade_queries,json=downgradeQueries,proto3" json:"downgrade_queries,omitempty"`
	// Details of verifying the correctness of upgrade_queries.
	UpgradeVerification *MetadataSourceQueryConfig_MigrationScheme_VerificationScheme `protobuf:"bytes,2,opt,name=upgrade_verification,json=upgradeVerification,proto3" json:"upgrade_verification,omitempty"`
	// Details of verifying the correctness of downgrade_queries.
	DowngradeVerification *MetadataSourceQueryConfig_MigrationScheme_VerificationScheme `protobuf:"bytes,4,opt,name=downgrade_verification,json=downgradeVerification,proto3" json:"downgrade_verification,omitempty"`
	// contains filtered or unexported fields
}

A migration scheme that is used by a migration function to transit a database at a schema_version to schema_version + 1. DDL is often metadata source specific, if provided, each metadata source should have its own setting.

func (*MetadataSourceQueryConfig_MigrationScheme) Descriptor deprecated 

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

Deprecated: Use MetadataSourceQueryConfig_MigrationScheme.ProtoReflect.Descriptor instead.

func (*MetadataSourceQueryConfig_MigrationScheme) GetDowngradeQueries 

func (x *MetadataSourceQueryConfig_MigrationScheme) GetDowngradeQueries() []*MetadataSourceQueryConfig_TemplateQuery

func (*MetadataSourceQueryConfig_MigrationScheme) GetDowngradeVerification 

func (x *MetadataSourceQueryConfig_MigrationScheme) GetDowngradeVerification() *MetadataSourceQueryConfig_MigrationScheme_VerificationScheme

func (*MetadataSourceQueryConfig_MigrationScheme) GetUpgradeQueries 

func (x *MetadataSourceQueryConfig_MigrationScheme) GetUpgradeQueries() []*MetadataSourceQueryConfig_TemplateQuery

func (*MetadataSourceQueryConfig_MigrationScheme) GetUpgradeVerification 

func (x *MetadataSourceQueryConfig_MigrationScheme) GetUpgradeVerification() *MetadataSourceQueryConfig_MigrationScheme_VerificationScheme

func (*MetadataSourceQueryConfig_MigrationScheme) ProtoMessage 

func (*MetadataSourceQueryConfig_MigrationScheme) ProtoMessage()

func (*MetadataSourceQueryConfig_MigrationScheme) ProtoReflect 

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

func (*MetadataSourceQueryConfig_MigrationScheme) Reset 

func (x *MetadataSourceQueryConfig_MigrationScheme) Reset()

func (*MetadataSourceQueryConfig_MigrationScheme) String 

func (x *MetadataSourceQueryConfig_MigrationScheme) String() string

type MetadataSourceQueryConfig_MigrationScheme_VerificationScheme 

type MetadataSourceQueryConfig_MigrationScheme_VerificationScheme struct {

	// This optional field defines the additional details of recreating:
	// a) the schema of previous version, as the DDL queries will not be
	//    available in newer library versions.
	// b) and/or the records of related tables which have schema changes.
	// Note the setup queries is used in a sequence along with other migration
	// schemes of previous version in order to test upgrading from all
	// known previous versions to the library version.
	PreviousVersionSetupQueries []*MetadataSourceQueryConfig_TemplateQuery `` /* 146-byte string literal not displayed */
	// This optional field defines the verification queries, each of which
	// returns only True/False in the select to assert the state transition
	// invariant is the same, e.g.,
	// * conditions on number of rows
	// * conditions on data model entities (e.g., type, artifact, property).
	PostMigrationVerificationQueries []*MetadataSourceQueryConfig_TemplateQuery `` /* 161-byte string literal not displayed */
	// contains filtered or unexported fields
}

For test purposes, it defines the setup query and post condition invariants of a migration scheme.

func (*MetadataSourceQueryConfig_MigrationScheme_VerificationScheme) Descriptor deprecated 

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

Deprecated: Use MetadataSourceQueryConfig_MigrationScheme_VerificationScheme.ProtoReflect.Descriptor instead.

func (*MetadataSourceQueryConfig_MigrationScheme_VerificationScheme) GetPostMigrationVerificationQueries 

func (x *MetadataSourceQueryConfig_MigrationScheme_VerificationScheme) GetPostMigrationVerificationQueries() []*MetadataSourceQueryConfig_TemplateQuery

func (*MetadataSourceQueryConfig_MigrationScheme_VerificationScheme) GetPreviousVersionSetupQueries 

func (x *MetadataSourceQueryConfig_MigrationScheme_VerificationScheme) GetPreviousVersionSetupQueries() []*MetadataSourceQueryConfig_TemplateQuery

func (*MetadataSourceQueryConfig_MigrationScheme_VerificationScheme) ProtoMessage 

func (*MetadataSourceQueryConfig_MigrationScheme_VerificationScheme) ProtoMessage()

func (*MetadataSourceQueryConfig_MigrationScheme_VerificationScheme) ProtoReflect 

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

func (*MetadataSourceQueryConfig_MigrationScheme_VerificationScheme) Reset 

func (x *MetadataSourceQueryConfig_MigrationScheme_VerificationScheme) Reset()

func (*MetadataSourceQueryConfig_MigrationScheme_VerificationScheme) String 

func (x *MetadataSourceQueryConfig_MigrationScheme_VerificationScheme) String() string

type MetadataSourceQueryConfig_TemplateQuery 

type MetadataSourceQueryConfig_TemplateQuery struct {
	Query        string `protobuf:"bytes,1,opt,name=query,proto3" json:"query,omitempty"`
	ParameterNum int32  `protobuf:"varint,2,opt,name=parameter_num,json=parameterNum,proto3" json:"parameter_num,omitempty"`
	// contains filtered or unexported fields
}

Template of a SQL query, which can contain parameterized variables using $0, $1, ... $9. For instance: 

query: "select * from foo where bar = $0"
parameter_num: 1

func (*MetadataSourceQueryConfig_TemplateQuery) Descriptor deprecated 

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

Deprecated: Use MetadataSourceQueryConfig_TemplateQuery.ProtoReflect.Descriptor instead.

func (*MetadataSourceQueryConfig_TemplateQuery) GetParameterNum 

func (x *MetadataSourceQueryConfig_TemplateQuery) GetParameterNum() int32

func (*MetadataSourceQueryConfig_TemplateQuery) GetQuery 

func (x *MetadataSourceQueryConfig_TemplateQuery) GetQuery() string

func (*MetadataSourceQueryConfig_TemplateQuery) ProtoMessage 

func (*MetadataSourceQueryConfig_TemplateQuery) ProtoMessage()

func (*MetadataSourceQueryConfig_TemplateQuery) ProtoReflect 

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

func (*MetadataSourceQueryConfig_TemplateQuery) Reset 

func (x *MetadataSourceQueryConfig_TemplateQuery) Reset()

func (*MetadataSourceQueryConfig_TemplateQuery) String 

func (x *MetadataSourceQueryConfig_TemplateQuery) String() string

type MetadataSourceType 

type MetadataSourceType int32

Contains supported metadata sources types in MetadataAccessObject. 

const (
	MetadataSourceType_UNKNOWN_METADATA_SOURCE MetadataSourceType = 0
	// a fake in memory metadata_source for testing
	// DEPRECATED -- use SQLITE_METADATA_SOURCE instead.
	MetadataSourceType_FAKE_METADATA_SOURCE MetadataSourceType = 1
	// a MYSQL metadata source.
	MetadataSourceType_MYSQL_METADATA_SOURCE MetadataSourceType = 2
	// A Sqlite metadata source.
	MetadataSourceType_SQLITE_METADATA_SOURCE MetadataSourceType = 3
)

func (MetadataSourceType) Descriptor 

func (MetadataSourceType) Descriptor() protoreflect.EnumDescriptor

func (MetadataSourceType) Enum 

func (x MetadataSourceType) Enum() *MetadataSourceType

func (MetadataSourceType) EnumDescriptor deprecated 

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

Deprecated: Use MetadataSourceType.Descriptor instead.

func (MetadataSourceType) Number 

func (x MetadataSourceType) Number() protoreflect.EnumNumber

func (MetadataSourceType) String 

func (x MetadataSourceType) String() string

func (MetadataSourceType) Type 

func (MetadataSourceType) Type() protoreflect.EnumType

type MetadataStoreClientConfig 

type MetadataStoreClientConfig struct {

	// The hostname or IP address of the gRPC server. Must be specified.
	Host *string `protobuf:"bytes,1,opt,name=host" json:"host,omitempty"`
	// The TCP Port number that the gRPC server accepts connections on.
	// Must be specified.
	Port *uint32 `protobuf:"varint,2,opt,name=port" json:"port,omitempty"`
	// Configuration for a secure gRPC channel.
	// If not given, insecure connection is used.
	SslConfig *MetadataStoreClientConfig_SSLConfig `protobuf:"bytes,3,opt,name=ssl_config,json=sslConfig" json:"ssl_config,omitempty"`
	// GRPC channel creation arguments.
	ChannelArguments *GrpcChannelArguments `protobuf:"bytes,4,opt,name=channel_arguments,json=channelArguments" json:"channel_arguments,omitempty"`
	// Time duration that a client is willing to wait for a reply from the server.
	// If unset, the timeout is considered infinite. When the field is specified,
	// Grpc APIs would return DeadlineExceededError when server does not respond
	// within `client_timeout_sec`. Floating point valued, in seconds.
	ClientTimeoutSec *float64 `protobuf:"fixed64,5,opt,name=client_timeout_sec,json=clientTimeoutSec" json:"client_timeout_sec,omitempty"`
	// contains filtered or unexported fields
}

Configuration for the gRPC metadata store client.

func (*MetadataStoreClientConfig) Descriptor deprecated 

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

Deprecated: Use MetadataStoreClientConfig.ProtoReflect.Descriptor instead.

func (*MetadataStoreClientConfig) GetChannelArguments 

func (x *MetadataStoreClientConfig) GetChannelArguments() *GrpcChannelArguments

func (*MetadataStoreClientConfig) GetClientTimeoutSec 

func (x *MetadataStoreClientConfig) GetClientTimeoutSec() float64

func (*MetadataStoreClientConfig) GetHost 

func (x *MetadataStoreClientConfig) GetHost() string

func (*MetadataStoreClientConfig) GetPort 

func (x *MetadataStoreClientConfig) GetPort() uint32

func (*MetadataStoreClientConfig) GetSslConfig 

func (x *MetadataStoreClientConfig) GetSslConfig() *MetadataStoreClientConfig_SSLConfig

func (*MetadataStoreClientConfig) ProtoMessage 

func (*MetadataStoreClientConfig) ProtoMessage()

func (*MetadataStoreClientConfig) ProtoReflect 

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

func (*MetadataStoreClientConfig) Reset 

func (x *MetadataStoreClientConfig) Reset()

func (*MetadataStoreClientConfig) String 

func (x *MetadataStoreClientConfig) String() string

type MetadataStoreClientConfig_SSLConfig 

type MetadataStoreClientConfig_SSLConfig struct {

	// The PEM-encoded private key as a byte string, or Empty if no private key
	// should be used.
	ClientKey *string `protobuf:"bytes,1,opt,name=client_key,json=clientKey" json:"client_key,omitempty"`
	// The PEM-encoded certificate chain as a byte string to use or or Empty if
	// no certificate chain should be used.
	ServerCert *string `protobuf:"bytes,2,opt,name=server_cert,json=serverCert" json:"server_cert,omitempty"`
	// The PEM-encoded root certificates as a byte string, or Empty to retrieve
	// them from a default location chosen by gRPC runtime.
	CustomCa *string `protobuf:"bytes,3,opt,name=custom_ca,json=customCa" json:"custom_ca,omitempty"`
	// contains filtered or unexported fields
}

func (*MetadataStoreClientConfig_SSLConfig) Descriptor deprecated 

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

Deprecated: Use MetadataStoreClientConfig_SSLConfig.ProtoReflect.Descriptor instead.

func (*MetadataStoreClientConfig_SSLConfig) GetClientKey 

func (x *MetadataStoreClientConfig_SSLConfig) GetClientKey() string

func (*MetadataStoreClientConfig_SSLConfig) GetCustomCa 

func (x *MetadataStoreClientConfig_SSLConfig) GetCustomCa() string

func (*MetadataStoreClientConfig_SSLConfig) GetServerCert 

func (x *MetadataStoreClientConfig_SSLConfig) GetServerCert() string

func (*MetadataStoreClientConfig_SSLConfig) ProtoMessage 

func (*MetadataStoreClientConfig_SSLConfig) ProtoMessage()

func (*MetadataStoreClientConfig_SSLConfig) ProtoReflect 

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

func (*MetadataStoreClientConfig_SSLConfig) Reset 

func (x *MetadataStoreClientConfig_SSLConfig) Reset()

func (*MetadataStoreClientConfig_SSLConfig) String 

func (x *MetadataStoreClientConfig_SSLConfig) String() string

type MetadataStoreServerConfig 

type MetadataStoreServerConfig struct {

	// Configuration to connect the metadata source backend.
	ConnectionConfig *ConnectionConfig `protobuf:"bytes,1,opt,name=connection_config,json=connectionConfig" json:"connection_config,omitempty"`
	// Configuration for upgrade and downgrade migrations the metadata source.
	MigrationOptions *MigrationOptions `protobuf:"bytes,3,opt,name=migration_options,json=migrationOptions" json:"migration_options,omitempty"`
	// Configuration for a secure gRPC channel.
	// If not given, insecure connection is used.
	SslConfig *MetadataStoreServerConfig_SSLConfig `protobuf:"bytes,2,opt,name=ssl_config,json=sslConfig" json:"ssl_config,omitempty"`
	// contains filtered or unexported fields
}

Configuration for the gRPC metadata store server.

func (*MetadataStoreServerConfig) Descriptor deprecated 

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

Deprecated: Use MetadataStoreServerConfig.ProtoReflect.Descriptor instead.

func (*MetadataStoreServerConfig) GetConnectionConfig 

func (x *MetadataStoreServerConfig) GetConnectionConfig() *ConnectionConfig

func (*MetadataStoreServerConfig) GetMigrationOptions 

func (x *MetadataStoreServerConfig) GetMigrationOptions() *MigrationOptions

func (*MetadataStoreServerConfig) GetSslConfig 

func (x *MetadataStoreServerConfig) GetSslConfig() *MetadataStoreServerConfig_SSLConfig

func (*MetadataStoreServerConfig) ProtoMessage 

func (*MetadataStoreServerConfig) ProtoMessage()

func (*MetadataStoreServerConfig) ProtoReflect 

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

func (*MetadataStoreServerConfig) Reset 

func (x *MetadataStoreServerConfig) Reset()

func (*MetadataStoreServerConfig) String 

func (x *MetadataStoreServerConfig) String() string

type MetadataStoreServerConfig_SSLConfig 

type MetadataStoreServerConfig_SSLConfig struct {

	// Private server key for SSL
	ServerKey *string `protobuf:"bytes,1,opt,name=server_key,json=serverKey" json:"server_key,omitempty"`
	// Public server certificate
	ServerCert *string `protobuf:"bytes,2,opt,name=server_cert,json=serverCert" json:"server_cert,omitempty"`
	// Custom certificate authority
	CustomCa *string `protobuf:"bytes,3,opt,name=custom_ca,json=customCa" json:"custom_ca,omitempty"`
	// Valid client certificate required?
	ClientVerify *bool `protobuf:"varint,4,opt,name=client_verify,json=clientVerify" json:"client_verify,omitempty"`
	// contains filtered or unexported fields
}

func (*MetadataStoreServerConfig_SSLConfig) Descriptor deprecated 

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

Deprecated: Use MetadataStoreServerConfig_SSLConfig.ProtoReflect.Descriptor instead.

func (*MetadataStoreServerConfig_SSLConfig) GetClientVerify 

func (x *MetadataStoreServerConfig_SSLConfig) GetClientVerify() bool

func (*MetadataStoreServerConfig_SSLConfig) GetCustomCa 

func (x *MetadataStoreServerConfig_SSLConfig) GetCustomCa() string

func (*MetadataStoreServerConfig_SSLConfig) GetServerCert 

func (x *MetadataStoreServerConfig_SSLConfig) GetServerCert() string

func (*MetadataStoreServerConfig_SSLConfig) GetServerKey 

func (x *MetadataStoreServerConfig_SSLConfig) GetServerKey() string

func (*MetadataStoreServerConfig_SSLConfig) ProtoMessage 

func (*MetadataStoreServerConfig_SSLConfig) ProtoMessage()

func (*MetadataStoreServerConfig_SSLConfig) ProtoReflect 

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

func (*MetadataStoreServerConfig_SSLConfig) Reset 

func (x *MetadataStoreServerConfig_SSLConfig) Reset()

func (*MetadataStoreServerConfig_SSLConfig) String 

func (x *MetadataStoreServerConfig_SSLConfig) String() string

type MetadataStoreServiceClient 

type MetadataStoreServiceClient interface {
	// Inserts or updates an ArtifactType.
	//
	// A type has a set of strong typed properties describing the schema of any
	// stored instance associated with that type. A type is identified by a name
	// and an optional version.
	//
	// Type Creation:
	// If no type exists in the database with the given identifier
	// (name, version), it creates a new type and returns the type_id.
	//
	// Type Evolution:
	// If the request type with the same (name, version) already exists
	// (let's call it stored_type), the method enforces the stored_type can be
	// updated only when the request type is backward compatible for the already
	// stored instances.
	//
	// Backwards compatibility is violated iff:
	//
	//   a) there is a property where the request type and stored_type have
	//      different value type (e.g., int vs. string)
	//   b) `can_add_fields = false` and the request type has a new property that
	//      is not stored.
	//   c) `can_omit_fields = false` and stored_type has an existing property
	//      that is not provided in the request type.
	//
	// If non-backward type change is required in the application, e.g.,
	// deprecate properties, re-purpose property name, change value types,
	// a new type can be created with a different (name, version) identifier.
	// Note the type version is optional, and a version value with empty string
	// is treated as unset.
	//
	// Args:
	//   artifact_type: the type to be inserted or updated.
	//   can_add_fields:
	//     when set to true, new properties can be added;
	//     when set to false, returns ALREADY_EXISTS if the request type has
	//     properties that are not in stored_type.
	//   can_omit_fields:
	//     when set to true, stored properties can be omitted in the request type;
	//     when set to false, returns ALREADY_EXISTS if the stored_type has
	//     properties not in the request type.
	//
	// Returns:
	//   The type_id of the stored type.
	//
	// Raises:
	//   ALREADY_EXISTS error in the case listed above.
	//   INVALID_ARGUMENT error, if the given type has no name, or any
	//     property value type is unknown.
	PutArtifactType(ctx context.Context, in *PutArtifactTypeRequest, opts ...grpc.CallOption) (*PutArtifactTypeResponse, error)
	// Inserts or updates an ExecutionType. Please refer to PutArtifactType for
	// type upsert API description.
	PutExecutionType(ctx context.Context, in *PutExecutionTypeRequest, opts ...grpc.CallOption) (*PutExecutionTypeResponse, error)
	// Inserts or updates an ContextType. Please refer to PutArtifactType for
	// type upsert API description.
	PutContextType(ctx context.Context, in *PutContextTypeRequest, opts ...grpc.CallOption) (*PutContextTypeResponse, error)
	// Bulk inserts types atomically.
	PutTypes(ctx context.Context, in *PutTypesRequest, opts ...grpc.CallOption) (*PutTypesResponse, error)
	// Inserts or updates artifacts in the database.
	//
	// If an artifact_id is specified for an artifact, it is an update.
	// If an artifact_id is unspecified, it will insert a new artifact.
	// For new artifacts, type must be specified.
	// For old artifacts, type must be unchanged or unspecified.
	//
	// Args:
	//   artifacts: A list of artifacts to insert or update.
	//
	// Returns:
	//   A list of artifact ids index-aligned with the input.
	PutArtifacts(ctx context.Context, in *PutArtifactsRequest, opts ...grpc.CallOption) (*PutArtifactsResponse, error)
	// Inserts or updates executions in the database.
	//
	// If an execution_id is specified for an execution, it is an update.
	// If an execution_id is unspecified, it will insert a new execution.
	// For new executions, type must be specified.
	// For old executions, type must be unchanged or unspecified.
	//
	// Args:
	//   executions: A list of executions to insert or update.
	//
	// Returns:
	//   A list of execution ids index-aligned with the input.
	//
	PutExecutions(ctx context.Context, in *PutExecutionsRequest, opts ...grpc.CallOption) (*PutExecutionsResponse, error)
	// Inserts events in the database.
	//
	// The execution_id and artifact_id must already exist.
	// Once created, events cannot be modified.
	//
	// Args:
	//   events: A list of events to insert or update.
	PutEvents(ctx context.Context, in *PutEventsRequest, opts ...grpc.CallOption) (*PutEventsResponse, error)
	// Inserts or updates an Execution and its input and output artifacts and
	// related contexts atomically. The `artifact_event_pairs` include the state
	// changes of the Artifacts used or generated by the Execution, as well as the
	// input/output Event. The `contexts` describe the associations of the
	// execution and the attributions of the artifacts.
	//
	// If an execution_id, artifact_id or context_id is specified, it is an
	// update, otherwise it does an insertion. For insertion, type must be
	// specified.
	//
	// Args:
	//   execution: An execution to insert or update.
	//   artifact_event_pairs: Artifacts to insert or update and events to insert.
	//   contexts: The contexts that the execution and the artifacts belong to.
	//
	// Returns:
	//   An execution id and a list of artifacts and contexts ids index-aligned
	//   with the input.
	PutExecution(ctx context.Context, in *PutExecutionRequest, opts ...grpc.CallOption) (*PutExecutionResponse, error)
	// Inserts or updates contexts in database and returns a list of context ids.
	//
	// If an context_id is specified for a context, it is an update.
	// If an context_id is unspecified, it will insert a new context.
	// For new contexts, type must be specified.
	// For old contexts, type must be unchanged or unspecified.
	//
	// Args:
	//   contexts: A list of contexts to insert or update.
	//
	// Returns:
	//   A list of context ids index-aligned with the input.
	PutContexts(ctx context.Context, in *PutContextsRequest, opts ...grpc.CallOption) (*PutContextsResponse, error)
	// Inserts attribution and association relationships in the database.
	// The context_id, artifact_id, and execution_id must already exist.
	// If the relationship exists, this call does nothing. Once added, the
	// relationships cannot be modified.
	//
	// Args:
	//   attributions: A list of attributions to insert.
	//   associations: A list of associations to insert.
	PutAttributionsAndAssociations(ctx context.Context, in *PutAttributionsAndAssociationsRequest, opts ...grpc.CallOption) (*PutAttributionsAndAssociationsResponse, error)
	// Inserts parental context relationships in the database.
	// The ParentContext relationship has direction. The call fails if cycles are
	// detected.
	//
	// Args:
	//   parent_contexts: A list of parent contexts to insert.
	PutParentContexts(ctx context.Context, in *PutParentContextsRequest, opts ...grpc.CallOption) (*PutParentContextsResponse, error)
	// Gets an artifact type. Returns a NOT_FOUND error if the type does not
	// exist.
	GetArtifactType(ctx context.Context, in *GetArtifactTypeRequest, opts ...grpc.CallOption) (*GetArtifactTypeResponse, error)
	// Gets a list of artifact types by ID.
	// If no artifact types with an ID exists, the artifact type is skipped.
	GetArtifactTypesByID(ctx context.Context, in *GetArtifactTypesByIDRequest, opts ...grpc.CallOption) (*GetArtifactTypesByIDResponse, error)
	// Gets a list of all artifact types.
	GetArtifactTypes(ctx context.Context, in *GetArtifactTypesRequest, opts ...grpc.CallOption) (*GetArtifactTypesResponse, error)
	// Gets an execution type, or None if it does not exist.
	GetExecutionType(ctx context.Context, in *GetExecutionTypeRequest, opts ...grpc.CallOption) (*GetExecutionTypeResponse, error)
	// Gets a list of execution types by ID.
	// If no execution types with an ID exists, the execution type is skipped.
	GetExecutionTypesByID(ctx context.Context, in *GetExecutionTypesByIDRequest, opts ...grpc.CallOption) (*GetExecutionTypesByIDResponse, error)
	// Gets a list of all execution types.
	GetExecutionTypes(ctx context.Context, in *GetExecutionTypesRequest, opts ...grpc.CallOption) (*GetExecutionTypesResponse, error)
	// Gets a context type. Returns a NOT_FOUND error if the type does not exist.
	GetContextType(ctx context.Context, in *GetContextTypeRequest, opts ...grpc.CallOption) (*GetContextTypeResponse, error)
	// Gets a list of context types by ID.
	// If no context types with an ID exists, the context type is skipped.
	GetContextTypesByID(ctx context.Context, in *GetContextTypesByIDRequest, opts ...grpc.CallOption) (*GetContextTypesByIDResponse, error)
	// Gets a list of all context types.
	GetContextTypes(ctx context.Context, in *GetContextTypesRequest, opts ...grpc.CallOption) (*GetContextTypesResponse, error)
	// Gets all the artifacts.
	GetArtifacts(ctx context.Context, in *GetArtifactsRequest, opts ...grpc.CallOption) (*GetArtifactsResponse, error)
	// Gets all the executions.
	GetExecutions(ctx context.Context, in *GetExecutionsRequest, opts ...grpc.CallOption) (*GetExecutionsResponse, error)
	// Gets all the contexts.
	GetContexts(ctx context.Context, in *GetContextsRequest, opts ...grpc.CallOption) (*GetContextsResponse, error)
	// Gets all artifacts with matching ids.
	//
	// The result is not index-aligned: if an id is not found, it is not returned.
	//
	// Args:
	//   artifact_ids: A list of artifact ids to retrieve.
	//
	// Returns:
	//   Artifacts with matching ids.
	GetArtifactsByID(ctx context.Context, in *GetArtifactsByIDRequest, opts ...grpc.CallOption) (*GetArtifactsByIDResponse, error)
	// Gets all executions with matching ids.
	//
	// The result is not index-aligned: if an id is not found, it is not returned.
	//
	// Args:
	//   execution_ids: A list of execution ids to retrieve.
	GetExecutionsByID(ctx context.Context, in *GetExecutionsByIDRequest, opts ...grpc.CallOption) (*GetExecutionsByIDResponse, error)
	// Gets all contexts with matching ids.
	//
	// The result is not index-aligned: if an id is not found, it is not returned.
	//
	// Args:
	//   context_ids: A list of context ids to retrieve.
	GetContextsByID(ctx context.Context, in *GetContextsByIDRequest, opts ...grpc.CallOption) (*GetContextsByIDResponse, error)
	// Gets all the artifacts of a given type.
	GetArtifactsByType(ctx context.Context, in *GetArtifactsByTypeRequest, opts ...grpc.CallOption) (*GetArtifactsByTypeResponse, error)
	// Gets all the executions of a given type.
	GetExecutionsByType(ctx context.Context, in *GetExecutionsByTypeRequest, opts ...grpc.CallOption) (*GetExecutionsByTypeResponse, error)
	// Gets all the contexts of a given type.
	GetContextsByType(ctx context.Context, in *GetContextsByTypeRequest, opts ...grpc.CallOption) (*GetContextsByTypeResponse, error)
	// Gets the artifact of the given type and artifact name.
	GetArtifactByTypeAndName(ctx context.Context, in *GetArtifactByTypeAndNameRequest, opts ...grpc.CallOption) (*GetArtifactByTypeAndNameResponse, error)
	// Gets the execution of the given type and execution name.
	GetExecutionByTypeAndName(ctx context.Context, in *GetExecutionByTypeAndNameRequest, opts ...grpc.CallOption) (*GetExecutionByTypeAndNameResponse, error)
	// Gets the context of the given type and context name.
	GetContextByTypeAndName(ctx context.Context, in *GetContextByTypeAndNameRequest, opts ...grpc.CallOption) (*GetContextByTypeAndNameResponse, error)
	// Gets all the artifacts with matching uris.
	GetArtifactsByURI(ctx context.Context, in *GetArtifactsByURIRequest, opts ...grpc.CallOption) (*GetArtifactsByURIResponse, error)
	// Gets all events with matching execution ids.
	GetEventsByExecutionIDs(ctx context.Context, in *GetEventsByExecutionIDsRequest, opts ...grpc.CallOption) (*GetEventsByExecutionIDsResponse, error)
	// Gets all events with matching artifact ids.
	GetEventsByArtifactIDs(ctx context.Context, in *GetEventsByArtifactIDsRequest, opts ...grpc.CallOption) (*GetEventsByArtifactIDsResponse, error)
	// Gets all context that an artifact is attributed to.
	GetContextsByArtifact(ctx context.Context, in *GetContextsByArtifactRequest, opts ...grpc.CallOption) (*GetContextsByArtifactResponse, error)
	// Gets all context that an execution is associated with.
	GetContextsByExecution(ctx context.Context, in *GetContextsByExecutionRequest, opts ...grpc.CallOption) (*GetContextsByExecutionResponse, error)
	// Gets all parent contexts that a context is related.
	GetParentContextsByContext(ctx context.Context, in *GetParentContextsByContextRequest, opts ...grpc.CallOption) (*GetParentContextsByContextResponse, error)
	// Gets all children contexts that a context is related.
	GetChildrenContextsByContext(ctx context.Context, in *GetChildrenContextsByContextRequest, opts ...grpc.CallOption) (*GetChildrenContextsByContextResponse, error)
	// Gets all direct artifacts that a context attributes to.
	GetArtifactsByContext(ctx context.Context, in *GetArtifactsByContextRequest, opts ...grpc.CallOption) (*GetArtifactsByContextResponse, error)
	// Gets all direct executions that a context associates with.
	GetExecutionsByContext(ctx context.Context, in *GetExecutionsByContextRequest, opts ...grpc.CallOption) (*GetExecutionsByContextResponse, error)
}

MetadataStoreServiceClient is the client API for MetadataStoreService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewMetadataStoreServiceClient 

func NewMetadataStoreServiceClient(cc grpc.ClientConnInterface) MetadataStoreServiceClient

type MetadataStoreServiceServer 

type MetadataStoreServiceServer interface {
	// Inserts or updates an ArtifactType.
	//
	// A type has a set of strong typed properties describing the schema of any
	// stored instance associated with that type. A type is identified by a name
	// and an optional version.
	//
	// Type Creation:
	// If no type exists in the database with the given identifier
	// (name, version), it creates a new type and returns the type_id.
	//
	// Type Evolution:
	// If the request type with the same (name, version) already exists
	// (let's call it stored_type), the method enforces the stored_type can be
	// updated only when the request type is backward compatible for the already
	// stored instances.
	//
	// Backwards compatibility is violated iff:
	//
	//   a) there is a property where the request type and stored_type have
	//      different value type (e.g., int vs. string)
	//   b) `can_add_fields = false` and the request type has a new property that
	//      is not stored.
	//   c) `can_omit_fields = false` and stored_type has an existing property
	//      that is not provided in the request type.
	//
	// If non-backward type change is required in the application, e.g.,
	// deprecate properties, re-purpose property name, change value types,
	// a new type can be created with a different (name, version) identifier.
	// Note the type version is optional, and a version value with empty string
	// is treated as unset.
	//
	// Args:
	//   artifact_type: the type to be inserted or updated.
	//   can_add_fields:
	//     when set to true, new properties can be added;
	//     when set to false, returns ALREADY_EXISTS if the request type has
	//     properties that are not in stored_type.
	//   can_omit_fields:
	//     when set to true, stored properties can be omitted in the request type;
	//     when set to false, returns ALREADY_EXISTS if the stored_type has
	//     properties not in the request type.
	//
	// Returns:
	//   The type_id of the stored type.
	//
	// Raises:
	//   ALREADY_EXISTS error in the case listed above.
	//   INVALID_ARGUMENT error, if the given type has no name, or any
	//     property value type is unknown.
	PutArtifactType(context.Context, *PutArtifactTypeRequest) (*PutArtifactTypeResponse, error)
	// Inserts or updates an ExecutionType. Please refer to PutArtifactType for
	// type upsert API description.
	PutExecutionType(context.Context, *PutExecutionTypeRequest) (*PutExecutionTypeResponse, error)
	// Inserts or updates an ContextType. Please refer to PutArtifactType for
	// type upsert API description.
	PutContextType(context.Context, *PutContextTypeRequest) (*PutContextTypeResponse, error)
	// Bulk inserts types atomically.
	PutTypes(context.Context, *PutTypesRequest) (*PutTypesResponse, error)
	// Inserts or updates artifacts in the database.
	//
	// If an artifact_id is specified for an artifact, it is an update.
	// If an artifact_id is unspecified, it will insert a new artifact.
	// For new artifacts, type must be specified.
	// For old artifacts, type must be unchanged or unspecified.
	//
	// Args:
	//   artifacts: A list of artifacts to insert or update.
	//
	// Returns:
	//   A list of artifact ids index-aligned with the input.
	PutArtifacts(context.Context, *PutArtifactsRequest) (*PutArtifactsResponse, error)
	// Inserts or updates executions in the database.
	//
	// If an execution_id is specified for an execution, it is an update.
	// If an execution_id is unspecified, it will insert a new execution.
	// For new executions, type must be specified.
	// For old executions, type must be unchanged or unspecified.
	//
	// Args:
	//   executions: A list of executions to insert or update.
	//
	// Returns:
	//   A list of execution ids index-aligned with the input.
	//
	PutExecutions(context.Context, *PutExecutionsRequest) (*PutExecutionsResponse, error)
	// Inserts events in the database.
	//
	// The execution_id and artifact_id must already exist.
	// Once created, events cannot be modified.
	//
	// Args:
	//   events: A list of events to insert or update.
	PutEvents(context.Context, *PutEventsRequest) (*PutEventsResponse, error)
	// Inserts or updates an Execution and its input and output artifacts and
	// related contexts atomically. The `artifact_event_pairs` include the state
	// changes of the Artifacts used or generated by the Execution, as well as the
	// input/output Event. The `contexts` describe the associations of the
	// execution and the attributions of the artifacts.
	//
	// If an execution_id, artifact_id or context_id is specified, it is an
	// update, otherwise it does an insertion. For insertion, type must be
	// specified.
	//
	// Args:
	//   execution: An execution to insert or update.
	//   artifact_event_pairs: Artifacts to insert or update and events to insert.
	//   contexts: The contexts that the execution and the artifacts belong to.
	//
	// Returns:
	//   An execution id and a list of artifacts and contexts ids index-aligned
	//   with the input.
	PutExecution(context.Context, *PutExecutionRequest) (*PutExecutionResponse, error)
	// Inserts or updates contexts in database and returns a list of context ids.
	//
	// If an context_id is specified for a context, it is an update.
	// If an context_id is unspecified, it will insert a new context.
	// For new contexts, type must be specified.
	// For old contexts, type must be unchanged or unspecified.
	//
	// Args:
	//   contexts: A list of contexts to insert or update.
	//
	// Returns:
	//   A list of context ids index-aligned with the input.
	PutContexts(context.Context, *PutContextsRequest) (*PutContextsResponse, error)
	// Inserts attribution and association relationships in the database.
	// The context_id, artifact_id, and execution_id must already exist.
	// If the relationship exists, this call does nothing. Once added, the
	// relationships cannot be modified.
	//
	// Args:
	//   attributions: A list of attributions to insert.
	//   associations: A list of associations to insert.
	PutAttributionsAndAssociations(context.Context, *PutAttributionsAndAssociationsRequest) (*PutAttributionsAndAssociationsResponse, error)
	// Inserts parental context relationships in the database.
	// The ParentContext relationship has direction. The call fails if cycles are
	// detected.
	//
	// Args:
	//   parent_contexts: A list of parent contexts to insert.
	PutParentContexts(context.Context, *PutParentContextsRequest) (*PutParentContextsResponse, error)
	// Gets an artifact type. Returns a NOT_FOUND error if the type does not
	// exist.
	GetArtifactType(context.Context, *GetArtifactTypeRequest) (*GetArtifactTypeResponse, error)
	// Gets a list of artifact types by ID.
	// If no artifact types with an ID exists, the artifact type is skipped.
	GetArtifactTypesByID(context.Context, *GetArtifactTypesByIDRequest) (*GetArtifactTypesByIDResponse, error)
	// Gets a list of all artifact types.
	GetArtifactTypes(context.Context, *GetArtifactTypesRequest) (*GetArtifactTypesResponse, error)
	// Gets an execution type, or None if it does not exist.
	GetExecutionType(context.Context, *GetExecutionTypeRequest) (*GetExecutionTypeResponse, error)
	// Gets a list of execution types by ID.
	// If no execution types with an ID exists, the execution type is skipped.
	GetExecutionTypesByID(context.Context, *GetExecutionTypesByIDRequest) (*GetExecutionTypesByIDResponse, error)
	// Gets a list of all execution types.
	GetExecutionTypes(context.Context, *GetExecutionTypesRequest) (*GetExecutionTypesResponse, error)
	// Gets a context type. Returns a NOT_FOUND error if the type does not exist.
	GetContextType(context.Context, *GetContextTypeRequest) (*GetContextTypeResponse, error)
	// Gets a list of context types by ID.
	// If no context types with an ID exists, the context type is skipped.
	GetContextTypesByID(context.Context, *GetContextTypesByIDRequest) (*GetContextTypesByIDResponse, error)
	// Gets a list of all context types.
	GetContextTypes(context.Context, *GetContextTypesRequest) (*GetContextTypesResponse, error)
	// Gets all the artifacts.
	GetArtifacts(context.Context, *GetArtifactsRequest) (*GetArtifactsResponse, error)
	// Gets all the executions.
	GetExecutions(context.Context, *GetExecutionsRequest) (*GetExecutionsResponse, error)
	// Gets all the contexts.
	GetContexts(context.Context, *GetContextsRequest) (*GetContextsResponse, error)
	// Gets all artifacts with matching ids.
	//
	// The result is not index-aligned: if an id is not found, it is not returned.
	//
	// Args:
	//   artifact_ids: A list of artifact ids to retrieve.
	//
	// Returns:
	//   Artifacts with matching ids.
	GetArtifactsByID(context.Context, *GetArtifactsByIDRequest) (*GetArtifactsByIDResponse, error)
	// Gets all executions with matching ids.
	//
	// The result is not index-aligned: if an id is not found, it is not returned.
	//
	// Args:
	//   execution_ids: A list of execution ids to retrieve.
	GetExecutionsByID(context.Context, *GetExecutionsByIDRequest) (*GetExecutionsByIDResponse, error)
	// Gets all contexts with matching ids.
	//
	// The result is not index-aligned: if an id is not found, it is not returned.
	//
	// Args:
	//   context_ids: A list of context ids to retrieve.
	GetContextsByID(context.Context, *GetContextsByIDRequest) (*GetContextsByIDResponse, error)
	// Gets all the artifacts of a given type.
	GetArtifactsByType(context.Context, *GetArtifactsByTypeRequest) (*GetArtifactsByTypeResponse, error)
	// Gets all the executions of a given type.
	GetExecutionsByType(context.Context, *GetExecutionsByTypeRequest) (*GetExecutionsByTypeResponse, error)
	// Gets all the contexts of a given type.
	GetContextsByType(context.Context, *GetContextsByTypeRequest) (*GetContextsByTypeResponse, error)
	// Gets the artifact of the given type and artifact name.
	GetArtifactByTypeAndName(context.Context, *GetArtifactByTypeAndNameRequest) (*GetArtifactByTypeAndNameResponse, error)
	// Gets the execution of the given type and execution name.
	GetExecutionByTypeAndName(context.Context, *GetExecutionByTypeAndNameRequest) (*GetExecutionByTypeAndNameResponse, error)
	// Gets the context of the given type and context name.
	GetContextByTypeAndName(context.Context, *GetContextByTypeAndNameRequest) (*GetContextByTypeAndNameResponse, error)
	// Gets all the artifacts with matching uris.
	GetArtifactsByURI(context.Context, *GetArtifactsByURIRequest) (*GetArtifactsByURIResponse, error)
	// Gets all events with matching execution ids.
	GetEventsByExecutionIDs(context.Context, *GetEventsByExecutionIDsRequest) (*GetEventsByExecutionIDsResponse, error)
	// Gets all events with matching artifact ids.
	GetEventsByArtifactIDs(context.Context, *GetEventsByArtifactIDsRequest) (*GetEventsByArtifactIDsResponse, error)
	// Gets all context that an artifact is attributed to.
	GetContextsByArtifact(context.Context, *GetContextsByArtifactRequest) (*GetContextsByArtifactResponse, error)
	// Gets all context that an execution is associated with.
	GetContextsByExecution(context.Context, *GetContextsByExecutionRequest) (*GetContextsByExecutionResponse, error)
	// Gets all parent contexts that a context is related.
	GetParentContextsByContext(context.Context, *GetParentContextsByContextRequest) (*GetParentContextsByContextResponse, error)
	// Gets all children contexts that a context is related.
	GetChildrenContextsByContext(context.Context, *GetChildrenContextsByContextRequest) (*GetChildrenContextsByContextResponse, error)
	// Gets all direct artifacts that a context attributes to.
	GetArtifactsByContext(context.Context, *GetArtifactsByContextRequest) (*GetArtifactsByContextResponse, error)
	// Gets all direct executions that a context associates with.
	GetExecutionsByContext(context.Context, *GetExecutionsByContextRequest) (*GetExecutionsByContextResponse, error)
}

MetadataStoreServiceServer is the server API for MetadataStoreService service.

type MigrationOptions 

type MigrationOptions struct {

	// If not set, by default the upgrade migration is disabled. MLMD only
	// compares db_v with the lib_v, and raise error if the two do not align.
	// If the field is set to true, MLMD performs upgrade migration. It upgrades
	// the database schema version (db_v) to align with the library schema
	// version (lib_v) when connecting to the database.
	// Schema migration should not be run concurrently with multiple clients to
	// prevent data races.
	EnableUpgradeMigration *bool `protobuf:"varint,3,opt,name=enable_upgrade_migration,json=enableUpgradeMigration" json:"enable_upgrade_migration,omitempty"`
	// Downgrade the given database to the specified schema version.
	// For v0.13.2 release, the schema_version is 0.
	// For 0.14.0 and 0.15.0 release, the schema_version is 4.
	// More details are described in g3doc/get_start.md#upgrade-mlmd-library
	// Set this field only when a database is accidentally upgraded by a newer
	// version library. Each library version only knows how to downgrade to
	// previous schema versions. As downgrade migrations inevitably introduce
	// data loss, please consider taking a backup of the database before
	// downgrading schema.
	// After downgrade migration, the database connection is canceled. The user
	// needs to downgrade the library to use the database.
	DowngradeToSchemaVersion *int64 `` /* 138-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*MigrationOptions) Descriptor deprecated 

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

Deprecated: Use MigrationOptions.ProtoReflect.Descriptor instead.

func (*MigrationOptions) GetDowngradeToSchemaVersion 

func (x *MigrationOptions) GetDowngradeToSchemaVersion() int64

func (*MigrationOptions) GetEnableUpgradeMigration 

func (x *MigrationOptions) GetEnableUpgradeMigration() bool

func (*MigrationOptions) ProtoMessage 

func (*MigrationOptions) ProtoMessage()

func (*MigrationOptions) ProtoReflect 

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

func (*MigrationOptions) Reset 

func (x *MigrationOptions) Reset()

func (*MigrationOptions) String 

func (x *MigrationOptions) String() string

type MySQLDatabaseConfig 

type MySQLDatabaseConfig struct {

	// The hostname or IP address of the MYSQL server:
	// * If unspecified, a connection to the local host is assumed.
	//   The client connects using a Unix socket specified by `socket`.
	// * Otherwise, TCP/IP is used.
	// Currently a replicated MYSQL backend is not supported.
	Host *string `protobuf:"bytes,1,opt,name=host" json:"host,omitempty"`
	// The TCP Port number that the MYSQL server accepts connections on.
	// If unspecified, the default MYSQL port (3306) is used.
	Port *uint32 `protobuf:"varint,2,opt,name=port" json:"port,omitempty"`
	// The database to connect to. Must be specified.
	// After connecting to the MYSQL server, this database is created if not
	// already present.
	// All queries after Connect() are assumed to be for this database.
	Database *string `protobuf:"bytes,3,opt,name=database" json:"database,omitempty"`
	// The MYSQL login id. If empty, the current user is assumed.
	User *string `protobuf:"bytes,4,opt,name=user" json:"user,omitempty"`
	// The password to use for `user`. If empty, only MYSQL user ids that don't
	// have a password set are allowed to connect.
	Password *string `protobuf:"bytes,5,opt,name=password" json:"password,omitempty"`
	// The Unix socket to use to connect to the server. If unspecified, a
	// `host` must be provided.
	Socket *string `protobuf:"bytes,6,opt,name=socket" json:"socket,omitempty"`
	// If the field is set, the ssl options are set in mysql_options before
	// establishing a connection. It is ignored if the mysql server does not
	// enable SSL.
	SslOptions *MySQLDatabaseConfig_SSLOptions `protobuf:"bytes,7,opt,name=ssl_options,json=sslOptions" json:"ssl_options,omitempty"`
	// contains filtered or unexported fields
}

func (*MySQLDatabaseConfig) Descriptor deprecated 

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

Deprecated: Use MySQLDatabaseConfig.ProtoReflect.Descriptor instead.

func (*MySQLDatabaseConfig) GetDatabase 

func (x *MySQLDatabaseConfig) GetDatabase() string

func (*MySQLDatabaseConfig) GetHost 

func (x *MySQLDatabaseConfig) GetHost() string

func (*MySQLDatabaseConfig) GetPassword 

func (x *MySQLDatabaseConfig) GetPassword() string

func (*MySQLDatabaseConfig) GetPort 

func (x *MySQLDatabaseConfig) GetPort() uint32

func (*MySQLDatabaseConfig) GetSocket 

func (x *MySQLDatabaseConfig) GetSocket() string

func (*MySQLDatabaseConfig) GetSslOptions 

func (x *MySQLDatabaseConfig) GetSslOptions() *MySQLDatabaseConfig_SSLOptions

func (*MySQLDatabaseConfig) GetUser 

func (x *MySQLDatabaseConfig) GetUser() string

func (*MySQLDatabaseConfig) ProtoMessage 

func (*MySQLDatabaseConfig) ProtoMessage()

func (*MySQLDatabaseConfig) ProtoReflect 

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

func (*MySQLDatabaseConfig) Reset 

func (x *MySQLDatabaseConfig) Reset()

func (*MySQLDatabaseConfig) String 

func (x *MySQLDatabaseConfig) String() string

type MySQLDatabaseConfig_SSLOptions 

type MySQLDatabaseConfig_SSLOptions struct {

	// The path name of the client private key file.
	Key *string `protobuf:"bytes,1,opt,name=key" json:"key,omitempty"`
	// The path name of the client public key certificate file.
	Cert *string `protobuf:"bytes,2,opt,name=cert" json:"cert,omitempty"`
	// The path name of the CA certificate file.
	Ca *string `protobuf:"bytes,3,opt,name=ca" json:"ca,omitempty"`
	// The path name of the directory that contains trusted SSL CA certificates.
	Capath *string `protobuf:"bytes,4,opt,name=capath" json:"capath,omitempty"`
	// The list of permissible ciphers for SSL encryption.
	Cipher *string `protobuf:"bytes,5,opt,name=cipher" json:"cipher,omitempty"`
	// If set, enable verification of the server certificate against the host
	// name used when connecting to the server.
	VerifyServerCert *bool `protobuf:"varint,6,opt,name=verify_server_cert,json=verifyServerCert" json:"verify_server_cert,omitempty"`
	// contains filtered or unexported fields
}

The options to establish encrypted connections to MySQL using SSL.

func (*MySQLDatabaseConfig_SSLOptions) Descriptor deprecated 

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

Deprecated: Use MySQLDatabaseConfig_SSLOptions.ProtoReflect.Descriptor instead.

func (*MySQLDatabaseConfig_SSLOptions) GetCa 

func (x *MySQLDatabaseConfig_SSLOptions) GetCa() string

func (*MySQLDatabaseConfig_SSLOptions) GetCapath 

func (x *MySQLDatabaseConfig_SSLOptions) GetCapath() string

func (*MySQLDatabaseConfig_SSLOptions) GetCert 

func (x *MySQLDatabaseConfig_SSLOptions) GetCert() string

func (*MySQLDatabaseConfig_SSLOptions) GetCipher 

func (x *MySQLDatabaseConfig_SSLOptions) GetCipher() string

func (*MySQLDatabaseConfig_SSLOptions) GetKey 

func (x *MySQLDatabaseConfig_SSLOptions) GetKey() string

func (*MySQLDatabaseConfig_SSLOptions) GetVerifyServerCert 

func (x *MySQLDatabaseConfig_SSLOptions) GetVerifyServerCert() bool

func (*MySQLDatabaseConfig_SSLOptions) ProtoMessage 

func (*MySQLDatabaseConfig_SSLOptions) ProtoMessage()

func (*MySQLDatabaseConfig_SSLOptions) ProtoReflect 

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

func (*MySQLDatabaseConfig_SSLOptions) Reset 

func (x *MySQLDatabaseConfig_SSLOptions) Reset()

func (*MySQLDatabaseConfig_SSLOptions) String 

func (x *MySQLDatabaseConfig_SSLOptions) String() string

type NoneArtifactStructType 

type NoneArtifactStructType struct {
	// contains filtered or unexported fields
}

The only member of this type is a None artifact. Note: ArtifactStruct{} is a None artifact. This can represent an execution that has no outputs (or inputs), or can be part of a UnionArtifactStructType to represent an optional input. For example, StatsGen has an "optional" schema input. A practical example of this is: 

stats_gen_type = {
    "dict":{
       "properties":{
         "schema":{
           "union_type":{
             "none":{},
             "simple":{...schema type...}
            },
         },
         "data":{
           "simple":{...data_type...}
         }
      }
    }
};

func (*NoneArtifactStructType) Descriptor deprecated 

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

Deprecated: Use NoneArtifactStructType.ProtoReflect.Descriptor instead.

func (*NoneArtifactStructType) ProtoMessage 

func (*NoneArtifactStructType) ProtoMessage()

func (*NoneArtifactStructType) ProtoReflect 

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

func (*NoneArtifactStructType) Reset 

func (x *NoneArtifactStructType) Reset()

func (*NoneArtifactStructType) String 

func (x *NoneArtifactStructType) String() string

type ParentContext 

type ParentContext struct {
	ChildId  *int64 `protobuf:"varint,1,opt,name=child_id,json=childId" json:"child_id,omitempty"`
	ParentId *int64 `protobuf:"varint,2,opt,name=parent_id,json=parentId" json:"parent_id,omitempty"`
	// contains filtered or unexported fields
}

the Parental Context edges between Context and Context instances.

func (*ParentContext) Descriptor deprecated 

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

Deprecated: Use ParentContext.ProtoReflect.Descriptor instead.

func (*ParentContext) GetChildId 

func (x *ParentContext) GetChildId() int64

func (*ParentContext) GetParentId 

func (x *ParentContext) GetParentId() int64

func (*ParentContext) ProtoMessage 

func (*ParentContext) ProtoMessage()

func (*ParentContext) ProtoReflect 

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

func (*ParentContext) Reset 

func (x *ParentContext) Reset()

func (*ParentContext) String 

func (x *ParentContext) String() string

type PropertyType 

type PropertyType int32

The list of supported property value types. 

const (
	PropertyType_UNKNOWN PropertyType = 0
	PropertyType_INT     PropertyType = 1
	PropertyType_DOUBLE  PropertyType = 2
	PropertyType_STRING  PropertyType = 3
	PropertyType_STRUCT  PropertyType = 4
)

func (PropertyType) Descriptor 

func (PropertyType) Descriptor() protoreflect.EnumDescriptor

func (PropertyType) Enum 

func (x PropertyType) Enum() *PropertyType

func (PropertyType) EnumDescriptor deprecated 

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

Deprecated: Use PropertyType.Descriptor instead.

func (PropertyType) Number 

func (x PropertyType) Number() protoreflect.EnumNumber

func (PropertyType) String 

func (x PropertyType) String() string

func (PropertyType) Type 

func (PropertyType) Type() protoreflect.EnumType

func (*PropertyType) UnmarshalJSON deprecated 

func (x *PropertyType) UnmarshalJSON(b []byte) error

Deprecated: Do not use.

type PutArtifactTypeRequest 

type PutArtifactTypeRequest struct {

	// The field is required in any request. Stored types in MLMD can be updated
	// by introducing new properties and remain backward compatible. If a type
	// with the same name exists in the database, it updates the existing type,
	// otherwise it creates a new type.
	ArtifactType *ArtifactType `protobuf:"bytes,1,opt,name=artifact_type,json=artifactType" json:"artifact_type,omitempty"`
	// If true then allows adding properties to an existing stored type.
	// If false, then type update is not allowed and it raises AlreadyExists
	// error if the given type has any new property that is not defined in the
	// stored type.
	CanAddFields *bool `protobuf:"varint,2,opt,name=can_add_fields,json=canAddFields" json:"can_add_fields,omitempty"`
	// If true then allows omitting properties of an existing stored type.
	// If false, then no properties of the stored type can be omitted in the
	// given type, otherwise it raises AlreadyExists error.
	CanOmitFields *bool `protobuf:"varint,5,opt,name=can_omit_fields,json=canOmitFields" json:"can_omit_fields,omitempty"`
	// Deprecated fields.
	//
	// Deprecated: Do not use.
	CanDeleteFields *bool `protobuf:"varint,3,opt,name=can_delete_fields,json=canDeleteFields" json:"can_delete_fields,omitempty"`
	// Deprecated: Do not use.
	AllFieldsMatch *bool `protobuf:"varint,4,opt,name=all_fields_match,json=allFieldsMatch,def=1" json:"all_fields_match,omitempty"`
	// contains filtered or unexported fields
}

func (*PutArtifactTypeRequest) Descriptor deprecated 

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

Deprecated: Use PutArtifactTypeRequest.ProtoReflect.Descriptor instead.

func (*PutArtifactTypeRequest) GetAllFieldsMatch deprecated 

func (x *PutArtifactTypeRequest) GetAllFieldsMatch() bool

Deprecated: Do not use.

func (*PutArtifactTypeRequest) GetArtifactType 

func (x *PutArtifactTypeRequest) GetArtifactType() *ArtifactType

func (*PutArtifactTypeRequest) GetCanAddFields 

func (x *PutArtifactTypeRequest) GetCanAddFields() bool

func (*PutArtifactTypeRequest) GetCanDeleteFields deprecated 

func (x *PutArtifactTypeRequest) GetCanDeleteFields() bool

Deprecated: Do not use.

func (*PutArtifactTypeRequest) GetCanOmitFields 

func (x *PutArtifactTypeRequest) GetCanOmitFields() bool

func (*PutArtifactTypeRequest) ProtoMessage 

func (*PutArtifactTypeRequest) ProtoMessage()

func (*PutArtifactTypeRequest) ProtoReflect 

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

func (*PutArtifactTypeRequest) Reset 

func (x *PutArtifactTypeRequest) Reset()

func (*PutArtifactTypeRequest) String 

func (x *PutArtifactTypeRequest) String() string

type PutArtifactTypeResponse 

type PutArtifactTypeResponse struct {

	// The type ID of the artifact type.
	TypeId *int64 `protobuf:"varint,1,opt,name=type_id,json=typeId" json:"type_id,omitempty"`
	// contains filtered or unexported fields
}

func (*PutArtifactTypeResponse) Descriptor deprecated 

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

Deprecated: Use PutArtifactTypeResponse.ProtoReflect.Descriptor instead.

func (*PutArtifactTypeResponse) GetTypeId 

func (x *PutArtifactTypeResponse) GetTypeId() int64

func (*PutArtifactTypeResponse) ProtoMessage 

func (*PutArtifactTypeResponse) ProtoMessage()

func (*PutArtifactTypeResponse) ProtoReflect 

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

func (*PutArtifactTypeResponse) Reset 

func (x *PutArtifactTypeResponse) Reset()

func (*PutArtifactTypeResponse) String 

func (x *PutArtifactTypeResponse) String() string

type PutArtifactsRequest 

type PutArtifactsRequest struct {
	Artifacts []*Artifact `protobuf:"bytes,1,rep,name=artifacts" json:"artifacts,omitempty"`
	// Additional options to change the behavior of the method.
	Options *PutArtifactsRequest_Options `protobuf:"bytes,2,opt,name=options" json:"options,omitempty"`
	// contains filtered or unexported fields
}

func (*PutArtifactsRequest) Descriptor deprecated 

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

Deprecated: Use PutArtifactsRequest.ProtoReflect.Descriptor instead.

func (*PutArtifactsRequest) GetArtifacts 

func (x *PutArtifactsRequest) GetArtifacts() []*Artifact

func (*PutArtifactsRequest) GetOptions 

func (x *PutArtifactsRequest) GetOptions() *PutArtifactsRequest_Options

func (*PutArtifactsRequest) ProtoMessage 

func (*PutArtifactsRequest) ProtoMessage()

func (*PutArtifactsRequest) ProtoReflect 

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

func (*PutArtifactsRequest) Reset 

func (x *PutArtifactsRequest) Reset()

func (*PutArtifactsRequest) String 

func (x *PutArtifactsRequest) String() string

type PutArtifactsRequest_Options 

type PutArtifactsRequest_Options struct {

	// When there are multiple writers to update an existing node to
	// different states, there may be a race and the end result of the
	// concurrent update is nondeterministic. If the field is set, then an
	// optimistic concurrency control (OCC) scheme is used during update:
	// it compares the `artifact`.`last_update_time_since_epoch` in the request
	// with the stored `last_update_time_since_epoch` having the same
	// `artifact`.`id`. If they are different, the request fails, and the user
	// can read the stored node and retry node update.
	// When the option is set, the timestamp after update is guaranteed to be
	// increased and different from the input artifact.
	// When set the option, the caller should set it for all concurrent writers.
	AbortIfLatestUpdatedTimeChanged *bool `` /* 156-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*PutArtifactsRequest_Options) Descriptor deprecated 

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

Deprecated: Use PutArtifactsRequest_Options.ProtoReflect.Descriptor instead.

func (*PutArtifactsRequest_Options) GetAbortIfLatestUpdatedTimeChanged 

func (x *PutArtifactsRequest_Options) GetAbortIfLatestUpdatedTimeChanged() bool

func (*PutArtifactsRequest_Options) ProtoMessage 

func (*PutArtifactsRequest_Options) ProtoMessage()

func (*PutArtifactsRequest_Options) ProtoReflect 

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

func (*PutArtifactsRequest_Options) Reset 

func (x *PutArtifactsRequest_Options) Reset()

func (*PutArtifactsRequest_Options) String 

func (x *PutArtifactsRequest_Options) String() string

type PutArtifactsResponse 

type PutArtifactsResponse struct {

	// A list of artifact ids index-aligned with PutArtifactsRequest.
	ArtifactIds []int64 `protobuf:"varint,1,rep,name=artifact_ids,json=artifactIds" json:"artifact_ids,omitempty"`
	// contains filtered or unexported fields
}

func (*PutArtifactsResponse) Descriptor deprecated 

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

Deprecated: Use PutArtifactsResponse.ProtoReflect.Descriptor instead.

func (*PutArtifactsResponse) GetArtifactIds 

func (x *PutArtifactsResponse) GetArtifactIds() []int64

func (*PutArtifactsResponse) ProtoMessage 

func (*PutArtifactsResponse) ProtoMessage()

func (*PutArtifactsResponse) ProtoReflect 

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

func (*PutArtifactsResponse) Reset 

func (x *PutArtifactsResponse) Reset()

func (*PutArtifactsResponse) String 

func (x *PutArtifactsResponse) String() string

type PutAttributionsAndAssociationsRequest 

type PutAttributionsAndAssociationsRequest struct {
	Attributions []*Attribution `protobuf:"bytes,1,rep,name=attributions" json:"attributions,omitempty"`
	Associations []*Association `protobuf:"bytes,2,rep,name=associations" json:"associations,omitempty"`
	// contains filtered or unexported fields
}

func (*PutAttributionsAndAssociationsRequest) Descriptor deprecated 

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

Deprecated: Use PutAttributionsAndAssociationsRequest.ProtoReflect.Descriptor instead.

func (*PutAttributionsAndAssociationsRequest) GetAssociations 

func (x *PutAttributionsAndAssociationsRequest) GetAssociations() []*Association

func (*PutAttributionsAndAssociationsRequest) GetAttributions 

func (x *PutAttributionsAndAssociationsRequest) GetAttributions() []*Attribution

func (*PutAttributionsAndAssociationsRequest) ProtoMessage 

func (*PutAttributionsAndAssociationsRequest) ProtoMessage()

func (*PutAttributionsAndAssociationsRequest) ProtoReflect 

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

func (*PutAttributionsAndAssociationsRequest) Reset 

func (x *PutAttributionsAndAssociationsRequest) Reset()

func (*PutAttributionsAndAssociationsRequest) String 

func (x *PutAttributionsAndAssociationsRequest) String() string

type PutAttributionsAndAssociationsResponse 

type PutAttributionsAndAssociationsResponse struct {
	// contains filtered or unexported fields
}

func (*PutAttributionsAndAssociationsResponse) Descriptor deprecated 

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

Deprecated: Use PutAttributionsAndAssociationsResponse.ProtoReflect.Descriptor instead.

func (*PutAttributionsAndAssociationsResponse) ProtoMessage 

func (*PutAttributionsAndAssociationsResponse) ProtoMessage()

func (*PutAttributionsAndAssociationsResponse) ProtoReflect 

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

func (*PutAttributionsAndAssociationsResponse) Reset 

func (x *PutAttributionsAndAssociationsResponse) Reset()

func (*PutAttributionsAndAssociationsResponse) String 

func (x *PutAttributionsAndAssociationsResponse) String() string

type PutContextTypeRequest 

type PutContextTypeRequest struct {

	// The field is required in any request. Stored types in MLMD can be updated
	// by introducing new properties and remain backward compatible. If a type
	// with the same name exists in the database, it updates the existing type,
	// otherwise it creates a new type.
	ContextType *ContextType `protobuf:"bytes,1,opt,name=context_type,json=contextType" json:"context_type,omitempty"`
	// If true then allows adding properties to an existing stored type.
	// If false, then type update is not allowed and it raises AlreadyExists
	// error if the given type has any new property that is not defined in the
	// stored type.
	CanAddFields *bool `protobuf:"varint,2,opt,name=can_add_fields,json=canAddFields" json:"can_add_fields,omitempty"`
	// If true then allows omitting properties of an existing stored type.
	// If false, then no properties of the stored type can be omitted in the
	// given type, otherwise it raises AlreadyExists error.
	CanOmitFields *bool `protobuf:"varint,5,opt,name=can_omit_fields,json=canOmitFields" json:"can_omit_fields,omitempty"`
	// Deprecated fields.
	//
	// Deprecated: Do not use.
	CanDeleteFields *bool `protobuf:"varint,3,opt,name=can_delete_fields,json=canDeleteFields" json:"can_delete_fields,omitempty"`
	// Deprecated: Do not use.
	AllFieldsMatch *bool `protobuf:"varint,4,opt,name=all_fields_match,json=allFieldsMatch,def=1" json:"all_fields_match,omitempty"`
	// contains filtered or unexported fields
}

func (*PutContextTypeRequest) Descriptor deprecated 

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

Deprecated: Use PutContextTypeRequest.ProtoReflect.Descriptor instead.

func (*PutContextTypeRequest) GetAllFieldsMatch deprecated 

func (x *PutContextTypeRequest) GetAllFieldsMatch() bool

Deprecated: Do not use.

func (*PutContextTypeRequest) GetCanAddFields 

func (x *PutContextTypeRequest) GetCanAddFields() bool

func (*PutContextTypeRequest) GetCanDeleteFields deprecated 

func (x *PutContextTypeRequest) GetCanDeleteFields() bool

Deprecated: Do not use.

func (*PutContextTypeRequest) GetCanOmitFields 

func (x *PutContextTypeRequest) GetCanOmitFields() bool

func (*PutContextTypeRequest) GetContextType 

func (x *PutContextTypeRequest) GetContextType() *ContextType

func (*PutContextTypeRequest) ProtoMessage 

func (*PutContextTypeRequest) ProtoMessage()

func (*PutContextTypeRequest) ProtoReflect 

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

func (*PutContextTypeRequest) Reset 

func (x *PutContextTypeRequest) Reset()

func (*PutContextTypeRequest) String 

func (x *PutContextTypeRequest) String() string

type PutContextTypeResponse 

type PutContextTypeResponse struct {

	// The type ID of the context type.
	TypeId *int64 `protobuf:"varint,1,opt,name=type_id,json=typeId" json:"type_id,omitempty"`
	// contains filtered or unexported fields
}

func (*PutContextTypeResponse) Descriptor deprecated 

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

Deprecated: Use PutContextTypeResponse.ProtoReflect.Descriptor instead.

func (*PutContextTypeResponse) GetTypeId 

func (x *PutContextTypeResponse) GetTypeId() int64

func (*PutContextTypeResponse) ProtoMessage 

func (*PutContextTypeResponse) ProtoMessage()

func (*PutContextTypeResponse) ProtoReflect 

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

func (*PutContextTypeResponse) Reset 

func (x *PutContextTypeResponse) Reset()

func (*PutContextTypeResponse) String 

func (x *PutContextTypeResponse) String() string

type PutContextsRequest 

type PutContextsRequest struct {
	Contexts []*Context `protobuf:"bytes,1,rep,name=contexts" json:"contexts,omitempty"`
	// contains filtered or unexported fields
}

func (*PutContextsRequest) Descriptor deprecated 

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

Deprecated: Use PutContextsRequest.ProtoReflect.Descriptor instead.

func (*PutContextsRequest) GetContexts 

func (x *PutContextsRequest) GetContexts() []*Context

func (*PutContextsRequest) ProtoMessage 

func (*PutContextsRequest) ProtoMessage()

func (*PutContextsRequest) ProtoReflect 

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

func (*PutContextsRequest) Reset 

func (x *PutContextsRequest) Reset()

func (*PutContextsRequest) String 

func (x *PutContextsRequest) String() string

type PutContextsResponse 

type PutContextsResponse struct {

	// A list of context ids index-aligned with PutContextsRequest.
	ContextIds []int64 `protobuf:"varint,1,rep,name=context_ids,json=contextIds" json:"context_ids,omitempty"`
	// contains filtered or unexported fields
}

func (*PutContextsResponse) Descriptor deprecated 

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

Deprecated: Use PutContextsResponse.ProtoReflect.Descriptor instead.

func (*PutContextsResponse) GetContextIds 

func (x *PutContextsResponse) GetContextIds() []int64

func (*PutContextsResponse) ProtoMessage 

func (*PutContextsResponse) ProtoMessage()

func (*PutContextsResponse) ProtoReflect 

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

func (*PutContextsResponse) Reset 

func (x *PutContextsResponse) Reset()

func (*PutContextsResponse) String 

func (x *PutContextsResponse) String() string

type PutEventsRequest 

type PutEventsRequest struct {
	Events []*Event `protobuf:"bytes,1,rep,name=events" json:"events,omitempty"`
	// contains filtered or unexported fields
}

func (*PutEventsRequest) Descriptor deprecated 

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

Deprecated: Use PutEventsRequest.ProtoReflect.Descriptor instead.

func (*PutEventsRequest) GetEvents 

func (x *PutEventsRequest) GetEvents() []*Event

func (*PutEventsRequest) ProtoMessage 

func (*PutEventsRequest) ProtoMessage()

func (*PutEventsRequest) ProtoReflect 

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

func (*PutEventsRequest) Reset 

func (x *PutEventsRequest) Reset()

func (*PutEventsRequest) String 

func (x *PutEventsRequest) String() string

type PutEventsResponse 

type PutEventsResponse struct {
	// contains filtered or unexported fields
}

func (*PutEventsResponse) Descriptor deprecated 

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

Deprecated: Use PutEventsResponse.ProtoReflect.Descriptor instead.

func (*PutEventsResponse) ProtoMessage 

func (*PutEventsResponse) ProtoMessage()

func (*PutEventsResponse) ProtoReflect 

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

func (*PutEventsResponse) Reset 

func (x *PutEventsResponse) Reset()

func (*PutEventsResponse) String 

func (x *PutEventsResponse) String() string

type PutExecutionRequest 

type PutExecutionRequest struct {

	// The execution that produces many artifact and event pairs.
	Execution *Execution `protobuf:"bytes,1,opt,name=execution" json:"execution,omitempty"`
	// The list of artifact and event pairs.
	ArtifactEventPairs []*PutExecutionRequest_ArtifactAndEvent `protobuf:"bytes,2,rep,name=artifact_event_pairs,json=artifactEventPairs" json:"artifact_event_pairs,omitempty"`
	// A list of contexts associated with the execution and artifacts. For each
	// given context without a context.id, it inserts the context, otherwise it
	// updates the stored context with the same id.
	// Associations between each pair of contexts and the execution, and
	// attributions between each pair of contexts and artifacts are created if
	// they do not already exist.
	Contexts []*Context `protobuf:"bytes,3,rep,name=contexts" json:"contexts,omitempty"`
	// Additional options to change the behavior of the method.
	Options *PutExecutionRequest_Options `protobuf:"bytes,4,opt,name=options" json:"options,omitempty"`
	// contains filtered or unexported fields
}

func (*PutExecutionRequest) Descriptor deprecated 

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

Deprecated: Use PutExecutionRequest.ProtoReflect.Descriptor instead.

func (*PutExecutionRequest) GetArtifactEventPairs 

func (x *PutExecutionRequest) GetArtifactEventPairs() []*PutExecutionRequest_ArtifactAndEvent

func (*PutExecutionRequest) GetContexts 

func (x *PutExecutionRequest) GetContexts() []*Context

func (*PutExecutionRequest) GetExecution 

func (x *PutExecutionRequest) GetExecution() *Execution

func (*PutExecutionRequest) GetOptions 

func (x *PutExecutionRequest) GetOptions() *PutExecutionRequest_Options

func (*PutExecutionRequest) ProtoMessage 

func (*PutExecutionRequest) ProtoMessage()

func (*PutExecutionRequest) ProtoReflect 

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

func (*PutExecutionRequest) Reset 

func (x *PutExecutionRequest) Reset()

func (*PutExecutionRequest) String 

func (x *PutExecutionRequest) String() string

type PutExecutionRequest_ArtifactAndEvent 

type PutExecutionRequest_ArtifactAndEvent struct {

	// The pair may have an artifact. If present and no artifact.id is given,
	// then it inserts the artifact, otherwise it updates the artifact.
	Artifact *Artifact `protobuf:"bytes,1,opt,name=artifact" json:"artifact,omitempty"`
	// The pair may have an event. Providing event.artifact_id or
	// event.execution_id is optional. If the ids are given, it must align with
	// the `artifact`.id / `execution`.id respectively. If artifact is not
	// given and event.artifact_id is set, it must exist in the backend.
	Event *Event `protobuf:"bytes,2,opt,name=event" json:"event,omitempty"`
	// contains filtered or unexported fields
}

A pair of an artifact and an event used or generated by an execution, e.g., during the execution run, it uses none or many artifacts as input, and generate none or many artifacts as output.

func (*PutExecutionRequest_ArtifactAndEvent) Descriptor deprecated 

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

Deprecated: Use PutExecutionRequest_ArtifactAndEvent.ProtoReflect.Descriptor instead.

func (*PutExecutionRequest_ArtifactAndEvent) GetArtifact 

func (x *PutExecutionRequest_ArtifactAndEvent) GetArtifact() *Artifact

func (*PutExecutionRequest_ArtifactAndEvent) GetEvent 

func (x *PutExecutionRequest_ArtifactAndEvent) GetEvent() *Event

func (*PutExecutionRequest_ArtifactAndEvent) ProtoMessage 

func (*PutExecutionRequest_ArtifactAndEvent) ProtoMessage()

func (*PutExecutionRequest_ArtifactAndEvent) ProtoReflect 

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

func (*PutExecutionRequest_ArtifactAndEvent) Reset 

func (x *PutExecutionRequest_ArtifactAndEvent) Reset()

func (*PutExecutionRequest_ArtifactAndEvent) String 

func (x *PutExecutionRequest_ArtifactAndEvent) String() string

type PutExecutionRequest_Options 

type PutExecutionRequest_Options struct {

	// When there's a race to publish executions with a new context with the
	// same context.name, by default there'll be one writer succeeds and
	// the rest of the writers returning AlreadyExists errors. If set the field,
	// the failed writer will reuse the stored context in the transaction.
	ReuseContextIfAlreadyExist *bool `` /* 139-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*PutExecutionRequest_Options) Descriptor deprecated 

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

Deprecated: Use PutExecutionRequest_Options.ProtoReflect.Descriptor instead.

func (*PutExecutionRequest_Options) GetReuseContextIfAlreadyExist 

func (x *PutExecutionRequest_Options) GetReuseContextIfAlreadyExist() bool

func (*PutExecutionRequest_Options) ProtoMessage 

func (*PutExecutionRequest_Options) ProtoMessage()

func (*PutExecutionRequest_Options) ProtoReflect 

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

func (*PutExecutionRequest_Options) Reset 

func (x *PutExecutionRequest_Options) Reset()

func (*PutExecutionRequest_Options) String 

func (x *PutExecutionRequest_Options) String() string

type PutExecutionResponse 

type PutExecutionResponse struct {

	// An execution id of the `execution` in PutExecutionRequest.
	ExecutionId *int64 `protobuf:"varint,1,opt,name=execution_id,json=executionId" json:"execution_id,omitempty"`
	// A list of artifact ids index-aligned with `artifact_event_pairs` in the
	// PutExecutionRequest.
	ArtifactIds []int64 `protobuf:"varint,2,rep,name=artifact_ids,json=artifactIds" json:"artifact_ids,omitempty"`
	// A list of context ids index-aligned with `contexts` in the
	// PutExecutionRequest.
	ContextIds []int64 `protobuf:"varint,3,rep,name=context_ids,json=contextIds" json:"context_ids,omitempty"`
	// contains filtered or unexported fields
}

func (*PutExecutionResponse) Descriptor deprecated 

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

Deprecated: Use PutExecutionResponse.ProtoReflect.Descriptor instead.

func (*PutExecutionResponse) GetArtifactIds 

func (x *PutExecutionResponse) GetArtifactIds() []int64

func (*PutExecutionResponse) GetContextIds 

func (x *PutExecutionResponse) GetContextIds() []int64

func (*PutExecutionResponse) GetExecutionId 

func (x *PutExecutionResponse) GetExecutionId() int64

func (*PutExecutionResponse) ProtoMessage 

func (*PutExecutionResponse) ProtoMessage()

func (*PutExecutionResponse) ProtoReflect 

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

func (*PutExecutionResponse) Reset 

func (x *PutExecutionResponse) Reset()

func (*PutExecutionResponse) String 

func (x *PutExecutionResponse) String() string

type PutExecutionTypeRequest 

type PutExecutionTypeRequest struct {

	// The field is required in any request. Stored types in MLMD can be updated
	// by introducing new properties and remain backward compatible. If a type
	// with the same name exists in the database, it updates the existing type,
	// otherwise it creates a new type.
	ExecutionType *ExecutionType `protobuf:"bytes,1,opt,name=execution_type,json=executionType" json:"execution_type,omitempty"`
	// If true then allows adding properties to an existing stored type.
	// If false, then type update is not allowed and it raises AlreadyExists
	// error if the given type has any new property that is not defined in the
	// stored type.
	CanAddFields *bool `protobuf:"varint,2,opt,name=can_add_fields,json=canAddFields" json:"can_add_fields,omitempty"`
	// If true then allows omitting properties of an existing stored type.
	// If false, then no properties of the stored type can be omitted in the
	// given type, otherwise it raises AlreadyExists error.
	CanOmitFields *bool `protobuf:"varint,5,opt,name=can_omit_fields,json=canOmitFields" json:"can_omit_fields,omitempty"`
	// Deprecated fields.
	//
	// Deprecated: Do not use.
	CanDeleteFields *bool `protobuf:"varint,3,opt,name=can_delete_fields,json=canDeleteFields" json:"can_delete_fields,omitempty"`
	// Deprecated: Do not use.
	AllFieldsMatch *bool `protobuf:"varint,4,opt,name=all_fields_match,json=allFieldsMatch,def=1" json:"all_fields_match,omitempty"`
	// contains filtered or unexported fields
}

func (*PutExecutionTypeRequest) Descriptor deprecated 

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

Deprecated: Use PutExecutionTypeRequest.ProtoReflect.Descriptor instead.

func (*PutExecutionTypeRequest) GetAllFieldsMatch deprecated 

func (x *PutExecutionTypeRequest) GetAllFieldsMatch() bool

Deprecated: Do not use.

func (*PutExecutionTypeRequest) GetCanAddFields 

func (x *PutExecutionTypeRequest) GetCanAddFields() bool

func (*PutExecutionTypeRequest) GetCanDeleteFields deprecated 

func (x *PutExecutionTypeRequest) GetCanDeleteFields() bool

Deprecated: Do not use.

func (*PutExecutionTypeRequest) GetCanOmitFields 

func (x *PutExecutionTypeRequest) GetCanOmitFields() bool

func (*PutExecutionTypeRequest) GetExecutionType 

func (x *PutExecutionTypeRequest) GetExecutionType() *ExecutionType

func (*PutExecutionTypeRequest) ProtoMessage 

func (*PutExecutionTypeRequest) ProtoMessage()

func (*PutExecutionTypeRequest) ProtoReflect 

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

func (*PutExecutionTypeRequest) Reset 

func (x *PutExecutionTypeRequest) Reset()

func (*PutExecutionTypeRequest) String 

func (x *PutExecutionTypeRequest) String() string

type PutExecutionTypeResponse 

type PutExecutionTypeResponse struct {

	// The type ID of the execution type.
	TypeId *int64 `protobuf:"varint,1,opt,name=type_id,json=typeId" json:"type_id,omitempty"`
	// contains filtered or unexported fields
}

func (*PutExecutionTypeResponse) Descriptor deprecated 

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

Deprecated: Use PutExecutionTypeResponse.ProtoReflect.Descriptor instead.

func (*PutExecutionTypeResponse) GetTypeId 

func (x *PutExecutionTypeResponse) GetTypeId() int64

func (*PutExecutionTypeResponse) ProtoMessage 

func (*PutExecutionTypeResponse) ProtoMessage()

func (*PutExecutionTypeResponse) ProtoReflect 

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

func (*PutExecutionTypeResponse) Reset 

func (x *PutExecutionTypeResponse) Reset()

func (*PutExecutionTypeResponse) String 

func (x *PutExecutionTypeResponse) String() string

type PutExecutionsRequest 

type PutExecutionsRequest struct {
	Executions []*Execution `protobuf:"bytes,1,rep,name=executions" json:"executions,omitempty"`
	// contains filtered or unexported fields
}

func (*PutExecutionsRequest) Descriptor deprecated 

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

Deprecated: Use PutExecutionsRequest.ProtoReflect.Descriptor instead.

func (*PutExecutionsRequest) GetExecutions 

func (x *PutExecutionsRequest) GetExecutions() []*Execution

func (*PutExecutionsRequest) ProtoMessage 

func (*PutExecutionsRequest) ProtoMessage()

func (*PutExecutionsRequest) ProtoReflect 

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

func (*PutExecutionsRequest) Reset 

func (x *PutExecutionsRequest) Reset()

func (*PutExecutionsRequest) String 

func (x *PutExecutionsRequest) String() string

type PutExecutionsResponse 

type PutExecutionsResponse struct {

	// A list of execution ids index-aligned with PutExecutionsRequest.
	ExecutionIds []int64 `protobuf:"varint,1,rep,name=execution_ids,json=executionIds" json:"execution_ids,omitempty"`
	// contains filtered or unexported fields
}

func (*PutExecutionsResponse) Descriptor deprecated 

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

Deprecated: Use PutExecutionsResponse.ProtoReflect.Descriptor instead.

func (*PutExecutionsResponse) GetExecutionIds 

func (x *PutExecutionsResponse) GetExecutionIds() []int64

func (*PutExecutionsResponse) ProtoMessage 

func (*PutExecutionsResponse) ProtoMessage()

func (*PutExecutionsResponse) ProtoReflect 

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

func (*PutExecutionsResponse) Reset 

func (x *PutExecutionsResponse) Reset()

func (*PutExecutionsResponse) String 

func (x *PutExecutionsResponse) String() string

type PutParentContextsRequest 

type PutParentContextsRequest struct {
	ParentContexts []*ParentContext `protobuf:"bytes,1,rep,name=parent_contexts,json=parentContexts" json:"parent_contexts,omitempty"`
	// contains filtered or unexported fields
}

func (*PutParentContextsRequest) Descriptor deprecated 

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

Deprecated: Use PutParentContextsRequest.ProtoReflect.Descriptor instead.

func (*PutParentContextsRequest) GetParentContexts 

func (x *PutParentContextsRequest) GetParentContexts() []*ParentContext

func (*PutParentContextsRequest) ProtoMessage 

func (*PutParentContextsRequest) ProtoMessage()

func (*PutParentContextsRequest) ProtoReflect 

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

func (*PutParentContextsRequest) Reset 

func (x *PutParentContextsRequest) Reset()

func (*PutParentContextsRequest) String 

func (x *PutParentContextsRequest) String() string

type PutParentContextsResponse 

type PutParentContextsResponse struct {
	// contains filtered or unexported fields
}

func (*PutParentContextsResponse) Descriptor deprecated 

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

Deprecated: Use PutParentContextsResponse.ProtoReflect.Descriptor instead.

func (*PutParentContextsResponse) ProtoMessage 

func (*PutParentContextsResponse) ProtoMessage()

func (*PutParentContextsResponse) ProtoReflect 

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

func (*PutParentContextsResponse) Reset 

func (x *PutParentContextsResponse) Reset()

func (*PutParentContextsResponse) String 

func (x *PutParentContextsResponse) String() string

type PutTypesRequest 

type PutTypesRequest struct {
	ArtifactTypes  []*ArtifactType  `protobuf:"bytes,1,rep,name=artifact_types,json=artifactTypes" json:"artifact_types,omitempty"`
	ExecutionTypes []*ExecutionType `protobuf:"bytes,2,rep,name=execution_types,json=executionTypes" json:"execution_types,omitempty"`
	ContextTypes   []*ContextType   `protobuf:"bytes,3,rep,name=context_types,json=contextTypes" json:"context_types,omitempty"`
	// If true then allows adding properties to an existing stored type.
	// If false, then type update is not allowed and it raises AlreadyExists
	// error if the given type has any new property that is not defined in the
	// stored type.
	CanAddFields *bool `protobuf:"varint,4,opt,name=can_add_fields,json=canAddFields" json:"can_add_fields,omitempty"`
	// If true then allows omitting properties of an existing stored type.
	// If false, then no properties of the stored type can be omitted in the
	// given type, otherwise it raises AlreadyExists error.
	CanOmitFields *bool `protobuf:"varint,7,opt,name=can_omit_fields,json=canOmitFields" json:"can_omit_fields,omitempty"`
	// Deprecated fields.
	//
	// Deprecated: Do not use.
	CanDeleteFields *bool `protobuf:"varint,5,opt,name=can_delete_fields,json=canDeleteFields" json:"can_delete_fields,omitempty"`
	// Deprecated: Do not use.
	AllFieldsMatch *bool `protobuf:"varint,6,opt,name=all_fields_match,json=allFieldsMatch,def=1" json:"all_fields_match,omitempty"`
	// contains filtered or unexported fields
}

func (*PutTypesRequest) Descriptor deprecated 

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

Deprecated: Use PutTypesRequest.ProtoReflect.Descriptor instead.

func (*PutTypesRequest) GetAllFieldsMatch deprecated 

func (x *PutTypesRequest) GetAllFieldsMatch() bool

Deprecated: Do not use.

func (*PutTypesRequest) GetArtifactTypes 

func (x *PutTypesRequest) GetArtifactTypes() []*ArtifactType

func (*PutTypesRequest) GetCanAddFields 

func (x *PutTypesRequest) GetCanAddFields() bool

func (*PutTypesRequest) GetCanDeleteFields deprecated 

func (x *PutTypesRequest) GetCanDeleteFields() bool

Deprecated: Do not use.

func (*PutTypesRequest) GetCanOmitFields 

func (x *PutTypesRequest) GetCanOmitFields() bool

func (*PutTypesRequest) GetContextTypes 

func (x *PutTypesRequest) GetContextTypes() []*ContextType

func (*PutTypesRequest) GetExecutionTypes 

func (x *PutTypesRequest) GetExecutionTypes() []*ExecutionType

func (*PutTypesRequest) ProtoMessage 

func (*PutTypesRequest) ProtoMessage()

func (*PutTypesRequest) ProtoReflect 

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

func (*PutTypesRequest) Reset 

func (x *PutTypesRequest) Reset()

func (*PutTypesRequest) String 

func (x *PutTypesRequest) String() string

type PutTypesResponse 

type PutTypesResponse struct {

	// The type ids of the artifact type.
	ArtifactTypeIds []int64 `protobuf:"varint,1,rep,name=artifact_type_ids,json=artifactTypeIds" json:"artifact_type_ids,omitempty"`
	// The type ids of the execution type.
	ExecutionTypeIds []int64 `protobuf:"varint,2,rep,name=execution_type_ids,json=executionTypeIds" json:"execution_type_ids,omitempty"`
	// The type ids of the context type.
	ContextTypeIds []int64 `protobuf:"varint,3,rep,name=context_type_ids,json=contextTypeIds" json:"context_type_ids,omitempty"`
	// contains filtered or unexported fields
}

func (*PutTypesResponse) Descriptor deprecated 

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

Deprecated: Use PutTypesResponse.ProtoReflect.Descriptor instead.

func (*PutTypesResponse) GetArtifactTypeIds 

func (x *PutTypesResponse) GetArtifactTypeIds() []int64

func (*PutTypesResponse) GetContextTypeIds 

func (x *PutTypesResponse) GetContextTypeIds() []int64

func (*PutTypesResponse) GetExecutionTypeIds 

func (x *PutTypesResponse) GetExecutionTypeIds() []int64

func (*PutTypesResponse) ProtoMessage 

func (*PutTypesResponse) ProtoMessage()

func (*PutTypesResponse) ProtoReflect 

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

func (*PutTypesResponse) Reset 

func (x *PutTypesResponse) Reset()

func (*PutTypesResponse) String 

func (x *PutTypesResponse) String() string

type RecordSet 

type RecordSet struct {

	// index-aligned column names for all records
	ColumnNames []string `protobuf:"bytes,1,rep,name=column_names,json=columnNames,proto3" json:"column_names,omitempty"`
	// a list of records returned by a query
	Records []*RecordSet_Record `protobuf:"bytes,2,rep,name=records,proto3" json:"records,omitempty"`
	// contains filtered or unexported fields
}

A collection of returned records.

func (*RecordSet) Descriptor deprecated 

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

Deprecated: Use RecordSet.ProtoReflect.Descriptor instead.

func (*RecordSet) GetColumnNames 

func (x *RecordSet) GetColumnNames() []string

func (*RecordSet) GetRecords 

func (x *RecordSet) GetRecords() []*RecordSet_Record

func (*RecordSet) ProtoMessage 

func (*RecordSet) ProtoMessage()

func (*RecordSet) ProtoReflect 

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

func (*RecordSet) Reset 

func (x *RecordSet) Reset()

func (*RecordSet) String 

func (x *RecordSet) String() string

type RecordSet_Record 

type RecordSet_Record struct {
	Values []string `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

An individual record (e.g., row) returned by a MetadataSource. The record does not address the type conversion.

func (*RecordSet_Record) Descriptor deprecated 

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

Deprecated: Use RecordSet_Record.ProtoReflect.Descriptor instead.

func (*RecordSet_Record) GetValues 

func (x *RecordSet_Record) GetValues() []string

func (*RecordSet_Record) ProtoMessage 

func (*RecordSet_Record) ProtoMessage()

func (*RecordSet_Record) ProtoReflect 

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

func (*RecordSet_Record) Reset 

func (x *RecordSet_Record) Reset()

func (*RecordSet_Record) String 

func (x *RecordSet_Record) String() string

type RetryOptions 

type RetryOptions struct {

	// The max number of retries when transaction returns Aborted error.
	MaxNumRetries *int64 `protobuf:"varint,1,opt,name=max_num_retries,json=maxNumRetries" json:"max_num_retries,omitempty"`
	// contains filtered or unexported fields
}

func (*RetryOptions) Descriptor deprecated 

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

Deprecated: Use RetryOptions.ProtoReflect.Descriptor instead.

func (*RetryOptions) GetMaxNumRetries 

func (x *RetryOptions) GetMaxNumRetries() int64

func (*RetryOptions) ProtoMessage 

func (*RetryOptions) ProtoMessage()

func (*RetryOptions) ProtoReflect 

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

func (*RetryOptions) Reset 

func (x *RetryOptions) Reset()

func (*RetryOptions) String 

func (x *RetryOptions) String() string

type SqliteMetadataSourceConfig 

type SqliteMetadataSourceConfig struct {

	// A uri specifying Sqlite3 database filename, for example:
	//
	//   file:some_sqlite3_file_in_local_dir.db
	//   file:///home/username/some_sqlite3_file.db
	//
	// see https://www.sqlite.org/c3ref/open.html for model details
	//
	// If not given, a in-memory sqlite3 database is used, and destroyed when
	// disconnecting the metadata source.
	FilenameUri *string `protobuf:"bytes,1,opt,name=filename_uri,json=filenameUri" json:"filename_uri,omitempty"`
	// A flag specifying the connection mode. If not given, default connection
	// mode is set to READWRITE_OPENCREATE.
	ConnectionMode *SqliteMetadataSourceConfig_ConnectionMode `` /* 156-byte string literal not displayed */
	// contains filtered or unexported fields
}

A config contains the parameters when using with SqliteMetadatSource.

func (*SqliteMetadataSourceConfig) Descriptor deprecated 

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

Deprecated: Use SqliteMetadataSourceConfig.ProtoReflect.Descriptor instead.

func (*SqliteMetadataSourceConfig) GetConnectionMode 

func (x *SqliteMetadataSourceConfig) GetConnectionMode() SqliteMetadataSourceConfig_ConnectionMode

func (*SqliteMetadataSourceConfig) GetFilenameUri 

func (x *SqliteMetadataSourceConfig) GetFilenameUri() string

func (*SqliteMetadataSourceConfig) ProtoMessage 

func (*SqliteMetadataSourceConfig) ProtoMessage()

func (*SqliteMetadataSourceConfig) ProtoReflect 

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

func (*SqliteMetadataSourceConfig) Reset 

func (x *SqliteMetadataSourceConfig) Reset()

func (*SqliteMetadataSourceConfig) String 

func (x *SqliteMetadataSourceConfig) String() string

type SqliteMetadataSourceConfig_ConnectionMode 

type SqliteMetadataSourceConfig_ConnectionMode int32

Connection parameters for SQLite3 based metadata source. 

const (
	SqliteMetadataSourceConfig_UNKNOWN SqliteMetadataSourceConfig_ConnectionMode = 0
	// Connect a metadata source in read-only mode. Connection fail if the
	// sqlite3 database at the `filename` does not exist. Any queries modifying
	// the database fail.
	SqliteMetadataSourceConfig_READONLY SqliteMetadataSourceConfig_ConnectionMode = 1
	// Connect a metadata source in read/write mode. Connection fail if the
	// sqlite3 database at the `filename` does not exist.
	SqliteMetadataSourceConfig_READWRITE SqliteMetadataSourceConfig_ConnectionMode = 2
	// Similar to READWRITE. In addition, it creates the database if it does not
	// exist.
	SqliteMetadataSourceConfig_READWRITE_OPENCREATE SqliteMetadataSourceConfig_ConnectionMode = 3
)

func (SqliteMetadataSourceConfig_ConnectionMode) Descriptor 

func (SqliteMetadataSourceConfig_ConnectionMode) Descriptor() protoreflect.EnumDescriptor

func (SqliteMetadataSourceConfig_ConnectionMode) Enum 

func (x SqliteMetadataSourceConfig_ConnectionMode) Enum() *SqliteMetadataSourceConfig_ConnectionMode

func (SqliteMetadataSourceConfig_ConnectionMode) EnumDescriptor deprecated 

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

Deprecated: Use SqliteMetadataSourceConfig_ConnectionMode.Descriptor instead.

func (SqliteMetadataSourceConfig_ConnectionMode) Number 

func (x SqliteMetadataSourceConfig_ConnectionMode) Number() protoreflect.EnumNumber

func (SqliteMetadataSourceConfig_ConnectionMode) String 

func (x SqliteMetadataSourceConfig_ConnectionMode) String() string

func (SqliteMetadataSourceConfig_ConnectionMode) Type 

func (SqliteMetadataSourceConfig_ConnectionMode) Type() protoreflect.EnumType

func (*SqliteMetadataSourceConfig_ConnectionMode) UnmarshalJSON deprecated 

func (x *SqliteMetadataSourceConfig_ConnectionMode) UnmarshalJSON(b []byte) error

Deprecated: Do not use.

type TupleArtifactStructType 

type TupleArtifactStructType struct {
	Elements []*ArtifactStructType `protobuf:"bytes,1,rep,name=elements" json:"elements,omitempty"`
	// contains filtered or unexported fields
}

An ordered list of heterogeneous artifact structs. The length of the list is fixed. Each position in the list can have a different type.

func (*TupleArtifactStructType) Descriptor deprecated 

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

Deprecated: Use TupleArtifactStructType.ProtoReflect.Descriptor instead.

func (*TupleArtifactStructType) GetElements 

func (x *TupleArtifactStructType) GetElements() []*ArtifactStructType

func (*TupleArtifactStructType) ProtoMessage 

func (*TupleArtifactStructType) ProtoMessage()

func (*TupleArtifactStructType) ProtoReflect 

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

func (*TupleArtifactStructType) Reset 

func (x *TupleArtifactStructType) Reset()

func (*TupleArtifactStructType) String 

func (x *TupleArtifactStructType) String() string

type UnimplementedMetadataStoreServiceServer 

type UnimplementedMetadataStoreServiceServer struct {
}

UnimplementedMetadataStoreServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedMetadataStoreServiceServer) GetArtifactByTypeAndName 

func (*UnimplementedMetadataStoreServiceServer) GetArtifactByTypeAndName(context.Context, *GetArtifactByTypeAndNameRequest) (*GetArtifactByTypeAndNameResponse, error)

func (*UnimplementedMetadataStoreServiceServer) GetArtifactType 

func (*UnimplementedMetadataStoreServiceServer) GetArtifactType(context.Context, *GetArtifactTypeRequest) (*GetArtifactTypeResponse, error)

func (*UnimplementedMetadataStoreServiceServer) GetArtifactTypes 

func (*UnimplementedMetadataStoreServiceServer) GetArtifactTypes(context.Context, *GetArtifactTypesRequest) (*GetArtifactTypesResponse, error)

func (*UnimplementedMetadataStoreServiceServer) GetArtifactTypesByID 

func (*UnimplementedMetadataStoreServiceServer) GetArtifactTypesByID(context.Context, *GetArtifactTypesByIDRequest) (*GetArtifactTypesByIDResponse, error)

func (*UnimplementedMetadataStoreServiceServer) GetArtifacts 

func (*UnimplementedMetadataStoreServiceServer) GetArtifacts(context.Context, *GetArtifactsRequest) (*GetArtifactsResponse, error)

func (*UnimplementedMetadataStoreServiceServer) GetArtifactsByContext 

func (*UnimplementedMetadataStoreServiceServer) GetArtifactsByContext(context.Context, *GetArtifactsByContextRequest) (*GetArtifactsByContextResponse, error)

func (*UnimplementedMetadataStoreServiceServer) GetArtifactsByID 

func (*UnimplementedMetadataStoreServiceServer) GetArtifactsByID(context.Context, *GetArtifactsByIDRequest) (*GetArtifactsByIDResponse, error)

func (*UnimplementedMetadataStoreServiceServer) GetArtifactsByType 

func (*UnimplementedMetadataStoreServiceServer) GetArtifactsByType(context.Context, *GetArtifactsByTypeRequest) (*GetArtifactsByTypeResponse, error)

func (*UnimplementedMetadataStoreServiceServer) GetArtifactsByURI 

func (*UnimplementedMetadataStoreServiceServer) GetArtifactsByURI(context.Context, *GetArtifactsByURIRequest) (*GetArtifactsByURIResponse, error)

func (*UnimplementedMetadataStoreServiceServer) GetChildrenContextsByContext 

func (*UnimplementedMetadataStoreServiceServer) GetChildrenContextsByContext(context.Context, *GetChildrenContextsByContextRequest) (*GetChildrenContextsByContextResponse, error)

func (*UnimplementedMetadataStoreServiceServer) GetContextByTypeAndName 

func (*UnimplementedMetadataStoreServiceServer) GetContextByTypeAndName(context.Context, *GetContextByTypeAndNameRequest) (*GetContextByTypeAndNameResponse, error)

func (*UnimplementedMetadataStoreServiceServer) GetContextType 

func (*UnimplementedMetadataStoreServiceServer) GetContextType(context.Context, *GetContextTypeRequest) (*GetContextTypeResponse, error)

func (*UnimplementedMetadataStoreServiceServer) GetContextTypes 

func (*UnimplementedMetadataStoreServiceServer) GetContextTypes(context.Context, *GetContextTypesRequest) (*GetContextTypesResponse, error)

func (*UnimplementedMetadataStoreServiceServer) GetContextTypesByID 

func (*UnimplementedMetadataStoreServiceServer) GetContextTypesByID(context.Context, *GetContextTypesByIDRequest) (*GetContextTypesByIDResponse, error)

func (*UnimplementedMetadataStoreServiceServer) GetContexts 

func (*UnimplementedMetadataStoreServiceServer) GetContexts(context.Context, *GetContextsRequest) (*GetContextsResponse, error)

func (*UnimplementedMetadataStoreServiceServer) GetContextsByArtifact 

func (*UnimplementedMetadataStoreServiceServer) GetContextsByArtifact(context.Context, *GetContextsByArtifactRequest) (*GetContextsByArtifactResponse, error)

func (*UnimplementedMetadataStoreServiceServer) GetContextsByExecution 

func (*UnimplementedMetadataStoreServiceServer) GetContextsByExecution(context.Context, *GetContextsByExecutionRequest) (*GetContextsByExecutionResponse, error)

func (*UnimplementedMetadataStoreServiceServer) GetContextsByID 

func (*UnimplementedMetadataStoreServiceServer) GetContextsByID(context.Context, *GetContextsByIDRequest) (*GetContextsByIDResponse, error)

func (*UnimplementedMetadataStoreServiceServer) GetContextsByType 

func (*UnimplementedMetadataStoreServiceServer) GetContextsByType(context.Context, *GetContextsByTypeRequest) (*GetContextsByTypeResponse, error)

func (*UnimplementedMetadataStoreServiceServer) GetEventsByArtifactIDs 

func (*UnimplementedMetadataStoreServiceServer) GetEventsByArtifactIDs(context.Context, *GetEventsByArtifactIDsRequest) (*GetEventsByArtifactIDsResponse, error)

func (*UnimplementedMetadataStoreServiceServer) GetEventsByExecutionIDs 

func (*UnimplementedMetadataStoreServiceServer) GetEventsByExecutionIDs(context.Context, *GetEventsByExecutionIDsRequest) (*GetEventsByExecutionIDsResponse, error)

func (*UnimplementedMetadataStoreServiceServer) GetExecutionByTypeAndName 

func (*UnimplementedMetadataStoreServiceServer) GetExecutionByTypeAndName(context.Context, *GetExecutionByTypeAndNameRequest) (*GetExecutionByTypeAndNameResponse, error)

func (*UnimplementedMetadataStoreServiceServer) GetExecutionType 

func (*UnimplementedMetadataStoreServiceServer) GetExecutionType(context.Context, *GetExecutionTypeRequest) (*GetExecutionTypeResponse, error)

func (*UnimplementedMetadataStoreServiceServer) GetExecutionTypes 

func (*UnimplementedMetadataStoreServiceServer) GetExecutionTypes(context.Context, *GetExecutionTypesRequest) (*GetExecutionTypesResponse, error)

func (*UnimplementedMetadataStoreServiceServer) GetExecutionTypesByID 

func (*UnimplementedMetadataStoreServiceServer) GetExecutionTypesByID(context.Context, *GetExecutionTypesByIDRequest) (*GetExecutionTypesByIDResponse, error)

func (*UnimplementedMetadataStoreServiceServer) GetExecutions 

func (*UnimplementedMetadataStoreServiceServer) GetExecutions(context.Context, *GetExecutionsRequest) (*GetExecutionsResponse, error)

func (*UnimplementedMetadataStoreServiceServer) GetExecutionsByContext 

func (*UnimplementedMetadataStoreServiceServer) GetExecutionsByContext(context.Context, *GetExecutionsByContextRequest) (*GetExecutionsByContextResponse, error)

func (*UnimplementedMetadataStoreServiceServer) GetExecutionsByID 

func (*UnimplementedMetadataStoreServiceServer) GetExecutionsByID(context.Context, *GetExecutionsByIDRequest) (*GetExecutionsByIDResponse, error)

func (*UnimplementedMetadataStoreServiceServer) GetExecutionsByType 

func (*UnimplementedMetadataStoreServiceServer) GetExecutionsByType(context.Context, *GetExecutionsByTypeRequest) (*GetExecutionsByTypeResponse, error)

func (*UnimplementedMetadataStoreServiceServer) GetParentContextsByContext 

func (*UnimplementedMetadataStoreServiceServer) GetParentContextsByContext(context.Context, *GetParentContextsByContextRequest) (*GetParentContextsByContextResponse, error)

func (*UnimplementedMetadataStoreServiceServer) PutArtifactType 

func (*UnimplementedMetadataStoreServiceServer) PutArtifactType(context.Context, *PutArtifactTypeRequest) (*PutArtifactTypeResponse, error)

func (*UnimplementedMetadataStoreServiceServer) PutArtifacts 

func (*UnimplementedMetadataStoreServiceServer) PutArtifacts(context.Context, *PutArtifactsRequest) (*PutArtifactsResponse, error)

func (*UnimplementedMetadataStoreServiceServer) PutAttributionsAndAssociations 

func (*UnimplementedMetadataStoreServiceServer) PutAttributionsAndAssociations(context.Context, *PutAttributionsAndAssociationsRequest) (*PutAttributionsAndAssociationsResponse, error)

func (*UnimplementedMetadataStoreServiceServer) PutContextType 

func (*UnimplementedMetadataStoreServiceServer) PutContextType(context.Context, *PutContextTypeRequest) (*PutContextTypeResponse, error)

func (*UnimplementedMetadataStoreServiceServer) PutContexts 

func (*UnimplementedMetadataStoreServiceServer) PutContexts(context.Context, *PutContextsRequest) (*PutContextsResponse, error)

func (*UnimplementedMetadataStoreServiceServer) PutEvents 

func (*UnimplementedMetadataStoreServiceServer) PutEvents(context.Context, *PutEventsRequest) (*PutEventsResponse, error)

func (*UnimplementedMetadataStoreServiceServer) PutExecution 

func (*UnimplementedMetadataStoreServiceServer) PutExecution(context.Context, *PutExecutionRequest) (*PutExecutionResponse, error)

func (*UnimplementedMetadataStoreServiceServer) PutExecutionType 

func (*UnimplementedMetadataStoreServiceServer) PutExecutionType(context.Context, *PutExecutionTypeRequest) (*PutExecutionTypeResponse, error)

func (*UnimplementedMetadataStoreServiceServer) PutExecutions 

func (*UnimplementedMetadataStoreServiceServer) PutExecutions(context.Context, *PutExecutionsRequest) (*PutExecutionsResponse, error)

func (*UnimplementedMetadataStoreServiceServer) PutParentContexts 

func (*UnimplementedMetadataStoreServiceServer) PutParentContexts(context.Context, *PutParentContextsRequest) (*PutParentContextsResponse, error)

func (*UnimplementedMetadataStoreServiceServer) PutTypes 

func (*UnimplementedMetadataStoreServiceServer) PutTypes(context.Context, *PutTypesRequest) (*PutTypesResponse, error)

type UnionArtifactStructType 

type UnionArtifactStructType struct {

	// An artifact struct matches this type if it matches any of the candidates.
	// If candidates is empty, this is a bottom type (matches no artifacts).
	Candidates []*ArtifactStructType `protobuf:"bytes,1,rep,name=candidates" json:"candidates,omitempty"`
	// contains filtered or unexported fields
}

Represents a union of types.

func (*UnionArtifactStructType) Descriptor deprecated 

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

Deprecated: Use UnionArtifactStructType.ProtoReflect.Descriptor instead.

func (*UnionArtifactStructType) GetCandidates 

func (x *UnionArtifactStructType) GetCandidates() []*ArtifactStructType

func (*UnionArtifactStructType) ProtoMessage 

func (*UnionArtifactStructType) ProtoMessage()

func (*UnionArtifactStructType) ProtoReflect 

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

func (*UnionArtifactStructType) Reset 

func (x *UnionArtifactStructType) Reset()

func (*UnionArtifactStructType) String 

func (x *UnionArtifactStructType) String() string

type Value 

type Value struct {

	// Types that are assignable to Value:
	//	*Value_IntValue
	//	*Value_DoubleValue
	//	*Value_StringValue
	//	*Value_StructValue
	Value isValue_Value `protobuf_oneof:"value"`
	// contains filtered or unexported fields
}

A value in properties.

func (*Value) Descriptor deprecated 

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

Deprecated: Use Value.ProtoReflect.Descriptor instead.

func (*Value) GetDoubleValue 

func (x *Value) GetDoubleValue() float64

func (*Value) GetIntValue 

func (x *Value) GetIntValue() int64

func (*Value) GetStringValue 

func (x *Value) GetStringValue() string

func (*Value) GetStructValue 

func (x *Value) GetStructValue() *structpb.Struct

func (*Value) GetValue 

func (m *Value) GetValue() isValue_Value

func (*Value) ProtoMessage 

func (*Value) ProtoMessage()

func (*Value) ProtoReflect 

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

func (*Value) Reset 

func (x *Value) Reset()

func (*Value) String 

func (x *Value) String() string

type Value_DoubleValue 

type Value_DoubleValue struct {
	DoubleValue float64 `protobuf:"fixed64,2,opt,name=double_value,json=doubleValue,oneof"`
}

type Value_IntValue 

type Value_IntValue struct {
	IntValue int64 `protobuf:"varint,1,opt,name=int_value,json=intValue,oneof"`
}

type Value_StringValue 

type Value_StringValue struct {
	StringValue string `protobuf:"bytes,3,opt,name=string_value,json=stringValue,oneof"`
}

type Value_StructValue 

type Value_StructValue struct {
	StructValue *structpb.Struct `protobuf:"bytes,4,opt,name=struct_value,json=structValue,oneof"`
}

type Workspace 

type Workspace struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*Workspace) Descriptor deprecated 

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

Deprecated: Use Workspace.ProtoReflect.Descriptor instead.

func (*Workspace) GetName 

func (x *Workspace) GetName() string

func (*Workspace) ProtoMessage 

func (*Workspace) ProtoMessage()

func (*Workspace) ProtoReflect 

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

func (*Workspace) Reset 

func (x *Workspace) Reset()

func (*Workspace) String 

func (x *Workspace) 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.