datacatalog

package
v1.10.7-b0 Latest Latest
Warning

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

 Go to latest Published: Jan 8, 2024 License: Apache-2.0 Imports: 10 Imported by: 11

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var PaginationOptions_SortKey_name = map[int32]string{
	0: "CREATION_TIME",
}
View Source 
var PaginationOptions_SortKey_value = map[string]int32{
	"CREATION_TIME": 0,
}
View Source 
var PaginationOptions_SortOrder_name = map[int32]string{
	0: "DESCENDING",
	1: "ASCENDING",
}
View Source 
var PaginationOptions_SortOrder_value = map[string]int32{
	"DESCENDING": 0,
	"ASCENDING":  1,
}
View Source 
var SinglePropertyFilter_ComparisonOperator_name = map[int32]string{
	0: "EQUALS",
}
View Source 
var SinglePropertyFilter_ComparisonOperator_value = map[string]int32{
	"EQUALS": 0,
}

Functions

func RegisterDataCatalogServer 

func RegisterDataCatalogServer(s *grpc.Server, srv DataCatalogServer)

Types

type AddTagRequest 

type AddTagRequest struct {
	Tag                  *Tag     `protobuf:"bytes,1,opt,name=tag,proto3" json:"tag,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Request message for tagging an Artifact.

func (*AddTagRequest) Descriptor 

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

func (*AddTagRequest) GetTag 

func (m *AddTagRequest) GetTag() *Tag

func (*AddTagRequest) ProtoMessage 

func (*AddTagRequest) ProtoMessage()

func (*AddTagRequest) Reset 

func (m *AddTagRequest) Reset()

func (*AddTagRequest) String 

func (m *AddTagRequest) String() string

func (*AddTagRequest) XXX_DiscardUnknown 

func (m *AddTagRequest) XXX_DiscardUnknown()

func (*AddTagRequest) XXX_Marshal 

func (m *AddTagRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AddTagRequest) XXX_Merge 

func (m *AddTagRequest) XXX_Merge(src proto.Message)

func (*AddTagRequest) XXX_Size 

func (m *AddTagRequest) XXX_Size() int

func (*AddTagRequest) XXX_Unmarshal 

func (m *AddTagRequest) XXX_Unmarshal(b []byte) error

type AddTagResponse 

type AddTagResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Response message for tagging an Artifact.

func (*AddTagResponse) Descriptor 

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

func (*AddTagResponse) ProtoMessage 

func (*AddTagResponse) ProtoMessage()

func (*AddTagResponse) Reset 

func (m *AddTagResponse) Reset()

func (*AddTagResponse) String 

func (m *AddTagResponse) String() string

func (*AddTagResponse) XXX_DiscardUnknown 

func (m *AddTagResponse) XXX_DiscardUnknown()

func (*AddTagResponse) XXX_Marshal 

func (m *AddTagResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AddTagResponse) XXX_Merge 

func (m *AddTagResponse) XXX_Merge(src proto.Message)

func (*AddTagResponse) XXX_Size 

func (m *AddTagResponse) XXX_Size() int

func (*AddTagResponse) XXX_Unmarshal 

func (m *AddTagResponse) XXX_Unmarshal(b []byte) error

type Artifact 

type Artifact struct {
	Id                   string               `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Dataset              *DatasetID           `protobuf:"bytes,2,opt,name=dataset,proto3" json:"dataset,omitempty"`
	Data                 []*ArtifactData      `protobuf:"bytes,3,rep,name=data,proto3" json:"data,omitempty"`
	Metadata             *Metadata            `protobuf:"bytes,4,opt,name=metadata,proto3" json:"metadata,omitempty"`
	Partitions           []*Partition         `protobuf:"bytes,5,rep,name=partitions,proto3" json:"partitions,omitempty"`
	Tags                 []*Tag               `protobuf:"bytes,6,rep,name=tags,proto3" json:"tags,omitempty"`
	CreatedAt            *timestamp.Timestamp `protobuf:"bytes,7,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

Artifact message. It is composed of several string fields.

func (*Artifact) Descriptor 

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

func (*Artifact) GetCreatedAt 

func (m *Artifact) GetCreatedAt() *timestamp.Timestamp

func (*Artifact) GetData 

func (m *Artifact) GetData() []*ArtifactData

func (*Artifact) GetDataset 

func (m *Artifact) GetDataset() *DatasetID

func (*Artifact) GetId 

func (m *Artifact) GetId() string

func (*Artifact) GetMetadata 

func (m *Artifact) GetMetadata() *Metadata

func (*Artifact) GetPartitions 

func (m *Artifact) GetPartitions() []*Partition

func (*Artifact) GetTags 

func (m *Artifact) GetTags() []*Tag

func (*Artifact) ProtoMessage 

func (*Artifact) ProtoMessage()

func (*Artifact) Reset 

func (m *Artifact) Reset()

func (*Artifact) String 

func (m *Artifact) String() string

func (*Artifact) XXX_DiscardUnknown 

func (m *Artifact) XXX_DiscardUnknown()

func (*Artifact) XXX_Marshal 

func (m *Artifact) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Artifact) XXX_Merge 

func (m *Artifact) XXX_Merge(src proto.Message)

func (*Artifact) XXX_Size 

func (m *Artifact) XXX_Size() int

func (*Artifact) XXX_Unmarshal 

func (m *Artifact) XXX_Unmarshal(b []byte) error

type ArtifactData 

type ArtifactData struct {
	Name                 string        `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Value                *core.Literal `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

ArtifactData that belongs to an artifact

func (*ArtifactData) Descriptor 

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

func (*ArtifactData) GetName 

func (m *ArtifactData) GetName() string

func (*ArtifactData) GetValue 

func (m *ArtifactData) GetValue() *core.Literal

func (*ArtifactData) ProtoMessage 

func (*ArtifactData) ProtoMessage()

func (*ArtifactData) Reset 

func (m *ArtifactData) Reset()

func (*ArtifactData) String 

func (m *ArtifactData) String() string

func (*ArtifactData) XXX_DiscardUnknown 

func (m *ArtifactData) XXX_DiscardUnknown()

func (*ArtifactData) XXX_Marshal 

func (m *ArtifactData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ArtifactData) XXX_Merge 

func (m *ArtifactData) XXX_Merge(src proto.Message)

func (*ArtifactData) XXX_Size 

func (m *ArtifactData) XXX_Size() int

func (*ArtifactData) XXX_Unmarshal 

func (m *ArtifactData) XXX_Unmarshal(b []byte) error

type ArtifactPropertyFilter 

type ArtifactPropertyFilter struct {
	// oneof because we can add more properties in the future
	//
	// Types that are valid to be assigned to Property:
	//	*ArtifactPropertyFilter_ArtifactId
	Property             isArtifactPropertyFilter_Property `protobuf_oneof:"property"`
	XXX_NoUnkeyedLiteral struct{}                          `json:"-"`
	XXX_unrecognized     []byte                            `json:"-"`
	XXX_sizecache        int32                             `json:"-"`
}

Artifact properties we can filter by

func (*ArtifactPropertyFilter) Descriptor 

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

func (*ArtifactPropertyFilter) GetArtifactId 

func (m *ArtifactPropertyFilter) GetArtifactId() string

func (*ArtifactPropertyFilter) GetProperty 

func (m *ArtifactPropertyFilter) GetProperty() isArtifactPropertyFilter_Property

func (*ArtifactPropertyFilter) ProtoMessage 

func (*ArtifactPropertyFilter) ProtoMessage()

func (*ArtifactPropertyFilter) Reset 

func (m *ArtifactPropertyFilter) Reset()

func (*ArtifactPropertyFilter) String 

func (m *ArtifactPropertyFilter) String() string

func (*ArtifactPropertyFilter) XXX_DiscardUnknown 

func (m *ArtifactPropertyFilter) XXX_DiscardUnknown()

func (*ArtifactPropertyFilter) XXX_Marshal 

func (m *ArtifactPropertyFilter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ArtifactPropertyFilter) XXX_Merge 

func (m *ArtifactPropertyFilter) XXX_Merge(src proto.Message)

func (*ArtifactPropertyFilter) XXX_OneofWrappers 

func (*ArtifactPropertyFilter) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*ArtifactPropertyFilter) XXX_Size 

func (m *ArtifactPropertyFilter) XXX_Size() int

func (*ArtifactPropertyFilter) XXX_Unmarshal 

func (m *ArtifactPropertyFilter) XXX_Unmarshal(b []byte) error

type ArtifactPropertyFilter_ArtifactId 

type ArtifactPropertyFilter_ArtifactId struct {
	ArtifactId string `protobuf:"bytes,1,opt,name=artifact_id,json=artifactId,proto3,oneof"`
}

type CreateArtifactRequest 

type CreateArtifactRequest struct {
	Artifact             *Artifact `protobuf:"bytes,1,opt,name=artifact,proto3" json:"artifact,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

Request message for creating an Artifact and its associated artifact Data.

func (*CreateArtifactRequest) Descriptor 

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

func (*CreateArtifactRequest) GetArtifact 

func (m *CreateArtifactRequest) GetArtifact() *Artifact

func (*CreateArtifactRequest) ProtoMessage 

func (*CreateArtifactRequest) ProtoMessage()

func (*CreateArtifactRequest) Reset 

func (m *CreateArtifactRequest) Reset()

func (*CreateArtifactRequest) String 

func (m *CreateArtifactRequest) String() string

func (*CreateArtifactRequest) XXX_DiscardUnknown 

func (m *CreateArtifactRequest) XXX_DiscardUnknown()

func (*CreateArtifactRequest) XXX_Marshal 

func (m *CreateArtifactRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreateArtifactRequest) XXX_Merge 

func (m *CreateArtifactRequest) XXX_Merge(src proto.Message)

func (*CreateArtifactRequest) XXX_Size 

func (m *CreateArtifactRequest) XXX_Size() int

func (*CreateArtifactRequest) XXX_Unmarshal 

func (m *CreateArtifactRequest) XXX_Unmarshal(b []byte) error

type CreateArtifactResponse 

type CreateArtifactResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Response message for creating an Artifact.

func (*CreateArtifactResponse) Descriptor 

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

func (*CreateArtifactResponse) ProtoMessage 

func (*CreateArtifactResponse) ProtoMessage()

func (*CreateArtifactResponse) Reset 

func (m *CreateArtifactResponse) Reset()

func (*CreateArtifactResponse) String 

func (m *CreateArtifactResponse) String() string

func (*CreateArtifactResponse) XXX_DiscardUnknown 

func (m *CreateArtifactResponse) XXX_DiscardUnknown()

func (*CreateArtifactResponse) XXX_Marshal 

func (m *CreateArtifactResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreateArtifactResponse) XXX_Merge 

func (m *CreateArtifactResponse) XXX_Merge(src proto.Message)

func (*CreateArtifactResponse) XXX_Size 

func (m *CreateArtifactResponse) XXX_Size() int

func (*CreateArtifactResponse) XXX_Unmarshal 

func (m *CreateArtifactResponse) XXX_Unmarshal(b []byte) error

type CreateDatasetRequest 

type CreateDatasetRequest struct {
	Dataset              *Dataset `protobuf:"bytes,1,opt,name=dataset,proto3" json:"dataset,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Request message for creating a Dataset.

func (*CreateDatasetRequest) Descriptor 

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

func (*CreateDatasetRequest) GetDataset 

func (m *CreateDatasetRequest) GetDataset() *Dataset

func (*CreateDatasetRequest) ProtoMessage 

func (*CreateDatasetRequest) ProtoMessage()

func (*CreateDatasetRequest) Reset 

func (m *CreateDatasetRequest) Reset()

func (*CreateDatasetRequest) String 

func (m *CreateDatasetRequest) String() string

func (*CreateDatasetRequest) XXX_DiscardUnknown 

func (m *CreateDatasetRequest) XXX_DiscardUnknown()

func (*CreateDatasetRequest) XXX_Marshal 

func (m *CreateDatasetRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreateDatasetRequest) XXX_Merge 

func (m *CreateDatasetRequest) XXX_Merge(src proto.Message)

func (*CreateDatasetRequest) XXX_Size 

func (m *CreateDatasetRequest) XXX_Size() int

func (*CreateDatasetRequest) XXX_Unmarshal 

func (m *CreateDatasetRequest) XXX_Unmarshal(b []byte) error

type CreateDatasetResponse 

type CreateDatasetResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Response message for creating a Dataset

func (*CreateDatasetResponse) Descriptor 

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

func (*CreateDatasetResponse) ProtoMessage 

func (*CreateDatasetResponse) ProtoMessage()

func (*CreateDatasetResponse) Reset 

func (m *CreateDatasetResponse) Reset()

func (*CreateDatasetResponse) String 

func (m *CreateDatasetResponse) String() string

func (*CreateDatasetResponse) XXX_DiscardUnknown 

func (m *CreateDatasetResponse) XXX_DiscardUnknown()

func (*CreateDatasetResponse) XXX_Marshal 

func (m *CreateDatasetResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreateDatasetResponse) XXX_Merge 

func (m *CreateDatasetResponse) XXX_Merge(src proto.Message)

func (*CreateDatasetResponse) XXX_Size 

func (m *CreateDatasetResponse) XXX_Size() int

func (*CreateDatasetResponse) XXX_Unmarshal 

func (m *CreateDatasetResponse) XXX_Unmarshal(b []byte) error

type DataCatalogClient 

type DataCatalogClient interface {
	// Create a new Dataset. Datasets are unique based on the DatasetID. Datasets are logical groupings of artifacts.
	// Each dataset can have one or more artifacts
	CreateDataset(ctx context.Context, in *CreateDatasetRequest, opts ...grpc.CallOption) (*CreateDatasetResponse, error)
	// Get a Dataset by the DatasetID. This returns the Dataset with the associated metadata.
	GetDataset(ctx context.Context, in *GetDatasetRequest, opts ...grpc.CallOption) (*GetDatasetResponse, error)
	// Create an artifact and the artifact data associated with it. An artifact can be a hive partition or arbitrary
	// files or data values
	CreateArtifact(ctx context.Context, in *CreateArtifactRequest, opts ...grpc.CallOption) (*CreateArtifactResponse, error)
	// Retrieve an artifact by an identifying handle. This returns an artifact along with the artifact data.
	GetArtifact(ctx context.Context, in *GetArtifactRequest, opts ...grpc.CallOption) (*GetArtifactResponse, error)
	// Associate a tag with an artifact. Tags are unique within a Dataset.
	AddTag(ctx context.Context, in *AddTagRequest, opts ...grpc.CallOption) (*AddTagResponse, error)
	// Return a paginated list of artifacts
	ListArtifacts(ctx context.Context, in *ListArtifactsRequest, opts ...grpc.CallOption) (*ListArtifactsResponse, error)
	// Return a paginated list of datasets
	ListDatasets(ctx context.Context, in *ListDatasetsRequest, opts ...grpc.CallOption) (*ListDatasetsResponse, error)
	// Updates an existing artifact, overwriting the stored artifact data in the underlying blob storage.
	UpdateArtifact(ctx context.Context, in *UpdateArtifactRequest, opts ...grpc.CallOption) (*UpdateArtifactResponse, error)
	// Attempts to get or extend a reservation for the corresponding artifact. If one already exists
	// (ie. another entity owns the reservation) then that reservation is retrieved.
	// Once you acquire a reservation, you need to  periodically extend the reservation with an
	// identical call. If the reservation is not extended before the defined expiration, it may be
	// acquired by another task.
	// Note: We may have multiple concurrent tasks with the same signature and the same input that
	// try to populate the same artifact at the same time. Thus with reservation, only one task can
	// run at a time, until the reservation expires.
	// Note: If task A does not extend the reservation in time and the reservation expires, another
	// task B may take over the reservation, resulting in two tasks A and B running in parallel. So
	// a third task C may get the Artifact from A or B, whichever writes last.
	GetOrExtendReservation(ctx context.Context, in *GetOrExtendReservationRequest, opts ...grpc.CallOption) (*GetOrExtendReservationResponse, error)
	// Release the reservation when the task holding the spot fails so that the other tasks
	// can grab the spot.
	ReleaseReservation(ctx context.Context, in *ReleaseReservationRequest, opts ...grpc.CallOption) (*ReleaseReservationResponse, error)
}

DataCatalogClient is the client API for DataCatalog service.

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

func NewDataCatalogClient 

func NewDataCatalogClient(cc *grpc.ClientConn) DataCatalogClient

type DataCatalogServer 

type DataCatalogServer interface {
	// Create a new Dataset. Datasets are unique based on the DatasetID. Datasets are logical groupings of artifacts.
	// Each dataset can have one or more artifacts
	CreateDataset(context.Context, *CreateDatasetRequest) (*CreateDatasetResponse, error)
	// Get a Dataset by the DatasetID. This returns the Dataset with the associated metadata.
	GetDataset(context.Context, *GetDatasetRequest) (*GetDatasetResponse, error)
	// Create an artifact and the artifact data associated with it. An artifact can be a hive partition or arbitrary
	// files or data values
	CreateArtifact(context.Context, *CreateArtifactRequest) (*CreateArtifactResponse, error)
	// Retrieve an artifact by an identifying handle. This returns an artifact along with the artifact data.
	GetArtifact(context.Context, *GetArtifactRequest) (*GetArtifactResponse, error)
	// Associate a tag with an artifact. Tags are unique within a Dataset.
	AddTag(context.Context, *AddTagRequest) (*AddTagResponse, error)
	// Return a paginated list of artifacts
	ListArtifacts(context.Context, *ListArtifactsRequest) (*ListArtifactsResponse, error)
	// Return a paginated list of datasets
	ListDatasets(context.Context, *ListDatasetsRequest) (*ListDatasetsResponse, error)
	// Updates an existing artifact, overwriting the stored artifact data in the underlying blob storage.
	UpdateArtifact(context.Context, *UpdateArtifactRequest) (*UpdateArtifactResponse, error)
	// Attempts to get or extend a reservation for the corresponding artifact. If one already exists
	// (ie. another entity owns the reservation) then that reservation is retrieved.
	// Once you acquire a reservation, you need to  periodically extend the reservation with an
	// identical call. If the reservation is not extended before the defined expiration, it may be
	// acquired by another task.
	// Note: We may have multiple concurrent tasks with the same signature and the same input that
	// try to populate the same artifact at the same time. Thus with reservation, only one task can
	// run at a time, until the reservation expires.
	// Note: If task A does not extend the reservation in time and the reservation expires, another
	// task B may take over the reservation, resulting in two tasks A and B running in parallel. So
	// a third task C may get the Artifact from A or B, whichever writes last.
	GetOrExtendReservation(context.Context, *GetOrExtendReservationRequest) (*GetOrExtendReservationResponse, error)
	// Release the reservation when the task holding the spot fails so that the other tasks
	// can grab the spot.
	ReleaseReservation(context.Context, *ReleaseReservationRequest) (*ReleaseReservationResponse, error)
}

DataCatalogServer is the server API for DataCatalog service.

type Dataset 

type Dataset struct {
	Id                   *DatasetID `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Metadata             *Metadata  `protobuf:"bytes,2,opt,name=metadata,proto3" json:"metadata,omitempty"`
	PartitionKeys        []string   `protobuf:"bytes,3,rep,name=partitionKeys,proto3" json:"partitionKeys,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

Dataset message. It is uniquely identified by DatasetID.

func (*Dataset) Descriptor 

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

func (*Dataset) GetId 

func (m *Dataset) GetId() *DatasetID

func (*Dataset) GetMetadata 

func (m *Dataset) GetMetadata() *Metadata

func (*Dataset) GetPartitionKeys 

func (m *Dataset) GetPartitionKeys() []string

func (*Dataset) ProtoMessage 

func (*Dataset) ProtoMessage()

func (*Dataset) Reset 

func (m *Dataset) Reset()

func (*Dataset) String 

func (m *Dataset) String() string

func (*Dataset) XXX_DiscardUnknown 

func (m *Dataset) XXX_DiscardUnknown()

func (*Dataset) XXX_Marshal 

func (m *Dataset) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Dataset) XXX_Merge 

func (m *Dataset) XXX_Merge(src proto.Message)

func (*Dataset) XXX_Size 

func (m *Dataset) XXX_Size() int

func (*Dataset) XXX_Unmarshal 

func (m *Dataset) XXX_Unmarshal(b []byte) error

type DatasetID 

type DatasetID struct {
	Project              string   `protobuf:"bytes,1,opt,name=project,proto3" json:"project,omitempty"`
	Name                 string   `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Domain               string   `protobuf:"bytes,3,opt,name=domain,proto3" json:"domain,omitempty"`
	Version              string   `protobuf:"bytes,4,opt,name=version,proto3" json:"version,omitempty"`
	UUID                 string   `protobuf:"bytes,5,opt,name=UUID,proto3" json:"UUID,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

DatasetID message that is composed of several string fields.

func (*DatasetID) Descriptor 

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

func (*DatasetID) GetDomain 

func (m *DatasetID) GetDomain() string

func (*DatasetID) GetName 

func (m *DatasetID) GetName() string

func (*DatasetID) GetProject 

func (m *DatasetID) GetProject() string

func (*DatasetID) GetUUID 

func (m *DatasetID) GetUUID() string

func (*DatasetID) GetVersion 

func (m *DatasetID) GetVersion() string

func (*DatasetID) ProtoMessage 

func (*DatasetID) ProtoMessage()

func (*DatasetID) Reset 

func (m *DatasetID) Reset()

func (*DatasetID) String 

func (m *DatasetID) String() string

func (*DatasetID) XXX_DiscardUnknown 

func (m *DatasetID) XXX_DiscardUnknown()

func (*DatasetID) XXX_Marshal 

func (m *DatasetID) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DatasetID) XXX_Merge 

func (m *DatasetID) XXX_Merge(src proto.Message)

func (*DatasetID) XXX_Size 

func (m *DatasetID) XXX_Size() int

func (*DatasetID) XXX_Unmarshal 

func (m *DatasetID) XXX_Unmarshal(b []byte) error

type DatasetPropertyFilter 

type DatasetPropertyFilter struct {
	// Types that are valid to be assigned to Property:
	//	*DatasetPropertyFilter_Project
	//	*DatasetPropertyFilter_Name
	//	*DatasetPropertyFilter_Domain
	//	*DatasetPropertyFilter_Version
	Property             isDatasetPropertyFilter_Property `protobuf_oneof:"property"`
	XXX_NoUnkeyedLiteral struct{}                         `json:"-"`
	XXX_unrecognized     []byte                           `json:"-"`
	XXX_sizecache        int32                            `json:"-"`
}

Dataset properties we can filter by

func (*DatasetPropertyFilter) Descriptor 

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

func (*DatasetPropertyFilter) GetDomain 

func (m *DatasetPropertyFilter) GetDomain() string

func (*DatasetPropertyFilter) GetName 

func (m *DatasetPropertyFilter) GetName() string

func (*DatasetPropertyFilter) GetProject 

func (m *DatasetPropertyFilter) GetProject() string

func (*DatasetPropertyFilter) GetProperty 

func (m *DatasetPropertyFilter) GetProperty() isDatasetPropertyFilter_Property

func (*DatasetPropertyFilter) GetVersion 

func (m *DatasetPropertyFilter) GetVersion() string

func (*DatasetPropertyFilter) ProtoMessage 

func (*DatasetPropertyFilter) ProtoMessage()

func (*DatasetPropertyFilter) Reset 

func (m *DatasetPropertyFilter) Reset()

func (*DatasetPropertyFilter) String 

func (m *DatasetPropertyFilter) String() string

func (*DatasetPropertyFilter) XXX_DiscardUnknown 

func (m *DatasetPropertyFilter) XXX_DiscardUnknown()

func (*DatasetPropertyFilter) XXX_Marshal 

func (m *DatasetPropertyFilter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DatasetPropertyFilter) XXX_Merge 

func (m *DatasetPropertyFilter) XXX_Merge(src proto.Message)

func (*DatasetPropertyFilter) XXX_OneofWrappers 

func (*DatasetPropertyFilter) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*DatasetPropertyFilter) XXX_Size 

func (m *DatasetPropertyFilter) XXX_Size() int

func (*DatasetPropertyFilter) XXX_Unmarshal 

func (m *DatasetPropertyFilter) XXX_Unmarshal(b []byte) error

type DatasetPropertyFilter_Domain 

type DatasetPropertyFilter_Domain struct {
	Domain string `protobuf:"bytes,3,opt,name=domain,proto3,oneof"`
}

type DatasetPropertyFilter_Name 

type DatasetPropertyFilter_Name struct {
	Name string `protobuf:"bytes,2,opt,name=name,proto3,oneof"`
}

type DatasetPropertyFilter_Project 

type DatasetPropertyFilter_Project struct {
	Project string `protobuf:"bytes,1,opt,name=project,proto3,oneof"`
}

type DatasetPropertyFilter_Version 

type DatasetPropertyFilter_Version struct {
	Version string `protobuf:"bytes,4,opt,name=version,proto3,oneof"`
}

type FilterExpression 

type FilterExpression struct {
	Filters              []*SinglePropertyFilter `protobuf:"bytes,1,rep,name=filters,proto3" json:"filters,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                `json:"-"`
	XXX_unrecognized     []byte                  `json:"-"`
	XXX_sizecache        int32                   `json:"-"`
}

Filter expression that is composed of a combination of single filters

func (*FilterExpression) Descriptor 

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

func (*FilterExpression) GetFilters 

func (m *FilterExpression) GetFilters() []*SinglePropertyFilter

func (*FilterExpression) ProtoMessage 

func (*FilterExpression) ProtoMessage()

func (*FilterExpression) Reset 

func (m *FilterExpression) Reset()

func (*FilterExpression) String 

func (m *FilterExpression) String() string

func (*FilterExpression) XXX_DiscardUnknown 

func (m *FilterExpression) XXX_DiscardUnknown()

func (*FilterExpression) XXX_Marshal 

func (m *FilterExpression) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FilterExpression) XXX_Merge 

