datacatalog.pb.go

// Code generated by protoc-gen-go. DO NOT EDIT.
// source: flyteidl/datacatalog/datacatalog.proto

package datacatalog

import (
	context "context"
	fmt "fmt"
	proto "github.com/golang/protobuf/proto"
	grpc "google.golang.org/grpc"
	codes "google.golang.org/grpc/codes"
	status "google.golang.org/grpc/status"
	math "math"
)

// Reference imports to suppress errors if they are not otherwise used.
var _ = proto.Marshal
var _ = fmt.Errorf
var _ = math.Inf

// This is a compile-time assertion to ensure that this generated file
// is compatible with the proto package it is being compiled against.
// A compilation error at this line likely means your copy of the
// proto package needs to be updated.
const _ = proto.ProtoPackageIsVersion3 // please upgrade the proto package

type QueryOperator int32

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

var QueryOperator_name = map[int32]string{
	0: "EQUAL",
	1: "GREATER_THAN",
	2: "LESSER_THAN",
}

var QueryOperator_value = map[string]int32{
	"EQUAL":        0,
	"GREATER_THAN": 1,
	"LESSER_THAN":  2,
}

func (x QueryOperator) String() string {
	return proto.EnumName(QueryOperator_name, int32(x))
}

func (QueryOperator) EnumDescriptor() ([]byte, []int) {
	return fileDescriptor_275951237ff4368a, []int{0}
}

type CreateResponse_Status int32

const (
	CreateResponse_ALREADY_EXISTS CreateResponse_Status = 0
	CreateResponse_CREATED        CreateResponse_Status = 1
)

var CreateResponse_Status_name = map[int32]string{
	0: "ALREADY_EXISTS",
	1: "CREATED",
}

var CreateResponse_Status_value = map[string]int32{
	"ALREADY_EXISTS": 0,
	"CREATED":        1,
}

func (x CreateResponse_Status) String() string {
	return proto.EnumName(CreateResponse_Status_name, int32(x))
}

func (CreateResponse_Status) EnumDescriptor() ([]byte, []int) {
	return fileDescriptor_275951237ff4368a, []int{11, 0}
}

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 (m *Parameter) Reset()         { *m = Parameter{} }
func (m *Parameter) String() string { return proto.CompactTextString(m) }
func (*Parameter) ProtoMessage()    {}
func (*Parameter) Descriptor() ([]byte, []int) {
	return fileDescriptor_275951237ff4368a, []int{0}
}

func (m *Parameter) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_Parameter.Unmarshal(m, b)
}
func (m *Parameter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_Parameter.Marshal(b, m, deterministic)
}
func (m *Parameter) XXX_Merge(src proto.Message) {
	xxx_messageInfo_Parameter.Merge(m, src)
}
func (m *Parameter) XXX_Size() int {
	return xxx_messageInfo_Parameter.Size(m)
}
func (m *Parameter) XXX_DiscardUnknown() {
	xxx_messageInfo_Parameter.DiscardUnknown(m)
}

var xxx_messageInfo_Parameter proto.InternalMessageInfo

func (m *Parameter) GetName() string {
	if m != nil {
		return m.Name
	}
	return ""
}

func (m *Parameter) GetValue() string {
	if m != nil {
		return m.Value
	}
	return ""
}

