datacatalog

package
v0.17.9 Latest Latest
Warning

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

 Go to latest Published: Mar 10, 2020 License: Apache-2.0 Imports: 17 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var CreateResponse_Status_name = map[int32]string{
	0: "ALREADY_EXISTS",
	1: "CREATED",
}
View Source 
var CreateResponse_Status_value = map[string]int32{
	"ALREADY_EXISTS": 0,
	"CREATED":        1,
}
View Source 
var QueryOperator_name = map[int32]string{
	0: "EQUAL",
	1: "GREATER_THAN",
	2: "LESSER_THAN",
}
View Source 
var QueryOperator_value = map[string]int32{
	"EQUAL":        0,
	"GREATER_THAN": 1,
	"LESSER_THAN":  2,
}

Functions

func RegisterArtifactsServer 

func RegisterArtifactsServer(s *grpc.Server, srv ArtifactsServer)

Types

type Artifact 

type Artifact struct {
	Provenance           string       `protobuf:"bytes,1,opt,name=provenance,proto3" json:"provenance,omitempty"`
	Name                 string       `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Version              string       `protobuf:"bytes,3,opt,name=version,proto3" json:"version,omitempty"`
	Revision             int64        `protobuf:"varint,4,opt,name=revision,proto3" json:"revision,omitempty"`
	CreatedAt            int64        `protobuf:"varint,5,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	ReferenceId          string       `protobuf:"bytes,6,opt,name=reference_id,json=referenceId,proto3" json:"reference_id,omitempty"`
	Inputs               []*Parameter `protobuf:"bytes,7,rep,name=inputs,proto3" json:"inputs,omitempty"`
	Outputs              []*Parameter `protobuf:"bytes,8,rep,name=outputs,proto3" json:"outputs,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

Before jumping to message definition, lets go over the expected flow- 

An Artifact represents an unit-of-work identified by (task, version, inputs). This is
encoded as unique hash for faster queries(called provenance). An artifact is persisted with some other
attributes (revision, createdAt, reference_id, outputs).
Only Discovery service knows about the hashing algorithm; one can use the closure (task, version, inputs)
to query an artifact if it doesnt have the provenance value.

Before starting the work on a task, programming-model first checks if the task has been done.
  Request:   GET (task, version, inputs)
  Response:  (Exists, Artifact) or (NotFound, nil)
if not found, Task executor goes ahead with the execution and at the end of execution creates a new entry in
the discovery service
  Request:  CREATE (task, version, inputs) + (revision, reference_id, outputs)
  Response: (Exists, Artifact) or (Created, Artifact)

One can also Query all the artifacts by querying any subset of properties.

Message Artifact represents the complete information of an artifact- field that unique define the artifact + properties. Message ArtifactInternal is our storage model where we create an additional derived column for faster queries. Message ArtifactId only represents field that uniquely define the artifact.

func (*Artifact) Descriptor 

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

func (*Artifact) GetCreatedAt 

func (m *Artifact) GetCreatedAt() int64

func (*Artifact) GetInputs 

func (m *Artifact) GetInputs() []*Parameter

func (*Artifact) GetName 

func (m *Artifact) GetName() string

func (*Artifact) GetOutputs 

func (m *Artifact) GetOutputs() []*Parameter

func (*Artifact) GetProvenance 

func (m *Artifact) GetProvenance() string

func (*Artifact) GetReferenceId 

func (m *Artifact) GetReferenceId() string

func (*Artifact) GetRevision 

func (m *Artifact) GetRevision() int64

func (*Artifact) GetVersion 

func (m *Artifact) GetVersion() string

func (*Artifact) ProtoMessage 

func (*Artifact) ProtoMessage()

func (*Artifact) Reset 

func (m *Artifact) Reset()

func (*Artifact) String 

func (m *Artifact) String() string

func (*Artifact) Validate 

func (m *Artifact) Validate() error

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

func (*Artifact) XXX_DiscardUnknown 

func (m *Artifact) XXX_DiscardUnknown()

func (*Artifact) XXX_Marshal 

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

func (*Artifact) XXX_Merge 

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

func (*Artifact) XXX_Size 

func (m *Artifact) XXX_Size() int

func (*Artifact) XXX_Unmarshal 

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

type ArtifactId 

type ArtifactId struct {
	Name                 string       `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Version              string       `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	Inputs               []*Parameter `protobuf:"bytes,3,rep,name=inputs,proto3" json:"inputs,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*ArtifactId) Descriptor 

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

func (*ArtifactId) GetInputs 

func (m *ArtifactId) GetInputs() []*Parameter

func (*ArtifactId) GetName 

func (m *ArtifactId) GetName() string

func (*ArtifactId) GetVersion 

func (m *ArtifactId) GetVersion() string

func (*ArtifactId) ProtoMessage 

func (*ArtifactId) ProtoMessage()

func (*ArtifactId) Reset 

func (m *ArtifactId) Reset()

func (*ArtifactId) String 

func (m *ArtifactId) String() string

func (*ArtifactId) Validate 

func (m *ArtifactId) Validate() error

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

func (*ArtifactId) XXX_DiscardUnknown 

func (m *ArtifactId) XXX_DiscardUnknown()

func (*ArtifactId) XXX_Marshal 

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

func (*ArtifactId) XXX_Merge 

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

func (*ArtifactId) XXX_Size 

func (m *ArtifactId) XXX_Size() int

func (*ArtifactId) XXX_Unmarshal 

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

type ArtifactIdValidationError 

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

ArtifactIdValidationError is the validation error returned by ArtifactId.Validate if the designated constraints aren't met.

func (ArtifactIdValidationError) Cause 

func (e ArtifactIdValidationError) Cause() error

Cause function returns cause value.

func (ArtifactIdValidationError) Error 

func (e ArtifactIdValidationError) Error() string

Error satisfies the builtin error interface

func (ArtifactIdValidationError) ErrorName 

func (e ArtifactIdValidationError) ErrorName() string

ErrorName returns error name.

func (ArtifactIdValidationError) Field 

func (e ArtifactIdValidationError) Field() string

Field function returns field value.

func (ArtifactIdValidationError) Key 

func (e ArtifactIdValidationError) Key() bool

Key function returns key value.

func (ArtifactIdValidationError) Reason 

func (e ArtifactIdValidationError) Reason() string

Reason function returns reason value.

type ArtifactValidationError 

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

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

func (ArtifactValidationError) Cause 

func (e ArtifactValidationError) Cause() error

Cause function returns cause value.

func (ArtifactValidationError) Error 

func (e ArtifactValidationError) Error() string

Error satisfies the builtin error interface

func (ArtifactValidationError) ErrorName 

func (e ArtifactValidationError) ErrorName() string

ErrorName returns error name.

func (ArtifactValidationError) Field 

func (e ArtifactValidationError) Field() string

Field function returns field value.

func (ArtifactValidationError) Key 

func (e ArtifactValidationError) Key() bool

Key function returns key value.

func (ArtifactValidationError) Reason 

func (e ArtifactValidationError) Reason() string

Reason function returns reason value.

type ArtifactsClient 

type ArtifactsClient interface {
	Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetResponse, error)
	Query(ctx context.Context, in *QueryRequest, opts ...grpc.CallOption) (*QueryResponse, error)
	Create(ctx context.Context, in *CreateRequest, opts ...grpc.CallOption) (*CreateResponse, error)
	GenerateProvenance(ctx context.Context, in *GenerateProvenanceRequest, opts ...grpc.CallOption) (*GenerateProvenanceResponse, error)
}