func (m *FilterExpression) XXX_Merge(src proto.Message)

func (*FilterExpression) XXX_Size 

func (m *FilterExpression) XXX_Size() int

func (*FilterExpression) XXX_Unmarshal 

func (m *FilterExpression) XXX_Unmarshal(b []byte) error

type GetArtifactRequest 

type GetArtifactRequest struct {
	Dataset *DatasetID `protobuf:"bytes,1,opt,name=dataset,proto3" json:"dataset,omitempty"`
	// Types that are valid to be assigned to QueryHandle:
	//	*GetArtifactRequest_ArtifactId
	//	*GetArtifactRequest_TagName
	QueryHandle          isGetArtifactRequest_QueryHandle `protobuf_oneof:"query_handle"`
	XXX_NoUnkeyedLiteral struct{}                         `json:"-"`
	XXX_unrecognized     []byte                           `json:"-"`
	XXX_sizecache        int32                            `json:"-"`
}

Request message for retrieving an Artifact. Retrieve an artifact based on a query handle that can be one of artifact_id or tag. The result returned will include the artifact data and metadata associated with the artifact.

func (*GetArtifactRequest) Descriptor 

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

func (*GetArtifactRequest) GetArtifactId 

func (m *GetArtifactRequest) GetArtifactId() string

func (*GetArtifactRequest) GetDataset 