// 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.
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:"-"`
}

func (m *Artifact) Reset()         { *m = Artifact{} }
func (m *Artifact) String() string { return proto.CompactTextString(m) }
func (*Artifact) ProtoMessage()    {}
func (*Artifact) Descriptor() ([]byte, []int) {
	return fileDescriptor_275951237ff4368a, []int{1}
}

func (m *Artifact) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_Artifact.Unmarshal(m, b)
}
func (m *Artifact) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_Artifact.Marshal(b, m, deterministic)
}
func (m *Artifact) XXX_Merge(src proto.Message) {
	xxx_messageInfo_Artifact.Merge(m, src)
}
func (m *Artifact) XXX_Size() int {
	return xxx_messageInfo_Artifact.Size(m)
}
func (m *Artifact) XXX_DiscardUnknown() {
	xxx_messageInfo_Artifact.DiscardUnknown(m)
}

var xxx_messageInfo_Artifact proto.InternalMessageInfo

func (m *Artifact) GetProvenance() string {
	if m != nil {
		return m.Provenance
	}
	return ""
}

func (m *Artifact) GetName() string {
	if m != nil {
		return m.Name
	}
	return ""
}

func (m *Artifact) GetVersion() string {
	if m != nil {
		return m.Version
	}
	return ""
}

func (m *Artifact) GetRevision() int64 {
	if m != nil {
		return m.Revision
	}
	return 0
}

func (m *Artifact) GetCreatedAt() int64 {
	if m != nil {
		return m.CreatedAt
	}
	return 0
}

func (m *Artifact) GetReferenceId() string {
	if m != nil {
		return m.ReferenceId
	}
	return ""
}

func (m *Artifact) GetInputs() []*Parameter {
	if m != nil {
		return m.Inputs
	}
	return nil
}

func (m *Artifact) GetOutputs() []*Parameter {
	if m != nil {
		return m.Outputs
	}
	return nil
}

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 (m *ArtifactId) Reset()         { *m = ArtifactId{} }
func (m *ArtifactId) String() string { return proto.CompactTextString(m) }
func (*ArtifactId) ProtoMessage()    {}
func (*ArtifactId) Descriptor() ([]byte, []int) {
	return fileDescriptor_275951237ff4368a, []int{2}
}

func (m *ArtifactId) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_ArtifactId.Unmarshal(m, b)
}
func (m *ArtifactId) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_ArtifactId.Marshal(b, m, deterministic)
}
func (m *ArtifactId) XXX_Merge(src proto.Message) {
	xxx_messageInfo_ArtifactId.Merge(m, src)
}
func (m *ArtifactId) XXX_Size() int {
	return xxx_messageInfo_ArtifactId.Size(m)
}
func (m *ArtifactId) XXX_DiscardUnknown() {
	xxx_messageInfo_ArtifactId.DiscardUnknown(m)
}

var xxx_messageInfo_ArtifactId proto.InternalMessageInfo

func (m *ArtifactId) GetName() string {
	if m != nil {
		return m.Name
	}
	return ""
}

func (m *ArtifactId) GetVersion() string {
	if m != nil {
		return m.Version
	}
	return ""
}

func (m *ArtifactId) GetInputs() []*Parameter {
	if m != nil {
		return m.Inputs
	}
	return nil
}

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 (m *GetRequest) Reset()         { *m = GetRequest{} }
func (m *GetRequest) String() string { return proto.CompactTextString(m) }
func (*GetRequest) ProtoMessage()    {}
func (*GetRequest) Descriptor() ([]byte, []int) {
	return fileDescriptor_275951237ff4368a, []int{3}
}

func (m *GetRequest) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_GetRequest.Unmarshal(m, b)
}
func (m *GetRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_GetRequest.Marshal(b, m, deterministic)
}
func (m *GetRequest) XXX_Merge(src proto.Message) {
	xxx_messageInfo_GetRequest.Merge(m, src)
}
func (m *GetRequest) XXX_Size() int {
	return xxx_messageInfo_GetRequest.Size(m)
}
func (m *GetRequest) XXX_DiscardUnknown() {
	xxx_messageInfo_GetRequest.DiscardUnknown(m)
}

var xxx_messageInfo_GetRequest proto.InternalMessageInfo

type isGetRequest_Id interface {
	isGetRequest_Id()
}

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

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

func (*GetRequest_Provenance) isGetRequest_Id() {}

func (*GetRequest_ArtifactId) isGetRequest_Id() {}

func (m *GetRequest) GetId() isGetRequest_Id {
	if m != nil {
		return m.Id
	}
	return nil
}

func (m *GetRequest) GetProvenance() string {
	if x, ok := m.GetId().(*GetRequest_Provenance); ok {
		return x.Provenance
	}
	return ""
}

func (m *GetRequest) GetArtifactId() *ArtifactId {
	if x, ok := m.GetId().(*GetRequest_ArtifactId); ok {
		return x.ArtifactId
	}
	return nil
}

// XXX_OneofWrappers is for the internal use of the proto package.
func (*GetRequest) XXX_OneofWrappers() []interface{} {
	return []interface{}{
		(*GetRequest_Provenance)(nil),
		(*GetRequest_ArtifactId)(nil),
	}
}

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 (m *GetResponse) Reset()         { *m = GetResponse{} }
func (m *GetResponse) String() string { return proto.CompactTextString(m) }
func (*GetResponse) ProtoMessage()    {}
func (*GetResponse) Descriptor() ([]byte, []int) {
	return fileDescriptor_275951237ff4368a, []int{4}
}

func (m *GetResponse) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_GetResponse.Unmarshal(m, b)
}
func (m *GetResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_GetResponse.Marshal(b, m, deterministic)
}
func (m *GetResponse) XXX_Merge(src proto.Message) {
	xxx_messageInfo_GetResponse.Merge(m, src)
}
func (m *GetResponse) XXX_Size() int {
	return xxx_messageInfo_GetResponse.Size(m)
}
func (m *GetResponse) XXX_DiscardUnknown() {
	xxx_messageInfo_GetResponse.DiscardUnknown(m)
}

var xxx_messageInfo_GetResponse proto.InternalMessageInfo

func (m *GetResponse) GetArtifact() *Artifact {
	if m != nil {
		return m.Artifact
	}
	return nil
}

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 (m *IntFilter) Reset()         { *m = IntFilter{} }
func (m *IntFilter) String() string { return proto.CompactTextString(m) }
func (*IntFilter) ProtoMessage()    {}
func (*IntFilter) Descriptor() ([]byte, []int) {
	return fileDescriptor_275951237ff4368a, []int{5}
}

func (m *IntFilter) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_IntFilter.Unmarshal(m, b)
}
func (m *IntFilter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_IntFilter.Marshal(b, m, deterministic)
}
func (m *IntFilter) XXX_Merge(src proto.Message) {
	xxx_messageInfo_IntFilter.Merge(m, src)
}
func (m *IntFilter) XXX_Size() int {
	return xxx_messageInfo_IntFilter.Size(m)
}
func (m *IntFilter) XXX_DiscardUnknown() {
	xxx_messageInfo_IntFilter.DiscardUnknown(m)
}

var xxx_messageInfo_IntFilter proto.InternalMessageInfo

func (m *IntFilter) GetValue() int64 {
	if m != nil {
		return m.Value
	}
	return 0
}

func (m *IntFilter) GetOperator() QueryOperator {
	if m != nil {
		return m.Operator
	}
	return QueryOperator_EQUAL
}

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 (m *IntRangeFilter) Reset()         { *m = IntRangeFilter{} }
func (m *IntRangeFilter) String() string { return proto.CompactTextString(m) }
func (*IntRangeFilter) ProtoMessage()    {}
func (*IntRangeFilter) Descriptor() ([]byte, []int) {
	return fileDescriptor_275951237ff4368a, []int{6}
}

func (m *IntRangeFilter) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_IntRangeFilter.Unmarshal(m, b)
}
func (m *IntRangeFilter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_IntRangeFilter.Marshal(b, m, deterministic)
}
func (m *IntRangeFilter) XXX_Merge(src proto.Message) {
	xxx_messageInfo_IntRangeFilter.Merge(m, src)
}
func (m *IntRangeFilter) XXX_Size() int {
	return xxx_messageInfo_IntRangeFilter.Size(m)
}
func (m *IntRangeFilter) XXX_DiscardUnknown() {
	xxx_messageInfo_IntRangeFilter.DiscardUnknown(m)
}

var xxx_messageInfo_IntRangeFilter proto.InternalMessageInfo

func (m *IntRangeFilter) GetMin() int64 {
	if m != nil {
		return m.Min
	}
	return 0
}

func (m *IntRangeFilter) GetMax() int64 {
	if m != nil {
		return m.Max
	}
	return 0
}

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 (m *IntQueryKey) Reset()         { *m = IntQueryKey{} }
func (m *IntQueryKey) String() string { return proto.CompactTextString(m) }
func (*IntQueryKey) ProtoMessage()    {}
func (*IntQueryKey) Descriptor() ([]byte, []int) {
	return fileDescriptor_275951237ff4368a, []int{7}
}

func (m *IntQueryKey) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_IntQueryKey.Unmarshal(m, b)
}
func (m *IntQueryKey) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_IntQueryKey.Marshal(b, m, deterministic)
}
func (m *IntQueryKey) XXX_Merge(src proto.Message) {
	xxx_messageInfo_IntQueryKey.Merge(m, src)
}
func (m *IntQueryKey) XXX_Size() int {
	return xxx_messageInfo_IntQueryKey.Size(m)
}
func (m *IntQueryKey) XXX_DiscardUnknown() {
	xxx_messageInfo_IntQueryKey.DiscardUnknown(m)
}

var xxx_messageInfo_IntQueryKey proto.InternalMessageInfo

type isIntQueryKey_Filter interface {
	isIntQueryKey_Filter()
}

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

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

func (*IntQueryKey_Val) isIntQueryKey_Filter() {}

func (*IntQueryKey_Range) isIntQueryKey_Filter() {}

func (m *IntQueryKey) GetFilter() isIntQueryKey_Filter {
	if m != nil {
		return m.Filter
	}
	return nil
}

func (m *IntQueryKey) GetVal() *IntFilter {
	if x, ok := m.GetFilter().(*IntQueryKey_Val); ok {
		return x.Val
	}
	return nil
}

func (m *IntQueryKey) GetRange() *IntRangeFilter {
	if x, ok := m.GetFilter().(*IntQueryKey_Range); ok {
		return x.Range
	}
	return nil
}

// XXX_OneofWrappers is for the internal use of the proto package.
func (*IntQueryKey) XXX_OneofWrappers() []interface{} {
	return []interface{}{
		(*IntQueryKey_Val)(nil),
		(*IntQueryKey_Range)(nil),
	}
}

// QueryRequest allows queries on a range of values for revision column and point queries on created_at
// and reference_id
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:"-"`
}

