datacatalog

package
v1.0.15 Latest Latest
Warning

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

Go to latest
Published: Apr 20, 2023 License: Apache-2.0 Imports: 20 Imported by: 0

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) Validate

func (m *AddTagRequest) Validate() error

Validate checks the field values on AddTagRequest with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

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 AddTagRequestValidationError

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

AddTagRequestValidationError is the validation error returned by AddTagRequest.Validate if the designated constraints aren't met.

func (AddTagRequestValidationError) Cause

Cause function returns cause value.

func (AddTagRequestValidationError) Error

Error satisfies the builtin error interface

func (AddTagRequestValidationError) ErrorName

func (e AddTagRequestValidationError) ErrorName() string

ErrorName returns error name.

func (AddTagRequestValidationError) Field

Field function returns field value.

func (AddTagRequestValidationError) Key

Key function returns key value.

func (AddTagRequestValidationError) Reason

Reason function returns reason value.

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) Validate

func (m *AddTagResponse) Validate() error

Validate checks the field values on AddTagResponse with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

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 AddTagResponseValidationError

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

AddTagResponseValidationError is the validation error returned by AddTagResponse.Validate if the designated constraints aren't met.

func (AddTagResponseValidationError) Cause

Cause function returns cause value.

func (AddTagResponseValidationError) Error

Error satisfies the builtin error interface

func (AddTagResponseValidationError) ErrorName

func (e AddTagResponseValidationError) ErrorName() string

ErrorName returns error name.

func (AddTagResponseValidationError) Field

Field function returns field value.

func (AddTagResponseValidationError) Key

Key function returns key value.

func (AddTagResponseValidationError) Reason

Reason function returns reason value.

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) Validate

func (m *Artifact) Validate() error

Validate checks the field values on Artifact with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

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) Validate

func (m *ArtifactData) Validate() error

Validate checks the field values on ArtifactData with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

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 ArtifactDataValidationError

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

ArtifactDataValidationError is the validation error returned by ArtifactData.Validate if the designated constraints aren't met.

func (ArtifactDataValidationError) Cause

Cause function returns cause value.

func (ArtifactDataValidationError) Error

Error satisfies the builtin error interface

func (ArtifactDataValidationError) ErrorName

func (e ArtifactDataValidationError) ErrorName() string

ErrorName returns error name.

func (ArtifactDataValidationError) Field

Field function returns field value.

func (ArtifactDataValidationError) Key

Key function returns key value.

func (ArtifactDataValidationError) Reason

Reason function returns reason value.

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) Validate

func (m *ArtifactPropertyFilter) Validate() error

Validate checks the field values on ArtifactPropertyFilter with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

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 ArtifactPropertyFilterValidationError

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

ArtifactPropertyFilterValidationError is the validation error returned by ArtifactPropertyFilter.Validate if the designated constraints aren't met.

func (ArtifactPropertyFilterValidationError) Cause

Cause function returns cause value.

func (ArtifactPropertyFilterValidationError) Error

Error satisfies the builtin error interface

func (ArtifactPropertyFilterValidationError) ErrorName

ErrorName returns error name.

func (ArtifactPropertyFilterValidationError) Field

Field function returns field value.

func (ArtifactPropertyFilterValidationError) Key

Key function returns key value.

func (ArtifactPropertyFilterValidationError) Reason

Reason function returns reason value.

type ArtifactPropertyFilter_ArtifactId

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

type ArtifactValidationError

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

ArtifactValidationError is the validation error returned by Artifact.Validate if the designated constraints aren't met.

func (ArtifactValidationError) Cause

func (e ArtifactValidationError) Cause() error

Cause function returns cause value.

func (ArtifactValidationError) Error

func (e ArtifactValidationError) Error() string

Error satisfies the builtin error interface

func (ArtifactValidationError) ErrorName

func (e ArtifactValidationError) ErrorName() string

ErrorName returns error name.

func (ArtifactValidationError) Field

func (e ArtifactValidationError) Field() string

Field function returns field value.

func (ArtifactValidationError) Key

func (e ArtifactValidationError) Key() bool

Key function returns key value.

func (ArtifactValidationError) Reason

func (e ArtifactValidationError) Reason() string

Reason function returns reason value.

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) Validate

func (m *CreateArtifactRequest) Validate() error

