datacatalog

package
v0.2.2 Latest Latest
Warning

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

 Go to latest Published: Aug 28, 2020 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

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

Functions

func RegisterDataCatalogServer 

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

Types

type AddTagRequest 

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

func (*AddTagRequest) Descriptor 

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

func (*AddTagRequest) GetTag 

func (m *AddTagRequest) GetTag() *Tag

func (*AddTagRequest) ProtoMessage 

func (*AddTagRequest) ProtoMessage()

func (*AddTagRequest) Reset 

func (m *AddTagRequest) Reset()

func (*AddTagRequest) String 

func (m *AddTagRequest) String() string

func (*AddTagRequest) XXX_DiscardUnknown 

func (m *AddTagRequest) XXX_DiscardUnknown()

func (*AddTagRequest) XXX_Marshal 

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

func (*AddTagRequest) XXX_Merge 

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

func (*AddTagRequest) XXX_Size 

func (m *AddTagRequest) XXX_Size() int

func (*AddTagRequest) XXX_Unmarshal 

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

type AddTagResponse 

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

func (*AddTagResponse) Descriptor 

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

func (*AddTagResponse) ProtoMessage 

func (*AddTagResponse) ProtoMessage()

func (*AddTagResponse) Reset 

func (m *AddTagResponse) Reset()

func (*AddTagResponse) String 

func (m *AddTagResponse) String() string

func (*AddTagResponse) XXX_DiscardUnknown 

func (m *AddTagResponse) XXX_DiscardUnknown()

func (*AddTagResponse) XXX_Marshal 

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

func (*AddTagResponse) XXX_Merge 

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

func (*AddTagResponse) XXX_Size 

func (m *AddTagResponse) XXX_Size() int

func (*AddTagResponse) XXX_Unmarshal 

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

type Artifact 

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

func (*Artifact) Descriptor 

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

func (*Artifact) GetCreatedAt added in v0.2.1 

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

func (*Artifact) GetData 

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

func (*Artifact) GetDataset 

func (m *Artifact) GetDataset() *DatasetID

func (*Artifact) GetId 

func (m *Artifact) GetId() string

func (*Artifact) GetMetadata 

func (m *Artifact) GetMetadata() *Metadata

func (*Artifact) GetPartitions added in v0.1.2 

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

func (*Artifact) GetTags added in v0.1.2 

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

func (*Artifact) ProtoMessage 

func (*Artifact) ProtoMessage()

func (*Artifact) Reset 

func (m *Artifact) Reset()

func (*Artifact) String 

func (m *Artifact) String() string

func (*Artifact) XXX_DiscardUnknown 

func (m *Artifact) XXX_DiscardUnknown()

func (*Artifact) XXX_Marshal 

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

func (*Artifact) XXX_Merge 

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

func (*Artifact) XXX_Size 

func (m *Artifact) XXX_Size() int

func (*Artifact) XXX_Unmarshal 

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

type ArtifactData 

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

func (*ArtifactData) Descriptor 

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

func (*ArtifactData) GetName 

func (m *ArtifactData) GetName() string

func (*ArtifactData) GetValue 

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

func (*ArtifactData) ProtoMessage 

func (*ArtifactData) ProtoMessage()

func (*ArtifactData) Reset 

func (m *ArtifactData) Reset()

func (*ArtifactData) String 

func (m *ArtifactData) String() string

func (*ArtifactData) XXX_DiscardUnknown 

func (m *ArtifactData) XXX_DiscardUnknown()

func (*ArtifactData) XXX_Marshal 

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

func (*ArtifactData) XXX_Merge 

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

func (*ArtifactData) XXX_Size 

func (m *ArtifactData) XXX_Size() int

func (*ArtifactData) XXX_Unmarshal 

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

type ArtifactPropertyFilter added in v0.1.2 

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

Artifact properties we can filter by

func (*ArtifactPropertyFilter) Descriptor added in v0.1.2 

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

func (*ArtifactPropertyFilter) GetArtifactId added in v0.1.2 

func (m *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) Reset added in v0.1.2 

func (m *ArtifactPropertyFilter) Reset()

func (*ArtifactPropertyFilter) String added in v0.1.2 

func (m *ArtifactPropertyFilter) String() string

func (*ArtifactPropertyFilter) XXX_DiscardUnknown added in v0.1.2 

