identifier.pb.go

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

package core

import (
	fmt "fmt"
	proto "github.com/golang/protobuf/proto"
	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

// Indicates a resource type within Flyte.
type ResourceType int32

const (
	ResourceType_UNSPECIFIED ResourceType = 0
	ResourceType_TASK        ResourceType = 1
	ResourceType_WORKFLOW    ResourceType = 2
	ResourceType_LAUNCH_PLAN ResourceType = 3
)

var ResourceType_name = map[int32]string{
	0: "UNSPECIFIED",
	1: "TASK",
	2: "WORKFLOW",
	3: "LAUNCH_PLAN",
}

var ResourceType_value = map[string]int32{
	"UNSPECIFIED": 0,
	"TASK":        1,
	"WORKFLOW":    2,
	"LAUNCH_PLAN": 3,
}

func (x ResourceType) String() string {
	return proto.EnumName(ResourceType_name, int32(x))
}

func (ResourceType) EnumDescriptor() ([]byte, []int) {
	return fileDescriptor_adfa846a86e1fa0c, []int{0}
}

// Encapsulation of fields that uniquely identifies a Flyte resource.
type Identifier struct {
	// Identifies the specific type of resource that this identifer corresponds to.
	ResourceType ResourceType `protobuf:"varint,1,opt,name=resource_type,json=resourceType,proto3,enum=flyteidl.core.ResourceType" json:"resource_type,omitempty"`
	// Name of the project the resource belongs to.
	Project string `protobuf:"bytes,2,opt,name=project,proto3" json:"project,omitempty"`
	// Name of the domain the resource belongs to.
	// A domain can be considered as a subset within a specific project.
	Domain string `protobuf:"bytes,3,opt,name=domain,proto3" json:"domain,omitempty"`
	// User provided value for the resource.
	Name string `protobuf:"bytes,4,opt,name=name,proto3" json:"name,omitempty"`
	// Specific version of the resource.
	Version              string   `protobuf:"bytes,5,opt,name=version,proto3" json:"version,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (m *Identifier) Reset()         { *m = Identifier{} }
func (m *Identifier) String() string { return proto.CompactTextString(m) }
func (*Identifier) ProtoMessage()    {}
func (*Identifier) Descriptor() ([]byte, []int) {
	return fileDescriptor_adfa846a86e1fa0c, []int{0}
}

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

var xxx_messageInfo_Identifier proto.InternalMessageInfo

func (m *Identifier) GetResourceType() ResourceType {
	if m != nil {
		return m.ResourceType
	}
	return ResourceType_UNSPECIFIED
}

func (m *Identifier) GetProject() string {
	if m != nil {
		return m.Project
	}
	return ""
}

func (m *Identifier) GetDomain() string {
	if m != nil {
		return m.Domain
	}
	return ""
}

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

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

// Encapsulation of fields that uniquely identifies a Flyte workflow execution
type WorkflowExecutionIdentifier struct {
	// Name of the project the resource belongs to.
	Project string `protobuf:"bytes,1,opt,name=project,proto3" json:"project,omitempty"`
	// Name of the domain the resource belongs to.
	// A domain can be considered as a subset within a specific project.
	Domain string `protobuf:"bytes,2,opt,name=domain,proto3" json:"domain,omitempty"`
	// User or system provided value for the resource.
	Name                 string   `protobuf:"bytes,4,opt,name=name,proto3" json:"name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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

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

var xxx_messageInfo_WorkflowExecutionIdentifier proto.InternalMessageInfo

func (m *WorkflowExecutionIdentifier) GetProject() string {
	if m != nil {
		return m.Project
	}
	return ""
}

func (m *WorkflowExecutionIdentifier) GetDomain() string {
	if m != nil {
		return m.Domain
	}
	return ""
}

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

// Encapsulation of fields that identify a Flyte node execution entity.
type NodeExecutionIdentifier struct {
	NodeId               string                       `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	ExecutionId          *WorkflowExecutionIdentifier `protobuf:"bytes,2,opt,name=execution_id,json=executionId,proto3" json:"execution_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                     `json:"-"`
	XXX_unrecognized     []byte                       `json:"-"`
	XXX_sizecache        int32                        `json:"-"`
}

func (m *NodeExecutionIdentifier) Reset()         { *m = NodeExecutionIdentifier{} }
func (m *NodeExecutionIdentifier) String() string { return proto.CompactTextString(m) }
func (*NodeExecutionIdentifier) ProtoMessage()    {}
func (*NodeExecutionIdentifier) Descriptor() ([]byte, []int) {
	return fileDescriptor_adfa846a86e1fa0c, []int{2}
}

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

var xxx_messageInfo_NodeExecutionIdentifier proto.InternalMessageInfo

func (m *NodeExecutionIdentifier) GetNodeId() string {
	if m != nil {
		return m.NodeId
	}
	return ""
}

func (m *NodeExecutionIdentifier) GetExecutionId() *WorkflowExecutionIdentifier {
	if m != nil {
		return m.ExecutionId
	}
	return nil
}

// Encapsulation of fields that identify a Flyte task execution entity.
type TaskExecutionIdentifier struct {
	TaskId               *Identifier              `protobuf:"bytes,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	NodeExecutionId      *NodeExecutionIdentifier `protobuf:"bytes,2,opt,name=node_execution_id,json=nodeExecutionId,proto3" json:"node_execution_id,omitempty"`
	RetryAttempt         uint32                   `protobuf:"varint,3,opt,name=retry_attempt,json=retryAttempt,proto3" json:"retry_attempt,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                 `json:"-"`
	XXX_unrecognized     []byte                   `json:"-"`
	XXX_sizecache        int32                    `json:"-"`
}

func (m *TaskExecutionIdentifier) Reset()         { *m = TaskExecutionIdentifier{} }
func (m *TaskExecutionIdentifier) String() string { return proto.CompactTextString(m) }
func (*TaskExecutionIdentifier) ProtoMessage()    {}
func (*TaskExecutionIdentifier) Descriptor() ([]byte, []int) {
	return fileDescriptor_adfa846a86e1fa0c, []int{3}
}

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

var xxx_messageInfo_TaskExecutionIdentifier proto.InternalMessageInfo

func (m *TaskExecutionIdentifier) GetTaskId() *Identifier {
	if m != nil {
		return m.TaskId
	}
	return nil
}

func (m *TaskExecutionIdentifier) GetNodeExecutionId() *NodeExecutionIdentifier {
	if m != nil {
		return m.NodeExecutionId
	}
	return nil
}

func (m *TaskExecutionIdentifier) GetRetryAttempt() uint32 {
	if m != nil {
		return m.RetryAttempt
	}
	return 0
}

func init() {
	proto.RegisterEnum("flyteidl.core.ResourceType", ResourceType_name, ResourceType_value)
	proto.RegisterType((*Identifier)(nil), "flyteidl.core.Identifier")
	proto.RegisterType((*WorkflowExecutionIdentifier)(nil), "flyteidl.core.WorkflowExecutionIdentifier")
	proto.RegisterType((*NodeExecutionIdentifier)(nil), "flyteidl.core.NodeExecutionIdentifier")
	proto.RegisterType((*TaskExecutionIdentifier)(nil), "flyteidl.core.TaskExecutionIdentifier")
}

func init() { proto.RegisterFile("flyteidl/core/identifier.proto", fileDescriptor_adfa846a86e1fa0c) }

var fileDescriptor_adfa846a86e1fa0c = []byte{
	// 426 bytes of a gzipped FileDescriptorProto
	0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x84, 0x53, 0xd1, 0x6e, 0xd3, 0x30,
	0x14, 0xc5, 0x5d, 0x69, 0xc7, 0x6d, 0xcb, 0x8a, 0x1f, 0x68, 0xd0, 0x24, 0x34, 0x15, 0x09, 0x4d,
	0x93, 0x48, 0x50, 0xf8, 0x01, 0xca, 0xe8, 0xb4, 0x68, 0xa5, 0x9b, 0xb2, 0x4e, 0x95, 0x78, 0xa9,
	0xd2, 0xf8, 0xb6, 0x98, 0x26, 0x76, 0xe4, 0xb8, 0x40, 0x1e, 0xf9, 0x21, 0x3e, 0x83, 0xef, 0x42,
	0xce, 0x92, 0x91, 0x56, 0x2d, 0xbc, 0xe5, 0xdc, 0x73, 0x7c, 0xcf, 0x71, 0x72, 0x02, 0x2f, 0x17,
	0x51, 0xa6, 0x91, 0xb3, 0xc8, 0x09, 0xa5, 0x42, 0x87, 0x33, 0x14, 0x9a, 0x2f, 0x38, 0x2a, 0x3b,
	0x51, 0x52, 0x4b, 0xda, 0x29, 0x79, 0xdb, 0xf0, 0xfd, 0x5f, 0x04, 0xc0, 0x7b, 0xd0, 0xd0, 0xf7,
	0xd0, 0x51, 0x98, 0xca, 0xb5, 0x0a, 0x71, 0xa6, 0xb3, 0x04, 0x2d, 0x72, 0x42, 0x4e, 0x9f, 0xba,
	0xc7, 0xf6, 0xc6, 0x29, 0xdb, 0x2f, 0x34, 0x93, 0x2c, 0x41, 0xbf, 0xad, 0x2a, 0x88, 0x5a, 0xd0,
	0x4c, 0x94, 0xfc, 0x8a, 0xa1, 0xb6, 0x6a, 0x27, 0xe4, 0xf4, 0x89, 0x5f, 0x42, 0xfa, 0x1c, 0x1a,
	0x4c, 0xc6, 0x01, 0x17, 0xd6, 0x41, 0x4e, 0x14, 0x88, 0x52, 0xa8, 0x8b, 0x20, 0x46, 0xab, 0x9e,
	0x4f, 0xf3, 0x67, 0xb3, 0xe5, 0x1b, 0xaa, 0x94, 0x4b, 0x61, 0x3d, 0xbe, 0xdf, 0x52, 0xc0, 0x7e,
	0x08, 0xc7, 0x53, 0xa9, 0x56, 0x8b, 0x48, 0x7e, 0x1f, 0xfe, 0xc0, 0x70, 0xad, 0xb9, 0x14, 0x95,
	0x0b, 0x54, 0xec, 0xc9, 0x3e, 0xfb, 0xda, 0xff, 0xec, 0xfb, 0x3f, 0x09, 0xf4, 0xc6, 0x92, 0xe1,
	0x2e, 0x87, 0x1e, 0x34, 0x85, 0x64, 0x38, 0xe3, 0xac, 0x70, 0x68, 0x18, 0xe8, 0x31, 0xfa, 0x09,
	0xda, 0x58, 0xea, 0x0d, 0x6b, 0x6c, 0x5a, 0xee, 0xd9, 0xd6, 0xab, 0xfb, 0x47, 0x78, 0xbf, 0x85,
	0x7f, 0x87, 0xfd, 0xdf, 0x04, 0x7a, 0x93, 0x20, 0x5d, 0xed, 0xca, 0xe0, 0x42, 0x53, 0x07, 0xe9,
	0xaa, 0xcc, 0xd0, 0x72, 0x5f, 0x6c, 0xb9, 0x54, 0x96, 0x36, 0x8c, 0xd2, 0x63, 0xd4, 0x87, 0x67,
	0x79, 0xee, 0x1d, 0x19, 0x5f, 0x6f, 0x9d, 0xde, 0x73, 0x75, 0xff, 0x48, 0x6c, 0x12, 0xf4, 0x95,
	0xa9, 0x8b, 0x56, 0xd9, 0x2c, 0xd0, 0x1a, 0xe3, 0x44, 0xe7, 0x5f, 0xb6, 0x63, 0x1a, 0xa1, 0x55,
	0x36, 0xb8, 0x9f, 0x9d, 0x5d, 0x42, 0xbb, 0xda, 0x17, 0x7a, 0x04, 0xad, 0xbb, 0xf1, 0xed, 0xcd,
	0xf0, 0xdc, 0xbb, 0xf0, 0x86, 0x1f, 0xbb, 0x8f, 0xe8, 0x21, 0xd4, 0x27, 0x83, 0xdb, 0xab, 0x2e,
	0xa1, 0x6d, 0x38, 0x9c, 0x5e, 0xfb, 0x57, 0x17, 0xa3, 0xeb, 0x69, 0xb7, 0x66, 0x84, 0xa3, 0xc1,
	0xdd, 0xf8, 0xfc, 0x72, 0x76, 0x33, 0x1a, 0x8c, 0xbb, 0x07, 0x1f, 0xdc, 0xcf, 0x6f, 0x97, 0x5c,
	0x7f, 0x59, 0xcf, 0xed, 0x50, 0xc6, 0x4e, 0x94, 0x2d, 0xb4, 0xf3, 0xd0, 0xf6, 0x25, 0x0a, 0x27,
	0x99, 0xbf, 0x59, 0x4a, 0x67, 0xe3, 0x07, 0x98, 0x37, 0xf2, 0xda, 0xbf, 0xfb, 0x13, 0x00, 0x00,
	0xff, 0xff, 0x50, 0xa4, 0x59, 0x3a, 0x18, 0x03, 0x00, 0x00,
}