Validate checks the field values on CreateArtifactRequest with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

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 CreateArtifactRequestValidationError

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

CreateArtifactRequestValidationError is the validation error returned by CreateArtifactRequest.Validate if the designated constraints aren't met.

func (CreateArtifactRequestValidationError) Cause

Cause function returns cause value.

func (CreateArtifactRequestValidationError) Error

Error satisfies the builtin error interface

func (CreateArtifactRequestValidationError) ErrorName

ErrorName returns error name.

func (CreateArtifactRequestValidationError) Field

Field function returns field value.

func (CreateArtifactRequestValidationError) Key

Key function returns key value.

func (CreateArtifactRequestValidationError) Reason

Reason function returns reason value.

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) Validate

func (m *CreateArtifactResponse) Validate() error

Validate checks the field values on CreateArtifactResponse with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

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 CreateArtifactResponseValidationError

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

CreateArtifactResponseValidationError is the validation error returned by CreateArtifactResponse.Validate if the designated constraints aren't met.

func (CreateArtifactResponseValidationError) Cause

Cause function returns cause value.

func (CreateArtifactResponseValidationError) Error

Error satisfies the builtin error interface

func (CreateArtifactResponseValidationError) ErrorName

ErrorName returns error name.

func (CreateArtifactResponseValidationError) Field

Field function returns field value.

func (CreateArtifactResponseValidationError) Key

Key function returns key value.

func (CreateArtifactResponseValidationError) Reason

Reason function returns reason value.

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) Validate

func (m *CreateDatasetRequest) Validate() error

Validate checks the field values on CreateDatasetRequest with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

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 CreateDatasetRequestValidationError

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

CreateDatasetRequestValidationError is the validation error returned by CreateDatasetRequest.Validate if the designated constraints aren't met.

func (CreateDatasetRequestValidationError) Cause

Cause function returns cause value.

func (CreateDatasetRequestValidationError) Error

Error satisfies the builtin error interface

func (CreateDatasetRequestValidationError) ErrorName

ErrorName returns error name.

func (CreateDatasetRequestValidationError) Field

Field function returns field value.

func (CreateDatasetRequestValidationError) Key

Key function returns key value.

func (CreateDatasetRequestValidationError) Reason

Reason function returns reason value.

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) Validate

func (m *CreateDatasetResponse) Validate() error

Validate checks the field values on CreateDatasetResponse with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

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 CreateDatasetResponseValidationError

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

CreateDatasetResponseValidationError is the validation error returned by CreateDatasetResponse.Validate if the designated constraints aren't met.

func (CreateDatasetResponseValidationError) Cause

Cause function returns cause value.

func (CreateDatasetResponseValidationError) Error

Error satisfies the builtin error interface

func (CreateDatasetResponseValidationError) ErrorName

ErrorName returns error name.

func (CreateDatasetResponseValidationError) Field

Field function returns field value.

func (CreateDatasetResponseValidationError) Key

Key function returns key value.

func (CreateDatasetResponseValidationError) Reason

Reason function returns reason value.

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) Validate

func (m *Dataset) Validate() error

Validate checks the field values on Dataset with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

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) Validate

func (m *DatasetID) Validate() error

Validate checks the field values on DatasetID with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

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 DatasetIDValidationError

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

DatasetIDValidationError is the validation error returned by DatasetID.Validate if the designated constraints aren't met.

func (DatasetIDValidationError) Cause

func (e DatasetIDValidationError) Cause() error

Cause function returns cause value.

func (DatasetIDValidationError) Error

func (e DatasetIDValidationError) Error() string

Error satisfies the builtin error interface

func (DatasetIDValidationError) ErrorName

func (e DatasetIDValidationError) ErrorName() string

ErrorName returns error name.

func (DatasetIDValidationError) Field

func (e DatasetIDValidationError) Field() string

Field function returns field value.

func (DatasetIDValidationError) Key

Key function returns key value.

func (DatasetIDValidationError) Reason

func (e DatasetIDValidationError) Reason() string

Reason function returns reason value.

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) Validate

func (m *DatasetPropertyFilter) Validate() error

Validate checks the field values on DatasetPropertyFilter with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

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 DatasetPropertyFilterValidationError

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

DatasetPropertyFilterValidationError is the validation error returned by DatasetPropertyFilter.Validate if the designated constraints aren't met.

func (DatasetPropertyFilterValidationError) Cause