func (m *ArtifactPropertyFilter) XXX_DiscardUnknown()

func (*ArtifactPropertyFilter) XXX_Marshal added in v0.1.2 

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

func (*ArtifactPropertyFilter) XXX_Merge added in v0.1.2 

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

func (*ArtifactPropertyFilter) XXX_OneofWrappers added in v0.1.2 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*ArtifactPropertyFilter) XXX_Size added in v0.1.2 

func (m *ArtifactPropertyFilter) XXX_Size() int

func (*ArtifactPropertyFilter) XXX_Unmarshal added in v0.1.2 

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

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"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*CreateArtifactRequest) Descriptor 

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

func (*CreateArtifactRequest) GetArtifact 

func (m *CreateArtifactRequest) GetArtifact() *Artifact

func (*CreateArtifactRequest) ProtoMessage 

func (*CreateArtifactRequest) ProtoMessage()

func (*CreateArtifactRequest) Reset 

func (m *CreateArtifactRequest) Reset()

func (*CreateArtifactRequest) String 

func (m *CreateArtifactRequest) String() string

func (*CreateArtifactRequest) XXX_DiscardUnknown 

func (m *CreateArtifactRequest) XXX_DiscardUnknown()

func (*CreateArtifactRequest) XXX_Marshal 

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

func (*CreateArtifactRequest) XXX_Merge 

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

func (*CreateArtifactRequest) XXX_Size 

func (m *CreateArtifactRequest) XXX_Size() int

func (*CreateArtifactRequest) XXX_Unmarshal 

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

type CreateArtifactResponse 

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

func (*CreateArtifactResponse) Descriptor 

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

func (*CreateArtifactResponse) ProtoMessage 

func (*CreateArtifactResponse) ProtoMessage()

func (*CreateArtifactResponse) Reset 

func (m *CreateArtifactResponse) Reset()

func (*CreateArtifactResponse) String 

func (m *CreateArtifactResponse) String() string

func (*CreateArtifactResponse) XXX_DiscardUnknown 

func (m *CreateArtifactResponse) XXX_DiscardUnknown()

func (*CreateArtifactResponse) XXX_Marshal 

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

func (*CreateArtifactResponse) XXX_Merge 

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

func (*CreateArtifactResponse) XXX_Size 

func (m *CreateArtifactResponse) XXX_Size() int

func (*CreateArtifactResponse) XXX_Unmarshal 

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

type CreateDatasetRequest 

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

func (*CreateDatasetRequest) Descriptor 

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

func (*CreateDatasetRequest) GetDataset 

func (m *CreateDatasetRequest) GetDataset() *Dataset

func (*CreateDatasetRequest) ProtoMessage 

func (*CreateDatasetRequest) ProtoMessage()

func (*CreateDatasetRequest) Reset 

func (m *CreateDatasetRequest) Reset()

func (*CreateDatasetRequest) String 

func (m *CreateDatasetRequest) String() string

func (*CreateDatasetRequest) XXX_DiscardUnknown 

func (m *CreateDatasetRequest) XXX_DiscardUnknown()

func (*CreateDatasetRequest) XXX_Marshal 

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

func (*CreateDatasetRequest) XXX_Merge 

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

func (*CreateDatasetRequest) XXX_Size 

func (m *CreateDatasetRequest) XXX_Size() int

func (*CreateDatasetRequest) XXX_Unmarshal 

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

type CreateDatasetResponse 

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

func (*CreateDatasetResponse) Descriptor 

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

func (*CreateDatasetResponse) ProtoMessage 

func (*CreateDatasetResponse) ProtoMessage()

func (*CreateDatasetResponse) Reset 

func (m *CreateDatasetResponse) Reset()

func (*CreateDatasetResponse) String 

func (m *CreateDatasetResponse) String() string

func (*CreateDatasetResponse) XXX_DiscardUnknown 

func (m *CreateDatasetResponse) XXX_DiscardUnknown()

func (*CreateDatasetResponse) XXX_Marshal 

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

func (*CreateDatasetResponse) XXX_Merge 

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

func (*CreateDatasetResponse) XXX_Size 

func (m *CreateDatasetResponse) XXX_Size() int

func (*CreateDatasetResponse) XXX_Unmarshal 

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

type DataCatalogClient 

type DataCatalogClient interface {
	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.ClientConn) 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"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*Dataset) Descriptor 

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

