datacatalog

package
v0.3.0 Latest Latest
Warning

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

Go to latest
Published: Mar 5, 2021 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	SinglePropertyFilter_ComparisonOperator_name = map[int32]string{
		0: "EQUALS",
	}
	SinglePropertyFilter_ComparisonOperator_value = map[string]int32{
		"EQUALS": 0,
	}
)

Enum value maps for SinglePropertyFilter_ComparisonOperator.

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

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

View Source
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) Descriptor() ([]byte, []int)

Deprecated: Use Artifact.ProtoReflect.Descriptor instead.

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 (x *Artifact) GetDataset() *DatasetID

func (*Artifact) GetId

func (x *Artifact) GetId() string

func (*Artifact) GetMetadata

func (x *Artifact) GetMetadata() *Metadata

func (*Artifact) GetPartitions added in v0.1.2

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

func (*Artifact) GetTags added in v0.1.2

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

func (*Artifact) ProtoMessage

func (*Artifact) ProtoMessage()

func (*Artifact) ProtoReflect added in v0.2.131

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

func (*Artifact) Reset

func (x *Artifact) Reset()

func (*Artifact) String

func (x *Artifact) String() string

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.

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) Descriptor() ([]byte, []int)

Deprecated: Use Dataset.ProtoReflect.Descriptor instead.

func (*Dataset) GetId

func (x *Dataset) GetId() *DatasetID

func (*Dataset) GetMetadata

func (x *Dataset) GetMetadata() *Metadata

func (*Dataset) GetPartitionKeys added in v0.1.2

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

func (*Dataset) ProtoMessage

func (*Dataset) ProtoMessage()

func (*Dataset) ProtoReflect added in v0.2.131

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

func (*Dataset) Reset

func (x *Dataset) Reset()

func (*Dataset) String

func (x *Dataset) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use DatasetID.ProtoReflect.Descriptor instead.

func (*DatasetID) GetDomain

func (x *DatasetID) GetDomain() string

func (*DatasetID) GetName

func (x *DatasetID) GetName() string

func (*DatasetID) GetProject

func (x *DatasetID) GetProject() string

func (*DatasetID) GetUUID added in v0.1.2

func (x *DatasetID) GetUUID() string

func (*DatasetID) GetVersion

func (x *DatasetID) GetVersion() string

func (*DatasetID) ProtoMessage

func (*DatasetID) ProtoMessage()

func (*DatasetID) ProtoReflect added in v0.2.131

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

func (*DatasetID) Reset

func (x *DatasetID) Reset()

func (*DatasetID) String

func (x *DatasetID) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use Metadata.ProtoReflect.Descriptor instead.

func (*Metadata) GetKeyMap

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

func (*Metadata) ProtoMessage

func (*Metadata) ProtoMessage()

func (*Metadata) ProtoReflect added in v0.2.131

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

func (*Metadata) Reset

func (x *Metadata) Reset()

func (*Metadata) String

func (x *Metadata) String() string

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 (*PaginationOptions) GetSortOrder added in v0.1.2

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) Enum added in v0.2.131

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 (PaginationOptions_SortKey) String added in v0.1.2

func (x PaginationOptions_SortKey) String() string

func (PaginationOptions_SortKey) Type added in v0.2.131

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) Enum added in v0.2.131

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 (PaginationOptions_SortOrder) String added in v0.1.2

func (PaginationOptions_SortOrder) Type added in v0.2.131

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) Descriptor() ([]byte, []int)

Deprecated: Use Partition.ProtoReflect.Descriptor instead.

func (*Partition) GetKey added in v0.1.2

func (x *Partition) GetKey() string

func (*Partition) GetValue added in v0.1.2

func (x *Partition) GetValue() string

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

func (*Partition) Reset added in v0.1.2

func (x *Partition) Reset()

func (*Partition) String added in v0.1.2

func (x *Partition) String() string

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 (*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) Enum added in v0.2.131

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 (SinglePropertyFilter_ComparisonOperator) String added in v0.1.2

func (SinglePropertyFilter_ComparisonOperator) Type added in v0.2.131

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) Descriptor() ([]byte, []int)

Deprecated: Use Tag.ProtoReflect.Descriptor instead.

func (*Tag) GetArtifactId

func (x *Tag) GetArtifactId() string

func (*Tag) GetDataset

func (x *Tag) GetDataset() *DatasetID

func (*Tag) GetName

func (x *Tag) GetName() string

func (*Tag) ProtoMessage

func (*Tag) ProtoMessage()

func (*Tag) ProtoReflect added in v0.2.131

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

func (*Tag) Reset

func (x *Tag) Reset()

func (*Tag) String

func (x *Tag) String() string

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

func (*UnimplementedDataCatalogServer) CreateDataset

func (*UnimplementedDataCatalogServer) GetArtifact

func (*UnimplementedDataCatalogServer) GetDataset

func (*UnimplementedDataCatalogServer) ListArtifacts added in v0.1.2

func (*UnimplementedDataCatalogServer) ListDatasets added in v0.1.2

Jump to

Keyboard shortcuts

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