func (m *QueryRequest) Reset()         { *m = QueryRequest{} }
func (m *QueryRequest) String() string { return proto.CompactTextString(m) }
func (*QueryRequest) ProtoMessage()    {}
func (*QueryRequest) Descriptor() ([]byte, []int) {
	return fileDescriptor_275951237ff4368a, []int{8}
}

func (m *QueryRequest) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_QueryRequest.Unmarshal(m, b)
}
func (m *QueryRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_QueryRequest.Marshal(b, m, deterministic)
}
func (m *QueryRequest) XXX_Merge(src proto.Message) {
	xxx_messageInfo_QueryRequest.Merge(m, src)
}
func (m *QueryRequest) XXX_Size() int {
	return xxx_messageInfo_QueryRequest.Size(m)
}
func (m *QueryRequest) XXX_DiscardUnknown() {
	xxx_messageInfo_QueryRequest.DiscardUnknown(m)
}

var xxx_messageInfo_QueryRequest proto.InternalMessageInfo

func (m *QueryRequest) GetName() string {
	if m != nil {
		return m.Name
	}
	return ""
}

func (m *QueryRequest) GetVersion() string {
	if m != nil {
		return m.Version
	}
	return ""
}

func (m *QueryRequest) GetRevision() *IntQueryKey {
	if m != nil {
		return m.Revision
	}
	return nil
}