func (*Dataset) GetId 

func (m *Dataset) GetId() *DatasetID

func (*Dataset) GetMetadata 

func (m *Dataset) GetMetadata() *Metadata

func (*Dataset) GetPartitionKeys added in v0.1.2 

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

func (*Dataset) ProtoMessage 

func (*Dataset) ProtoMessage()

func (*Dataset) Reset 

func (m *Dataset) Reset()

func (*Dataset) String 

func (m *Dataset) String() string

func (*Dataset) XXX_DiscardUnknown 

func (m *Dataset) XXX_DiscardUnknown()

func (*Dataset) XXX_Marshal 

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

func (*Dataset) XXX_Merge 

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

func (*Dataset) XXX_Size 

func (m *Dataset) XXX_Size() int

func (*Dataset) XXX_Unmarshal 

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

type DatasetID 

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

func (*DatasetID) Descriptor 

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

func (*DatasetID) GetDomain 

func (m *DatasetID) GetDomain() string

func (*DatasetID) GetName 

func (m *DatasetID) GetName() string

func (*DatasetID) GetProject 

func (m *DatasetID) GetProject() string

func (*DatasetID) GetUUID added in v0.1.2 

func (m *DatasetID) GetUUID() string

func (*DatasetID) GetVersion 

func (m *DatasetID) GetVersion() string

func (*DatasetID) ProtoMessage 

func (*DatasetID) ProtoMessage()

func (*DatasetID) Reset 

func (m *DatasetID) Reset()

func (*DatasetID) String 

func (m *DatasetID) String() string

func (*DatasetID) XXX_DiscardUnknown 

func (m *DatasetID) XXX_DiscardUnknown()

func (*DatasetID) XXX_Marshal 

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

func (*DatasetID) XXX_Merge 

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

func (*DatasetID) XXX_Size 

func (m *DatasetID) XXX_Size() int

func (*DatasetID) XXX_Unmarshal 

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

type DatasetPropertyFilter added in v0.1.2 

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

Dataset properties we can filter by

func (*DatasetPropertyFilter) Descriptor added in v0.1.2 

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

func (*DatasetPropertyFilter) GetDomain added in v0.1.2 

func (m *DatasetPropertyFilter) GetDomain() string

func (*DatasetPropertyFilter) GetName added in v0.1.2 

func (m *DatasetPropertyFilter) GetName() string

func (*DatasetPropertyFilter) GetProject added in v0.1.2 

func (m *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 (m *DatasetPropertyFilter) GetVersion() string

func (*DatasetPropertyFilter) ProtoMessage added in v0.1.2 

func (*DatasetPropertyFilter) ProtoMessage()

func (*DatasetPropertyFilter) Reset added in v0.1.2 

func (m *DatasetPropertyFilter) Reset()

func (*DatasetPropertyFilter) String added in v0.1.2 

func (m *DatasetPropertyFilter) String() string

func (*DatasetPropertyFilter) XXX_DiscardUnknown added in v0.1.2 

func (m *DatasetPropertyFilter) XXX_DiscardUnknown()

func (*DatasetPropertyFilter) XXX_Marshal added in v0.1.2 

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

func (*DatasetPropertyFilter) XXX_Merge added in v0.1.2 

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

func (*DatasetPropertyFilter) XXX_OneofWrappers added in v0.1.2 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*DatasetPropertyFilter) XXX_Size added in v0.1.2 

func (m *DatasetPropertyFilter) XXX_Size() int

func (*DatasetPropertyFilter) XXX_Unmarshal added in v0.1.2 

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

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"`
	XXX_NoUnkeyedLiteral struct{}                `json:"-"`
	XXX_unrecognized     []byte                  `json:"-"`
	XXX_sizecache        int32                   `json:"-"`
}

Filter expression that is composed of a combination of single filters

func (*FilterExpression) Descriptor added in v0.1.2 

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

func (*FilterExpression) GetFilters added in v0.1.2 

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

func (*FilterExpression) ProtoMessage added in v0.1.2 

func (*FilterExpression) ProtoMessage()

func (*FilterExpression) Reset added in v0.1.2 

func (m *FilterExpression) Reset()

func (*FilterExpression) String added in v0.1.2 

func (m *FilterExpression) String() string

func (*FilterExpression) XXX_DiscardUnknown added in v0.1.2 