Cause function returns cause value.

func (DatasetPropertyFilterValidationError) Error

Error satisfies the builtin error interface

func (DatasetPropertyFilterValidationError) ErrorName

ErrorName returns error name.

func (DatasetPropertyFilterValidationError) Field

Field function returns field value.

func (DatasetPropertyFilterValidationError) Key

Key function returns key value.

func (DatasetPropertyFilterValidationError) Reason

Reason function returns reason value.

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 DatasetValidationError

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

DatasetValidationError is the validation error returned by Dataset.Validate if the designated constraints aren't met.

func (DatasetValidationError) Cause

func (e DatasetValidationError) Cause() error

Cause function returns cause value.

func (DatasetValidationError) Error

func (e DatasetValidationError) Error() string

Error satisfies the builtin error interface

func (DatasetValidationError) ErrorName

func (e DatasetValidationError) ErrorName() string

ErrorName returns error name.

func (DatasetValidationError) Field

func (e DatasetValidationError) Field() string

Field function returns field value.

func (DatasetValidationError) Key

func (e DatasetValidationError) Key() bool

Key function returns key value.

func (DatasetValidationError) Reason

func (e DatasetValidationError) Reason() string

Reason function returns reason value.

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) Validate

func (m *FilterExpression) Validate() error

Validate checks the field values on FilterExpression with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

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 FilterExpressionValidationError

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

FilterExpressionValidationError is the validation error returned by FilterExpression.Validate if the designated constraints aren't met.

func (FilterExpressionValidationError) Cause

Cause function returns cause value.

func (FilterExpressionValidationError) Error

Error satisfies the builtin error interface

func (FilterExpressionValidationError) ErrorName

ErrorName returns error name.

func (FilterExpressionValidationError) Field

Field function returns field value.

func (FilterExpressionValidationError) Key

Key function returns key value.

func (FilterExpressionValidationError) Reason

Reason function returns reason value.

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) Validate

func (m *GetArtifactRequest) Validate() error

Validate checks the field values on GetArtifactRequest with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

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 GetArtifactRequestValidationError

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

GetArtifactRequestValidationError is the validation error returned by GetArtifactRequest.Validate if the designated constraints aren't met.

func (GetArtifactRequestValidationError) Cause

Cause function returns cause value.

func (GetArtifactRequestValidationError) Error

Error satisfies the builtin error interface

func (GetArtifactRequestValidationError) ErrorName

ErrorName returns error name.

func (GetArtifactRequestValidationError) Field

Field function returns field value.

func (GetArtifactRequestValidationError) Key

Key function returns key value.

func (GetArtifactRequestValidationError) Reason

Reason function returns reason value.

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) Validate

func (m *GetArtifactResponse) Validate() error

Validate checks the field values on GetArtifactResponse with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

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 GetArtifactResponseValidationError

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

GetArtifactResponseValidationError is the validation error returned by GetArtifactResponse.Validate if the designated constraints aren't met.

func (GetArtifactResponseValidationError) Cause

Cause function returns cause value.

func (GetArtifactResponseValidationError) Error

Error satisfies the builtin error interface

func (GetArtifactResponseValidationError) ErrorName

ErrorName returns error name.

func (GetArtifactResponseValidationError) Field

Field function returns field value.

func (GetArtifactResponseValidationError) Key

Key function returns key value.

func (GetArtifactResponseValidationError) Reason

Reason function returns reason value.

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) Validate

func (m *GetDatasetRequest) Validate() error

Validate checks the field values on GetDatasetRequest with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

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 GetDatasetRequestValidationError

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

GetDatasetRequestValidationError is the validation error returned by GetDatasetRequest.Validate if the designated constraints aren't met.

func (GetDatasetRequestValidationError) Cause

Cause function returns cause value.

func (GetDatasetRequestValidationError) Error

Error satisfies the builtin error interface

func (GetDatasetRequestValidationError) ErrorName

ErrorName returns error name.

func (GetDatasetRequestValidationError) Field

Field function returns field value.

func (GetDatasetRequestValidationError) Key

Key function returns key value.

func (GetDatasetRequestValidationError) Reason

Reason function returns reason value.

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) Validate

func (m *GetDatasetResponse) Validate() error

Validate checks the field values on GetDatasetResponse with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

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 GetDatasetResponseValidationError

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