func (m *QueryRequest) GetCreatedAt() int64 {
	if m != nil {
		return m.CreatedAt
	}
	return 0
}

func (m *QueryRequest) GetReferenceId() string {
	if m != nil {
		return m.ReferenceId
	}
	return ""
}

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 (m *QueryResponse) Reset()         { *m = QueryResponse{} }
func (m *QueryResponse) String() string { return proto.CompactTextString(m) }
func (*QueryResponse) ProtoMessage()    {}
func (*QueryResponse) Descriptor() ([]byte, []int) {
	return fileDescriptor_275951237ff4368a, []int{9}
}

func (m *QueryResponse) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_QueryResponse.Unmarshal(m, b)
}
func (m *QueryResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_QueryResponse.Marshal(b, m, deterministic)
}
func (m *QueryResponse) XXX_Merge(src proto.Message) {
	xxx_messageInfo_QueryResponse.Merge(m, src)
}
func (m *QueryResponse) XXX_Size() int {
	return xxx_messageInfo_QueryResponse.Size(m)
}
func (m *QueryResponse) XXX_DiscardUnknown() {
	xxx_messageInfo_QueryResponse.DiscardUnknown(m)
}

var xxx_messageInfo_QueryResponse proto.InternalMessageInfo

func (m *QueryResponse) GetArtifact() []*Artifact {
	if m != nil {
		return m.Artifact
	}
	return nil
}

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 (m *CreateRequest) Reset()         { *m = CreateRequest{} }
func (m *CreateRequest) String() string { return proto.CompactTextString(m) }
func (*CreateRequest) ProtoMessage()    {}
func (*CreateRequest) Descriptor() ([]byte, []int) {
	return fileDescriptor_275951237ff4368a, []int{10}
}

func (m *CreateRequest) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_CreateRequest.Unmarshal(m, b)
}
func (m *CreateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_CreateRequest.Marshal(b, m, deterministic)
}
func (m *CreateRequest) XXX_Merge(src proto.Message) {
	xxx_messageInfo_CreateRequest.Merge(m, src)
}
func (m *CreateRequest) XXX_Size() int {
	return xxx_messageInfo_CreateRequest.Size(m)
}
func (m *CreateRequest) XXX_DiscardUnknown() {
	xxx_messageInfo_CreateRequest.DiscardUnknown(m)
}

var xxx_messageInfo_CreateRequest proto.InternalMessageInfo

func (m *CreateRequest) GetRef() *ArtifactId {
	if m != nil {
		return m.Ref
	}
	return nil
}

func (m *CreateRequest) GetReferenceId() string {
	if m != nil {
		return m.ReferenceId
	}
	return ""
}

func (m *CreateRequest) GetRevision() int64 {
	if m != nil {
		return m.Revision
	}
	return 0
}

func (m *CreateRequest) GetOutputs() []*Parameter {
	if m != nil {
		return m.Outputs
	}
	return nil
}

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 (m *CreateResponse) Reset()         { *m = CreateResponse{} }
func (m *CreateResponse) String() string { return proto.CompactTextString(m) }
func (*CreateResponse) ProtoMessage()    {}
func (*CreateResponse) Descriptor() ([]byte, []int) {
	return fileDescriptor_275951237ff4368a, []int{11}
}

func (m *CreateResponse) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_CreateResponse.Unmarshal(m, b)
}
func (m *CreateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_CreateResponse.Marshal(b, m, deterministic)
}
func (m *CreateResponse) XXX_Merge(src proto.Message) {
	xxx_messageInfo_CreateResponse.Merge(m, src)
}
func (m *CreateResponse) XXX_Size() int {
	return xxx_messageInfo_CreateResponse.Size(m)
}
func (m *CreateResponse) XXX_DiscardUnknown() {
	xxx_messageInfo_CreateResponse.DiscardUnknown(m)
}

var xxx_messageInfo_CreateResponse proto.InternalMessageInfo

func (m *CreateResponse) GetArtifact() *Artifact {
	if m != nil {
		return m.Artifact
	}
	return nil
}

