event.pb.go

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

package admin

import (
	fmt "fmt"
	event "github.com/flyteorg/flyteidl/gen/pb-go/flyteidl/event"
	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 that a sent event was not used to update execution state due to
// the referenced execution already being terminated (and therefore ineligible
// for further state transitions).
type EventErrorAlreadyInTerminalState struct {
	// +required
	CurrentPhase         string   `protobuf:"bytes,1,opt,name=current_phase,json=currentPhase,proto3" json:"current_phase,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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

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

var xxx_messageInfo_EventErrorAlreadyInTerminalState proto.InternalMessageInfo

func (m *EventErrorAlreadyInTerminalState) GetCurrentPhase() string {
	if m != nil {
		return m.CurrentPhase
	}
	return ""
}

// Indicates why a sent event was not used to update execution.
type EventFailureReason struct {
	// +required
	//
	// Types that are valid to be assigned to Reason:
	//	*EventFailureReason_AlreadyInTerminalState
	Reason               isEventFailureReason_Reason `protobuf_oneof:"reason"`
	XXX_NoUnkeyedLiteral struct{}                    `json:"-"`
	XXX_unrecognized     []byte                      `json:"-"`
	XXX_sizecache        int32                       `json:"-"`
}

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

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

var xxx_messageInfo_EventFailureReason proto.InternalMessageInfo

type isEventFailureReason_Reason interface {
	isEventFailureReason_Reason()
}

type EventFailureReason_AlreadyInTerminalState struct {
	AlreadyInTerminalState *EventErrorAlreadyInTerminalState `protobuf:"bytes,1,opt,name=already_in_terminal_state,json=alreadyInTerminalState,proto3,oneof"`
}

func (*EventFailureReason_AlreadyInTerminalState) isEventFailureReason_Reason() {}

func (m *EventFailureReason) GetReason() isEventFailureReason_Reason {
	if m != nil {
		return m.Reason
	}
	return nil
}

func (m *EventFailureReason) GetAlreadyInTerminalState() *EventErrorAlreadyInTerminalState {
	if x, ok := m.GetReason().(*EventFailureReason_AlreadyInTerminalState); ok {
		return x.AlreadyInTerminalState
	}
	return nil
}

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

// Request to send a notification that a workflow execution event has occurred.
type WorkflowExecutionEventRequest struct {
	// Unique ID for this request that can be traced between services
	RequestId string `protobuf:"bytes,1,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	// Details about the event that occurred.
	Event                *event.WorkflowExecutionEvent `protobuf:"bytes,2,opt,name=event,proto3" json:"event,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                      `json:"-"`
	XXX_unrecognized     []byte                        `json:"-"`
	XXX_sizecache        int32                         `json:"-"`
}

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

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

var xxx_messageInfo_WorkflowExecutionEventRequest proto.InternalMessageInfo

func (m *WorkflowExecutionEventRequest) GetRequestId() string {
	if m != nil {
		return m.RequestId
	}
	return ""
}

func (m *WorkflowExecutionEventRequest) GetEvent() *event.WorkflowExecutionEvent {
	if m != nil {
		return m.Event
	}
	return nil
}

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

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

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

var xxx_messageInfo_WorkflowExecutionEventResponse proto.InternalMessageInfo

// Request to send a notification that a node execution event has occurred.
type NodeExecutionEventRequest struct {
	// Unique ID for this request that can be traced between services
	RequestId string `protobuf:"bytes,1,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	// Details about the event that occurred.
	Event                *event.NodeExecutionEvent `protobuf:"bytes,2,opt,name=event,proto3" json:"event,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

func (m *NodeExecutionEventRequest) Reset()         { *m = NodeExecutionEventRequest{} }
func (m *NodeExecutionEventRequest) String() string { return proto.CompactTextString(m) }
func (*NodeExecutionEventRequest) ProtoMessage()    {}
func (*NodeExecutionEventRequest) Descriptor() ([]byte, []int) {
	return fileDescriptor_4581752dea61f248, []int{4}
}

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

var xxx_messageInfo_NodeExecutionEventRequest proto.InternalMessageInfo

func (m *NodeExecutionEventRequest) GetRequestId() string {
	if m != nil {
		return m.RequestId
	}
	return ""
}

func (m *NodeExecutionEventRequest) GetEvent() *event.NodeExecutionEvent {
	if m != nil {
		return m.Event
	}
	return nil
}

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

func (m *NodeExecutionEventResponse) Reset()         { *m = NodeExecutionEventResponse{} }
func (m *NodeExecutionEventResponse) String() string { return proto.CompactTextString(m) }
func (*NodeExecutionEventResponse) ProtoMessage()    {}
func (*NodeExecutionEventResponse) Descriptor() ([]byte, []int) {
	return fileDescriptor_4581752dea61f248, []int{5}
}

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

var xxx_messageInfo_NodeExecutionEventResponse proto.InternalMessageInfo

// Request to send a notification that a task execution event has occurred.
type TaskExecutionEventRequest struct {
	// Unique ID for this request that can be traced between services
	RequestId string `protobuf:"bytes,1,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	// Details about the event that occurred.
	Event                *event.TaskExecutionEvent `protobuf:"bytes,2,opt,name=event,proto3" json:"event,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

func (m *TaskExecutionEventRequest) Reset()         { *m = TaskExecutionEventRequest{} }
func (m *TaskExecutionEventRequest) String() string { return proto.CompactTextString(m) }
func (*TaskExecutionEventRequest) ProtoMessage()    {}
func (*TaskExecutionEventRequest) Descriptor() ([]byte, []int) {
	return fileDescriptor_4581752dea61f248, []int{6}
}

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

var xxx_messageInfo_TaskExecutionEventRequest proto.InternalMessageInfo

func (m *TaskExecutionEventRequest) GetRequestId() string {
	if m != nil {
		return m.RequestId
	}
	return ""
}

func (m *TaskExecutionEventRequest) GetEvent() *event.TaskExecutionEvent {
	if m != nil {
		return m.Event
	}
	return nil
}

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

func (m *TaskExecutionEventResponse) Reset()         { *m = TaskExecutionEventResponse{} }
func (m *TaskExecutionEventResponse) String() string { return proto.CompactTextString(m) }
func (*TaskExecutionEventResponse) ProtoMessage()    {}
func (*TaskExecutionEventResponse) Descriptor() ([]byte, []int) {
	return fileDescriptor_4581752dea61f248, []int{7}
}

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

var xxx_messageInfo_TaskExecutionEventResponse proto.InternalMessageInfo

func init() {
	proto.RegisterType((*EventErrorAlreadyInTerminalState)(nil), "flyteidl.admin.EventErrorAlreadyInTerminalState")
	proto.RegisterType((*EventFailureReason)(nil), "flyteidl.admin.EventFailureReason")
	proto.RegisterType((*WorkflowExecutionEventRequest)(nil), "flyteidl.admin.WorkflowExecutionEventRequest")
	proto.RegisterType((*WorkflowExecutionEventResponse)(nil), "flyteidl.admin.WorkflowExecutionEventResponse")
	proto.RegisterType((*NodeExecutionEventRequest)(nil), "flyteidl.admin.NodeExecutionEventRequest")
	proto.RegisterType((*NodeExecutionEventResponse)(nil), "flyteidl.admin.NodeExecutionEventResponse")
	proto.RegisterType((*TaskExecutionEventRequest)(nil), "flyteidl.admin.TaskExecutionEventRequest")
	proto.RegisterType((*TaskExecutionEventResponse)(nil), "flyteidl.admin.TaskExecutionEventResponse")
}

func init() { proto.RegisterFile("flyteidl/admin/event.proto", fileDescriptor_4581752dea61f248) }

var fileDescriptor_4581752dea61f248 = []byte{
	// 349 bytes of a gzipped FileDescriptorProto
	0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xb4, 0x93, 0x4f, 0x4b, 0xf3, 0x40,
	0x10, 0x87, 0xdf, 0xbe, 0x60, 0xb1, 0xe3, 0x9f, 0x43, 0x0e, 0xd2, 0x16, 0x2b, 0x25, 0x82, 0x78,
	0x31, 0x11, 0x45, 0xf4, 0xe0, 0xc5, 0x42, 0xd5, 0x5e, 0x44, 0x62, 0x41, 0xf0, 0x12, 0xb6, 0xcd,
	0x34, 0x5d, 0x9a, 0xec, 0xc6, 0xd9, 0x8d, 0x5a, 0xf0, 0x2b, 0xf8, 0x9d, 0xa5, 0x9b, 0x68, 0x8c,
	0xa4, 0x08, 0x82, 0xb7, 0x64, 0x66, 0xf2, 0xfc, 0x9e, 0x2c, 0xb3, 0xd0, 0x9e, 0x44, 0x73, 0x8d,
	0x3c, 0x88, 0x5c, 0x16, 0xc4, 0x5c, 0xb8, 0xf8, 0x84, 0x42, 0x3b, 0x09, 0x49, 0x2d, 0xad, 0xcd,
	0x8f, 0x9e, 0x63, 0x7a, 0xed, 0x62, 0xd6, 0x4c, 0x7d, 0x9d, 0xb5, 0xaf, 0xa0, 0xdb, 0x5f, 0xbc,
	0xf6, 0x89, 0x24, 0x5d, 0x44, 0x84, 0x2c, 0x98, 0x0f, 0xc4, 0x10, 0x29, 0xe6, 0x82, 0x45, 0x77,
	0x9a, 0x69, 0xb4, 0x76, 0x61, 0x63, 0x9c, 0x12, 0xa1, 0xd0, 0x7e, 0x32, 0x65, 0x0a, 0x9b, 0xb5,
	0x6e, 0x6d, 0xbf, 0xe1, 0xad, 0xe7, 0xc5, 0xdb, 0x45, 0xcd, 0x7e, 0xab, 0x81, 0x65, 0x48, 0x97,
	0x8c, 0x47, 0x29, 0xa1, 0x87, 0x4c, 0x49, 0x61, 0xc5, 0xd0, 0x62, 0x19, 0xd5, 0xe7, 0xc2, 0xd7,
	0x39, 0xd7, 0x57, 0x0b, 0xb0, 0xe1, 0xac, 0x1d, 0x1d, 0x3a, 0x65, 0x5f, 0xe7, 0x27, 0xa1, 0xeb,
	0x7f, 0xde, 0x16, 0xab, 0xec, 0xf4, 0x56, 0xa1, 0x4e, 0x26, 0xd8, 0x7e, 0x85, 0xce, 0xbd, 0xa4,
	0xd9, 0x24, 0x92, 0xcf, 0xfd, 0x17, 0x1c, 0xa7, 0x9a, 0x4b, 0x61, 0xc0, 0x1e, 0x3e, 0xa6, 0xa8,
	0xb4, 0xd5, 0x01, 0xa0, 0xec, 0xd1, 0xe7, 0x41, 0xfe, 0x4b, 0x8d, 0xbc, 0x32, 0x08, 0xac, 0x73,
	0x58, 0x31, 0xe7, 0xd4, 0xfc, 0x6f, 0x24, 0xf7, 0x0a, 0xc9, 0xec, 0xf8, 0x96, 0xc0, 0xb3, 0x8f,
	0xec, 0x2e, 0xec, 0x2c, 0x4b, 0x57, 0x89, 0x14, 0x0a, 0x6d, 0x0d, 0xad, 0x1b, 0x19, 0xe0, 0xaf,
	0xdc, 0xce, 0xca, 0x6e, 0xf6, 0x77, 0xb7, 0x0a, 0x70, 0xee, 0xb5, 0x0d, 0xed, 0xaa, 0xd4, 0xc2,
	0x69, 0xc8, 0xd4, 0xec, 0x4f, 0x9c, 0x2a, 0xc0, 0x85, 0x53, 0x55, 0x6a, 0xe6, 0xd4, 0x3b, 0x7d,
	0x38, 0x09, 0xb9, 0x9e, 0xa6, 0x23, 0x67, 0x2c, 0x63, 0xd7, 0x40, 0x25, 0x85, 0xee, 0xe7, 0x4a,
	0x87, 0x28, 0xdc, 0x64, 0x74, 0x10, 0x4a, 0xb7, 0x7c, 0x23, 0x46, 0x75, 0xb3, 0xe0, 0xc7, 0xef,
	0x01, 0x00, 0x00, 0xff, 0xff, 0x7b, 0xb0, 0xc6, 0xd1, 0x2a, 0x03, 0x00, 0x00,
}