datacatalog

package
v0.18.14 Latest Latest
Warning

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

Go to latest
Published: Feb 26, 2021 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

Error satisfies the builtin error interface

func (ArtifactIdValidationError) ErrorName

func (e ArtifactIdValidationError) ErrorName() string

ErrorName returns error name.

func (ArtifactIdValidationError) Field

Field function returns field value.

func (ArtifactIdValidationError) Key

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

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

Cause function returns cause value.

func (CreateRequestValidationError) Error

Error satisfies the builtin error interface

func (CreateRequestValidationError) ErrorName

func (e CreateRequestValidationError) ErrorName() string

ErrorName returns error name.

func (CreateRequestValidationError) Field

Field function returns field value.

func (CreateRequestValidationError) Key

Key function returns key value.

func (CreateRequestValidationError) Reason

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

Cause function returns cause value.

func (CreateResponseValidationError) Error

Error satisfies the builtin error interface

func (CreateResponseValidationError) ErrorName

func (e CreateResponseValidationError) ErrorName() string

ErrorName returns error name.

func (CreateResponseValidationError) Field

Field function returns field value.

func (CreateResponseValidationError) Key

Key function returns key value.

func (CreateResponseValidationError) Reason

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

Cause function returns cause value.

func (GenerateProvenanceRequestValidationError) Error

Error satisfies the builtin error interface

func (GenerateProvenanceRequestValidationError) ErrorName

ErrorName returns error name.

func (GenerateProvenanceRequestValidationError) Field

Field function returns field value.

func (GenerateProvenanceRequestValidationError) Key

Key function returns key value.

func (GenerateProvenanceRequestValidationError) Reason

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

Cause function returns cause value.

func (GenerateProvenanceResponseValidationError) Error

Error satisfies the builtin error interface

func (GenerateProvenanceResponseValidationError) ErrorName

ErrorName returns error name.

func (GenerateProvenanceResponseValidationError) Field

Field function returns field value.

func (GenerateProvenanceResponseValidationError) Key

Key function returns key value.

func (GenerateProvenanceResponseValidationError) Reason

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

Error satisfies the builtin error interface

func (GetRequestValidationError) ErrorName

func (e GetRequestValidationError) ErrorName() string

ErrorName returns error name.

func (GetRequestValidationError) Field

Field function returns field value.

func (GetRequestValidationError) Key

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

Cause function returns cause value.

func (GetResponseValidationError) Error

Error satisfies the builtin error interface

func (GetResponseValidationError) ErrorName

func (e GetResponseValidationError) ErrorName() string

ErrorName returns error name.

func (GetResponseValidationError) Field

Field function returns field value.

func (GetResponseValidationError) Key

Key function returns key value.

func (GetResponseValidationError) Reason

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

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

Cause function returns cause value.

func (IntQueryKeyValidationError) Error

Error satisfies the builtin error interface

func (IntQueryKeyValidationError) ErrorName

func (e IntQueryKeyValidationError) ErrorName() string

ErrorName returns error name.

func (IntQueryKeyValidationError) Field

Field function returns field value.

func (IntQueryKeyValidationError) Key

Key function returns key value.

func (IntQueryKeyValidationError) Reason

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

Cause function returns cause value.

func (IntRangeFilterValidationError) Error

Error satisfies the builtin error interface

func (IntRangeFilterValidationError) ErrorName

func (e IntRangeFilterValidationError) ErrorName() string

ErrorName returns error name.

func (IntRangeFilterValidationError) Field

Field function returns field value.

func (IntRangeFilterValidationError) Key

Key function returns key value.

func (IntRangeFilterValidationError) Reason

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

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

Cause function returns cause value.

func (QueryRequestValidationError) Error

Error satisfies the builtin error interface

func (QueryRequestValidationError) ErrorName

func (e QueryRequestValidationError) ErrorName() string

ErrorName returns error name.

func (QueryRequestValidationError) Field

Field function returns field value.

func (QueryRequestValidationError) Key

Key function returns key value.

func (QueryRequestValidationError) Reason

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

Cause function returns cause value.

func (QueryResponseValidationError) Error

Error satisfies the builtin error interface

func (QueryResponseValidationError) ErrorName

func (e QueryResponseValidationError) ErrorName() string

ErrorName returns error name.

func (QueryResponseValidationError) Field

Field function returns field value.

func (QueryResponseValidationError) Key

Key function returns key value.

func (QueryResponseValidationError) Reason

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) GenerateProvenance added in v0.4.20

func (*UnimplementedArtifactsServer) Get added in v0.4.20

func (*UnimplementedArtifactsServer) Query added in v0.4.20

Jump to

Keyboard shortcuts

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