func (m *GetArtifactRequest) GetDataset() *DatasetID

func (*GetArtifactRequest) GetQueryHandle 

func (m *GetArtifactRequest) GetQueryHandle() isGetArtifactRequest_QueryHandle

func (*GetArtifactRequest) GetTagName 

func (m *GetArtifactRequest) GetTagName() string

func (*GetArtifactRequest) ProtoMessage 

func (*GetArtifactRequest) ProtoMessage()

func (*GetArtifactRequest) Reset 

func (m *GetArtifactRequest) Reset()

func (*GetArtifactRequest) String 

func (m *GetArtifactRequest) String() string

func (*GetArtifactRequest) XXX_DiscardUnknown 

func (m *GetArtifactRequest) XXX_DiscardUnknown()

func (*GetArtifactRequest) XXX_Marshal 

func (m *GetArtifactRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetArtifactRequest) XXX_Merge 

func (m *GetArtifactRequest) XXX_Merge(src proto.Message)

func (*GetArtifactRequest) XXX_OneofWrappers 

func (*GetArtifactRequest) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*GetArtifactRequest) XXX_Size 

func (m *GetArtifactRequest) XXX_Size() int

func (*GetArtifactRequest) XXX_Unmarshal 

func (m *GetArtifactRequest) XXX_Unmarshal(b []byte) error