func (m *CreateResponse) GetStatus() CreateResponse_Status {
	if m != nil {
		return m.Status
	}
	return CreateResponse_ALREADY_EXISTS
}

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 (m *GenerateProvenanceRequest) Reset()         { *m = GenerateProvenanceRequest{} }
func (m *GenerateProvenanceRequest) String() string { return proto.CompactTextString(m) }
func (*GenerateProvenanceRequest) ProtoMessage()    {}
func (*GenerateProvenanceRequest) Descriptor() ([]byte, []int) {
	return fileDescriptor_275951237ff4368a, []int{12}
}

func (m *GenerateProvenanceRequest) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_GenerateProvenanceRequest.Unmarshal(m, b)
}
func (m *GenerateProvenanceRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_GenerateProvenanceRequest.Marshal(b, m, deterministic)
}
func (m *GenerateProvenanceRequest) XXX_Merge(src proto.Message) {
	xxx_messageInfo_GenerateProvenanceRequest.Merge(m, src)
}
func (m *GenerateProvenanceRequest) XXX_Size() int {
	return xxx_messageInfo_GenerateProvenanceRequest.Size(m)
}
func (m *GenerateProvenanceRequest) XXX_DiscardUnknown() {
	xxx_messageInfo_GenerateProvenanceRequest.DiscardUnknown(m)
}

var xxx_messageInfo_GenerateProvenanceRequest proto.InternalMessageInfo

func (m *GenerateProvenanceRequest) GetId() *ArtifactId {
	if m != nil {
		return m.Id
	}
	return nil
}

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 (m *GenerateProvenanceResponse) Reset()         { *m = GenerateProvenanceResponse{} }
func (m *GenerateProvenanceResponse) String() string { return proto.CompactTextString(m) }
func (*GenerateProvenanceResponse) ProtoMessage()    {}
func (*GenerateProvenanceResponse) Descriptor() ([]byte, []int) {
	return fileDescriptor_275951237ff4368a, []int{13}
}

func (m *GenerateProvenanceResponse) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_GenerateProvenanceResponse.Unmarshal(m, b)
}
func (m *GenerateProvenanceResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_GenerateProvenanceResponse.Marshal(b, m, deterministic)
}
func (m *GenerateProvenanceResponse) XXX_Merge(src proto.Message) {
	xxx_messageInfo_GenerateProvenanceResponse.Merge(m, src)
}
func (m *GenerateProvenanceResponse) XXX_Size() int {
	return xxx_messageInfo_GenerateProvenanceResponse.Size(m)
}
func (m *GenerateProvenanceResponse) XXX_DiscardUnknown() {
	xxx_messageInfo_GenerateProvenanceResponse.DiscardUnknown(m)
}

var xxx_messageInfo_GenerateProvenanceResponse proto.InternalMessageInfo

func (m *GenerateProvenanceResponse) GetProvenance() string {
	if m != nil {
		return m.Provenance
	}
	return ""
}

func init() {
	proto.RegisterEnum("pb.lyft.datacatalog.QueryOperator", QueryOperator_name, QueryOperator_value)
	proto.RegisterEnum("pb.lyft.datacatalog.CreateResponse_Status", CreateResponse_Status_name, CreateResponse_Status_value)
	proto.RegisterType((*Parameter)(nil), "pb.lyft.datacatalog.Parameter")
	proto.RegisterType((*Artifact)(nil), "pb.lyft.datacatalog.Artifact")
	proto.RegisterType((*ArtifactId)(nil), "pb.lyft.datacatalog.ArtifactId")
	proto.RegisterType((*GetRequest)(nil), "pb.lyft.datacatalog.GetRequest")
	proto.RegisterType((*GetResponse)(nil), "pb.lyft.datacatalog.GetResponse")
	proto.RegisterType((*IntFilter)(nil), "pb.lyft.datacatalog.IntFilter")
	proto.RegisterType((*IntRangeFilter)(nil), "pb.lyft.datacatalog.IntRangeFilter")
	proto.RegisterType((*IntQueryKey)(nil), "pb.lyft.datacatalog.IntQueryKey")
	proto.RegisterType((*QueryRequest)(nil), "pb.lyft.datacatalog.QueryRequest")
	proto.RegisterType((*QueryResponse)(nil), "pb.lyft.datacatalog.QueryResponse")
	proto.RegisterType((*CreateRequest)(nil), "pb.lyft.datacatalog.CreateRequest")
	proto.RegisterType((*CreateResponse)(nil), "pb.lyft.datacatalog.CreateResponse")
	proto.RegisterType((*GenerateProvenanceRequest)(nil), "pb.lyft.datacatalog.GenerateProvenanceRequest")
	proto.RegisterType((*GenerateProvenanceResponse)(nil), "pb.lyft.datacatalog.GenerateProvenanceResponse")
}

func init() {
	proto.RegisterFile("flyteidl/datacatalog/datacatalog.proto", fileDescriptor_275951237ff4368a)
}