func (m *FilterExpression) XXX_DiscardUnknown()

func (*FilterExpression) XXX_Marshal added in v0.1.2 

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

func (*FilterExpression) XXX_Merge added in v0.1.2 

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

func (*FilterExpression) XXX_Size added in v0.1.2 

func (m *FilterExpression) XXX_Size() int

func (*FilterExpression) XXX_Unmarshal added in v0.1.2 

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

type GetArtifactRequest 

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

func (*GetArtifactRequest) Descriptor 

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

func (*GetArtifactRequest) GetArtifactId 

func (m *GetArtifactRequest) GetArtifactId() string

func (*GetArtifactRequest) GetDataset 

func (m *GetArtifactRequest) GetDataset() *DatasetID

func (*GetArtifactRequest) GetQueryHandle 

func (m *GetArtifactRequest) GetQueryHandle() isGetArtifactRequest_QueryHandle

func (*GetArtifactRequest) GetTagName 

func (m *GetArtifactRequest) GetTagName() string

func (*GetArtifactRequest) ProtoMessage 

func (*GetArtifactRequest) ProtoMessage()

func (*GetArtifactRequest) Reset 

func (m *GetArtifactRequest) Reset()

func (*GetArtifactRequest) String 

func (m *GetArtifactRequest) String() string

func (*GetArtifactRequest) XXX_DiscardUnknown 

func (m *GetArtifactRequest) XXX_DiscardUnknown()

func (*GetArtifactRequest) XXX_Marshal 

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

func (*GetArtifactRequest) XXX_Merge 

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

func (*GetArtifactRequest) XXX_OneofWrappers 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*GetArtifactRequest) XXX_Size 

func (m *GetArtifactRequest) XXX_Size() int

func (*GetArtifactRequest) XXX_Unmarshal 

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

type GetArtifactRequest_ArtifactId 

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

type GetArtifactRequest_TagName 

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

type GetArtifactResponse 

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

func (*GetArtifactResponse) Descriptor 

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

func (*GetArtifactResponse) GetArtifact 

func (m *GetArtifactResponse) GetArtifact() *Artifact

func (*GetArtifactResponse) ProtoMessage 

func (*GetArtifactResponse) ProtoMessage()

func (*GetArtifactResponse) Reset 

func (m *GetArtifactResponse) Reset()

func (*GetArtifactResponse) String 

func (m *GetArtifactResponse) String() string

func (*GetArtifactResponse) XXX_DiscardUnknown 

func (m *GetArtifactResponse) XXX_DiscardUnknown()

func (*GetArtifactResponse) XXX_Marshal 

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

func (*GetArtifactResponse) XXX_Merge 

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

func (*GetArtifactResponse) XXX_Size 

func (m *GetArtifactResponse) XXX_Size() int

func (*GetArtifactResponse) XXX_Unmarshal 

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

type GetDatasetRequest 

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

func (*GetDatasetRequest) Descriptor 

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

func (*GetDatasetRequest) GetDataset 

func (m *GetDatasetRequest) GetDataset() *DatasetID

func (*GetDatasetRequest) ProtoMessage 

func (*GetDatasetRequest) ProtoMessage()

func (*GetDatasetRequest) Reset 

func (m *GetDatasetRequest) Reset()

func (*GetDatasetRequest) String 

func (m *GetDatasetRequest) String() string

func (*GetDatasetRequest) XXX_DiscardUnknown 

func (m *GetDatasetRequest) XXX_DiscardUnknown()

func (*GetDatasetRequest) XXX_Marshal 

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

func (*GetDatasetRequest) XXX_Merge 

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

func (*GetDatasetRequest) XXX_Size 

func (m *GetDatasetRequest) XXX_Size() int

func (*GetDatasetRequest) XXX_Unmarshal 

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

type GetDatasetResponse 

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

func (*GetDatasetResponse) Descriptor 

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

func (*GetDatasetResponse) GetDataset 

func (m *GetDatasetResponse) GetDataset() *Dataset

func (*GetDatasetResponse) ProtoMessage 

func (*GetDatasetResponse) ProtoMessage()

func (*GetDatasetResponse) Reset 

func (m *GetDatasetResponse) Reset()

func (*GetDatasetResponse) String 

func (m *GetDatasetResponse) String() string

func (*GetDatasetResponse) XXX_DiscardUnknown 