type GetArtifactRequest_ArtifactId 

type GetArtifactRequest_ArtifactId struct {
	ArtifactId string `protobuf:"bytes,2,opt,name=artifact_id,json=artifactId,proto3,oneof"`
}

type GetArtifactRequest_TagName 

type GetArtifactRequest_TagName struct {
	TagName string `protobuf:"bytes,3,opt,name=tag_name,json=tagName,proto3,oneof"`
}

type GetArtifactResponse 

type GetArtifactResponse struct {
	Artifact             *Artifact `protobuf:"bytes,1,opt,name=artifact,proto3" json:"artifact,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

Response message for retrieving an Artifact. The result returned will include the artifact data and metadata associated with the artifact.

func (*GetArtifactResponse) Descriptor 

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

func (*GetArtifactResponse) GetArtifact 

func (m *GetArtifactResponse) GetArtifact() *Artifact

func (*GetArtifactResponse) ProtoMessage 

func (*GetArtifactResponse) ProtoMessage()

func (*GetArtifactResponse) Reset 

func (m *GetArtifactResponse) Reset()

func (*GetArtifactResponse) String 

func (m *GetArtifactResponse) String() string

func (*GetArtifactResponse) XXX_DiscardUnknown 

func (m *GetArtifactResponse) XXX_DiscardUnknown()

func (*GetArtifactResponse) XXX_Marshal 

func (m *GetArtifactResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetArtifactResponse) XXX_Merge 

func (m *GetArtifactResponse) XXX_Merge(src proto.Message)

func (*GetArtifactResponse) XXX_Size 

func (m *GetArtifactResponse) XXX_Size() int

func (*GetArtifactResponse) XXX_Unmarshal 

func (m *GetArtifactResponse) XXX_Unmarshal(b []byte) error

type GetDatasetRequest 

type GetDatasetRequest struct {
	Dataset              *DatasetID `protobuf:"bytes,1,opt,name=dataset,proto3" json:"dataset,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

Request message for retrieving a Dataset. The Dataset is retrieved by it's unique identifier which is a combination of several fields.

func (*GetDatasetRequest) Descriptor 

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

func (*GetDatasetRequest) GetDataset 

func (m *GetDatasetRequest) GetDataset() *DatasetID

func (*GetDatasetRequest) ProtoMessage 

func (*GetDatasetRequest) ProtoMessage()

func (*GetDatasetRequest) Reset 

func (m *GetDatasetRequest) Reset()

func (*GetDatasetRequest) String 

func (m *GetDatasetRequest) String() string

func (*GetDatasetRequest) XXX_DiscardUnknown 

func (m *GetDatasetRequest) XXX_DiscardUnknown()

func (*GetDatasetRequest) XXX_Marshal 

func (m *GetDatasetRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetDatasetRequest) XXX_Merge 

func (m *GetDatasetRequest) XXX_Merge(src proto.Message)

func (*GetDatasetRequest) XXX_Size 

func (m *GetDatasetRequest) XXX_Size() int

func (*GetDatasetRequest) XXX_Unmarshal 

func (m *GetDatasetRequest) XXX_Unmarshal(b []byte) error

type GetDatasetResponse 

type GetDatasetResponse struct {
	Dataset              *Dataset `protobuf:"bytes,1,opt,name=dataset,proto3" json:"dataset,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Response message for retrieving a Dataset. The response will include the metadata for the Dataset.

func (*GetDatasetResponse) Descriptor 

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

func (*GetDatasetResponse) GetDataset 

func (m *GetDatasetResponse) GetDataset() *Dataset

func (*GetDatasetResponse) ProtoMessage 

func (*GetDatasetResponse) ProtoMessage()

func (*GetDatasetResponse) Reset 

func (m *GetDatasetResponse) Reset()

func (*GetDatasetResponse) String 

func (m *GetDatasetResponse) String() string

func (*GetDatasetResponse) XXX_DiscardUnknown 

func (m *GetDatasetResponse) XXX_DiscardUnknown()

func (*GetDatasetResponse) XXX_Marshal 

func (m *GetDatasetResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetDatasetResponse) XXX_Merge 

func (m *GetDatasetResponse) XXX_Merge(src proto.Message)

func (*GetDatasetResponse) XXX_Size 

func (m *GetDatasetResponse) XXX_Size() int

func (*GetDatasetResponse) XXX_Unmarshal 

func (m *GetDatasetResponse) XXX_Unmarshal(b []byte) error

type GetOrExtendReservationRequest 

type GetOrExtendReservationRequest struct {
	// The unique ID for the reservation
	ReservationId *ReservationID `protobuf:"bytes,1,opt,name=reservation_id,json=reservationId,proto3" json:"reservation_id,omitempty"`
	// The unique ID of the owner for the reservation
	OwnerId string `protobuf:"bytes,2,opt,name=owner_id,json=ownerId,proto3" json:"owner_id,omitempty"`
	// Requested reservation extension heartbeat interval
	HeartbeatInterval    *duration.Duration `protobuf:"bytes,3,opt,name=heartbeat_interval,json=heartbeatInterval,proto3" json:"heartbeat_interval,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

Try to acquire or extend an artifact reservation. If an active reservation exists, retrieve that instance.

func (*GetOrExtendReservationRequest) Descriptor 

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

func (*GetOrExtendReservationRequest) GetHeartbeatInterval 

func (m *GetOrExtendReservationRequest) GetHeartbeatInterval() *duration.Duration

func (*GetOrExtendReservationRequest) GetOwnerId 

func (m *GetOrExtendReservationRequest) GetOwnerId() string

func (*GetOrExtendReservationRequest) GetReservationId 

func (m *GetOrExtendReservationRequest) GetReservationId() *ReservationID

func (*GetOrExtendReservationRequest) ProtoMessage 

func (*GetOrExtendReservationRequest) ProtoMessage()

func (*GetOrExtendReservationRequest) Reset 

func (m *GetOrExtendReservationRequest) Reset()

func (*GetOrExtendReservationRequest) String 

func (m *GetOrExtendReservationRequest) String() string

func (*GetOrExtendReservationRequest) XXX_DiscardUnknown 

func (m *GetOrExtendReservationRequest) XXX_DiscardUnknown()

func (*GetOrExtendReservationRequest) XXX_Marshal 

func (m *GetOrExtendReservationRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetOrExtendReservationRequest) XXX_Merge 

func (m *GetOrExtendReservationRequest) XXX_Merge(src proto.Message)

func (*GetOrExtendReservationRequest) XXX_Size 

func (m *GetOrExtendReservationRequest) XXX_Size() int

func (*GetOrExtendReservationRequest) XXX_Unmarshal 

func (m *GetOrExtendReservationRequest) XXX_Unmarshal(b []byte) error

type GetOrExtendReservationResponse 

type GetOrExtendReservationResponse struct {
	// The reservation to be acquired or extended
	Reservation          *Reservation `protobuf:"bytes,1,opt,name=reservation,proto3" json:"reservation,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

Response including either a newly minted reservation or the existing reservation

func (*GetOrExtendReservationResponse) Descriptor 

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

func (*GetOrExtendReservationResponse) GetReservation 

func (m *GetOrExtendReservationResponse) GetReservation() *Reservation

func (*GetOrExtendReservationResponse) ProtoMessage 

func (*GetOrExtendReservationResponse) ProtoMessage()

func (*GetOrExtendReservationResponse) Reset 

func (m *GetOrExtendReservationResponse) Reset()

func (*GetOrExtendReservationResponse) String 

func (m *GetOrExtendReservationResponse) String() string

func (*GetOrExtendReservationResponse) XXX_DiscardUnknown 

func (m *GetOrExtendReservationResponse) XXX_DiscardUnknown()

func (*GetOrExtendReservationResponse) XXX_Marshal 

func (m *GetOrExtendReservationResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetOrExtendReservationResponse) XXX_Merge 

func (m *GetOrExtendReservationResponse) XXX_Merge(src proto.Message)

func (*GetOrExtendReservationResponse) XXX_Size 

func (m *GetOrExtendReservationResponse) XXX_Size() int

func (*GetOrExtendReservationResponse) XXX_Unmarshal 

func (m *GetOrExtendReservationResponse) XXX_Unmarshal(b []byte) error

type KeyValuePair 

type KeyValuePair struct {
	Key                  string   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value                string   `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*KeyValuePair) Descriptor 

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

func (*KeyValuePair) GetKey 

func (m *KeyValuePair) GetKey() string

func (*KeyValuePair) GetValue 

func (m *KeyValuePair) GetValue() string

func (*KeyValuePair) ProtoMessage 

func (*KeyValuePair) ProtoMessage()

func (*KeyValuePair) Reset 

func (m *KeyValuePair) Reset()

func (*KeyValuePair) String 

func (m *KeyValuePair) String() string

func (*KeyValuePair) XXX_DiscardUnknown 

func (m *KeyValuePair) XXX_DiscardUnknown()

func (*KeyValuePair) XXX_Marshal 

func (m *KeyValuePair) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*KeyValuePair) XXX_Merge 

func (m *KeyValuePair) XXX_Merge(src proto.Message)

func (*KeyValuePair) XXX_Size 

func (m *KeyValuePair) XXX_Size() int

func (*KeyValuePair) XXX_Unmarshal 

func (m *KeyValuePair) XXX_Unmarshal(b []byte) error

type ListArtifactsRequest 

type ListArtifactsRequest struct {
	// Use a datasetID for which you want to retrieve the artifacts
	Dataset *DatasetID `protobuf:"bytes,1,opt,name=dataset,proto3" json:"dataset,omitempty"`
	// Apply the filter expression to this query
	Filter *FilterExpression `protobuf:"bytes,2,opt,name=filter,proto3" json:"filter,omitempty"`
	// Pagination options to get a page of artifacts
	Pagination           *PaginationOptions `protobuf:"bytes,3,opt,name=pagination,proto3" json:"pagination,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

List the artifacts that belong to the Dataset, optionally filtered using filtered expression.

func (*ListArtifactsRequest) Descriptor 

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

func (*ListArtifactsRequest) GetDataset 

func (m *ListArtifactsRequest) GetDataset() *DatasetID

func (*ListArtifactsRequest) GetFilter 

func (m *ListArtifactsRequest) GetFilter() *FilterExpression

func (*ListArtifactsRequest) GetPagination 

func (m *ListArtifactsRequest) GetPagination() *PaginationOptions

func (*ListArtifactsRequest) ProtoMessage 

func (*ListArtifactsRequest) ProtoMessage()

func (*ListArtifactsRequest) Reset 

func (m *ListArtifactsRequest) Reset()

func (*ListArtifactsRequest) String 

func (m *ListArtifactsRequest) String() string

func (*ListArtifactsRequest) XXX_DiscardUnknown 

func (m *ListArtifactsRequest) XXX_DiscardUnknown()

func (*ListArtifactsRequest) XXX_Marshal 

func (m *ListArtifactsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListArtifactsRequest) XXX_Merge 

func (m *ListArtifactsRequest) XXX_Merge(src proto.Message)

func (*ListArtifactsRequest) XXX_Size 

func (m *ListArtifactsRequest) XXX_Size() int

func (*ListArtifactsRequest) XXX_Unmarshal 

func (m *ListArtifactsRequest) XXX_Unmarshal(b []byte) error

type ListArtifactsResponse 

type ListArtifactsResponse struct {
	// The list of artifacts
	Artifacts []*Artifact `protobuf:"bytes,1,rep,name=artifacts,proto3" json:"artifacts,omitempty"`
	// Token to use to request the next page, pass this into the next requests PaginationOptions
	NextToken            string   `protobuf:"bytes,2,opt,name=next_token,json=nextToken,proto3" json:"next_token,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Response to list artifacts

func (*ListArtifactsResponse) Descriptor 

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

func (*ListArtifactsResponse) GetArtifacts 

func (m *ListArtifactsResponse) GetArtifacts() []*Artifact

func (*ListArtifactsResponse) GetNextToken 

func (m *ListArtifactsResponse) GetNextToken() string

func (*ListArtifactsResponse) ProtoMessage 

func (*ListArtifactsResponse) ProtoMessage()

func (*ListArtifactsResponse) Reset 

func (m *ListArtifactsResponse) Reset()

func (*ListArtifactsResponse) String 

func (m *ListArtifactsResponse) String() string

func (*ListArtifactsResponse) XXX_DiscardUnknown 

func (m *ListArtifactsResponse) XXX_DiscardUnknown()

func (*ListArtifactsResponse) XXX_Marshal 

func (m *ListArtifactsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListArtifactsResponse) XXX_Merge 

func (m *ListArtifactsResponse) XXX_Merge(src proto.Message)

func (*ListArtifactsResponse) XXX_Size 

func (m *ListArtifactsResponse) XXX_Size() int

func (*ListArtifactsResponse) XXX_Unmarshal 

func (m *ListArtifactsResponse) XXX_Unmarshal(b []byte) error

type ListDatasetsRequest 

type ListDatasetsRequest struct {
	// Apply the filter expression to this query
	Filter *FilterExpression `protobuf:"bytes,1,opt,name=filter,proto3" json:"filter,omitempty"`
	// Pagination options to get a page of datasets
	Pagination           *PaginationOptions `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

List the datasets for the given query

func (*ListDatasetsRequest) Descriptor 

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

func (*ListDatasetsRequest) GetFilter 

func (m *ListDatasetsRequest) GetFilter() *FilterExpression

func (*ListDatasetsRequest) GetPagination 

func (m *ListDatasetsRequest) GetPagination() *PaginationOptions

func (*ListDatasetsRequest) ProtoMessage 

func (*ListDatasetsRequest) ProtoMessage()

func (*ListDatasetsRequest) Reset 

func (m *ListDatasetsRequest) Reset()

func (*ListDatasetsRequest) String 

func (m *ListDatasetsRequest) String() string

func (*ListDatasetsRequest) XXX_DiscardUnknown 

func (m *ListDatasetsRequest) XXX_DiscardUnknown()

func (*ListDatasetsRequest) XXX_Marshal 

func (m *ListDatasetsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListDatasetsRequest) XXX_Merge 

func (m *ListDatasetsRequest) XXX_Merge(src proto.Message)

func (*ListDatasetsRequest) XXX_Size 

func (m *ListDatasetsRequest) XXX_Size() int

func (*ListDatasetsRequest) XXX_Unmarshal 

func (m *ListDatasetsRequest) XXX_Unmarshal(b []byte) error

type ListDatasetsResponse 

type ListDatasetsResponse struct {
	// The list of datasets
	Datasets []*Dataset `protobuf:"bytes,1,rep,name=datasets,proto3" json:"datasets,omitempty"`
	// Token to use to request the next page, pass this into the next requests PaginationOptions
	NextToken            string   `protobuf:"bytes,2,opt,name=next_token,json=nextToken,proto3" json:"next_token,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

List the datasets response with token for next pagination

func (*ListDatasetsResponse) Descriptor 

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

func (*ListDatasetsResponse) GetDatasets 

func (m *ListDatasetsResponse) GetDatasets() []*Dataset

func (*ListDatasetsResponse) GetNextToken 

func (m *ListDatasetsResponse) GetNextToken() string

func (*ListDatasetsResponse) ProtoMessage 

func (*ListDatasetsResponse) ProtoMessage()

func (*ListDatasetsResponse) Reset 

func (m *ListDatasetsResponse) Reset()

func (*ListDatasetsResponse) String 

func (m *ListDatasetsResponse) String() string

func (*ListDatasetsResponse) XXX_DiscardUnknown 

func (m *ListDatasetsResponse) XXX_DiscardUnknown()

func (*ListDatasetsResponse) XXX_Marshal 

func (m *ListDatasetsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListDatasetsResponse) XXX_Merge 

func (m *ListDatasetsResponse) XXX_Merge(src proto.Message)

func (*ListDatasetsResponse) XXX_Size 

func (m *ListDatasetsResponse) XXX_Size() int

func (*ListDatasetsResponse) XXX_Unmarshal 

func (m *ListDatasetsResponse) XXX_Unmarshal(b []byte) error

type Metadata 

type Metadata struct {
	KeyMap               map[string]string `` /* 167-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

Metadata representation for artifacts and datasets

func (*Metadata) Descriptor 

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

func (*Metadata) GetKeyMap 

func (m *Metadata) GetKeyMap() map[string]string

func (*Metadata) ProtoMessage 

func (*Metadata) ProtoMessage()

func (*Metadata) Reset 

func (m *Metadata) Reset()

func (*Metadata) String 

func (m *Metadata) String() string

func (*Metadata) XXX_DiscardUnknown 

func (m *Metadata) XXX_DiscardUnknown()

func (*Metadata) XXX_Marshal 

func (m *Metadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Metadata) XXX_Merge 

func (m *Metadata) XXX_Merge(src proto.Message)

func (*Metadata) XXX_Size 

func (m *Metadata) XXX_Size() int

func (*Metadata) XXX_Unmarshal 

func (m *Metadata) XXX_Unmarshal(b []byte) error

type PaginationOptions 

type PaginationOptions struct {
	// the max number of results to return
	Limit uint32 `protobuf:"varint,1,opt,name=limit,proto3" json:"limit,omitempty"`
	// the token to pass to fetch the next page
	Token string `protobuf:"bytes,2,opt,name=token,proto3" json:"token,omitempty"`
	// the property that we want to sort the results by
	SortKey PaginationOptions_SortKey `protobuf:"varint,3,opt,name=sortKey,proto3,enum=datacatalog.PaginationOptions_SortKey" json:"sortKey,omitempty"`
	// the sort order of the results
	SortOrder            PaginationOptions_SortOrder `protobuf:"varint,4,opt,name=sortOrder,proto3,enum=datacatalog.PaginationOptions_SortOrder" json:"sortOrder,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                    `json:"-"`
	XXX_unrecognized     []byte                      `json:"-"`
	XXX_sizecache        int32                       `json:"-"`
}

Pagination options for making list requests

func (*PaginationOptions) Descriptor 

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

func (*PaginationOptions) GetLimit 

func (m *PaginationOptions) GetLimit() uint32

func (*PaginationOptions) GetSortKey 

func (m *PaginationOptions) GetSortKey() PaginationOptions_SortKey

func (*PaginationOptions) GetSortOrder 

func (m *PaginationOptions) GetSortOrder() PaginationOptions_SortOrder

func (*PaginationOptions) GetToken 

func (m *PaginationOptions) GetToken() string

func (*PaginationOptions) ProtoMessage 

func (*PaginationOptions) ProtoMessage()

func (*PaginationOptions) Reset 

func (m *PaginationOptions) Reset()

func (*PaginationOptions) String 

func (m *PaginationOptions) String() string

func (*PaginationOptions) XXX_DiscardUnknown 

func (m *PaginationOptions) XXX_DiscardUnknown()

func (*PaginationOptions) XXX_Marshal 

func (m *PaginationOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PaginationOptions) XXX_Merge 

func (m *PaginationOptions) XXX_Merge(src proto.Message)

func (*PaginationOptions) XXX_Size 

func (m *PaginationOptions) XXX_Size() int

func (*PaginationOptions) XXX_Unmarshal 

func (m *PaginationOptions) XXX_Unmarshal(b []byte) error

type PaginationOptions_SortKey 

type PaginationOptions_SortKey int32
const (
	PaginationOptions_CREATION_TIME PaginationOptions_SortKey = 0
)

func (PaginationOptions_SortKey) EnumDescriptor 

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

func (PaginationOptions_SortKey) String 

func (x PaginationOptions_SortKey) String() string

type PaginationOptions_SortOrder 

type PaginationOptions_SortOrder int32
const (
	PaginationOptions_DESCENDING PaginationOptions_SortOrder = 0
	PaginationOptions_ASCENDING  PaginationOptions_SortOrder = 1
)

func (PaginationOptions_SortOrder) EnumDescriptor 

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

func (PaginationOptions_SortOrder) String 

func (x PaginationOptions_SortOrder) String() string

type Partition 

type Partition struct {
	Key                  string   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value                string   `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

An artifact could have multiple partitions and each partition can have an arbitrary string key/value pair

func (*Partition) Descriptor 

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

func (*Partition) GetKey 

func (m *Partition) GetKey() string

func (*Partition) GetValue 

func (m *Partition) GetValue() string

func (*Partition) ProtoMessage 

func (*Partition) ProtoMessage()

func (*Partition) Reset 

func (m *Partition) Reset()

func (*Partition) String 

func (m *Partition) String() string

func (*Partition) XXX_DiscardUnknown 

func (m *Partition) XXX_DiscardUnknown()

func (*Partition) XXX_Marshal 

func (m *Partition) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Partition) XXX_Merge 

func (m *Partition) XXX_Merge(src proto.Message)

func (*Partition) XXX_Size 

func (m *Partition) XXX_Size() int

func (*Partition) XXX_Unmarshal 

func (m *Partition) XXX_Unmarshal(b []byte) error

type PartitionPropertyFilter 

type PartitionPropertyFilter struct {
	// Types that are valid to be assigned to Property:
	//	*PartitionPropertyFilter_KeyVal
	Property             isPartitionPropertyFilter_Property `protobuf_oneof:"property"`
	XXX_NoUnkeyedLiteral struct{}                           `json:"-"`
	XXX_unrecognized     []byte                             `json:"-"`
	XXX_sizecache        int32                              `json:"-"`
}

Partition properties we can filter by

func (*PartitionPropertyFilter) Descriptor 

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

func (*PartitionPropertyFilter) GetKeyVal 

func (m *PartitionPropertyFilter) GetKeyVal() *KeyValuePair

func (*PartitionPropertyFilter) GetProperty 

func (m *PartitionPropertyFilter) GetProperty() isPartitionPropertyFilter_Property

func (*PartitionPropertyFilter) ProtoMessage 

func (*PartitionPropertyFilter) ProtoMessage()

func (*PartitionPropertyFilter) Reset 

func (m *PartitionPropertyFilter) Reset()

func (*PartitionPropertyFilter) String 

func (m *PartitionPropertyFilter) String() string

func (*PartitionPropertyFilter) XXX_DiscardUnknown 

func (m *PartitionPropertyFilter) XXX_DiscardUnknown()

func (*PartitionPropertyFilter) XXX_Marshal 

func (m *PartitionPropertyFilter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PartitionPropertyFilter) XXX_Merge 

func (m *PartitionPropertyFilter) XXX_Merge(src proto.Message)

func (*PartitionPropertyFilter) XXX_OneofWrappers 

func (*PartitionPropertyFilter) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*PartitionPropertyFilter) XXX_Size 

func (m *PartitionPropertyFilter) XXX_Size() int

func (*PartitionPropertyFilter) XXX_Unmarshal 

func (m *PartitionPropertyFilter) XXX_Unmarshal(b []byte) error

type PartitionPropertyFilter_KeyVal 

type PartitionPropertyFilter_KeyVal struct {
	KeyVal *KeyValuePair `protobuf:"bytes,1,opt,name=key_val,json=keyVal,proto3,oneof"`
}

type ReleaseReservationRequest 

type ReleaseReservationRequest struct {
	// The unique ID for the reservation
	ReservationId *ReservationID `protobuf:"bytes,1,opt,name=reservation_id,json=reservationId,proto3" json:"reservation_id,omitempty"`
	// The unique ID of the owner for the reservation
	OwnerId              string   `protobuf:"bytes,2,opt,name=owner_id,json=ownerId,proto3" json:"owner_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Request to release reservation

func (*ReleaseReservationRequest) Descriptor 

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

func (*ReleaseReservationRequest) GetOwnerId 

func (m *ReleaseReservationRequest) GetOwnerId() string

func (*ReleaseReservationRequest) GetReservationId 

func (m *ReleaseReservationRequest) GetReservationId() *ReservationID

func (*ReleaseReservationRequest) ProtoMessage 

func (*ReleaseReservationRequest) ProtoMessage()

func (*ReleaseReservationRequest) Reset 

func (m *ReleaseReservationRequest) Reset()

func (*ReleaseReservationRequest) String 

func (m *ReleaseReservationRequest) String() string

func (*ReleaseReservationRequest) XXX_DiscardUnknown 

func (m *ReleaseReservationRequest) XXX_DiscardUnknown()

func (*ReleaseReservationRequest) XXX_Marshal 

func (m *ReleaseReservationRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReleaseReservationRequest) XXX_Merge 

func (m *ReleaseReservationRequest) XXX_Merge(src proto.Message)

func (*ReleaseReservationRequest) XXX_Size 

func (m *ReleaseReservationRequest) XXX_Size() int

func (*ReleaseReservationRequest) XXX_Unmarshal 

func (m *ReleaseReservationRequest) XXX_Unmarshal(b []byte) error

type ReleaseReservationResponse 

type ReleaseReservationResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Response to release reservation

func (*ReleaseReservationResponse) Descriptor 

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

func (*ReleaseReservationResponse) ProtoMessage 

func (*ReleaseReservationResponse) ProtoMessage()

func (*ReleaseReservationResponse) Reset 

func (m *ReleaseReservationResponse) Reset()

func (*ReleaseReservationResponse) String 

func (m *ReleaseReservationResponse) String() string

func (*ReleaseReservationResponse) XXX_DiscardUnknown 

func (m *ReleaseReservationResponse) XXX_DiscardUnknown()

func (*ReleaseReservationResponse) XXX_Marshal 

func (m *ReleaseReservationResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReleaseReservationResponse) XXX_Merge 

func (m *ReleaseReservationResponse) XXX_Merge(src proto.Message)

func (*ReleaseReservationResponse) XXX_Size 

func (m *ReleaseReservationResponse) XXX_Size() int

func (*ReleaseReservationResponse) XXX_Unmarshal 

func (m *ReleaseReservationResponse) XXX_Unmarshal(b []byte) error

type Reservation 

type Reservation struct {
	// The unique ID for the reservation
	ReservationId *ReservationID `protobuf:"bytes,1,opt,name=reservation_id,json=reservationId,proto3" json:"reservation_id,omitempty"`
	// The unique ID of the owner for the reservation
	OwnerId string `protobuf:"bytes,2,opt,name=owner_id,json=ownerId,proto3" json:"owner_id,omitempty"`
	// Recommended heartbeat interval to extend reservation
	HeartbeatInterval *duration.Duration `protobuf:"bytes,3,opt,name=heartbeat_interval,json=heartbeatInterval,proto3" json:"heartbeat_interval,omitempty"`
	// Expiration timestamp of this reservation
	ExpiresAt *timestamp.Timestamp `protobuf:"bytes,4,opt,name=expires_at,json=expiresAt,proto3" json:"expires_at,omitempty"`
	// Free-form metadata associated with the artifact
	Metadata             *Metadata `protobuf:"bytes,6,opt,name=metadata,proto3" json:"metadata,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

A reservation including owner, heartbeat interval, expiration timestamp, and various metadata.

func (*Reservation) Descriptor 

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

func (*Reservation) GetExpiresAt 

func (m *Reservation) GetExpiresAt() *timestamp.Timestamp

func (*Reservation) GetHeartbeatInterval 

func (m *Reservation) GetHeartbeatInterval() *duration.Duration

func (*Reservation) GetMetadata 

func (m *Reservation) GetMetadata() *Metadata

func (*Reservation) GetOwnerId 

func (m *Reservation) GetOwnerId() string

func (*Reservation) GetReservationId 

func (m *Reservation) GetReservationId() *ReservationID

func (*Reservation) ProtoMessage 

func (*Reservation) ProtoMessage()

func (*Reservation) Reset 

func (m *Reservation) Reset()

func (*Reservation) String 

func (m *Reservation) String() string

func (*Reservation) XXX_DiscardUnknown 

func (m *Reservation) XXX_DiscardUnknown()

func (*Reservation) XXX_Marshal 

func (m *Reservation) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Reservation) XXX_Merge 

func (m *Reservation) XXX_Merge(src proto.Message)

func (*Reservation) XXX_Size 

func (m *Reservation) XXX_Size() int

func (*Reservation) XXX_Unmarshal 

func (m *Reservation) XXX_Unmarshal(b []byte) error

type ReservationID 

type ReservationID struct {
	// The unique ID for the reserved dataset
	DatasetId *DatasetID `protobuf:"bytes,1,opt,name=dataset_id,json=datasetId,proto3" json:"dataset_id,omitempty"`
	// The specific artifact tag for the reservation
	TagName              string   `protobuf:"bytes,2,opt,name=tag_name,json=tagName,proto3" json:"tag_name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

ReservationID message that is composed of several string fields.

func (*ReservationID) Descriptor 

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

func (*ReservationID) GetDatasetId 

func (m *ReservationID) GetDatasetId() *DatasetID

func (*ReservationID) GetTagName 

func (m *ReservationID) GetTagName() string

func (*ReservationID) ProtoMessage 

func (*ReservationID) ProtoMessage()

func (*ReservationID) Reset 

func (m *ReservationID) Reset()

func (*ReservationID) String 

func (m *ReservationID) String() string

func (*ReservationID) XXX_DiscardUnknown 

func (m *ReservationID) XXX_DiscardUnknown()

func (*ReservationID) XXX_Marshal 

func (m *ReservationID) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReservationID) XXX_Merge 

func (m *ReservationID) XXX_Merge(src proto.Message)

func (*ReservationID) XXX_Size 

func (m *ReservationID) XXX_Size() int

func (*ReservationID) XXX_Unmarshal 

func (m *ReservationID) XXX_Unmarshal(b []byte) error

type SinglePropertyFilter 

type SinglePropertyFilter struct {
	// Types that are valid to be assigned to PropertyFilter:
	//	*SinglePropertyFilter_TagFilter
	//	*SinglePropertyFilter_PartitionFilter
	//	*SinglePropertyFilter_ArtifactFilter
	//	*SinglePropertyFilter_DatasetFilter
	PropertyFilter       isSinglePropertyFilter_PropertyFilter   `protobuf_oneof:"property_filter"`
	Operator             SinglePropertyFilter_ComparisonOperator `` /* 128-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                                `json:"-"`
	XXX_unrecognized     []byte                                  `json:"-"`
	XXX_sizecache        int32                                   `json:"-"`
}

A single property to filter on.

func (*SinglePropertyFilter) Descriptor 

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

func (*SinglePropertyFilter) GetArtifactFilter 

func (m *SinglePropertyFilter) GetArtifactFilter() *ArtifactPropertyFilter

func (*SinglePropertyFilter) GetDatasetFilter 

func (m *SinglePropertyFilter) GetDatasetFilter() *DatasetPropertyFilter

func (*SinglePropertyFilter) GetOperator 

func (m *SinglePropertyFilter) GetOperator() SinglePropertyFilter_ComparisonOperator

func (*SinglePropertyFilter) GetPartitionFilter 

func (m *SinglePropertyFilter) GetPartitionFilter() *PartitionPropertyFilter

func (*SinglePropertyFilter) GetPropertyFilter 

func (m *SinglePropertyFilter) GetPropertyFilter() isSinglePropertyFilter_PropertyFilter

func (*SinglePropertyFilter) GetTagFilter 

func (m *SinglePropertyFilter) GetTagFilter() *TagPropertyFilter

func (*SinglePropertyFilter) ProtoMessage 

func (*SinglePropertyFilter) ProtoMessage()

func (*SinglePropertyFilter) Reset 

func (m *SinglePropertyFilter) Reset()

func (*SinglePropertyFilter) String 

func (m *SinglePropertyFilter) String() string

func (*SinglePropertyFilter) XXX_DiscardUnknown 

func (m *SinglePropertyFilter) XXX_DiscardUnknown()

func (*SinglePropertyFilter) XXX_Marshal 

func (m *SinglePropertyFilter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SinglePropertyFilter) XXX_Merge 

func (m *SinglePropertyFilter) XXX_Merge(src proto.Message)

func (*SinglePropertyFilter) XXX_OneofWrappers 

func (*SinglePropertyFilter) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*SinglePropertyFilter) XXX_Size 

func (m *SinglePropertyFilter) XXX_Size() int

func (*SinglePropertyFilter) XXX_Unmarshal 

func (m *SinglePropertyFilter) XXX_Unmarshal(b []byte) error

type SinglePropertyFilter_ArtifactFilter 

type SinglePropertyFilter_ArtifactFilter struct {
	ArtifactFilter *ArtifactPropertyFilter `protobuf:"bytes,3,opt,name=artifact_filter,json=artifactFilter,proto3,oneof"`
}

type SinglePropertyFilter_ComparisonOperator 

type SinglePropertyFilter_ComparisonOperator int32

as use-cases come up we can add more operators, ex: gte, like, not eq etc. 

const (
	SinglePropertyFilter_EQUALS SinglePropertyFilter_ComparisonOperator = 0
)

func (SinglePropertyFilter_ComparisonOperator) EnumDescriptor 

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

func (SinglePropertyFilter_ComparisonOperator) String 

func (x SinglePropertyFilter_ComparisonOperator) String() string

type SinglePropertyFilter_DatasetFilter 

type SinglePropertyFilter_DatasetFilter struct {
	DatasetFilter *DatasetPropertyFilter `protobuf:"bytes,4,opt,name=dataset_filter,json=datasetFilter,proto3,oneof"`
}

type SinglePropertyFilter_PartitionFilter 

type SinglePropertyFilter_PartitionFilter struct {
	PartitionFilter *PartitionPropertyFilter `protobuf:"bytes,2,opt,name=partition_filter,json=partitionFilter,proto3,oneof"`
}

type SinglePropertyFilter_TagFilter 

type SinglePropertyFilter_TagFilter struct {
	TagFilter *TagPropertyFilter `protobuf:"bytes,1,opt,name=tag_filter,json=tagFilter,proto3,oneof"`
}

type Tag 

type Tag struct {
	Name                 string     `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	ArtifactId           string     `protobuf:"bytes,2,opt,name=artifact_id,json=artifactId,proto3" json:"artifact_id,omitempty"`
	Dataset              *DatasetID `protobuf:"bytes,3,opt,name=dataset,proto3" json:"dataset,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

Tag message that is unique to a Dataset. It is associated to a single artifact and can be retrieved by name later.

func (*Tag) Descriptor 

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

func (*Tag) GetArtifactId 

func (m *Tag) GetArtifactId() string

func (*Tag) GetDataset 

func (m *Tag) GetDataset() *DatasetID

func (*Tag) GetName 

func (m *Tag) GetName() string

func (*Tag) ProtoMessage 

func (*Tag) ProtoMessage()

func (*Tag) Reset 

func (m *Tag) Reset()

func (*Tag) String 

func (m *Tag) String() string

func (*Tag) XXX_DiscardUnknown 

func (m *Tag) XXX_DiscardUnknown()

func (*Tag) XXX_Marshal 

func (m *Tag) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Tag) XXX_Merge 

func (m *Tag) XXX_Merge(src proto.Message)

func (*Tag) XXX_Size 

func (m *Tag) XXX_Size() int

func (*Tag) XXX_Unmarshal 

func (m *Tag) XXX_Unmarshal(b []byte) error

type TagPropertyFilter 

type TagPropertyFilter struct {
	// Types that are valid to be assigned to Property:
	//	*TagPropertyFilter_TagName
	Property             isTagPropertyFilter_Property `protobuf_oneof:"property"`
	XXX_NoUnkeyedLiteral struct{}                     `json:"-"`
	XXX_unrecognized     []byte                       `json:"-"`
	XXX_sizecache        int32                        `json:"-"`
}

Tag properties we can filter by

func (*TagPropertyFilter) Descriptor 

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

func (*TagPropertyFilter) GetProperty 

func (m *TagPropertyFilter) GetProperty() isTagPropertyFilter_Property

func (*TagPropertyFilter) GetTagName 

func (m *TagPropertyFilter) GetTagName() string

func (*TagPropertyFilter) ProtoMessage 

func (*TagPropertyFilter) ProtoMessage()

func (*TagPropertyFilter) Reset 

func (m *TagPropertyFilter) Reset()

func (*TagPropertyFilter) String 

func (m *TagPropertyFilter) String() string

func (*TagPropertyFilter) XXX_DiscardUnknown 

func (m *TagPropertyFilter) XXX_DiscardUnknown()

func (*TagPropertyFilter) XXX_Marshal 

func (m *TagPropertyFilter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TagPropertyFilter) XXX_Merge 

func (m *TagPropertyFilter) XXX_Merge(src proto.Message)

func (*TagPropertyFilter) XXX_OneofWrappers 

func (*TagPropertyFilter) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*TagPropertyFilter) XXX_Size 

func (m *TagPropertyFilter) XXX_Size() int

func (*TagPropertyFilter) XXX_Unmarshal 

func (m *TagPropertyFilter) XXX_Unmarshal(b []byte) error

type TagPropertyFilter_TagName 

type TagPropertyFilter_TagName struct {
	TagName string `protobuf:"bytes,1,opt,name=tag_name,json=tagName,proto3,oneof"`
}

type UnimplementedDataCatalogServer 

type UnimplementedDataCatalogServer struct {
}

UnimplementedDataCatalogServer can be embedded to have forward compatible implementations.

func (*UnimplementedDataCatalogServer) AddTag 

func (*UnimplementedDataCatalogServer) AddTag(ctx context.Context, req *AddTagRequest) (*AddTagResponse, error)

func (*UnimplementedDataCatalogServer) CreateArtifact 

func (*UnimplementedDataCatalogServer) CreateArtifact(ctx context.Context, req *CreateArtifactRequest) (*CreateArtifactResponse, error)

func (*UnimplementedDataCatalogServer) CreateDataset 

func (*UnimplementedDataCatalogServer) CreateDataset(ctx context.Context, req *CreateDatasetRequest) (*CreateDatasetResponse, error)

func (*UnimplementedDataCatalogServer) GetArtifact 

func (*UnimplementedDataCatalogServer) GetArtifact(ctx context.Context, req *GetArtifactRequest) (*GetArtifactResponse, error)

func (*UnimplementedDataCatalogServer) GetDataset 

func (*UnimplementedDataCatalogServer) GetDataset(ctx context.Context, req *GetDatasetRequest) (*GetDatasetResponse, error)

func (*UnimplementedDataCatalogServer) GetOrExtendReservation 

func (*UnimplementedDataCatalogServer) GetOrExtendReservation(ctx context.Context, req *GetOrExtendReservationRequest) (*GetOrExtendReservationResponse, error)

func (*UnimplementedDataCatalogServer) ListArtifacts 

func (*UnimplementedDataCatalogServer) ListArtifacts(ctx context.Context, req *ListArtifactsRequest) (*ListArtifactsResponse, error)

func (*UnimplementedDataCatalogServer) ListDatasets 

func (*UnimplementedDataCatalogServer) ListDatasets(ctx context.Context, req *ListDatasetsRequest) (*ListDatasetsResponse, error)

func (*UnimplementedDataCatalogServer) ReleaseReservation 

func (*UnimplementedDataCatalogServer) ReleaseReservation(ctx context.Context, req *ReleaseReservationRequest) (*ReleaseReservationResponse, error)

func (*UnimplementedDataCatalogServer) UpdateArtifact 

func (*UnimplementedDataCatalogServer) UpdateArtifact(ctx context.Context, req *UpdateArtifactRequest) (*UpdateArtifactResponse, error)

type UpdateArtifactRequest 

type UpdateArtifactRequest struct {
	// ID of dataset the artifact is associated with
	Dataset *DatasetID `protobuf:"bytes,1,opt,name=dataset,proto3" json:"dataset,omitempty"`
	// Either ID of artifact or name of tag to retrieve existing artifact from
	//
	// Types that are valid to be assigned to QueryHandle:
	//	*UpdateArtifactRequest_ArtifactId
	//	*UpdateArtifactRequest_TagName
	QueryHandle isUpdateArtifactRequest_QueryHandle `protobuf_oneof:"query_handle"`
	// List of data to overwrite stored artifact data with. Must contain ALL data for updated Artifact as any missing
	// ArtifactData entries will be removed from the underlying blob storage and database.
	Data []*ArtifactData `protobuf:"bytes,4,rep,name=data,proto3" json:"data,omitempty"`
	// Update execution metadata(including execution domain, name, node, project data) when overwriting cache
	Metadata             *Metadata `protobuf:"bytes,5,opt,name=metadata,proto3" json:"metadata,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

Request message for updating an Artifact and overwriting its associated ArtifactData.

func (*UpdateArtifactRequest) Descriptor 

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

func (*UpdateArtifactRequest) GetArtifactId 

func (m *UpdateArtifactRequest) GetArtifactId() string

func (*UpdateArtifactRequest) GetData 

func (m *UpdateArtifactRequest) GetData() []*ArtifactData

func (*UpdateArtifactRequest) GetDataset 

func (m *UpdateArtifactRequest) GetDataset() *DatasetID

func (*UpdateArtifactRequest) GetMetadata added in v1.10.7 

func (m *UpdateArtifactRequest) GetMetadata() *Metadata

func (*UpdateArtifactRequest) GetQueryHandle 

func (m *UpdateArtifactRequest) GetQueryHandle() isUpdateArtifactRequest_QueryHandle

func (*UpdateArtifactRequest) GetTagName 

func (m *UpdateArtifactRequest) GetTagName() string

func (*UpdateArtifactRequest) ProtoMessage 

func (*UpdateArtifactRequest) ProtoMessage()

func (*UpdateArtifactRequest) Reset 

func (m *UpdateArtifactRequest) Reset()

func (*UpdateArtifactRequest) String 

func (m *UpdateArtifactRequest) String() string

func (*UpdateArtifactRequest) XXX_DiscardUnknown 

func (m *UpdateArtifactRequest) XXX_DiscardUnknown()

func (*UpdateArtifactRequest) XXX_Marshal 

func (m *UpdateArtifactRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UpdateArtifactRequest) XXX_Merge 

func (m *UpdateArtifactRequest) XXX_Merge(src proto.Message)

func (*UpdateArtifactRequest) XXX_OneofWrappers 

func (*UpdateArtifactRequest) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*UpdateArtifactRequest) XXX_Size 

func (m *UpdateArtifactRequest) XXX_Size() int

func (*UpdateArtifactRequest) XXX_Unmarshal 

func (m *UpdateArtifactRequest) XXX_Unmarshal(b []byte) error

type UpdateArtifactRequest_ArtifactId 

type UpdateArtifactRequest_ArtifactId struct {
	ArtifactId string `protobuf:"bytes,2,opt,name=artifact_id,json=artifactId,proto3,oneof"`
}

type UpdateArtifactRequest_TagName 

type UpdateArtifactRequest_TagName struct {
	TagName string `protobuf:"bytes,3,opt,name=tag_name,json=tagName,proto3,oneof"`
}

type UpdateArtifactResponse 

type UpdateArtifactResponse struct {
	// The unique ID of the artifact updated
	ArtifactId           string   `protobuf:"bytes,1,opt,name=artifact_id,json=artifactId,proto3" json:"artifact_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Response message for updating an Artifact.

func (*UpdateArtifactResponse) Descriptor 

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

func (*UpdateArtifactResponse) GetArtifactId 

func (m *UpdateArtifactResponse) GetArtifactId() string

func (*UpdateArtifactResponse) ProtoMessage 

func (*UpdateArtifactResponse) ProtoMessage()

func (*UpdateArtifactResponse) Reset 

func (m *UpdateArtifactResponse) Reset()

func (*UpdateArtifactResponse) String 

func (m *UpdateArtifactResponse) String() string

func (*UpdateArtifactResponse) XXX_DiscardUnknown 

func (m *UpdateArtifactResponse) XXX_DiscardUnknown()

func (*UpdateArtifactResponse) XXX_Marshal 

func (m *UpdateArtifactResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UpdateArtifactResponse) XXX_Merge 

func (m *UpdateArtifactResponse) XXX_Merge(src proto.Message)

func (*UpdateArtifactResponse) XXX_Size 

func (m *UpdateArtifactResponse) XXX_Size() int

func (*UpdateArtifactResponse) XXX_Unmarshal 

func (m *UpdateArtifactResponse) XXX_Unmarshal(b []byte) error

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.