GetDatasetResponseValidationError is the validation error returned by GetDatasetResponse.Validate if the designated constraints aren't met.

func (GetDatasetResponseValidationError) Cause

Cause function returns cause value.

func (GetDatasetResponseValidationError) Error

Error satisfies the builtin error interface

func (GetDatasetResponseValidationError) ErrorName

ErrorName returns error name.

func (GetDatasetResponseValidationError) Field

Field function returns field value.

func (GetDatasetResponseValidationError) Key

Key function returns key value.

func (GetDatasetResponseValidationError) Reason

Reason function returns reason value.

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, retreive 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 (*GetOrExtendReservationRequest) Validate

func (m *GetOrExtendReservationRequest) Validate() error

Validate checks the field values on GetOrExtendReservationRequest with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

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 GetOrExtendReservationRequestValidationError

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

GetOrExtendReservationRequestValidationError is the validation error returned by GetOrExtendReservationRequest.Validate if the designated constraints aren't met.

func (GetOrExtendReservationRequestValidationError) Cause

Cause function returns cause value.

func (GetOrExtendReservationRequestValidationError) Error

Error satisfies the builtin error interface

func (GetOrExtendReservationRequestValidationError) ErrorName

ErrorName returns error name.

func (GetOrExtendReservationRequestValidationError) Field

Field function returns field value.

func (GetOrExtendReservationRequestValidationError) Key

Key function returns key value.

func (GetOrExtendReservationRequestValidationError) Reason

Reason function returns reason value.

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 (*GetOrExtendReservationResponse) Validate

func (m *GetOrExtendReservationResponse) Validate() error

Validate checks the field values on GetOrExtendReservationResponse with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

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 GetOrExtendReservationResponseValidationError

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

GetOrExtendReservationResponseValidationError is the validation error returned by GetOrExtendReservationResponse.Validate if the designated constraints aren't met.

func (GetOrExtendReservationResponseValidationError) Cause

Cause function returns cause value.

func (GetOrExtendReservationResponseValidationError) Error

Error satisfies the builtin error interface

func (GetOrExtendReservationResponseValidationError) ErrorName

ErrorName returns error name.

func (GetOrExtendReservationResponseValidationError) Field

Field function returns field value.

func (GetOrExtendReservationResponseValidationError) Key

Key function returns key value.

func (GetOrExtendReservationResponseValidationError) Reason

Reason function returns reason value.

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) Validate

func (m *KeyValuePair) Validate() error

Validate checks the field values on KeyValuePair with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

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 KeyValuePairValidationError

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

KeyValuePairValidationError is the validation error returned by KeyValuePair.Validate if the designated constraints aren't met.

func (KeyValuePairValidationError) Cause

Cause function returns cause value.

func (KeyValuePairValidationError) Error

Error satisfies the builtin error interface

func (KeyValuePairValidationError) ErrorName

func (e KeyValuePairValidationError) ErrorName() string

ErrorName returns error name.

func (KeyValuePairValidationError) Field

Field function returns field value.

func (KeyValuePairValidationError) Key

Key function returns key value.

func (KeyValuePairValidationError) Reason

Reason function returns reason value.

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) Validate

func (m *ListArtifactsRequest) Validate() error

Validate checks the field values on ListArtifactsRequest with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

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 ListArtifactsRequestValidationError

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

ListArtifactsRequestValidationError is the validation error returned by ListArtifactsRequest.Validate if the designated constraints aren't met.

func (ListArtifactsRequestValidationError) Cause

Cause function returns cause value.

func (ListArtifactsRequestValidationError) Error

Error satisfies the builtin error interface

func (ListArtifactsRequestValidationError) ErrorName

ErrorName returns error name.

func (ListArtifactsRequestValidationError) Field

Field function returns field value.

func (ListArtifactsRequestValidationError) Key

Key function returns key value.

func (ListArtifactsRequestValidationError) Reason

Reason function returns reason value.

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) Validate

func (m *ListArtifactsResponse) Validate() error

Validate checks the field values on ListArtifactsResponse with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

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 ListArtifactsResponseValidationError

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

ListArtifactsResponseValidationError is the validation error returned by ListArtifactsResponse.Validate if the designated constraints aren't met.

func (ListArtifactsResponseValidationError) Cause

Cause function returns cause value.

func (ListArtifactsResponseValidationError) Error

