Documentation
¶
Index ¶
- Variables
- func RegisterDataCatalogServer(s *grpc.Server, srv DataCatalogServer)
- type AddTagRequest
- type AddTagResponse
- type Artifact
- func (*Artifact) Descriptor() ([]byte, []int)deprecated
- func (x *Artifact) GetCreatedAt() *timestamppb.Timestamp
- func (x *Artifact) GetData() []*ArtifactData
- func (x *Artifact) GetDataset() *DatasetID
- func (x *Artifact) GetId() string
- func (x *Artifact) GetMetadata() *Metadata
- func (x *Artifact) GetPartitions() []*Partition
- func (x *Artifact) GetTags() []*Tag
- func (*Artifact) ProtoMessage()
- func (x *Artifact) ProtoReflect() protoreflect.Message
- func (x *Artifact) Reset()
- func (x *Artifact) String() string
- type ArtifactData
- func (*ArtifactData) Descriptor() ([]byte, []int)deprecated
- func (x *ArtifactData) GetName() string
- func (x *ArtifactData) GetValue() *core.Literal
- func (*ArtifactData) ProtoMessage()
- func (x *ArtifactData) ProtoReflect() protoreflect.Message
- func (x *ArtifactData) Reset()
- func (x *ArtifactData) String() string
- type ArtifactPropertyFilter
- func (*ArtifactPropertyFilter) Descriptor() ([]byte, []int)deprecated
- func (x *ArtifactPropertyFilter) GetArtifactId() string
- func (m *ArtifactPropertyFilter) GetProperty() isArtifactPropertyFilter_Property
- func (*ArtifactPropertyFilter) ProtoMessage()
- func (x *ArtifactPropertyFilter) ProtoReflect() protoreflect.Message
- func (x *ArtifactPropertyFilter) Reset()
- func (x *ArtifactPropertyFilter) String() string
- type ArtifactPropertyFilter_ArtifactId
- type CreateArtifactRequest
- func (*CreateArtifactRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CreateArtifactRequest) GetArtifact() *Artifact
- func (*CreateArtifactRequest) ProtoMessage()
- func (x *CreateArtifactRequest) ProtoReflect() protoreflect.Message
- func (x *CreateArtifactRequest) Reset()
- func (x *CreateArtifactRequest) String() string
- type CreateArtifactResponse
- type CreateDatasetRequest
- func (*CreateDatasetRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CreateDatasetRequest) GetDataset() *Dataset
- func (*CreateDatasetRequest) ProtoMessage()
- func (x *CreateDatasetRequest) ProtoReflect() protoreflect.Message
- func (x *CreateDatasetRequest) Reset()
- func (x *CreateDatasetRequest) String() string
- type CreateDatasetResponse
- type DataCatalogClient
- type DataCatalogServer
- type Dataset
- func (*Dataset) Descriptor() ([]byte, []int)deprecated
- func (x *Dataset) GetId() *DatasetID
- func (x *Dataset) GetMetadata() *Metadata
- func (x *Dataset) GetPartitionKeys() []string
- func (*Dataset) ProtoMessage()
- func (x *Dataset) ProtoReflect() protoreflect.Message
- func (x *Dataset) Reset()
- func (x *Dataset) String() string
- type DatasetID
- func (*DatasetID) Descriptor() ([]byte, []int)deprecated
- func (x *DatasetID) GetDomain() string
- func (x *DatasetID) GetName() string
- func (x *DatasetID) GetProject() string
- func (x *DatasetID) GetUUID() string
- func (x *DatasetID) GetVersion() string
- func (*DatasetID) ProtoMessage()
- func (x *DatasetID) ProtoReflect() protoreflect.Message
- func (x *DatasetID) Reset()
- func (x *DatasetID) String() string
- type DatasetPropertyFilter
- func (*DatasetPropertyFilter) Descriptor() ([]byte, []int)deprecated
- func (x *DatasetPropertyFilter) GetDomain() string
- func (x *DatasetPropertyFilter) GetName() string
- func (x *DatasetPropertyFilter) GetProject() string
- func (m *DatasetPropertyFilter) GetProperty() isDatasetPropertyFilter_Property
- func (x *DatasetPropertyFilter) GetVersion() string
- func (*DatasetPropertyFilter) ProtoMessage()
- func (x *DatasetPropertyFilter) ProtoReflect() protoreflect.Message
- func (x *DatasetPropertyFilter) Reset()
- func (x *DatasetPropertyFilter) String() string
- type DatasetPropertyFilter_Domain
- type DatasetPropertyFilter_Name
- type DatasetPropertyFilter_Project
- type DatasetPropertyFilter_Version
- type FilterExpression
- func (*FilterExpression) Descriptor() ([]byte, []int)deprecated
- func (x *FilterExpression) GetFilters() []*SinglePropertyFilter
- func (*FilterExpression) ProtoMessage()
- func (x *FilterExpression) ProtoReflect() protoreflect.Message
- func (x *FilterExpression) Reset()
- func (x *FilterExpression) String() string
- type GetArtifactRequest
- func (*GetArtifactRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetArtifactRequest) GetArtifactId() string
- func (x *GetArtifactRequest) GetDataset() *DatasetID
- func (m *GetArtifactRequest) GetQueryHandle() isGetArtifactRequest_QueryHandle
- func (x *GetArtifactRequest) GetTagName() string
- func (*GetArtifactRequest) ProtoMessage()
- func (x *GetArtifactRequest) ProtoReflect() protoreflect.Message
- func (x *GetArtifactRequest) Reset()
- func (x *GetArtifactRequest) String() string
- type GetArtifactRequest_ArtifactId
- type GetArtifactRequest_TagName
- type GetArtifactResponse
- func (*GetArtifactResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetArtifactResponse) GetArtifact() *Artifact
- func (*GetArtifactResponse) ProtoMessage()
- func (x *GetArtifactResponse) ProtoReflect() protoreflect.Message
- func (x *GetArtifactResponse) Reset()
- func (x *GetArtifactResponse) String() string
- type GetDatasetRequest
- func (*GetDatasetRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetDatasetRequest) GetDataset() *DatasetID
- func (*GetDatasetRequest) ProtoMessage()
- func (x *GetDatasetRequest) ProtoReflect() protoreflect.Message
- func (x *GetDatasetRequest) Reset()
- func (x *GetDatasetRequest) String() string
- type GetDatasetResponse
- func (*GetDatasetResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetDatasetResponse) GetDataset() *Dataset
- func (*GetDatasetResponse) ProtoMessage()
- func (x *GetDatasetResponse) ProtoReflect() protoreflect.Message
- func (x *GetDatasetResponse) Reset()
- func (x *GetDatasetResponse) String() string
- type KeyValuePair
- func (*KeyValuePair) Descriptor() ([]byte, []int)deprecated
- func (x *KeyValuePair) GetKey() string
- func (x *KeyValuePair) GetValue() string
- func (*KeyValuePair) ProtoMessage()
- func (x *KeyValuePair) ProtoReflect() protoreflect.Message
- func (x *KeyValuePair) Reset()
- func (x *KeyValuePair) String() string
- type ListArtifactsRequest
- func (*ListArtifactsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListArtifactsRequest) GetDataset() *DatasetID
- func (x *ListArtifactsRequest) GetFilter() *FilterExpression
- func (x *ListArtifactsRequest) GetPagination() *PaginationOptions
- func (*ListArtifactsRequest) ProtoMessage()
- func (x *ListArtifactsRequest) ProtoReflect() protoreflect.Message
- func (x *ListArtifactsRequest) Reset()
- func (x *ListArtifactsRequest) String() string
- type ListArtifactsResponse
- func (*ListArtifactsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListArtifactsResponse) GetArtifacts() []*Artifact
- func (x *ListArtifactsResponse) GetNextToken() string
- func (*ListArtifactsResponse) ProtoMessage()
- func (x *ListArtifactsResponse) ProtoReflect() protoreflect.Message
- func (x *ListArtifactsResponse) Reset()
- func (x *ListArtifactsResponse) String() string
- type ListDatasetsRequest
- func (*ListDatasetsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListDatasetsRequest) GetFilter() *FilterExpression
- func (x *ListDatasetsRequest) GetPagination() *PaginationOptions
- func (*ListDatasetsRequest) ProtoMessage()
- func (x *ListDatasetsRequest) ProtoReflect() protoreflect.Message
- func (x *ListDatasetsRequest) Reset()
- func (x *ListDatasetsRequest) String() string
- type ListDatasetsResponse
- func (*ListDatasetsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListDatasetsResponse) GetDatasets() []*Dataset
- func (x *ListDatasetsResponse) GetNextToken() string
- func (*ListDatasetsResponse) ProtoMessage()
- func (x *ListDatasetsResponse) ProtoReflect() protoreflect.Message
- func (x *ListDatasetsResponse) Reset()
- func (x *ListDatasetsResponse) String() string
- type Metadata
- type PaginationOptions
- func (*PaginationOptions) Descriptor() ([]byte, []int)deprecated
- func (x *PaginationOptions) GetLimit() uint32
- func (x *PaginationOptions) GetSortKey() PaginationOptions_SortKey
- func (x *PaginationOptions) GetSortOrder() PaginationOptions_SortOrder
- func (x *PaginationOptions) GetToken() string
- func (*PaginationOptions) ProtoMessage()
- func (x *PaginationOptions) ProtoReflect() protoreflect.Message
- func (x *PaginationOptions) Reset()
- func (x *PaginationOptions) String() string
- type PaginationOptions_SortKey
- func (PaginationOptions_SortKey) Descriptor() protoreflect.EnumDescriptor
- func (x PaginationOptions_SortKey) Enum() *PaginationOptions_SortKey
- func (PaginationOptions_SortKey) EnumDescriptor() ([]byte, []int)deprecated
- func (x PaginationOptions_SortKey) Number() protoreflect.EnumNumber
- func (x PaginationOptions_SortKey) String() string
- func (PaginationOptions_SortKey) Type() protoreflect.EnumType
- type PaginationOptions_SortOrder
- func (PaginationOptions_SortOrder) Descriptor() protoreflect.EnumDescriptor
- func (x PaginationOptions_SortOrder) Enum() *PaginationOptions_SortOrder
- func (PaginationOptions_SortOrder) EnumDescriptor() ([]byte, []int)deprecated
- func (x PaginationOptions_SortOrder) Number() protoreflect.EnumNumber
- func (x PaginationOptions_SortOrder) String() string
- func (PaginationOptions_SortOrder) Type() protoreflect.EnumType
- type Partition
- type PartitionPropertyFilter
- func (*PartitionPropertyFilter) Descriptor() ([]byte, []int)deprecated
- func (x *PartitionPropertyFilter) GetKeyVal() *KeyValuePair
- func (m *PartitionPropertyFilter) GetProperty() isPartitionPropertyFilter_Property
- func (*PartitionPropertyFilter) ProtoMessage()
- func (x *PartitionPropertyFilter) ProtoReflect() protoreflect.Message
- func (x *PartitionPropertyFilter) Reset()
- func (x *PartitionPropertyFilter) String() string
- type PartitionPropertyFilter_KeyVal
- type SinglePropertyFilter
- func (*SinglePropertyFilter) Descriptor() ([]byte, []int)deprecated
- func (x *SinglePropertyFilter) GetArtifactFilter() *ArtifactPropertyFilter
- func (x *SinglePropertyFilter) GetDatasetFilter() *DatasetPropertyFilter
- func (x *SinglePropertyFilter) GetOperator() SinglePropertyFilter_ComparisonOperator
- func (x *SinglePropertyFilter) GetPartitionFilter() *PartitionPropertyFilter
- func (m *SinglePropertyFilter) GetPropertyFilter() isSinglePropertyFilter_PropertyFilter
- func (x *SinglePropertyFilter) GetTagFilter() *TagPropertyFilter
- func (*SinglePropertyFilter) ProtoMessage()
- func (x *SinglePropertyFilter) ProtoReflect() protoreflect.Message
- func (x *SinglePropertyFilter) Reset()
- func (x *SinglePropertyFilter) String() string
- type SinglePropertyFilter_ArtifactFilter
- type SinglePropertyFilter_ComparisonOperator
- func (SinglePropertyFilter_ComparisonOperator) Descriptor() protoreflect.EnumDescriptor
- func (x SinglePropertyFilter_ComparisonOperator) Enum() *SinglePropertyFilter_ComparisonOperator
- func (SinglePropertyFilter_ComparisonOperator) EnumDescriptor() ([]byte, []int)deprecated
- func (x SinglePropertyFilter_ComparisonOperator) Number() protoreflect.EnumNumber
- func (x SinglePropertyFilter_ComparisonOperator) String() string
- func (SinglePropertyFilter_ComparisonOperator) Type() protoreflect.EnumType
- type SinglePropertyFilter_DatasetFilter
- type SinglePropertyFilter_PartitionFilter
- type SinglePropertyFilter_TagFilter
- type Tag
- type TagPropertyFilter
- func (*TagPropertyFilter) Descriptor() ([]byte, []int)deprecated
- func (m *TagPropertyFilter) GetProperty() isTagPropertyFilter_Property
- func (x *TagPropertyFilter) GetTagName() string
- func (*TagPropertyFilter) ProtoMessage()
- func (x *TagPropertyFilter) ProtoReflect() protoreflect.Message
- func (x *TagPropertyFilter) Reset()
- func (x *TagPropertyFilter) String() string
- type TagPropertyFilter_TagName
- type UnimplementedDataCatalogServer
- func (*UnimplementedDataCatalogServer) AddTag(context.Context, *AddTagRequest) (*AddTagResponse, error)
- func (*UnimplementedDataCatalogServer) CreateArtifact(context.Context, *CreateArtifactRequest) (*CreateArtifactResponse, error)
- func (*UnimplementedDataCatalogServer) CreateDataset(context.Context, *CreateDatasetRequest) (*CreateDatasetResponse, error)
- func (*UnimplementedDataCatalogServer) GetArtifact(context.Context, *GetArtifactRequest) (*GetArtifactResponse, error)
- func (*UnimplementedDataCatalogServer) GetDataset(context.Context, *GetDatasetRequest) (*GetDatasetResponse, error)
- func (*UnimplementedDataCatalogServer) ListArtifacts(context.Context, *ListArtifactsRequest) (*ListArtifactsResponse, error)
- func (*UnimplementedDataCatalogServer) ListDatasets(context.Context, *ListDatasetsRequest) (*ListDatasetsResponse, error)
Constants ¶
This section is empty.
Variables ¶
var ( SinglePropertyFilter_ComparisonOperator_name = map[int32]string{ 0: "EQUALS", } SinglePropertyFilter_ComparisonOperator_value = map[string]int32{ "EQUALS": 0, } )
Enum value maps for SinglePropertyFilter_ComparisonOperator.
var ( PaginationOptions_SortOrder_name = map[int32]string{ 0: "DESCENDING", 1: "ASCENDING", } PaginationOptions_SortOrder_value = map[string]int32{ "DESCENDING": 0, "ASCENDING": 1, } )
Enum value maps for PaginationOptions_SortOrder.
var ( PaginationOptions_SortKey_name = map[int32]string{ 0: "CREATION_TIME", } PaginationOptions_SortKey_value = map[string]int32{ "CREATION_TIME": 0, } )
Enum value maps for PaginationOptions_SortKey.
var File_service_proto protoreflect.FileDescriptor
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"`
// contains filtered or unexported fields
}
func (*AddTagRequest) Descriptor
deprecated
func (*AddTagRequest) Descriptor() ([]byte, []int)
Deprecated: Use AddTagRequest.ProtoReflect.Descriptor instead.
func (*AddTagRequest) GetTag ¶
func (x *AddTagRequest) GetTag() *Tag
func (*AddTagRequest) ProtoMessage ¶
func (*AddTagRequest) ProtoMessage()
func (*AddTagRequest) ProtoReflect ¶ added in v0.2.131
func (x *AddTagRequest) ProtoReflect() protoreflect.Message
func (*AddTagRequest) Reset ¶
func (x *AddTagRequest) Reset()
func (*AddTagRequest) String ¶
func (x *AddTagRequest) String() string
type AddTagResponse ¶
type AddTagResponse struct {
// contains filtered or unexported fields
}
func (*AddTagResponse) Descriptor
deprecated
func (*AddTagResponse) Descriptor() ([]byte, []int)
Deprecated: Use AddTagResponse.ProtoReflect.Descriptor instead.
func (*AddTagResponse) ProtoMessage ¶
func (*AddTagResponse) ProtoMessage()
func (*AddTagResponse) ProtoReflect ¶ added in v0.2.131
func (x *AddTagResponse) ProtoReflect() protoreflect.Message
func (*AddTagResponse) Reset ¶
func (x *AddTagResponse) Reset()
func (*AddTagResponse) String ¶
func (x *AddTagResponse) String() string
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 *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"` // creation timestamp of artifact, autogenerated by service
// contains filtered or unexported fields
}
func (*Artifact) Descriptor
deprecated
func (*Artifact) GetCreatedAt ¶ added in v0.2.131
func (x *Artifact) GetCreatedAt() *timestamppb.Timestamp
func (*Artifact) GetData ¶
func (x *Artifact) GetData() []*ArtifactData
func (*Artifact) GetDataset ¶
func (*Artifact) GetMetadata ¶
func (*Artifact) GetPartitions ¶ added in v0.1.2
func (*Artifact) ProtoMessage ¶
func (*Artifact) ProtoMessage()
func (*Artifact) ProtoReflect ¶ added in v0.2.131
func (x *Artifact) ProtoReflect() protoreflect.Message
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"`
// contains filtered or unexported fields
}
func (*ArtifactData) Descriptor
deprecated
func (*ArtifactData) Descriptor() ([]byte, []int)
Deprecated: Use ArtifactData.ProtoReflect.Descriptor instead.
func (*ArtifactData) GetName ¶
func (x *ArtifactData) GetName() string
func (*ArtifactData) GetValue ¶
func (x *ArtifactData) GetValue() *core.Literal
func (*ArtifactData) ProtoMessage ¶
func (*ArtifactData) ProtoMessage()
func (*ArtifactData) ProtoReflect ¶ added in v0.2.131
func (x *ArtifactData) ProtoReflect() protoreflect.Message
func (*ArtifactData) Reset ¶
func (x *ArtifactData) Reset()
func (*ArtifactData) String ¶
func (x *ArtifactData) String() string
type ArtifactPropertyFilter ¶ added in v0.1.2
type ArtifactPropertyFilter struct {
// oneof because we can add more properties in the future
//
// Types that are assignable to Property:
// *ArtifactPropertyFilter_ArtifactId
Property isArtifactPropertyFilter_Property `protobuf_oneof:"property"`
// contains filtered or unexported fields
}
Artifact properties we can filter by
func (*ArtifactPropertyFilter) Descriptor
deprecated
added in
v0.1.2
func (*ArtifactPropertyFilter) Descriptor() ([]byte, []int)
Deprecated: Use ArtifactPropertyFilter.ProtoReflect.Descriptor instead.
func (*ArtifactPropertyFilter) GetArtifactId ¶ added in v0.1.2
func (x *ArtifactPropertyFilter) GetArtifactId() string
func (*ArtifactPropertyFilter) GetProperty ¶ added in v0.1.2
func (m *ArtifactPropertyFilter) GetProperty() isArtifactPropertyFilter_Property
func (*ArtifactPropertyFilter) ProtoMessage ¶ added in v0.1.2
func (*ArtifactPropertyFilter) ProtoMessage()
func (*ArtifactPropertyFilter) ProtoReflect ¶ added in v0.2.131
func (x *ArtifactPropertyFilter) ProtoReflect() protoreflect.Message
func (*ArtifactPropertyFilter) Reset ¶ added in v0.1.2
func (x *ArtifactPropertyFilter) Reset()
func (*ArtifactPropertyFilter) String ¶ added in v0.1.2
func (x *ArtifactPropertyFilter) String() string
type ArtifactPropertyFilter_ArtifactId ¶ added in v0.1.2
type ArtifactPropertyFilter_ArtifactId struct {
ArtifactId string `protobuf:"bytes,1,opt,name=artifact_id,json=artifactId,proto3,oneof"`
}
type CreateArtifactRequest ¶
type CreateArtifactRequest struct {
Artifact *Artifact `protobuf:"bytes,1,opt,name=artifact,proto3" json:"artifact,omitempty"`
// contains filtered or unexported fields
}
func (*CreateArtifactRequest) Descriptor
deprecated
func (*CreateArtifactRequest) Descriptor() ([]byte, []int)
Deprecated: Use CreateArtifactRequest.ProtoReflect.Descriptor instead.
func (*CreateArtifactRequest) GetArtifact ¶
func (x *CreateArtifactRequest) GetArtifact() *Artifact
func (*CreateArtifactRequest) ProtoMessage ¶
func (*CreateArtifactRequest) ProtoMessage()
func (*CreateArtifactRequest) ProtoReflect ¶ added in v0.2.131
func (x *CreateArtifactRequest) ProtoReflect() protoreflect.Message
func (*CreateArtifactRequest) Reset ¶
func (x *CreateArtifactRequest) Reset()
func (*CreateArtifactRequest) String ¶
func (x *CreateArtifactRequest) String() string
type CreateArtifactResponse ¶
type CreateArtifactResponse struct {
// contains filtered or unexported fields
}
func (*CreateArtifactResponse) Descriptor
deprecated
func (*CreateArtifactResponse) Descriptor() ([]byte, []int)
Deprecated: Use CreateArtifactResponse.ProtoReflect.Descriptor instead.
func (*CreateArtifactResponse) ProtoMessage ¶
func (*CreateArtifactResponse) ProtoMessage()
func (*CreateArtifactResponse) ProtoReflect ¶ added in v0.2.131
func (x *CreateArtifactResponse) ProtoReflect() protoreflect.Message
func (*CreateArtifactResponse) Reset ¶
func (x *CreateArtifactResponse) Reset()
func (*CreateArtifactResponse) String ¶
func (x *CreateArtifactResponse) String() string
type CreateDatasetRequest ¶
type CreateDatasetRequest struct {
Dataset *Dataset `protobuf:"bytes,1,opt,name=dataset,proto3" json:"dataset,omitempty"`
// contains filtered or unexported fields
}
func (*CreateDatasetRequest) Descriptor
deprecated
func (*CreateDatasetRequest) Descriptor() ([]byte, []int)
Deprecated: Use CreateDatasetRequest.ProtoReflect.Descriptor instead.
func (*CreateDatasetRequest) GetDataset ¶
func (x *CreateDatasetRequest) GetDataset() *Dataset
func (*CreateDatasetRequest) ProtoMessage ¶
func (*CreateDatasetRequest) ProtoMessage()
func (*CreateDatasetRequest) ProtoReflect ¶ added in v0.2.131
func (x *CreateDatasetRequest) ProtoReflect() protoreflect.Message
func (*CreateDatasetRequest) Reset ¶
func (x *CreateDatasetRequest) Reset()
func (*CreateDatasetRequest) String ¶
func (x *CreateDatasetRequest) String() string
type CreateDatasetResponse ¶
type CreateDatasetResponse struct {
// contains filtered or unexported fields
}
func (*CreateDatasetResponse) Descriptor
deprecated
func (*CreateDatasetResponse) Descriptor() ([]byte, []int)
Deprecated: Use CreateDatasetResponse.ProtoReflect.Descriptor instead.
func (*CreateDatasetResponse) ProtoMessage ¶
func (*CreateDatasetResponse) ProtoMessage()
func (*CreateDatasetResponse) ProtoReflect ¶ added in v0.2.131
func (x *CreateDatasetResponse) ProtoReflect() protoreflect.Message
func (*CreateDatasetResponse) Reset ¶
func (x *CreateDatasetResponse) Reset()
func (*CreateDatasetResponse) String ¶
func (x *CreateDatasetResponse) String() string
type DataCatalogClient ¶
type DataCatalogClient interface {
CreateDataset(ctx context.Context, in *CreateDatasetRequest, opts ...grpc.CallOption) (*CreateDatasetResponse, error)
GetDataset(ctx context.Context, in *GetDatasetRequest, opts ...grpc.CallOption) (*GetDatasetResponse, error)
CreateArtifact(ctx context.Context, in *CreateArtifactRequest, opts ...grpc.CallOption) (*CreateArtifactResponse, error)
GetArtifact(ctx context.Context, in *GetArtifactRequest, opts ...grpc.CallOption) (*GetArtifactResponse, error)
AddTag(ctx context.Context, in *AddTagRequest, opts ...grpc.CallOption) (*AddTagResponse, error)
ListArtifacts(ctx context.Context, in *ListArtifactsRequest, opts ...grpc.CallOption) (*ListArtifactsResponse, error)
ListDatasets(ctx context.Context, in *ListDatasetsRequest, opts ...grpc.CallOption) (*ListDatasetsResponse, 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.ClientConnInterface) DataCatalogClient
type DataCatalogServer ¶
type DataCatalogServer interface {
CreateDataset(context.Context, *CreateDatasetRequest) (*CreateDatasetResponse, error)
GetDataset(context.Context, *GetDatasetRequest) (*GetDatasetResponse, error)
CreateArtifact(context.Context, *CreateArtifactRequest) (*CreateArtifactResponse, error)
GetArtifact(context.Context, *GetArtifactRequest) (*GetArtifactResponse, error)
AddTag(context.Context, *AddTagRequest) (*AddTagResponse, error)
ListArtifacts(context.Context, *ListArtifactsRequest) (*ListArtifactsResponse, error)
ListDatasets(context.Context, *ListDatasetsRequest) (*ListDatasetsResponse, 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"`
// contains filtered or unexported fields
}
func (*Dataset) Descriptor
deprecated
func (*Dataset) GetMetadata ¶
func (*Dataset) GetPartitionKeys ¶ added in v0.1.2
func (*Dataset) ProtoMessage ¶
func (*Dataset) ProtoMessage()
func (*Dataset) ProtoReflect ¶ added in v0.2.131
func (x *Dataset) ProtoReflect() protoreflect.Message
type DatasetID ¶
type DatasetID struct {
Project string `protobuf:"bytes,1,opt,name=project,proto3" json:"project,omitempty"` // The name of the project
Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` // The name of the dataset
Domain string `protobuf:"bytes,3,opt,name=domain,proto3" json:"domain,omitempty"` // The domain (eg. environment)
Version string `protobuf:"bytes,4,opt,name=version,proto3" json:"version,omitempty"` // Version of the data schema
UUID string `protobuf:"bytes,5,opt,name=UUID,proto3" json:"UUID,omitempty"` // UUID for the dataset (if set the above fields are optional)
// contains filtered or unexported fields
}
func (*DatasetID) Descriptor
deprecated
func (*DatasetID) GetProject ¶
func (*DatasetID) GetVersion ¶
func (*DatasetID) ProtoMessage ¶
func (*DatasetID) ProtoMessage()
func (*DatasetID) ProtoReflect ¶ added in v0.2.131
func (x *DatasetID) ProtoReflect() protoreflect.Message
type DatasetPropertyFilter ¶ added in v0.1.2
type DatasetPropertyFilter struct {
// Types that are assignable to Property:
// *DatasetPropertyFilter_Project
// *DatasetPropertyFilter_Name
// *DatasetPropertyFilter_Domain
// *DatasetPropertyFilter_Version
Property isDatasetPropertyFilter_Property `protobuf_oneof:"property"`
// contains filtered or unexported fields
}
Dataset properties we can filter by
func (*DatasetPropertyFilter) Descriptor
deprecated
added in
v0.1.2
func (*DatasetPropertyFilter) Descriptor() ([]byte, []int)
Deprecated: Use DatasetPropertyFilter.ProtoReflect.Descriptor instead.
func (*DatasetPropertyFilter) GetDomain ¶ added in v0.1.2
func (x *DatasetPropertyFilter) GetDomain() string
func (*DatasetPropertyFilter) GetName ¶ added in v0.1.2
func (x *DatasetPropertyFilter) GetName() string
func (*DatasetPropertyFilter) GetProject ¶ added in v0.1.2
func (x *DatasetPropertyFilter) GetProject() string
func (*DatasetPropertyFilter) GetProperty ¶ added in v0.1.2
func (m *DatasetPropertyFilter) GetProperty() isDatasetPropertyFilter_Property
func (*DatasetPropertyFilter) GetVersion ¶ added in v0.1.2
func (x *DatasetPropertyFilter) GetVersion() string
func (*DatasetPropertyFilter) ProtoMessage ¶ added in v0.1.2
func (*DatasetPropertyFilter) ProtoMessage()
func (*DatasetPropertyFilter) ProtoReflect ¶ added in v0.2.131
func (x *DatasetPropertyFilter) ProtoReflect() protoreflect.Message
func (*DatasetPropertyFilter) Reset ¶ added in v0.1.2
func (x *DatasetPropertyFilter) Reset()
func (*DatasetPropertyFilter) String ¶ added in v0.1.2
func (x *DatasetPropertyFilter) String() string
type DatasetPropertyFilter_Domain ¶ added in v0.1.2
type DatasetPropertyFilter_Domain struct {
Domain string `protobuf:"bytes,3,opt,name=domain,proto3,oneof"`
}
type DatasetPropertyFilter_Name ¶ added in v0.1.2
type DatasetPropertyFilter_Name struct {
Name string `protobuf:"bytes,2,opt,name=name,proto3,oneof"`
}
type DatasetPropertyFilter_Project ¶ added in v0.1.2
type DatasetPropertyFilter_Project struct {
Project string `protobuf:"bytes,1,opt,name=project,proto3,oneof"`
}
type DatasetPropertyFilter_Version ¶ added in v0.1.2
type DatasetPropertyFilter_Version struct {
Version string `protobuf:"bytes,4,opt,name=version,proto3,oneof"`
}
type FilterExpression ¶ added in v0.1.2
type FilterExpression struct {
Filters []*SinglePropertyFilter `protobuf:"bytes,1,rep,name=filters,proto3" json:"filters,omitempty"`
// contains filtered or unexported fields
}
Filter expression that is composed of a combination of single filters
func (*FilterExpression) Descriptor
deprecated
added in
v0.1.2
func (*FilterExpression) Descriptor() ([]byte, []int)
Deprecated: Use FilterExpression.ProtoReflect.Descriptor instead.
func (*FilterExpression) GetFilters ¶ added in v0.1.2
func (x *FilterExpression) GetFilters() []*SinglePropertyFilter
func (*FilterExpression) ProtoMessage ¶ added in v0.1.2
func (*FilterExpression) ProtoMessage()
func (*FilterExpression) ProtoReflect ¶ added in v0.2.131
func (x *FilterExpression) ProtoReflect() protoreflect.Message
func (*FilterExpression) Reset ¶ added in v0.1.2
func (x *FilterExpression) Reset()
func (*FilterExpression) String ¶ added in v0.1.2
func (x *FilterExpression) String() string
type GetArtifactRequest ¶
type GetArtifactRequest struct {
Dataset *DatasetID `protobuf:"bytes,1,opt,name=dataset,proto3" json:"dataset,omitempty"`
// Types that are assignable to QueryHandle:
// *GetArtifactRequest_ArtifactId
// *GetArtifactRequest_TagName
QueryHandle isGetArtifactRequest_QueryHandle `protobuf_oneof:"query_handle"`
// contains filtered or unexported fields
}
func (*GetArtifactRequest) Descriptor
deprecated
func (*GetArtifactRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetArtifactRequest.ProtoReflect.Descriptor instead.
func (*GetArtifactRequest) GetArtifactId ¶
func (x *GetArtifactRequest) GetArtifactId() string
func (*GetArtifactRequest) GetDataset ¶
func (x *GetArtifactRequest) GetDataset() *DatasetID
func (*GetArtifactRequest) GetQueryHandle ¶
func (m *GetArtifactRequest) GetQueryHandle() isGetArtifactRequest_QueryHandle
func (*GetArtifactRequest) GetTagName ¶
func (x *GetArtifactRequest) GetTagName() string
func (*GetArtifactRequest) ProtoMessage ¶
func (*GetArtifactRequest) ProtoMessage()
func (*GetArtifactRequest) ProtoReflect ¶ added in v0.2.131
func (x *GetArtifactRequest) ProtoReflect() protoreflect.Message
func (*GetArtifactRequest) Reset ¶
func (x *GetArtifactRequest) Reset()
func (*GetArtifactRequest) String ¶
func (x *GetArtifactRequest) String() string
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"`
// contains filtered or unexported fields
}
func (*GetArtifactResponse) Descriptor
deprecated
func (*GetArtifactResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetArtifactResponse.ProtoReflect.Descriptor instead.
func (*GetArtifactResponse) GetArtifact ¶
func (x *GetArtifactResponse) GetArtifact() *Artifact
func (*GetArtifactResponse) ProtoMessage ¶
func (*GetArtifactResponse) ProtoMessage()
func (*GetArtifactResponse) ProtoReflect ¶ added in v0.2.131
func (x *GetArtifactResponse) ProtoReflect() protoreflect.Message
func (*GetArtifactResponse) Reset ¶
func (x *GetArtifactResponse) Reset()
func (*GetArtifactResponse) String ¶
func (x *GetArtifactResponse) String() string
type GetDatasetRequest ¶
type GetDatasetRequest struct {
Dataset *DatasetID `protobuf:"bytes,1,opt,name=dataset,proto3" json:"dataset,omitempty"`
// contains filtered or unexported fields
}
func (*GetDatasetRequest) Descriptor
deprecated
func (*GetDatasetRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetDatasetRequest.ProtoReflect.Descriptor instead.
func (*GetDatasetRequest) GetDataset ¶
func (x *GetDatasetRequest) GetDataset() *DatasetID
func (*GetDatasetRequest) ProtoMessage ¶
func (*GetDatasetRequest) ProtoMessage()
func (*GetDatasetRequest) ProtoReflect ¶ added in v0.2.131
func (x *GetDatasetRequest) ProtoReflect() protoreflect.Message
func (*GetDatasetRequest) Reset ¶
func (x *GetDatasetRequest) Reset()
func (*GetDatasetRequest) String ¶
func (x *GetDatasetRequest) String() string
type GetDatasetResponse ¶
type GetDatasetResponse struct {
Dataset *Dataset `protobuf:"bytes,1,opt,name=dataset,proto3" json:"dataset,omitempty"`
// contains filtered or unexported fields
}
func (*GetDatasetResponse) Descriptor
deprecated
func (*GetDatasetResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetDatasetResponse.ProtoReflect.Descriptor instead.
func (*GetDatasetResponse) GetDataset ¶
func (x *GetDatasetResponse) GetDataset() *Dataset
func (*GetDatasetResponse) ProtoMessage ¶
func (*GetDatasetResponse) ProtoMessage()
func (*GetDatasetResponse) ProtoReflect ¶ added in v0.2.131
func (x *GetDatasetResponse) ProtoReflect() protoreflect.Message
func (*GetDatasetResponse) Reset ¶
func (x *GetDatasetResponse) Reset()
func (*GetDatasetResponse) String ¶
func (x *GetDatasetResponse) String() string
type KeyValuePair ¶ added in v0.1.2
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"`
// contains filtered or unexported fields
}
func (*KeyValuePair) Descriptor
deprecated
added in
v0.1.2
func (*KeyValuePair) Descriptor() ([]byte, []int)
Deprecated: Use KeyValuePair.ProtoReflect.Descriptor instead.
func (*KeyValuePair) GetKey ¶ added in v0.1.2
func (x *KeyValuePair) GetKey() string
func (*KeyValuePair) GetValue ¶ added in v0.1.2
func (x *KeyValuePair) GetValue() string
func (*KeyValuePair) ProtoMessage ¶ added in v0.1.2
func (*KeyValuePair) ProtoMessage()
func (*KeyValuePair) ProtoReflect ¶ added in v0.2.131
func (x *KeyValuePair) ProtoReflect() protoreflect.Message
func (*KeyValuePair) Reset ¶ added in v0.1.2
func (x *KeyValuePair) Reset()
func (*KeyValuePair) String ¶ added in v0.1.2
func (x *KeyValuePair) String() string
type ListArtifactsRequest ¶ added in v0.1.2
type ListArtifactsRequest struct {
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"`
// contains filtered or unexported fields
}
List the artifacts that belong to the Dataset
func (*ListArtifactsRequest) Descriptor
deprecated
added in
v0.1.2
func (*ListArtifactsRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListArtifactsRequest.ProtoReflect.Descriptor instead.
func (*ListArtifactsRequest) GetDataset ¶ added in v0.1.2
func (x *ListArtifactsRequest) GetDataset() *DatasetID
func (*ListArtifactsRequest) GetFilter ¶ added in v0.1.2
func (x *ListArtifactsRequest) GetFilter() *FilterExpression
func (*ListArtifactsRequest) GetPagination ¶ added in v0.1.2
func (x *ListArtifactsRequest) GetPagination() *PaginationOptions
func (*ListArtifactsRequest) ProtoMessage ¶ added in v0.1.2
func (*ListArtifactsRequest) ProtoMessage()
func (*ListArtifactsRequest) ProtoReflect ¶ added in v0.2.131
func (x *ListArtifactsRequest) ProtoReflect() protoreflect.Message
func (*ListArtifactsRequest) Reset ¶ added in v0.1.2
func (x *ListArtifactsRequest) Reset()
func (*ListArtifactsRequest) String ¶ added in v0.1.2
func (x *ListArtifactsRequest) String() string
type ListArtifactsResponse ¶ added in v0.1.2
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"`
// contains filtered or unexported fields
}
Response to list artifacts
func (*ListArtifactsResponse) Descriptor
deprecated
added in
v0.1.2
func (*ListArtifactsResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListArtifactsResponse.ProtoReflect.Descriptor instead.
func (*ListArtifactsResponse) GetArtifacts ¶ added in v0.1.2
func (x *ListArtifactsResponse) GetArtifacts() []*Artifact
func (*ListArtifactsResponse) GetNextToken ¶ added in v0.1.2
func (x *ListArtifactsResponse) GetNextToken() string
func (*ListArtifactsResponse) ProtoMessage ¶ added in v0.1.2
func (*ListArtifactsResponse) ProtoMessage()
func (*ListArtifactsResponse) ProtoReflect ¶ added in v0.2.131
func (x *ListArtifactsResponse) ProtoReflect() protoreflect.Message
func (*ListArtifactsResponse) Reset ¶ added in v0.1.2
func (x *ListArtifactsResponse) Reset()
func (*ListArtifactsResponse) String ¶ added in v0.1.2
func (x *ListArtifactsResponse) String() string
type ListDatasetsRequest ¶ added in v0.1.2
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"`
// contains filtered or unexported fields
}
List the datasets for the given query
func (*ListDatasetsRequest) Descriptor
deprecated
added in
v0.1.2
func (*ListDatasetsRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListDatasetsRequest.ProtoReflect.Descriptor instead.
func (*ListDatasetsRequest) GetFilter ¶ added in v0.1.2
func (x *ListDatasetsRequest) GetFilter() *FilterExpression
func (*ListDatasetsRequest) GetPagination ¶ added in v0.1.2
func (x *ListDatasetsRequest) GetPagination() *PaginationOptions
func (*ListDatasetsRequest) ProtoMessage ¶ added in v0.1.2
func (*ListDatasetsRequest) ProtoMessage()
func (*ListDatasetsRequest) ProtoReflect ¶ added in v0.2.131
func (x *ListDatasetsRequest) ProtoReflect() protoreflect.Message
func (*ListDatasetsRequest) Reset ¶ added in v0.1.2
func (x *ListDatasetsRequest) Reset()
func (*ListDatasetsRequest) String ¶ added in v0.1.2
func (x *ListDatasetsRequest) String() string
type ListDatasetsResponse ¶ added in v0.1.2
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"`
// contains filtered or unexported fields
}
List the datasets response with token for next pagination
func (*ListDatasetsResponse) Descriptor
deprecated
added in
v0.1.2
func (*ListDatasetsResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListDatasetsResponse.ProtoReflect.Descriptor instead.
func (*ListDatasetsResponse) GetDatasets ¶ added in v0.1.2
func (x *ListDatasetsResponse) GetDatasets() []*Dataset
func (*ListDatasetsResponse) GetNextToken ¶ added in v0.1.2
func (x *ListDatasetsResponse) GetNextToken() string
func (*ListDatasetsResponse) ProtoMessage ¶ added in v0.1.2
func (*ListDatasetsResponse) ProtoMessage()
func (*ListDatasetsResponse) ProtoReflect ¶ added in v0.2.131
func (x *ListDatasetsResponse) ProtoReflect() protoreflect.Message
func (*ListDatasetsResponse) Reset ¶ added in v0.1.2
func (x *ListDatasetsResponse) Reset()
func (*ListDatasetsResponse) String ¶ added in v0.1.2
func (x *ListDatasetsResponse) String() string
type Metadata ¶
type Metadata struct {
KeyMap map[string]string `` // key map is a dictionary of key/val strings that represent metadata
/* 167-byte string literal not displayed */
// contains filtered or unexported fields
}
func (*Metadata) Descriptor
deprecated
func (*Metadata) ProtoMessage ¶
func (*Metadata) ProtoMessage()
func (*Metadata) ProtoReflect ¶ added in v0.2.131
func (x *Metadata) ProtoReflect() protoreflect.Message
type PaginationOptions ¶ added in v0.1.2
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"`
// contains filtered or unexported fields
}
Pagination options for making list requests
func (*PaginationOptions) Descriptor
deprecated
added in
v0.1.2
func (*PaginationOptions) Descriptor() ([]byte, []int)
Deprecated: Use PaginationOptions.ProtoReflect.Descriptor instead.
func (*PaginationOptions) GetLimit ¶ added in v0.1.2
func (x *PaginationOptions) GetLimit() uint32
func (*PaginationOptions) GetSortKey ¶ added in v0.1.2
func (x *PaginationOptions) GetSortKey() PaginationOptions_SortKey
func (*PaginationOptions) GetSortOrder ¶ added in v0.1.2
func (x *PaginationOptions) GetSortOrder() PaginationOptions_SortOrder
func (*PaginationOptions) GetToken ¶ added in v0.1.2
func (x *PaginationOptions) GetToken() string
func (*PaginationOptions) ProtoMessage ¶ added in v0.1.2
func (*PaginationOptions) ProtoMessage()
func (*PaginationOptions) ProtoReflect ¶ added in v0.2.131
func (x *PaginationOptions) ProtoReflect() protoreflect.Message
func (*PaginationOptions) Reset ¶ added in v0.1.2
func (x *PaginationOptions) Reset()
func (*PaginationOptions) String ¶ added in v0.1.2
func (x *PaginationOptions) String() string
type PaginationOptions_SortKey ¶ added in v0.1.2
type PaginationOptions_SortKey int32
const (
PaginationOptions_CREATION_TIME PaginationOptions_SortKey = 0
)
func (PaginationOptions_SortKey) Descriptor ¶ added in v0.2.131
func (PaginationOptions_SortKey) Descriptor() protoreflect.EnumDescriptor
func (PaginationOptions_SortKey) Enum ¶ added in v0.2.131
func (x PaginationOptions_SortKey) Enum() *PaginationOptions_SortKey
func (PaginationOptions_SortKey) EnumDescriptor
deprecated
added in
v0.1.2
func (PaginationOptions_SortKey) EnumDescriptor() ([]byte, []int)
Deprecated: Use PaginationOptions_SortKey.Descriptor instead.
func (PaginationOptions_SortKey) Number ¶ added in v0.2.131
func (x PaginationOptions_SortKey) Number() protoreflect.EnumNumber
func (PaginationOptions_SortKey) String ¶ added in v0.1.2
func (x PaginationOptions_SortKey) String() string
func (PaginationOptions_SortKey) Type ¶ added in v0.2.131
func (PaginationOptions_SortKey) Type() protoreflect.EnumType
type PaginationOptions_SortOrder ¶ added in v0.1.2
type PaginationOptions_SortOrder int32
const ( PaginationOptions_DESCENDING PaginationOptions_SortOrder = 0 PaginationOptions_ASCENDING PaginationOptions_SortOrder = 1 )
func (PaginationOptions_SortOrder) Descriptor ¶ added in v0.2.131
func (PaginationOptions_SortOrder) Descriptor() protoreflect.EnumDescriptor
func (PaginationOptions_SortOrder) Enum ¶ added in v0.2.131
func (x PaginationOptions_SortOrder) Enum() *PaginationOptions_SortOrder
func (PaginationOptions_SortOrder) EnumDescriptor
deprecated
added in
v0.1.2
func (PaginationOptions_SortOrder) EnumDescriptor() ([]byte, []int)
Deprecated: Use PaginationOptions_SortOrder.Descriptor instead.
func (PaginationOptions_SortOrder) Number ¶ added in v0.2.131
func (x PaginationOptions_SortOrder) Number() protoreflect.EnumNumber
func (PaginationOptions_SortOrder) String ¶ added in v0.1.2
func (x PaginationOptions_SortOrder) String() string
func (PaginationOptions_SortOrder) Type ¶ added in v0.2.131
func (PaginationOptions_SortOrder) Type() protoreflect.EnumType
type Partition ¶ added in v0.1.2
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"`
// contains filtered or unexported fields
}
func (*Partition) Descriptor
deprecated
added in
v0.1.2
func (*Partition) ProtoMessage ¶ added in v0.1.2
func (*Partition) ProtoMessage()
func (*Partition) ProtoReflect ¶ added in v0.2.131
func (x *Partition) ProtoReflect() protoreflect.Message
type PartitionPropertyFilter ¶ added in v0.1.2
type PartitionPropertyFilter struct {
// Types that are assignable to Property:
// *PartitionPropertyFilter_KeyVal
Property isPartitionPropertyFilter_Property `protobuf_oneof:"property"`
// contains filtered or unexported fields
}
Partition properties we can filter by
func (*PartitionPropertyFilter) Descriptor
deprecated
added in
v0.1.2
func (*PartitionPropertyFilter) Descriptor() ([]byte, []int)
Deprecated: Use PartitionPropertyFilter.ProtoReflect.Descriptor instead.
func (*PartitionPropertyFilter) GetKeyVal ¶ added in v0.1.2
func (x *PartitionPropertyFilter) GetKeyVal() *KeyValuePair
func (*PartitionPropertyFilter) GetProperty ¶ added in v0.1.2
func (m *PartitionPropertyFilter) GetProperty() isPartitionPropertyFilter_Property
func (*PartitionPropertyFilter) ProtoMessage ¶ added in v0.1.2
func (*PartitionPropertyFilter) ProtoMessage()
func (*PartitionPropertyFilter) ProtoReflect ¶ added in v0.2.131
func (x *PartitionPropertyFilter) ProtoReflect() protoreflect.Message
func (*PartitionPropertyFilter) Reset ¶ added in v0.1.2
func (x *PartitionPropertyFilter) Reset()
func (*PartitionPropertyFilter) String ¶ added in v0.1.2
func (x *PartitionPropertyFilter) String() string
type PartitionPropertyFilter_KeyVal ¶ added in v0.1.2
type PartitionPropertyFilter_KeyVal struct {
KeyVal *KeyValuePair `protobuf:"bytes,1,opt,name=key_val,json=keyVal,proto3,oneof"`
}
type SinglePropertyFilter ¶ added in v0.1.2
type SinglePropertyFilter struct {
// Types that are assignable to PropertyFilter:
// *SinglePropertyFilter_TagFilter
// *SinglePropertyFilter_PartitionFilter
// *SinglePropertyFilter_ArtifactFilter
// *SinglePropertyFilter_DatasetFilter
PropertyFilter isSinglePropertyFilter_PropertyFilter `protobuf_oneof:"property_filter"`
Operator SinglePropertyFilter_ComparisonOperator `` // field 10 in case we add more entities to query
/* 128-byte string literal not displayed */
// contains filtered or unexported fields
}
A single property to filter on.
func (*SinglePropertyFilter) Descriptor
deprecated
added in
v0.1.2
func (*SinglePropertyFilter) Descriptor() ([]byte, []int)
Deprecated: Use SinglePropertyFilter.ProtoReflect.Descriptor instead.
func (*SinglePropertyFilter) GetArtifactFilter ¶ added in v0.1.2
func (x *SinglePropertyFilter) GetArtifactFilter() *ArtifactPropertyFilter
func (*SinglePropertyFilter) GetDatasetFilter ¶ added in v0.1.2
func (x *SinglePropertyFilter) GetDatasetFilter() *DatasetPropertyFilter
func (*SinglePropertyFilter) GetOperator ¶ added in v0.1.2
func (x *SinglePropertyFilter) GetOperator() SinglePropertyFilter_ComparisonOperator
func (*SinglePropertyFilter) GetPartitionFilter ¶ added in v0.1.2
func (x *SinglePropertyFilter) GetPartitionFilter() *PartitionPropertyFilter
func (*SinglePropertyFilter) GetPropertyFilter ¶ added in v0.1.2
func (m *SinglePropertyFilter) GetPropertyFilter() isSinglePropertyFilter_PropertyFilter
func (*SinglePropertyFilter) GetTagFilter ¶ added in v0.1.2
func (x *SinglePropertyFilter) GetTagFilter() *TagPropertyFilter
func (*SinglePropertyFilter) ProtoMessage ¶ added in v0.1.2
func (*SinglePropertyFilter) ProtoMessage()
func (*SinglePropertyFilter) ProtoReflect ¶ added in v0.2.131
func (x *SinglePropertyFilter) ProtoReflect() protoreflect.Message
func (*SinglePropertyFilter) Reset ¶ added in v0.1.2
func (x *SinglePropertyFilter) Reset()
func (*SinglePropertyFilter) String ¶ added in v0.1.2
func (x *SinglePropertyFilter) String() string
type SinglePropertyFilter_ArtifactFilter ¶ added in v0.1.2
type SinglePropertyFilter_ArtifactFilter struct {
ArtifactFilter *ArtifactPropertyFilter `protobuf:"bytes,3,opt,name=artifact_filter,json=artifactFilter,proto3,oneof"`
}
type SinglePropertyFilter_ComparisonOperator ¶ added in v0.1.2
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) Descriptor ¶ added in v0.2.131
func (SinglePropertyFilter_ComparisonOperator) Descriptor() protoreflect.EnumDescriptor
func (SinglePropertyFilter_ComparisonOperator) EnumDescriptor
deprecated
added in
v0.1.2
func (SinglePropertyFilter_ComparisonOperator) EnumDescriptor() ([]byte, []int)
Deprecated: Use SinglePropertyFilter_ComparisonOperator.Descriptor instead.
func (SinglePropertyFilter_ComparisonOperator) Number ¶ added in v0.2.131
func (x SinglePropertyFilter_ComparisonOperator) Number() protoreflect.EnumNumber
func (SinglePropertyFilter_ComparisonOperator) String ¶ added in v0.1.2
func (x SinglePropertyFilter_ComparisonOperator) String() string
func (SinglePropertyFilter_ComparisonOperator) Type ¶ added in v0.2.131
func (SinglePropertyFilter_ComparisonOperator) Type() protoreflect.EnumType
type SinglePropertyFilter_DatasetFilter ¶ added in v0.1.2
type SinglePropertyFilter_DatasetFilter struct {
DatasetFilter *DatasetPropertyFilter `protobuf:"bytes,4,opt,name=dataset_filter,json=datasetFilter,proto3,oneof"`
}
type SinglePropertyFilter_PartitionFilter ¶ added in v0.1.2
type SinglePropertyFilter_PartitionFilter struct {
PartitionFilter *PartitionPropertyFilter `protobuf:"bytes,2,opt,name=partition_filter,json=partitionFilter,proto3,oneof"`
}
type SinglePropertyFilter_TagFilter ¶ added in v0.1.2
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"`
// contains filtered or unexported fields
}
func (*Tag) Descriptor
deprecated
func (*Tag) GetArtifactId ¶
func (*Tag) GetDataset ¶
func (*Tag) ProtoMessage ¶
func (*Tag) ProtoMessage()
func (*Tag) ProtoReflect ¶ added in v0.2.131
func (x *Tag) ProtoReflect() protoreflect.Message
type TagPropertyFilter ¶ added in v0.1.2
type TagPropertyFilter struct {
// Types that are assignable to Property:
// *TagPropertyFilter_TagName
Property isTagPropertyFilter_Property `protobuf_oneof:"property"`
// contains filtered or unexported fields
}
Tag properties we can filter by
func (*TagPropertyFilter) Descriptor
deprecated
added in
v0.1.2
func (*TagPropertyFilter) Descriptor() ([]byte, []int)
Deprecated: Use TagPropertyFilter.ProtoReflect.Descriptor instead.
func (*TagPropertyFilter) GetProperty ¶ added in v0.1.2
func (m *TagPropertyFilter) GetProperty() isTagPropertyFilter_Property
func (*TagPropertyFilter) GetTagName ¶ added in v0.1.2
func (x *TagPropertyFilter) GetTagName() string
func (*TagPropertyFilter) ProtoMessage ¶ added in v0.1.2
func (*TagPropertyFilter) ProtoMessage()
func (*TagPropertyFilter) ProtoReflect ¶ added in v0.2.131
func (x *TagPropertyFilter) ProtoReflect() protoreflect.Message
func (*TagPropertyFilter) Reset ¶ added in v0.1.2
func (x *TagPropertyFilter) Reset()
func (*TagPropertyFilter) String ¶ added in v0.1.2
func (x *TagPropertyFilter) String() string
type TagPropertyFilter_TagName ¶ added in v0.1.2
type TagPropertyFilter_TagName struct {
TagName string `protobuf:"bytes,1,opt,name=tag_name,json=tagName,proto3,oneof"`
}
type UnimplementedDataCatalogServer ¶
type UnimplementedDataCatalogServer struct {
}
UnimplementedDataCatalogServer can be embedded to have forward compatible implementations.
func (*UnimplementedDataCatalogServer) AddTag ¶
func (*UnimplementedDataCatalogServer) AddTag(context.Context, *AddTagRequest) (*AddTagResponse, error)
func (*UnimplementedDataCatalogServer) CreateArtifact ¶
func (*UnimplementedDataCatalogServer) CreateArtifact(context.Context, *CreateArtifactRequest) (*CreateArtifactResponse, error)
func (*UnimplementedDataCatalogServer) CreateDataset ¶
func (*UnimplementedDataCatalogServer) CreateDataset(context.Context, *CreateDatasetRequest) (*CreateDatasetResponse, error)
func (*UnimplementedDataCatalogServer) GetArtifact ¶
func (*UnimplementedDataCatalogServer) GetArtifact(context.Context, *GetArtifactRequest) (*GetArtifactResponse, error)
func (*UnimplementedDataCatalogServer) GetDataset ¶
func (*UnimplementedDataCatalogServer) GetDataset(context.Context, *GetDatasetRequest) (*GetDatasetResponse, error)
func (*UnimplementedDataCatalogServer) ListArtifacts ¶ added in v0.1.2
func (*UnimplementedDataCatalogServer) ListArtifacts(context.Context, *ListArtifactsRequest) (*ListArtifactsResponse, error)
func (*UnimplementedDataCatalogServer) ListDatasets ¶ added in v0.1.2
func (*UnimplementedDataCatalogServer) ListDatasets(context.Context, *ListDatasetsRequest) (*ListDatasetsResponse, error)