var fileDescriptor_275951237ff4368a = []byte{
	// 790 bytes of a gzipped FileDescriptorProto
	0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xa4, 0x56, 0xdd, 0x6e, 0xda, 0x48,
	0x14, 0xc6, 0x36, 0xbf, 0xc7, 0x09, 0x8b, 0xce, 0xee, 0x05, 0x8b, 0x94, 0x2c, 0x99, 0x48, 0xab,
	0x6c, 0x2e, 0x88, 0x96, 0xdd, 0x56, 0xad, 0x9a, 0x56, 0x82, 0x84, 0x02, 0x29, 0x6a, 0x13, 0x93,
	0x4a, 0x6d, 0x6f, 0xd0, 0x04, 0x86, 0xc8, 0x12, 0xb1, 0xe9, 0x78, 0xa0, 0xe1, 0x0d, 0x7a, 0xd9,
	0xc7, 0xe8, 0x33, 0xb4, 0x7d, 0xaf, 0xde, 0x56, 0x1e, 0x3c, 0x8e, 0x53, 0x4c, 0x02, 0xea, 0x9d,
	0xe7, 0xcc, 0x39, 0xdf, 0xf9, 0xe6, 0x3b, 0x3f, 0x00, 0x7f, 0x0f, 0x47, 0x33, 0xc1, 0xec, 0xc1,
	0xe8, 0x60, 0x40, 0x05, 0xed, 0x53, 0x41, 0x47, 0xee, 0x65, 0xf4, 0xbb, 0x32, 0xe6, 0xae, 0x70,
	0xf1, 0xf7, 0xf1, 0x45, 0x65, 0x34, 0x1b, 0x8a, 0x4a, 0xe4, 0x8a, 0x3c, 0x80, 0xdc, 0x29, 0xe5,
	0xf4, 0x8a, 0x09, 0xc6, 0x11, 0x21, 0xe9, 0xd0, 0x2b, 0x56, 0xd4, 0xca, 0xda, 0x5e, 0xce, 0x92,
	0xdf, 0xf8, 0x07, 0xa4, 0xa6, 0x74, 0x34, 0x61, 0x45, 0x5d, 0x1a, 0xe7, 0x07, 0xf2, 0x59, 0x87,
	0x6c, 0x8d, 0x0b, 0x7b, 0x48, 0xfb, 0x02, 0xb7, 0x01, 0xc6, 0xdc, 0x9d, 0x32, 0x87, 0x3a, 0x7d,
	0x15, 0x1c, 0xb1, 0x84, 0xb0, 0x7a, 0x04, 0xb6, 0x08, 0x99, 0x29, 0xe3, 0x9e, 0xed, 0x3a, 0x45,
	0x43, 0x9a, 0xd5, 0x11, 0x4b, 0x90, 0xe5, 0x6c, 0x6a, 0xcb, 0xab, 0x64, 0x59, 0xdb, 0x33, 0xac,
	0xf0, 0x8c, 0x5b, 0x00, 0x7d, 0xce, 0xa8, 0x60, 0x83, 0x1e, 0x15, 0xc5, 0x94, 0xbc, 0xcd, 0x05,
	0x96, 0x9a, 0xc0, 0x1d, 0xd8, 0xe0, 0x6c, 0xc8, 0x38, 0x73, 0xfa, 0xac, 0x67, 0x0f, 0x8a, 0x69,
	0x89, 0x6c, 0x86, 0xb6, 0xf6, 0x00, 0x1f, 0x42, 0xda, 0x76, 0xc6, 0x13, 0xe1, 0x15, 0x33, 0x65,
	0x63, 0xcf, 0xac, 0x6e, 0x57, 0x62, 0x54, 0xa9, 0x84, 0x92, 0x58, 0x81, 0x37, 0x3e, 0x82, 0x8c,
	0x3b, 0x11, 0x32, 0x30, 0xbb, 0x52, 0xa0, 0x72, 0x27, 0x1c, 0x40, 0x29, 0xd5, 0x1e, 0xc4, 0x4a,
	0x1c, 0xd1, 0x42, 0xbf, 0xad, 0xc5, 0x0d, 0x5b, 0x63, 0x1d, 0xb6, 0xe4, 0x1a, 0xa0, 0xc9, 0x84,
	0xc5, 0xde, 0x4f, 0x98, 0x27, 0xb0, 0xbc, 0x58, 0x9f, 0x56, 0xe2, 0x56, 0x85, 0xea, 0x60, 0xd2,
	0x80, 0xa3, 0xaf, 0x9b, 0xcf, 0xc2, 0xac, 0xfe, 0x15, 0x9b, 0xec, 0xe6, 0x2d, 0x3e, 0x06, 0x0d,
	0x4f, 0xf5, 0x24, 0xe8, 0xf6, 0x80, 0xb4, 0xc0, 0x94, 0x99, 0xbd, 0xb1, 0xeb, 0x78, 0x0c, 0x1f,
	0x43, 0x56, 0xb9, 0xc8, 0xc4, 0x66, 0x75, 0xeb, 0x4e, 0x54, 0x2b, 0x74, 0x27, 0x14, 0x72, 0x6d,
	0x47, 0x3c, 0xb7, 0x47, 0x7e, 0x67, 0x86, 0x5d, 0xa8, 0xc9, 0x9a, 0xcf, 0x0f, 0xf8, 0x0c, 0xb2,
	0xee, 0x98, 0x71, 0x2a, 0x5c, 0x2e, 0x39, 0xe7, 0xab, 0x24, 0x16, 0xfd, 0x6c, 0xc2, 0xf8, 0xec,
	0x55, 0xe0, 0x69, 0x85, 0x31, 0xe4, 0x7f, 0xc8, 0xb7, 0x1d, 0x61, 0x51, 0xe7, 0x92, 0x05, 0x79,
	0x0a, 0x60, 0x5c, 0xd9, 0x4e, 0x90, 0xc5, 0xff, 0x94, 0x16, 0x7a, 0x2d, 0xe1, 0x7d, 0x0b, 0xbd,
	0x26, 0x1f, 0x35, 0x30, 0xdb, 0x8e, 0x90, 0xa0, 0x2f, 0xd8, 0x0c, 0xab, 0x60, 0x4c, 0xe9, 0x28,
	0x78, 0x5e, 0x7c, 0x85, 0xc2, 0x87, 0xb4, 0x12, 0x96, 0xef, 0x8c, 0x4f, 0x20, 0xc5, 0xfd, 0xb4,
	0x81, 0xd4, 0xbb, 0xcb, 0xa2, 0x22, 0xdc, 0x5a, 0x09, 0x6b, 0x1e, 0x53, 0xcf, 0x42, 0x7a, 0x28,
	0x4d, 0xe4, 0x9b, 0x06, 0x1b, 0x92, 0x87, 0x2a, 0xf5, 0x7a, 0xed, 0x75, 0x18, 0x19, 0x35, 0x43,
	0x12, 0x29, 0x2f, 0x23, 0xa2, 0x5e, 0xbb, 0x74, 0x18, 0x93, 0xf7, 0x0d, 0x63, 0x6a, 0x61, 0x18,
	0xc9, 0x09, 0x6c, 0x06, 0xec, 0x63, 0xdb, 0xc5, 0x58, 0xa7, 0x5d, 0xbe, 0x6a, 0xb0, 0x79, 0x24,
	0x93, 0x2b, 0x2d, 0xfe, 0x05, 0x83, 0xb3, 0x61, 0x50, 0x97, 0xfb, 0x9a, 0xd9, 0xf2, 0x7d, 0x17,
	0x38, 0xeb, 0x8b, 0x0b, 0xa4, 0xf4, 0x93, 0x66, 0xd1, 0xf5, 0x14, 0x59, 0x12, 0xc9, 0xf5, 0x96,
	0xc4, 0x17, 0x0d, 0xf2, 0x8a, 0xfd, 0x2f, 0x8f, 0x0e, 0xd6, 0x21, 0xed, 0x09, 0x2a, 0x26, 0x5e,
	0x30, 0x15, 0xfb, 0xb1, 0x81, 0xb7, 0xf3, 0x55, 0xba, 0x32, 0xc2, 0x0a, 0x22, 0xc9, 0x3f, 0x90,
	0x9e, 0x5b, 0x10, 0x21, 0x5f, 0xeb, 0x58, 0x8d, 0xda, 0xf1, 0xdb, 0x5e, 0xe3, 0x4d, 0xbb, 0x7b,
	0xde, 0x2d, 0x24, 0xd0, 0x84, 0xcc, 0x91, 0xd5, 0xa8, 0x9d, 0x37, 0x8e, 0x0b, 0x1a, 0xe9, 0xc0,
	0x9f, 0x4d, 0xe6, 0xf8, 0x33, 0xc5, 0x4e, 0xc3, 0x9d, 0xa2, 0xaa, 0x70, 0xe0, 0xaf, 0x85, 0x55,
	0x8b, 0xe0, 0x6f, 0x90, 0x43, 0x28, 0xc5, 0xa1, 0x05, 0xaa, 0xdc, 0xf3, 0x5b, 0xb3, 0xff, 0x34,
	0x68, 0x29, 0x35, 0xed, 0x98, 0x83, 0x54, 0xe3, 0xec, 0x75, 0xad, 0x53, 0x48, 0x60, 0x01, 0x36,
	0x9a, 0x92, 0xb4, 0xd5, 0x3b, 0x6f, 0xd5, 0x5e, 0x16, 0x34, 0xfc, 0x0d, 0xcc, 0x4e, 0xa3, 0xdb,
	0x55, 0x06, 0xbd, 0xfa, 0x5d, 0x87, 0x9c, 0xe2, 0xe3, 0xe1, 0x09, 0x18, 0x4d, 0x26, 0x30, 0x9e,
	0xf6, 0xcd, 0x82, 0x2d, 0x95, 0x97, 0x3b, 0xcc, 0x69, 0x93, 0x04, 0x9e, 0x42, 0x4a, 0x12, 0xc3,
	0x9d, 0xe5, 0x2b, 0x4a, 0xe1, 0x91, 0xbb, 0x5c, 0x42, 0xc4, 0x2e, 0xa4, 0xe7, 0x25, 0x44, 0x72,
	0x67, 0x7d, 0xe7, 0x98, 0xbb, 0x2b, 0xf4, 0x00, 0x49, 0xe0, 0x07, 0xc0, 0x45, 0xf5, 0xb1, 0xb2,
	0xe4, 0x81, 0x4b, 0x8a, 0x5e, 0x3a, 0x58, 0xd9, 0x5f, 0x25, 0xae, 0x17, 0xde, 0x99, 0x11, 0xdf,
	0x4f, 0x9a, 0x76, 0x91, 0x96, 0x7f, 0x5b, 0xfe, 0xfb, 0x11, 0x00, 0x00, 0xff, 0xff, 0xea, 0x1f,
	0xee, 0x85, 0xe0, 0x08, 0x00, 0x00,
}

// Reference imports to suppress errors if they are not otherwise used.
var _ context.Context
var _ grpc.ClientConn

// This is a compile-time assertion to ensure that this generated file
// is compatible with the grpc package it is being compiled against.
const _ = grpc.SupportPackageIsVersion4

// 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.
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)
}

type artifactsClient struct {
	cc *grpc.ClientConn
}

func NewArtifactsClient(cc *grpc.ClientConn) ArtifactsClient {
	return &artifactsClient{cc}
}

func (c *artifactsClient) Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetResponse, error) {
	out := new(GetResponse)
	err := c.cc.Invoke(ctx, "/pb.lyft.datacatalog.Artifacts/Get", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *artifactsClient) Query(ctx context.Context, in *QueryRequest, opts ...grpc.CallOption) (*QueryResponse, error) {
	out := new(QueryResponse)
	err := c.cc.Invoke(ctx, "/pb.lyft.datacatalog.Artifacts/Query", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *artifactsClient) Create(ctx context.Context, in *CreateRequest, opts ...grpc.CallOption) (*CreateResponse, error) {
	out := new(CreateResponse)
	err := c.cc.Invoke(ctx, "/pb.lyft.datacatalog.Artifacts/Create", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *artifactsClient) GenerateProvenance(ctx context.Context, in *GenerateProvenanceRequest, opts ...grpc.CallOption) (*GenerateProvenanceResponse, error) {
	out := new(GenerateProvenanceResponse)
	err := c.cc.Invoke(ctx, "/pb.lyft.datacatalog.Artifacts/GenerateProvenance", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

// ArtifactsServer is the server API for Artifacts service.
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)
}

// UnimplementedArtifactsServer can be embedded to have forward compatible implementations.
type UnimplementedArtifactsServer struct {
}

func (*UnimplementedArtifactsServer) Get(ctx context.Context, req *GetRequest) (*GetResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method Get not implemented")
}
func (*UnimplementedArtifactsServer) Query(ctx context.Context, req *QueryRequest) (*QueryResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method Query not implemented")
}
func (*UnimplementedArtifactsServer) Create(ctx context.Context, req *CreateRequest) (*CreateResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method Create not implemented")
}
func (*UnimplementedArtifactsServer) GenerateProvenance(ctx context.Context, req *GenerateProvenanceRequest) (*GenerateProvenanceResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GenerateProvenance not implemented")
}

func RegisterArtifactsServer(s *grpc.Server, srv ArtifactsServer) {
	s.RegisterService(&_Artifacts_serviceDesc, srv)
}

func _Artifacts_Get_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(GetRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ArtifactsServer).Get(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/pb.lyft.datacatalog.Artifacts/Get",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ArtifactsServer).Get(ctx, req.(*GetRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _Artifacts_Query_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(QueryRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ArtifactsServer).Query(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/pb.lyft.datacatalog.Artifacts/Query",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ArtifactsServer).Query(ctx, req.(*QueryRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _Artifacts_Create_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(CreateRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ArtifactsServer).Create(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/pb.lyft.datacatalog.Artifacts/Create",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ArtifactsServer).Create(ctx, req.(*CreateRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _Artifacts_GenerateProvenance_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(GenerateProvenanceRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ArtifactsServer).GenerateProvenance(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/pb.lyft.datacatalog.Artifacts/GenerateProvenance",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ArtifactsServer).GenerateProvenance(ctx, req.(*GenerateProvenanceRequest))
	}
	return interceptor(ctx, in, info, handler)
}

var _Artifacts_serviceDesc = grpc.ServiceDesc{
	ServiceName: "pb.lyft.datacatalog.Artifacts",
	HandlerType: (*ArtifactsServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Get",
			Handler:    _Artifacts_Get_Handler,
		},
		{
			MethodName: "Query",
			Handler:    _Artifacts_Query_Handler,
		},
		{
			MethodName: "Create",
			Handler:    _Artifacts_Create_Handler,
		},
		{
			MethodName: "GenerateProvenance",
			Handler:    _Artifacts_GenerateProvenance_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "flyteidl/datacatalog/datacatalog.proto",
}