Error satisfies the builtin error interface

func (ListArtifactsResponseValidationError) ErrorName

ErrorName returns error name.

func (ListArtifactsResponseValidationError) Field

Field function returns field value.

func (ListArtifactsResponseValidationError) Key

Key function returns key value.

func (ListArtifactsResponseValidationError) Reason

Reason function returns reason value.

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) Validate

func (m *ListDatasetsRequest) Validate() error

Validate checks the field values on ListDatasetsRequest with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

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 ListDatasetsRequestValidationError

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

ListDatasetsRequestValidationError is the validation error returned by ListDatasetsRequest.Validate if the designated constraints aren't met.

func (ListDatasetsRequestValidationError) Cause

Cause function returns cause value.

func (ListDatasetsRequestValidationError) Error

Error satisfies the builtin error interface

func (ListDatasetsRequestValidationError) ErrorName

ErrorName returns error name.

func (ListDatasetsRequestValidationError) Field

Field function returns field value.

func (ListDatasetsRequestValidationError) Key

Key function returns key value.

func (ListDatasetsRequestValidationError) Reason

Reason function returns reason value.

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) Validate

func (m *ListDatasetsResponse) Validate() error

Validate checks the field values on ListDatasetsResponse with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

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 ListDatasetsResponseValidationError

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

ListDatasetsResponseValidationError is the validation error returned by ListDatasetsResponse.Validate if the designated constraints aren't met.

func (ListDatasetsResponseValidationError) Cause

Cause function returns cause value.

func (ListDatasetsResponseValidationError) Error

Error satisfies the builtin error interface

func (ListDatasetsResponseValidationError) ErrorName

ErrorName returns error name.

func (ListDatasetsResponseValidationError) Field

Field function returns field value.

func (ListDatasetsResponseValidationError) Key

Key function returns key value.

func (ListDatasetsResponseValidationError) Reason

Reason function returns reason value.

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) Validate

func (m *Metadata) Validate() error

Validate checks the field values on Metadata with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

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 MetadataValidationError

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

MetadataValidationError is the validation error returned by Metadata.Validate if the designated constraints aren't met.

func (MetadataValidationError) Cause

func (e MetadataValidationError) Cause() error

Cause function returns cause value.

func (MetadataValidationError) Error

func (e MetadataValidationError) Error() string

Error satisfies the builtin error interface

func (MetadataValidationError) ErrorName

func (e MetadataValidationError) ErrorName() string

ErrorName returns error name.

func (MetadataValidationError) Field

func (e MetadataValidationError) Field() string

Field function returns field value.

func (MetadataValidationError) Key

func (e MetadataValidationError) Key() bool

Key function returns key value.

func (MetadataValidationError) Reason

func (e MetadataValidationError) Reason() string

Reason function returns reason value.

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 (*PaginationOptions) GetSortOrder

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) Validate

func (m *PaginationOptions) Validate() error

Validate checks the field values on PaginationOptions with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

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 PaginationOptionsValidationError

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

PaginationOptionsValidationError is the validation error returned by PaginationOptions.Validate if the designated constraints aren't met.

func (PaginationOptionsValidationError) Cause

Cause function returns cause value.

func (PaginationOptionsValidationError) Error

Error satisfies the builtin error interface

func (PaginationOptionsValidationError) ErrorName

ErrorName returns error name.

func (PaginationOptionsValidationError) Field

Field function returns field value.

func (PaginationOptionsValidationError) Key

Key function returns key value.

func (PaginationOptionsValidationError) Reason

Reason function returns reason value.

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

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) Validate

func (m *Partition) Validate() error

Validate checks the field values on Partition with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

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) Validate

func (m *PartitionPropertyFilter) Validate() error

Validate checks the field values on PartitionPropertyFilter with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

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 PartitionPropertyFilterValidationError

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

PartitionPropertyFilterValidationError is the validation error returned by PartitionPropertyFilter.Validate if the designated constraints aren't met.

func (PartitionPropertyFilterValidationError) Cause

Cause function returns cause value.

func (PartitionPropertyFilterValidationError) Error

Error satisfies the builtin error interface

func (PartitionPropertyFilterValidationError) ErrorName

ErrorName returns error name.

func (PartitionPropertyFilterValidationError) Field

Field function returns field value.

func (PartitionPropertyFilterValidationError) Key

Key function returns key value.