ArtifactsClient is the client API for Artifacts service.

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

func NewArtifactsClient 

func NewArtifactsClient(cc *grpc.ClientConn) ArtifactsClient

type ArtifactsServer 

type ArtifactsServer interface {
	Get(context.Context, *GetRequest) (*GetResponse, error)
	Query(context.Context, *QueryRequest) (*QueryResponse, error)
	Create(context.Context, *CreateRequest) (*CreateResponse, error)
	GenerateProvenance(context.Context, *GenerateProvenanceRequest) (*GenerateProvenanceResponse, error)
}

ArtifactsServer is the server API for Artifacts service.

type CreateRequest 

type CreateRequest struct {
	Ref                  *ArtifactId  `protobuf:"bytes,1,opt,name=ref,proto3" json:"ref,omitempty"`
	ReferenceId          string       `protobuf:"bytes,2,opt,name=reference_id,json=referenceId,proto3" json:"reference_id,omitempty"`
	Revision             int64        `protobuf:"varint,3,opt,name=revision,proto3" json:"revision,omitempty"`
	Outputs              []*Parameter `protobuf:"bytes,4,rep,name=outputs,proto3" json:"outputs,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*CreateRequest) Descriptor 

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

func (*CreateRequest) GetOutputs 

func (m *CreateRequest) GetOutputs() []*Parameter

func (*CreateRequest) GetRef 

func (m *CreateRequest) GetRef() *ArtifactId

func (*CreateRequest) GetReferenceId 

func (m *CreateRequest) GetReferenceId() string

func (*CreateRequest) GetRevision 

func (m *CreateRequest) GetRevision() int64

func (*CreateRequest) ProtoMessage 

func (*CreateRequest) ProtoMessage()

func (*CreateRequest) Reset 

func (m *CreateRequest) Reset()

func (*CreateRequest) String 

func (m *CreateRequest) String() string

func (*CreateRequest) Validate 

func (m *CreateRequest) Validate() error

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

func (*CreateRequest) XXX_DiscardUnknown 

func (m *CreateRequest) XXX_DiscardUnknown()

func (*CreateRequest) XXX_Marshal 

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

func (*CreateRequest) XXX_Merge 

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

func (*CreateRequest) XXX_Size 

func (m *CreateRequest) XXX_Size() int

func (*CreateRequest) XXX_Unmarshal 

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

type CreateRequestValidationError 

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

CreateRequestValidationError is the validation error returned by CreateRequest.Validate if the designated constraints aren't met.

func (CreateRequestValidationError) Cause 

func (e CreateRequestValidationError) Cause() error

Cause function returns cause value.

func (CreateRequestValidationError) Error 

func (e CreateRequestValidationError) Error() string

Error satisfies the builtin error interface

func (CreateRequestValidationError) ErrorName 

func (e CreateRequestValidationError) ErrorName() string

ErrorName returns error name.

func (CreateRequestValidationError) Field 

func (e CreateRequestValidationError) Field() string

Field function returns field value.

func (CreateRequestValidationError) Key 

func (e CreateRequestValidationError) Key() bool

Key function returns key value.

func (CreateRequestValidationError) Reason 

func (e CreateRequestValidationError) Reason() string

Reason function returns reason value.

type CreateResponse 

type CreateResponse struct {
	Artifact             *Artifact             `protobuf:"bytes,1,opt,name=artifact,proto3" json:"artifact,omitempty"`
	Status               CreateResponse_Status `protobuf:"varint,2,opt,name=status,proto3,enum=pb.lyft.datacatalog.CreateResponse_Status" json:"status,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*CreateResponse) Descriptor 

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

func (*CreateResponse) GetArtifact 

func (m *CreateResponse) GetArtifact() *Artifact

func (*CreateResponse) GetStatus 

func (m *CreateResponse) GetStatus() CreateResponse_Status

func (*CreateResponse) ProtoMessage 

func (*CreateResponse) ProtoMessage()

func (*CreateResponse) Reset 

func (m *CreateResponse) Reset()

func (*CreateResponse) String 

func (m *CreateResponse) String() string

func (*CreateResponse) Validate 

func (m *CreateResponse) Validate() error

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

func (*CreateResponse) XXX_DiscardUnknown 

func (m *CreateResponse) XXX_DiscardUnknown()

func (*CreateResponse) XXX_Marshal 

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

func (*CreateResponse) XXX_Merge 

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

func (*CreateResponse) XXX_Size 

func (m *CreateResponse) XXX_Size() int

func (*CreateResponse) XXX_Unmarshal 

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

type CreateResponseValidationError 

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

CreateResponseValidationError is the validation error returned by CreateResponse.Validate if the designated constraints aren't met.

func (CreateResponseValidationError) Cause 

func (e CreateResponseValidationError) Cause() error

Cause function returns cause value.

func (CreateResponseValidationError) Error 

func (e CreateResponseValidationError) Error() string

Error satisfies the builtin error interface

func (CreateResponseValidationError) ErrorName 

func (e CreateResponseValidationError) ErrorName() string

ErrorName returns error name.

func (CreateResponseValidationError) Field 

func (e CreateResponseValidationError) Field() string

Field function returns field value.

func (CreateResponseValidationError) Key 

func (e CreateResponseValidationError) Key() bool

Key function returns key value.

func (CreateResponseValidationError) Reason 

func (e CreateResponseValidationError) Reason() string

Reason function returns reason value.

type CreateResponse_Status 

type CreateResponse_Status int32
const (
	CreateResponse_ALREADY_EXISTS CreateResponse_Status = 0
	CreateResponse_CREATED        CreateResponse_Status = 1
)

func (CreateResponse_Status) EnumDescriptor 

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

func (CreateResponse_Status) String 

func (x CreateResponse_Status) String() string

type GenerateProvenanceRequest 

type GenerateProvenanceRequest struct {
	Id                   *ArtifactId `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*GenerateProvenanceRequest) Descriptor 

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

func (*GenerateProvenanceRequest) GetId 

func (m *GenerateProvenanceRequest) GetId() *ArtifactId

func (*GenerateProvenanceRequest) ProtoMessage 

func (*GenerateProvenanceRequest) ProtoMessage()

func (*GenerateProvenanceRequest) Reset 

func (m *GenerateProvenanceRequest) Reset()

func (*GenerateProvenanceRequest) String 

func (m *GenerateProvenanceRequest) String() string

func (*GenerateProvenanceRequest) Validate 

func (m *GenerateProvenanceRequest) Validate() error

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

func (*GenerateProvenanceRequest) XXX_DiscardUnknown 

func (m *GenerateProvenanceRequest) XXX_DiscardUnknown()

func (*GenerateProvenanceRequest) XXX_Marshal 

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

func (*GenerateProvenanceRequest) XXX_Merge 

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

func (*GenerateProvenanceRequest) XXX_Size 

func (m *GenerateProvenanceRequest) XXX_Size() int

func (*GenerateProvenanceRequest) XXX_Unmarshal 

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

type GenerateProvenanceRequestValidationError 

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

GenerateProvenanceRequestValidationError is the validation error returned by GenerateProvenanceRequest.Validate if the designated constraints aren't met.

func (GenerateProvenanceRequestValidationError) Cause 

func (e GenerateProvenanceRequestValidationError) Cause() error

Cause function returns cause value.

func (GenerateProvenanceRequestValidationError) Error 

func (e GenerateProvenanceRequestValidationError) Error() string

Error satisfies the builtin error interface

func (GenerateProvenanceRequestValidationError) ErrorName 

func (e GenerateProvenanceRequestValidationError) ErrorName() string

ErrorName returns error name.

func (GenerateProvenanceRequestValidationError) Field 

func (e GenerateProvenanceRequestValidationError) Field() string

Field function returns field value.

func (GenerateProvenanceRequestValidationError) Key 

func (e GenerateProvenanceRequestValidationError) Key() bool

Key function returns key value.

func (GenerateProvenanceRequestValidationError) Reason 

func (e GenerateProvenanceRequestValidationError) Reason() string

Reason function returns reason value.

type GenerateProvenanceResponse 

type GenerateProvenanceResponse struct {
	Provenance           string   `protobuf:"bytes,1,opt,name=provenance,proto3" json:"provenance,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GenerateProvenanceResponse) Descriptor 

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

func (*GenerateProvenanceResponse) GetProvenance 

func (m *GenerateProvenanceResponse) GetProvenance() string

func (*GenerateProvenanceResponse) ProtoMessage 

func (*GenerateProvenanceResponse) ProtoMessage()

func (*GenerateProvenanceResponse) Reset 

func (m *GenerateProvenanceResponse) Reset()

func (*GenerateProvenanceResponse) String 

func (m *GenerateProvenanceResponse) String() string

func (*GenerateProvenanceResponse) Validate 

func (m *GenerateProvenanceResponse) Validate() error

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

func (*GenerateProvenanceResponse) XXX_DiscardUnknown 

func (m *GenerateProvenanceResponse) XXX_DiscardUnknown()

func (*GenerateProvenanceResponse) XXX_Marshal 

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

func (*GenerateProvenanceResponse) XXX_Merge 

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

func (*GenerateProvenanceResponse) XXX_Size 

func (m *GenerateProvenanceResponse) XXX_Size() int

func (*GenerateProvenanceResponse) XXX_Unmarshal 

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

type GenerateProvenanceResponseValidationError 

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

GenerateProvenanceResponseValidationError is the validation error returned by GenerateProvenanceResponse.Validate if the designated constraints aren't met.

func (GenerateProvenanceResponseValidationError) Cause 

func (e GenerateProvenanceResponseValidationError) Cause() error

Cause function returns cause value.

func (GenerateProvenanceResponseValidationError) Error 

func (e GenerateProvenanceResponseValidationError) Error() string

Error satisfies the builtin error interface

func (GenerateProvenanceResponseValidationError) ErrorName 

func (e GenerateProvenanceResponseValidationError) ErrorName() string

ErrorName returns error name.

func (GenerateProvenanceResponseValidationError) Field 

func (e GenerateProvenanceResponseValidationError) Field() string

Field function returns field value.

func (GenerateProvenanceResponseValidationError) Key 

func (e GenerateProvenanceResponseValidationError) Key() bool

Key function returns key value.

func (GenerateProvenanceResponseValidationError) Reason 

func (e GenerateProvenanceResponseValidationError) Reason() string

Reason function returns reason value.

type GetRequest 

type GetRequest struct {
	// Types that are valid to be assigned to Id:
	//	*GetRequest_Provenance
	//	*GetRequest_ArtifactId
	Id                   isGetRequest_Id `protobuf_oneof:"id"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*GetRequest) Descriptor 

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

func (*GetRequest) GetArtifactId 

func (m *GetRequest) GetArtifactId() *ArtifactId

func (*GetRequest) GetId 

func (m *GetRequest) GetId() isGetRequest_Id

func (*GetRequest) GetProvenance 

func (m *GetRequest) GetProvenance() string

func (*GetRequest) ProtoMessage 

func (*GetRequest) ProtoMessage()

func (*GetRequest) Reset 

func (m *GetRequest) Reset()

func (*GetRequest) String 

func (m *GetRequest) String() string

func (*GetRequest) Validate 

func (m *GetRequest) Validate() error

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

func (*GetRequest) XXX_DiscardUnknown 

func (m *GetRequest) XXX_DiscardUnknown()

func (*GetRequest) XXX_Marshal 

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

func (*GetRequest) XXX_Merge 

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

func (*GetRequest) XXX_OneofWrappers added in v0.4.20 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*GetRequest) XXX_Size 

func (m *GetRequest) XXX_Size() int

func (*GetRequest) XXX_Unmarshal 

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

type GetRequestValidationError 

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

GetRequestValidationError is the validation error returned by GetRequest.Validate if the designated constraints aren't met.

func (GetRequestValidationError) Cause 

func (e GetRequestValidationError) Cause() error

Cause function returns cause value.

func (GetRequestValidationError) Error 

func (e GetRequestValidationError) Error() string

Error satisfies the builtin error interface

func (GetRequestValidationError) ErrorName 

func (e GetRequestValidationError) ErrorName() string

ErrorName returns error name.

func (GetRequestValidationError) Field 

func (e GetRequestValidationError) Field() string

Field function returns field value.

func (GetRequestValidationError) Key 

func (e GetRequestValidationError) Key() bool

Key function returns key value.

func (GetRequestValidationError) Reason 

func (e GetRequestValidationError) Reason() string

Reason function returns reason value.

type GetRequest_ArtifactId 

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

type GetRequest_Provenance 

type GetRequest_Provenance struct {
	Provenance string `protobuf:"bytes,1,opt,name=provenance,proto3,oneof"`
}

type GetResponse 

type GetResponse 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 (*GetResponse) Descriptor 

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

func (*GetResponse) GetArtifact 

func (m *GetResponse) GetArtifact() *Artifact

func (*GetResponse) ProtoMessage 

func (*GetResponse) ProtoMessage()

func (*GetResponse) Reset 

func (m *GetResponse) Reset()

func (*GetResponse) String 

func (m *GetResponse) String() string

func (*GetResponse) Validate 

func (m *GetResponse) Validate() error

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

func (*GetResponse) XXX_DiscardUnknown 

func (m *GetResponse) XXX_DiscardUnknown()

func (*GetResponse) XXX_Marshal 

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

func (*GetResponse) XXX_Merge 

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

func (*GetResponse) XXX_Size 

func (m *GetResponse) XXX_Size() int

func (*GetResponse) XXX_Unmarshal 

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

type GetResponseValidationError 

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

GetResponseValidationError is the validation error returned by GetResponse.Validate if the designated constraints aren't met.

func (GetResponseValidationError) Cause 

func (e GetResponseValidationError) Cause() error

Cause function returns cause value.

func (GetResponseValidationError) Error 

func (e GetResponseValidationError) Error() string

Error satisfies the builtin error interface

func (GetResponseValidationError) ErrorName 

func (e GetResponseValidationError) ErrorName() string

ErrorName returns error name.

func (GetResponseValidationError) Field 

func (e GetResponseValidationError) Field() string

Field function returns field value.

func (GetResponseValidationError) Key 

func (e GetResponseValidationError) Key() bool

Key function returns key value.

func (GetResponseValidationError) Reason 

func (e GetResponseValidationError) Reason() string

Reason function returns reason value.

type IntFilter 

type IntFilter struct {
	Value                int64         `protobuf:"varint,1,opt,name=value,proto3" json:"value,omitempty"`
	Operator             QueryOperator `protobuf:"varint,2,opt,name=operator,proto3,enum=pb.lyft.datacatalog.QueryOperator" json:"operator,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*IntFilter) Descriptor 

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

func (*IntFilter) GetOperator 

func (m *IntFilter) GetOperator() QueryOperator

func (*IntFilter) GetValue 

func (m *IntFilter) GetValue() int64

func (*IntFilter) ProtoMessage 

func (*IntFilter) ProtoMessage()

func (*IntFilter) Reset 

func (m *IntFilter) Reset()

func (*IntFilter) String 

func (m *IntFilter) String() string

func (*IntFilter) Validate 

func (m *IntFilter) Validate() error

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

func (*IntFilter) XXX_DiscardUnknown 

func (m *IntFilter) XXX_DiscardUnknown()

func (*IntFilter) XXX_Marshal 

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

func (*IntFilter) XXX_Merge 

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

func (*IntFilter) XXX_Size 

func (m *IntFilter) XXX_Size() int

func (*IntFilter) XXX_Unmarshal 

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

type IntFilterValidationError 

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

IntFilterValidationError is the validation error returned by IntFilter.Validate if the designated constraints aren't met.

func (IntFilterValidationError) Cause 

func (e IntFilterValidationError) Cause() error

Cause function returns cause value.

func (IntFilterValidationError) Error 

func (e IntFilterValidationError) Error() string

Error satisfies the builtin error interface

func (IntFilterValidationError) ErrorName 

func (e IntFilterValidationError) ErrorName() string

ErrorName returns error name.

func (IntFilterValidationError) Field 

func (e IntFilterValidationError) Field() string

Field function returns field value.

func (IntFilterValidationError) Key 

func (e IntFilterValidationError) Key() bool

Key function returns key value.

func (IntFilterValidationError) Reason 

func (e IntFilterValidationError) Reason() string

Reason function returns reason value.

type IntQueryKey 

type IntQueryKey struct {
	// Types that are valid to be assigned to Filter:
	//	*IntQueryKey_Val
	//	*IntQueryKey_Range
	Filter               isIntQueryKey_Filter `protobuf_oneof:"filter"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*IntQueryKey) Descriptor 

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

func (*IntQueryKey) GetFilter 

func (m *IntQueryKey) GetFilter() isIntQueryKey_Filter

func (*IntQueryKey) GetRange 

func (m *IntQueryKey) GetRange() *IntRangeFilter

func (*IntQueryKey) GetVal 

func (m *IntQueryKey) GetVal() *IntFilter

func (*IntQueryKey) ProtoMessage 

func (*IntQueryKey) ProtoMessage()

func (*IntQueryKey) Reset 

func (m *IntQueryKey) Reset()

func (*IntQueryKey) String 

func (m *IntQueryKey) String() string

func (*IntQueryKey) Validate 

func (m *IntQueryKey) Validate() error

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

func (*IntQueryKey) XXX_DiscardUnknown 

func (m *IntQueryKey) XXX_DiscardUnknown()

func (*IntQueryKey) XXX_Marshal 

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

func (*IntQueryKey) XXX_Merge 

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

func (*IntQueryKey) XXX_OneofWrappers added in v0.4.20 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*IntQueryKey) XXX_Size 

func (m *IntQueryKey) XXX_Size() int

func (*IntQueryKey) XXX_Unmarshal 

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

type IntQueryKeyValidationError 

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

IntQueryKeyValidationError is the validation error returned by IntQueryKey.Validate if the designated constraints aren't met.

func (IntQueryKeyValidationError) Cause 

func (e IntQueryKeyValidationError) Cause() error

Cause function returns cause value.

func (IntQueryKeyValidationError) Error 

func (e IntQueryKeyValidationError) Error() string

Error satisfies the builtin error interface

func (IntQueryKeyValidationError) ErrorName 

func (e IntQueryKeyValidationError) ErrorName() string

ErrorName returns error name.

func (IntQueryKeyValidationError) Field 

func (e IntQueryKeyValidationError) Field() string

Field function returns field value.

func (IntQueryKeyValidationError) Key 

func (e IntQueryKeyValidationError) Key() bool

Key function returns key value.

func (IntQueryKeyValidationError) Reason 

func (e IntQueryKeyValidationError) Reason() string

Reason function returns reason value.

type IntQueryKey_Range 

type IntQueryKey_Range struct {
	Range *IntRangeFilter `protobuf:"bytes,2,opt,name=range,proto3,oneof"`
}

type IntQueryKey_Val 

type IntQueryKey_Val struct {
	Val *IntFilter `protobuf:"bytes,1,opt,name=val,proto3,oneof"`
}

type IntRangeFilter 

type IntRangeFilter struct {
	Min                  int64    `protobuf:"varint,1,opt,name=min,proto3" json:"min,omitempty"`
	Max                  int64    `protobuf:"varint,2,opt,name=max,proto3" json:"max,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*IntRangeFilter) Descriptor 

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

func (*IntRangeFilter) GetMax 

func (m *IntRangeFilter) GetMax() int64

func (*IntRangeFilter) GetMin 

func (m *IntRangeFilter) GetMin() int64

func (*IntRangeFilter) ProtoMessage 

func (*IntRangeFilter) ProtoMessage()

func (*IntRangeFilter) Reset 

func (m *IntRangeFilter) Reset()

func (*IntRangeFilter) String 

func (m *IntRangeFilter) String() string

func (*IntRangeFilter) Validate 

func (m *IntRangeFilter) Validate() error

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

func (*IntRangeFilter) XXX_DiscardUnknown 

func (m *IntRangeFilter) XXX_DiscardUnknown()

func (*IntRangeFilter) XXX_Marshal 

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

func (*IntRangeFilter) XXX_Merge 

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

func (*IntRangeFilter) XXX_Size 

func (m *IntRangeFilter) XXX_Size() int

func (*IntRangeFilter) XXX_Unmarshal 

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

type IntRangeFilterValidationError 

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

IntRangeFilterValidationError is the validation error returned by IntRangeFilter.Validate if the designated constraints aren't met.

func (IntRangeFilterValidationError) Cause 

func (e IntRangeFilterValidationError) Cause() error

Cause function returns cause value.

func (IntRangeFilterValidationError) Error 

func (e IntRangeFilterValidationError) Error() string

Error satisfies the builtin error interface

func (IntRangeFilterValidationError) ErrorName 

func (e IntRangeFilterValidationError) ErrorName() string

ErrorName returns error name.

func (IntRangeFilterValidationError) Field 

func (e IntRangeFilterValidationError) Field() string

Field function returns field value.

func (IntRangeFilterValidationError) Key 

func (e IntRangeFilterValidationError) Key() bool

Key function returns key value.

func (IntRangeFilterValidationError) Reason 

func (e IntRangeFilterValidationError) Reason() string

Reason function returns reason value.

type Parameter 

type Parameter struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,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 (*Parameter) Descriptor 

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

func (*Parameter) GetName 

func (m *Parameter) GetName() string

func (*Parameter) GetValue 

func (m *Parameter) GetValue() string

func (*Parameter) ProtoMessage 

func (*Parameter) ProtoMessage()

func (*Parameter) Reset 

func (m *Parameter) Reset()

func (*Parameter) String 

func (m *Parameter) String() string

func (*Parameter) Validate 

func (m *Parameter) Validate() error

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

func (*Parameter) XXX_DiscardUnknown 

func (m *Parameter) XXX_DiscardUnknown()

func (*Parameter) XXX_Marshal 

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

func (*Parameter) XXX_Merge 

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

func (*Parameter) XXX_Size 

func (m *Parameter) XXX_Size() int

func (*Parameter) XXX_Unmarshal 

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

type ParameterValidationError 

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

ParameterValidationError is the validation error returned by Parameter.Validate if the designated constraints aren't met.

func (ParameterValidationError) Cause 

func (e ParameterValidationError) Cause() error

Cause function returns cause value.

func (ParameterValidationError) Error 

func (e ParameterValidationError) Error() string

Error satisfies the builtin error interface

func (ParameterValidationError) ErrorName 

func (e ParameterValidationError) ErrorName() string

ErrorName returns error name.

func (ParameterValidationError) Field 

func (e ParameterValidationError) Field() string

Field function returns field value.

func (ParameterValidationError) Key 

func (e ParameterValidationError) Key() bool

Key function returns key value.

func (ParameterValidationError) Reason 

func (e ParameterValidationError) Reason() string

Reason function returns reason value.

type QueryOperator 

type QueryOperator int32
const (
	QueryOperator_EQUAL        QueryOperator = 0
	QueryOperator_GREATER_THAN QueryOperator = 1
	QueryOperator_LESSER_THAN  QueryOperator = 2
)

func (QueryOperator) EnumDescriptor 

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

func (QueryOperator) String 

func (x QueryOperator) String() string

type QueryRequest 

type QueryRequest struct {
	Name                 string       `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Version              string       `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	Revision             *IntQueryKey `protobuf:"bytes,3,opt,name=revision,proto3" json:"revision,omitempty"`
	CreatedAt            int64        `protobuf:"varint,4,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	ReferenceId          string       `protobuf:"bytes,5,opt,name=reference_id,json=referenceId,proto3" json:"reference_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

QueryRequest allows queries on a range of values for revision column and point queries on created_at and reference_id

func (*QueryRequest) Descriptor 

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

func (*QueryRequest) GetCreatedAt 

func (m *QueryRequest) GetCreatedAt() int64

func (*QueryRequest) GetName 

func (m *QueryRequest) GetName() string

func (*QueryRequest) GetReferenceId 

func (m *QueryRequest) GetReferenceId() string

func (*QueryRequest) GetRevision 

func (m *QueryRequest) GetRevision() *IntQueryKey

func (*QueryRequest) GetVersion 

func (m *QueryRequest) GetVersion() string

func (*QueryRequest) ProtoMessage 

func (*QueryRequest) ProtoMessage()

func (*QueryRequest) Reset 

func (m *QueryRequest) Reset()

func (*QueryRequest) String 

func (m *QueryRequest) String() string

func (*QueryRequest) Validate 

func (m *QueryRequest) Validate() error

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

func (*QueryRequest) XXX_DiscardUnknown 

func (m *QueryRequest) XXX_DiscardUnknown()

func (*QueryRequest) XXX_Marshal 

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

func (*QueryRequest) XXX_Merge 

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

func (*QueryRequest) XXX_Size 

func (m *QueryRequest) XXX_Size() int

func (*QueryRequest) XXX_Unmarshal 

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

type QueryRequestValidationError 

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

QueryRequestValidationError is the validation error returned by QueryRequest.Validate if the designated constraints aren't met.

func (QueryRequestValidationError) Cause 

func (e QueryRequestValidationError) Cause() error

Cause function returns cause value.

func (QueryRequestValidationError) Error 

func (e QueryRequestValidationError) Error() string

Error satisfies the builtin error interface

func (QueryRequestValidationError) ErrorName 

func (e QueryRequestValidationError) ErrorName() string

ErrorName returns error name.

func (QueryRequestValidationError) Field 

func (e QueryRequestValidationError) Field() string

Field function returns field value.

func (QueryRequestValidationError) Key 

func (e QueryRequestValidationError) Key() bool

Key function returns key value.

func (QueryRequestValidationError) Reason 

func (e QueryRequestValidationError) Reason() string

Reason function returns reason value.

type QueryResponse 

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

func (*QueryResponse) Descriptor 

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

func (*QueryResponse) GetArtifact 

func (m *QueryResponse) GetArtifact() []*Artifact

func (*QueryResponse) ProtoMessage 

func (*QueryResponse) ProtoMessage()

func (*QueryResponse) Reset 

func (m *QueryResponse) Reset()

func (*QueryResponse) String 

func (m *QueryResponse) String() string

func (*QueryResponse) Validate 

func (m *QueryResponse) Validate() error

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

func (*QueryResponse) XXX_DiscardUnknown 

func (m *QueryResponse) XXX_DiscardUnknown()

func (*QueryResponse) XXX_Marshal 

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

func (*QueryResponse) XXX_Merge 

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

func (*QueryResponse) XXX_Size 

func (m *QueryResponse) XXX_Size() int

func (*QueryResponse) XXX_Unmarshal 

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

type QueryResponseValidationError 

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

QueryResponseValidationError is the validation error returned by QueryResponse.Validate if the designated constraints aren't met.

func (QueryResponseValidationError) Cause 

func (e QueryResponseValidationError) Cause() error

Cause function returns cause value.

func (QueryResponseValidationError) Error 

func (e QueryResponseValidationError) Error() string

Error satisfies the builtin error interface

func (QueryResponseValidationError) ErrorName 

func (e QueryResponseValidationError) ErrorName() string

ErrorName returns error name.

func (QueryResponseValidationError) Field 

func (e QueryResponseValidationError) Field() string

Field function returns field value.

func (QueryResponseValidationError) Key 

func (e QueryResponseValidationError) Key() bool

Key function returns key value.

func (QueryResponseValidationError) Reason 

func (e QueryResponseValidationError) Reason() string

Reason function returns reason value.

type UnimplementedArtifactsServer added in v0.4.20 

type UnimplementedArtifactsServer struct {
}

UnimplementedArtifactsServer can be embedded to have forward compatible implementations.

func (*UnimplementedArtifactsServer) Create added in v0.4.20 

func (*UnimplementedArtifactsServer) Create(ctx context.Context, req *CreateRequest) (*CreateResponse, error)

func (*UnimplementedArtifactsServer) GenerateProvenance added in v0.4.20 

func (*UnimplementedArtifactsServer) GenerateProvenance(ctx context.Context, req *GenerateProvenanceRequest) (*GenerateProvenanceResponse, error)

func (*UnimplementedArtifactsServer) Get added in v0.4.20 

func (*UnimplementedArtifactsServer) Get(ctx context.Context, req *GetRequest) (*GetResponse, error)

func (*UnimplementedArtifactsServer) Query added in v0.4.20 

func (*UnimplementedArtifactsServer) Query(ctx context.Context, req *QueryRequest) (*QueryResponse, 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.