func (m *GetDatasetResponse) XXX_DiscardUnknown()

func (*GetDatasetResponse) XXX_Marshal 

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

func (*GetDatasetResponse) XXX_Merge 

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

func (*GetDatasetResponse) XXX_Size 

func (m *GetDatasetResponse) XXX_Size() int

func (*GetDatasetResponse) XXX_Unmarshal 

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

type 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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*KeyValuePair) Descriptor added in v0.1.2 

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

func (*KeyValuePair) GetKey added in v0.1.2 

func (m *KeyValuePair) GetKey() string

func (*KeyValuePair) GetValue added in v0.1.2 

func (m *KeyValuePair) GetValue() string

func (*KeyValuePair) ProtoMessage added in v0.1.2 

func (*KeyValuePair) ProtoMessage()

func (*KeyValuePair) Reset added in v0.1.2 

func (m *KeyValuePair) Reset()

func (*KeyValuePair) String added in v0.1.2 

func (m *KeyValuePair) String() string

func (*KeyValuePair) XXX_DiscardUnknown added in v0.1.2 

func (m *KeyValuePair) XXX_DiscardUnknown()

func (*KeyValuePair) XXX_Marshal added in v0.1.2 

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

func (*KeyValuePair) XXX_Merge added in v0.1.2 

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

func (*KeyValuePair) XXX_Size added in v0.1.2 

func (m *KeyValuePair) XXX_Size() int

func (*KeyValuePair) XXX_Unmarshal added in v0.1.2 

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

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"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

List the artifacts that belong to the Dataset

func (*ListArtifactsRequest) Descriptor added in v0.1.2 

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

func (*ListArtifactsRequest) GetDataset added in v0.1.2 

func (m *ListArtifactsRequest) GetDataset() *DatasetID

func (*ListArtifactsRequest) GetFilter added in v0.1.2 

func (m *ListArtifactsRequest) GetFilter() *FilterExpression

func (*ListArtifactsRequest) GetPagination added in v0.1.2 

func (m *ListArtifactsRequest) GetPagination() *PaginationOptions

func (*ListArtifactsRequest) ProtoMessage added in v0.1.2 

func (*ListArtifactsRequest) ProtoMessage()

func (*ListArtifactsRequest) Reset added in v0.1.2 

func (m *ListArtifactsRequest) Reset()

func (*ListArtifactsRequest) String added in v0.1.2 

func (m *ListArtifactsRequest) String() string

func (*ListArtifactsRequest) XXX_DiscardUnknown added in v0.1.2 

func (m *ListArtifactsRequest) XXX_DiscardUnknown()

func (*ListArtifactsRequest) XXX_Marshal added in v0.1.2 

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

func (*ListArtifactsRequest) XXX_Merge added in v0.1.2 

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

func (*ListArtifactsRequest) XXX_Size added in v0.1.2 

func (m *ListArtifactsRequest) XXX_Size() int

func (*ListArtifactsRequest) XXX_Unmarshal added in v0.1.2 

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

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Response to list artifacts

func (*ListArtifactsResponse) Descriptor added in v0.1.2 

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

func (*ListArtifactsResponse) GetArtifacts added in v0.1.2 

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

func (*ListArtifactsResponse) GetNextToken added in v0.1.2 

func (m *ListArtifactsResponse) GetNextToken() string

func (*ListArtifactsResponse) ProtoMessage added in v0.1.2 

func (*ListArtifactsResponse) ProtoMessage()

func (*ListArtifactsResponse) Reset added in v0.1.2 

func (m *ListArtifactsResponse) Reset()

func (*ListArtifactsResponse) String added in v0.1.2 

func (m *ListArtifactsResponse) String() string

func (*ListArtifactsResponse) XXX_DiscardUnknown added in v0.1.2 

func (m *ListArtifactsResponse) XXX_DiscardUnknown()

func (*ListArtifactsResponse) XXX_Marshal added in v0.1.2 

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

func (*ListArtifactsResponse) XXX_Merge added in v0.1.2 

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

func (*ListArtifactsResponse) XXX_Size added in v0.1.2 

func (m *ListArtifactsResponse) XXX_Size() int

func (*ListArtifactsResponse) XXX_Unmarshal added in v0.1.2 

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

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"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

List the datasets for the given query