func (PartitionPropertyFilterValidationError) Reason

Reason function returns reason value.

type PartitionPropertyFilter_KeyVal

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

type PartitionValidationError

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

PartitionValidationError is the validation error returned by Partition.Validate if the designated constraints aren't met.

func (PartitionValidationError) Cause

func (e PartitionValidationError) Cause() error

Cause function returns cause value.

func (PartitionValidationError) Error

func (e PartitionValidationError) Error() string

Error satisfies the builtin error interface

func (PartitionValidationError) ErrorName

func (e PartitionValidationError) ErrorName() string

ErrorName returns error name.

func (PartitionValidationError) Field

func (e PartitionValidationError) Field() string

Field function returns field value.

func (PartitionValidationError) Key

Key function returns key value.

func (PartitionValidationError) Reason

func (e PartitionValidationError) Reason() string

Reason function returns reason value.

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) Validate

func (m *ReleaseReservationRequest) Validate() error

Validate checks the field values on ReleaseReservationRequest with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

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 ReleaseReservationRequestValidationError

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

ReleaseReservationRequestValidationError is the validation error returned by ReleaseReservationRequest.Validate if the designated constraints aren't met.

func (ReleaseReservationRequestValidationError) Cause

Cause function returns cause value.

func (ReleaseReservationRequestValidationError) Error

Error satisfies the builtin error interface

func (ReleaseReservationRequestValidationError) ErrorName

ErrorName returns error name.

func (ReleaseReservationRequestValidationError) Field

Field function returns field value.

func (ReleaseReservationRequestValidationError) Key

Key function returns key value.

func (ReleaseReservationRequestValidationError) Reason

Reason function returns reason value.

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) Validate

func (m *ReleaseReservationResponse) Validate() error

Validate checks the field values on ReleaseReservationResponse with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

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 ReleaseReservationResponseValidationError

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

ReleaseReservationResponseValidationError is the validation error returned by ReleaseReservationResponse.Validate if the designated constraints aren't met.

func (ReleaseReservationResponseValidationError) Cause

Cause function returns cause value.

func (ReleaseReservationResponseValidationError) Error

Error satisfies the builtin error interface

func (ReleaseReservationResponseValidationError) ErrorName

ErrorName returns error name.

func (ReleaseReservationResponseValidationError) Field

Field function returns field value.

func (ReleaseReservationResponseValidationError) Key

Key function returns key value.

func (ReleaseReservationResponseValidationError) Reason

Reason function returns reason value.

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) Validate

func (m *Reservation) Validate() error

Validate checks the field values on Reservation with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

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) Validate

func (m *ReservationID) Validate() error

Validate checks the field values on ReservationID with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

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 ReservationIDValidationError

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

ReservationIDValidationError is the validation error returned by ReservationID.Validate if the designated constraints aren't met.

func (ReservationIDValidationError) Cause

Cause function returns cause value.

func (ReservationIDValidationError) Error

Error satisfies the builtin error interface

func (ReservationIDValidationError) ErrorName

func (e ReservationIDValidationError) ErrorName() string

ErrorName returns error name.

func (ReservationIDValidationError) Field

Field function returns field value.

func (ReservationIDValidationError) Key

Key function returns key value.

func (ReservationIDValidationError) Reason

Reason function returns reason value.

type ReservationValidationError

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

ReservationValidationError is the validation error returned by Reservation.Validate if the designated constraints aren't met.

func (ReservationValidationError) Cause

Cause function returns cause value.

func (ReservationValidationError) Error

Error satisfies the builtin error interface

func (ReservationValidationError) ErrorName

func (e ReservationValidationError) ErrorName() string

ErrorName returns error name.

func (ReservationValidationError) Field

Field function returns field value.

func (ReservationValidationError) Key

Key function returns key value.

func (ReservationValidationError) Reason

Reason function returns reason value.

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 (*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) Validate

func (m *SinglePropertyFilter) Validate() error

Validate checks the field values on SinglePropertyFilter with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

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 SinglePropertyFilterValidationError

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

SinglePropertyFilterValidationError is the validation error returned by SinglePropertyFilter.Validate if the designated constraints aren't met.

func (SinglePropertyFilterValidationError) Cause

Cause function returns cause value.

func (SinglePropertyFilterValidationError) Error

Error satisfies the builtin error interface