func (*ListDatasetsRequest) Descriptor added in v0.1.2 

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

func (*ListDatasetsRequest) GetFilter added in v0.1.2 

func (m *ListDatasetsRequest) GetFilter() *FilterExpression

func (*ListDatasetsRequest) GetPagination added in v0.1.2 

func (m *ListDatasetsRequest) GetPagination() *PaginationOptions

func (*ListDatasetsRequest) ProtoMessage added in v0.1.2 

func (*ListDatasetsRequest) ProtoMessage()

func (*ListDatasetsRequest) Reset added in v0.1.2 

func (m *ListDatasetsRequest) Reset()

func (*ListDatasetsRequest) String added in v0.1.2 

func (m *ListDatasetsRequest) String() string

func (*ListDatasetsRequest) XXX_DiscardUnknown added in v0.1.2 

func (m *ListDatasetsRequest) XXX_DiscardUnknown()

func (*ListDatasetsRequest) XXX_Marshal added in v0.1.2 

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

func (*ListDatasetsRequest) XXX_Merge added in v0.1.2 

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

func (*ListDatasetsRequest) XXX_Size added in v0.1.2 

func (m *ListDatasetsRequest) XXX_Size() int

func (*ListDatasetsRequest) XXX_Unmarshal added in v0.1.2 

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

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

List the datasets response with token for next pagination

func (*ListDatasetsResponse) Descriptor added in v0.1.2 

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

func (*ListDatasetsResponse) GetDatasets added in v0.1.2 

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

func (*ListDatasetsResponse) GetNextToken added in v0.1.2 

func (m *ListDatasetsResponse) GetNextToken() string

func (*ListDatasetsResponse) ProtoMessage added in v0.1.2 

func (*ListDatasetsResponse) ProtoMessage()

func (*ListDatasetsResponse) Reset added in v0.1.2 

func (m *ListDatasetsResponse) Reset()

func (*ListDatasetsResponse) String added in v0.1.2 

func (m *ListDatasetsResponse) String() string

func (*ListDatasetsResponse) XXX_DiscardUnknown added in v0.1.2 

func (m *ListDatasetsResponse) XXX_DiscardUnknown()

func (*ListDatasetsResponse) XXX_Marshal added in v0.1.2 

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

func (*ListDatasetsResponse) XXX_Merge added in v0.1.2 

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

func (*ListDatasetsResponse) XXX_Size added in v0.1.2 

func (m *ListDatasetsResponse) XXX_Size() int

func (*ListDatasetsResponse) XXX_Unmarshal added in v0.1.2 

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

type Metadata 

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

func (*Metadata) Descriptor 

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

func (*Metadata) GetKeyMap 

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

func (*Metadata) ProtoMessage 

func (*Metadata) ProtoMessage()

func (*Metadata) Reset 

func (m *Metadata) Reset()

func (*Metadata) String 

func (m *Metadata) String() string

func (*Metadata) XXX_DiscardUnknown 

func (m *Metadata) XXX_DiscardUnknown()

func (*Metadata) XXX_Marshal 

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

func (*Metadata) XXX_Merge 

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

func (*Metadata) XXX_Size 

func (m *Metadata) XXX_Size() int

func (*Metadata) XXX_Unmarshal 

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

type PaginationOptions 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"`
	XXX_NoUnkeyedLiteral struct{}                    `json:"-"`
	XXX_unrecognized     []byte                      `json:"-"`
	XXX_sizecache        int32                       `json:"-"`
}

Pagination options for making list requests

func (*PaginationOptions) Descriptor added in v0.1.2 

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

func (*PaginationOptions) GetLimit added in v0.1.2 

func (m *PaginationOptions) GetLimit() uint32

func (*PaginationOptions) GetSortKey added in v0.1.2 

func (m *PaginationOptions) GetSortKey() PaginationOptions_SortKey

func (*PaginationOptions) GetSortOrder added in v0.1.2 

func (m *PaginationOptions) GetSortOrder() PaginationOptions_SortOrder

func (*PaginationOptions) GetToken added in v0.1.2 

func (m *PaginationOptions) GetToken() string

func (*PaginationOptions) ProtoMessage added in v0.1.2 

func (*PaginationOptions) ProtoMessage()

func (*PaginationOptions) Reset added in v0.1.2 

func (m *PaginationOptions) Reset()

func (*PaginationOptions) String added in v0.1.2 

func (m *PaginationOptions) String() string

func (*PaginationOptions) XXX_DiscardUnknown added in v0.1.2 

func (m *PaginationOptions) XXX_DiscardUnknown()

func (*PaginationOptions) XXX_Marshal added in v0.1.2 

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

func (*PaginationOptions) XXX_Merge added in v0.1.2 

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

func (*PaginationOptions) XXX_Size added in v0.1.2 

func (m *PaginationOptions) XXX_Size() int

func (*PaginationOptions) XXX_Unmarshal added in v0.1.2 

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

type PaginationOptions_SortKey added in v0.1.2 

type PaginationOptions_SortKey int32
const (
	PaginationOptions_CREATION_TIME PaginationOptions_SortKey = 0
)

func (PaginationOptions_SortKey) EnumDescriptor added in v0.1.2 

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

func (PaginationOptions_SortKey) String added in v0.1.2 

func (x PaginationOptions_SortKey) String() string

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) EnumDescriptor added in v0.1.2 

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

func (PaginationOptions_SortOrder) String added in v0.1.2 

func (x PaginationOptions_SortOrder) String() string

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Partition) Descriptor added in v0.1.2 

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

func (*Partition) GetKey added in v0.1.2 

func (m *Partition) GetKey() string

func (*Partition) GetValue added in v0.1.2 

func (m *Partition) GetValue() string

func (*Partition) ProtoMessage added in v0.1.2 

func (*Partition) ProtoMessage()

func (*Partition) Reset added in v0.1.2 

func (m *Partition) Reset()

func (*Partition) String added in v0.1.2 

func (m *Partition) String() string

func (*Partition) XXX_DiscardUnknown added in v0.1.2 

func (m *Partition) XXX_DiscardUnknown()

func (*Partition) XXX_Marshal added in v0.1.2 

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

func (*Partition) XXX_Merge added in v0.1.2 

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

func (*Partition) XXX_Size added in v0.1.2 

func (m *Partition) XXX_Size() int

func (*Partition) XXX_Unmarshal added in v0.1.2 

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

type PartitionPropertyFilter added in v0.1.2 

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

Partition properties we can filter by

func (*PartitionPropertyFilter) Descriptor added in v0.1.2 

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

func (*PartitionPropertyFilter) GetKeyVal added in v0.1.2 

func (m *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) Reset added in v0.1.2 

func (m *PartitionPropertyFilter) Reset()

func (*PartitionPropertyFilter) String added in v0.1.2 

func (m *PartitionPropertyFilter) String() string

func (*PartitionPropertyFilter) XXX_DiscardUnknown added in v0.1.2 

func (m *PartitionPropertyFilter) XXX_DiscardUnknown()

func (*PartitionPropertyFilter) XXX_Marshal added in v0.1.2 

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

func (*PartitionPropertyFilter) XXX_Merge added in v0.1.2 

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

func (*PartitionPropertyFilter) XXX_OneofWrappers added in v0.1.2 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*PartitionPropertyFilter) XXX_Size added in v0.1.2 

func (m *PartitionPropertyFilter) XXX_Size() int

func (*PartitionPropertyFilter) XXX_Unmarshal added in v0.1.2 

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

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 valid to be assigned to PropertyFilter:
	//	*SinglePropertyFilter_TagFilter
	//	*SinglePropertyFilter_PartitionFilter
	//	*SinglePropertyFilter_ArtifactFilter
	//	*SinglePropertyFilter_DatasetFilter
	PropertyFilter       isSinglePropertyFilter_PropertyFilter   `protobuf_oneof:"property_filter"`
	Operator             SinglePropertyFilter_ComparisonOperator `` /* 128-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                                `json:"-"`
	XXX_unrecognized     []byte                                  `json:"-"`
	XXX_sizecache        int32                                   `json:"-"`
}

A single property to filter on.

func (*SinglePropertyFilter) Descriptor added in v0.1.2 

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

func (*SinglePropertyFilter) GetArtifactFilter added in v0.1.2 

func (m *SinglePropertyFilter) GetArtifactFilter() *ArtifactPropertyFilter

func (*SinglePropertyFilter) GetDatasetFilter added in v0.1.2 

func (m *SinglePropertyFilter) GetDatasetFilter() *DatasetPropertyFilter

func (*SinglePropertyFilter) GetOperator added in v0.1.2 

func (m *SinglePropertyFilter) GetOperator() SinglePropertyFilter_ComparisonOperator

func (*SinglePropertyFilter) GetPartitionFilter added in v0.1.2 

func (m *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 (m *SinglePropertyFilter) GetTagFilter() *TagPropertyFilter

func (*SinglePropertyFilter) ProtoMessage added in v0.1.2 

func (*SinglePropertyFilter) ProtoMessage()

func (*SinglePropertyFilter) Reset added in v0.1.2 

func (m *SinglePropertyFilter) Reset()

func (*SinglePropertyFilter) String added in v0.1.2 

func (m *SinglePropertyFilter) String() string

func (*SinglePropertyFilter) XXX_DiscardUnknown added in v0.1.2 

func (m *SinglePropertyFilter) XXX_DiscardUnknown()

func (*SinglePropertyFilter) XXX_Marshal added in v0.1.2 

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

func (*SinglePropertyFilter) XXX_Merge added in v0.1.2 

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

func (*SinglePropertyFilter) XXX_OneofWrappers added in v0.1.2 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*SinglePropertyFilter) XXX_Size added in v0.1.2 

func (m *SinglePropertyFilter) XXX_Size() int

func (*SinglePropertyFilter) XXX_Unmarshal added in v0.1.2 

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

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) EnumDescriptor added in v0.1.2 

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

func (SinglePropertyFilter_ComparisonOperator) String added in v0.1.2 

func (x SinglePropertyFilter_ComparisonOperator) String() string

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"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*Tag) Descriptor 

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

func (*Tag) GetArtifactId 

func (m *Tag) GetArtifactId() string

func (*Tag) GetDataset 

func (m *Tag) GetDataset() *DatasetID

func (*Tag) GetName 

func (m *Tag) GetName() string

func (*Tag) ProtoMessage 

func (*Tag) ProtoMessage()

func (*Tag) Reset 

func (m *Tag) Reset()

func (*Tag) String 

func (m *Tag) String() string

func (*Tag) XXX_DiscardUnknown 

func (m *Tag) XXX_DiscardUnknown()

func (*Tag) XXX_Marshal 

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

func (*Tag) XXX_Merge 

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

func (*Tag) XXX_Size 

func (m *Tag) XXX_Size() int

func (*Tag) XXX_Unmarshal 

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

type TagPropertyFilter added in v0.1.2 

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

Tag properties we can filter by

func (*TagPropertyFilter) Descriptor added in v0.1.2 

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

func (*TagPropertyFilter) GetProperty added in v0.1.2 

func (m *TagPropertyFilter) GetProperty() isTagPropertyFilter_Property

func (*TagPropertyFilter) GetTagName added in v0.1.2 

func (m *TagPropertyFilter) GetTagName() string

func (*TagPropertyFilter) ProtoMessage added in v0.1.2 

func (*TagPropertyFilter) ProtoMessage()

func (*TagPropertyFilter) Reset added in v0.1.2 

func (m *TagPropertyFilter) Reset()

func (*TagPropertyFilter) String added in v0.1.2 

func (m *TagPropertyFilter) String() string

func (*TagPropertyFilter) XXX_DiscardUnknown added in v0.1.2 

func (m *TagPropertyFilter) XXX_DiscardUnknown()

func (*TagPropertyFilter) XXX_Marshal added in v0.1.2 

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

func (*TagPropertyFilter) XXX_Merge added in v0.1.2 

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

func (*TagPropertyFilter) XXX_OneofWrappers added in v0.1.2 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*TagPropertyFilter) XXX_Size added in v0.1.2 

func (m *TagPropertyFilter) XXX_Size() int

func (*TagPropertyFilter) XXX_Unmarshal added in v0.1.2 

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

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(ctx context.Context, req *AddTagRequest) (*AddTagResponse, error)

func (*UnimplementedDataCatalogServer) CreateArtifact 

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

func (*UnimplementedDataCatalogServer) CreateDataset 

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

func (*UnimplementedDataCatalogServer) GetArtifact 

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

func (*UnimplementedDataCatalogServer) GetDataset 

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

func (*UnimplementedDataCatalogServer) ListArtifacts added in v0.1.2 

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

func (*UnimplementedDataCatalogServer) ListDatasets added in v0.1.2 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.