func (SinglePropertyFilterValidationError) ErrorName

ErrorName returns error name.

func (SinglePropertyFilterValidationError) Field

Field function returns field value.

func (SinglePropertyFilterValidationError) Key

Key function returns key value.

func (SinglePropertyFilterValidationError) Reason

Reason function returns reason value.

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

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) Validate

func (m *Tag) Validate() error

Validate checks the field values on Tag with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

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) Validate

func (m *TagPropertyFilter) Validate() error

Validate checks the field values on TagPropertyFilter with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

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 TagPropertyFilterValidationError

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

TagPropertyFilterValidationError is the validation error returned by TagPropertyFilter.Validate if the designated constraints aren't met.

func (TagPropertyFilterValidationError) Cause

Cause function returns cause value.

func (TagPropertyFilterValidationError) Error

Error satisfies the builtin error interface

func (TagPropertyFilterValidationError) ErrorName

ErrorName returns error name.

func (TagPropertyFilterValidationError) Field

Field function returns field value.

func (TagPropertyFilterValidationError) Key

Key function returns key value.

func (TagPropertyFilterValidationError) Reason

Reason function returns reason value.

type TagPropertyFilter_TagName

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

type TagValidationError

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

TagValidationError is the validation error returned by Tag.Validate if the designated constraints aren't met.

func (TagValidationError) Cause

func (e TagValidationError) Cause() error

Cause function returns cause value.

func (TagValidationError) Error

func (e TagValidationError) Error() string

Error satisfies the builtin error interface

func (TagValidationError) ErrorName

func (e TagValidationError) ErrorName() string

ErrorName returns error name.

func (TagValidationError) Field

func (e TagValidationError) Field() string

Field function returns field value.

func (TagValidationError) Key

func (e TagValidationError) Key() bool

Key function returns key value.

func (TagValidationError) Reason

func (e TagValidationError) Reason() string

Reason function returns reason value.

type UnimplementedDataCatalogServer

type UnimplementedDataCatalogServer struct {
}

UnimplementedDataCatalogServer can be embedded to have forward compatible implementations.

func (*UnimplementedDataCatalogServer) AddTag

func (*UnimplementedDataCatalogServer) CreateArtifact

func (*UnimplementedDataCatalogServer) CreateDataset

func (*UnimplementedDataCatalogServer) GetArtifact

func (*UnimplementedDataCatalogServer) GetDataset

func (*UnimplementedDataCatalogServer) GetOrExtendReservation

func (*UnimplementedDataCatalogServer) ListArtifacts

func (*UnimplementedDataCatalogServer) ListDatasets

func (*UnimplementedDataCatalogServer) ReleaseReservation

func (*UnimplementedDataCatalogServer) UpdateArtifact

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"`
	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) 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) Validate

func (m *UpdateArtifactRequest) Validate() error

Validate checks the field values on UpdateArtifactRequest with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

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 UpdateArtifactRequestValidationError

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

UpdateArtifactRequestValidationError is the validation error returned by UpdateArtifactRequest.Validate if the designated constraints aren't met.

func (UpdateArtifactRequestValidationError) Cause

Cause function returns cause value.

func (UpdateArtifactRequestValidationError) Error

Error satisfies the builtin error interface

func (UpdateArtifactRequestValidationError) ErrorName

ErrorName returns error name.

func (UpdateArtifactRequestValidationError) Field

Field function returns field value.

func (UpdateArtifactRequestValidationError) Key

Key function returns key value.

func (UpdateArtifactRequestValidationError) Reason

Reason function returns reason value.

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) Validate

func (m *UpdateArtifactResponse) Validate() error

Validate checks the field values on UpdateArtifactResponse with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

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

type UpdateArtifactResponseValidationError

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

UpdateArtifactResponseValidationError is the validation error returned by UpdateArtifactResponse.Validate if the designated constraints aren't met.

func (UpdateArtifactResponseValidationError) Cause

Cause function returns cause value.

func (UpdateArtifactResponseValidationError) Error

Error satisfies the builtin error interface

func (UpdateArtifactResponseValidationError) ErrorName

ErrorName returns error name.

func (UpdateArtifactResponseValidationError) Field

Field function returns field value.

func (UpdateArtifactResponseValidationError) Key

Key function returns key value.

func (UpdateArtifactResponseValidationError) Reason

Reason function returns reason value.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL