event

package
v0.16.6 Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type NodeExecutionEvent

type NodeExecutionEvent struct {
	// Unique identifier for this node execution
	Id *core.NodeExecutionIdentifier `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// the id of the originator (Propeller) of the event
	ProducerId string                   `protobuf:"bytes,2,opt,name=producer_id,json=producerId,proto3" json:"producer_id,omitempty"`
	Phase      core.NodeExecution_Phase `protobuf:"varint,3,opt,name=phase,proto3,enum=flyteidl.core.NodeExecution_Phase" json:"phase,omitempty"`
	// This timestamp represents when the original event occurred, it is generated
	// by the executor of the node.
	OccurredAt *timestamp.Timestamp `protobuf:"bytes,4,opt,name=occurred_at,json=occurredAt,proto3" json:"occurred_at,omitempty"`
	InputUri   string               `protobuf:"bytes,5,opt,name=input_uri,json=inputUri,proto3" json:"input_uri,omitempty"`
	// Types that are valid to be assigned to OutputResult:
	//	*NodeExecutionEvent_OutputUri
	//	*NodeExecutionEvent_Error
	OutputResult isNodeExecutionEvent_OutputResult `protobuf_oneof:"output_result"`
	// Additional metadata to do with this event's node target based
	// on the node type
	//
	// Types that are valid to be assigned to TargetMetadata:
	//	*NodeExecutionEvent_WorkflowNodeMetadata
	TargetMetadata isNodeExecutionEvent_TargetMetadata `protobuf_oneof:"target_metadata"`
	// Specifies which task (if any) launched this node.
	ParentTaskMetadata   *ParentTaskExecutionMetadata `protobuf:"bytes,9,opt,name=parent_task_metadata,json=parentTaskMetadata,proto3" json:"parent_task_metadata,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                     `json:"-"`
	XXX_unrecognized     []byte                       `json:"-"`
	XXX_sizecache        int32                        `json:"-"`
}

func (*NodeExecutionEvent) Descriptor

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

func (*NodeExecutionEvent) GetError

func (m *NodeExecutionEvent) GetError() *core.ExecutionError

func (*NodeExecutionEvent) GetId

func (*NodeExecutionEvent) GetInputUri

func (m *NodeExecutionEvent) GetInputUri() string

func (*NodeExecutionEvent) GetOccurredAt

func (m *NodeExecutionEvent) GetOccurredAt() *timestamp.Timestamp

func (*NodeExecutionEvent) GetOutputResult

func (m *NodeExecutionEvent) GetOutputResult() isNodeExecutionEvent_OutputResult

func (*NodeExecutionEvent) GetOutputUri

func (m *NodeExecutionEvent) GetOutputUri() string

func (*NodeExecutionEvent) GetParentTaskMetadata

func (m *NodeExecutionEvent) GetParentTaskMetadata() *ParentTaskExecutionMetadata

func (*NodeExecutionEvent) GetPhase

func (*NodeExecutionEvent) GetProducerId

func (m *NodeExecutionEvent) GetProducerId() string

func (*NodeExecutionEvent) GetTargetMetadata

func (m *NodeExecutionEvent) GetTargetMetadata() isNodeExecutionEvent_TargetMetadata

func (*NodeExecutionEvent) GetWorkflowNodeMetadata

func (m *NodeExecutionEvent) GetWorkflowNodeMetadata() *WorkflowNodeMetadata

func (*NodeExecutionEvent) ProtoMessage

func (*NodeExecutionEvent) ProtoMessage()

func (*NodeExecutionEvent) Reset

func (m *NodeExecutionEvent) Reset()

func (*NodeExecutionEvent) String

func (m *NodeExecutionEvent) String() string

func (*NodeExecutionEvent) Validate

func (m *NodeExecutionEvent) Validate() error

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

func (*NodeExecutionEvent) XXX_DiscardUnknown

func (m *NodeExecutionEvent) XXX_DiscardUnknown()

func (*NodeExecutionEvent) XXX_Marshal

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

func (*NodeExecutionEvent) XXX_Merge

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

func (*NodeExecutionEvent) XXX_OneofWrappers added in v0.16.1

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*NodeExecutionEvent) XXX_Size

func (m *NodeExecutionEvent) XXX_Size() int

func (*NodeExecutionEvent) XXX_Unmarshal

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

type NodeExecutionEventValidationError

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

NodeExecutionEventValidationError is the validation error returned by NodeExecutionEvent.Validate if the designated constraints aren't met.

func (NodeExecutionEventValidationError) Cause

Cause function returns cause value.

func (NodeExecutionEventValidationError) Error

Error satisfies the builtin error interface

func (NodeExecutionEventValidationError) ErrorName

ErrorName returns error name.

func (NodeExecutionEventValidationError) Field

Field function returns field value.

func (NodeExecutionEventValidationError) Key

Key function returns key value.

func (NodeExecutionEventValidationError) Reason

Reason function returns reason value.

type NodeExecutionEvent_Error

type NodeExecutionEvent_Error struct {
	Error *core.ExecutionError `protobuf:"bytes,7,opt,name=error,proto3,oneof"`
}

type NodeExecutionEvent_OutputUri

type NodeExecutionEvent_OutputUri struct {
	OutputUri string `protobuf:"bytes,6,opt,name=output_uri,json=outputUri,proto3,oneof"`
}

type NodeExecutionEvent_WorkflowNodeMetadata

type NodeExecutionEvent_WorkflowNodeMetadata struct {
	WorkflowNodeMetadata *WorkflowNodeMetadata `protobuf:"bytes,8,opt,name=workflow_node_metadata,json=workflowNodeMetadata,proto3,oneof"`
}

type ParentTaskExecutionMetadata

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

func (*ParentTaskExecutionMetadata) Descriptor

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

func (*ParentTaskExecutionMetadata) GetId

func (*ParentTaskExecutionMetadata) ProtoMessage

func (*ParentTaskExecutionMetadata) ProtoMessage()

func (*ParentTaskExecutionMetadata) Reset

func (m *ParentTaskExecutionMetadata) Reset()

func (*ParentTaskExecutionMetadata) String

func (m *ParentTaskExecutionMetadata) String() string

func (*ParentTaskExecutionMetadata) Validate

func (m *ParentTaskExecutionMetadata) Validate() error

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

func (*ParentTaskExecutionMetadata) XXX_DiscardUnknown

func (m *ParentTaskExecutionMetadata) XXX_DiscardUnknown()

func (*ParentTaskExecutionMetadata) XXX_Marshal

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

func (*ParentTaskExecutionMetadata) XXX_Merge

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

func (*ParentTaskExecutionMetadata) XXX_Size

func (m *ParentTaskExecutionMetadata) XXX_Size() int

func (*ParentTaskExecutionMetadata) XXX_Unmarshal

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

type ParentTaskExecutionMetadataValidationError

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

ParentTaskExecutionMetadataValidationError is the validation error returned by ParentTaskExecutionMetadata.Validate if the designated constraints aren't met.

func (ParentTaskExecutionMetadataValidationError) Cause

Cause function returns cause value.

func (ParentTaskExecutionMetadataValidationError) Error

Error satisfies the builtin error interface

func (ParentTaskExecutionMetadataValidationError) ErrorName

ErrorName returns error name.

func (ParentTaskExecutionMetadataValidationError) Field

Field function returns field value.

func (ParentTaskExecutionMetadataValidationError) Key

Key function returns key value.

func (ParentTaskExecutionMetadataValidationError) Reason

Reason function returns reason value.

type TaskExecutionEvent

type TaskExecutionEvent struct {
	// ID of the task. In combination with the retryAttempt this will indicate
	// the task execution uniquely for a given parent node execution.
	TaskId *core.Identifier `protobuf:"bytes,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	// A task execution is always kicked off by a node execution, the event consumer
	// will use the parent_id to relate the task to it's parent node execution
	ParentNodeExecutionId *core.NodeExecutionIdentifier `` /* 128-byte string literal not displayed */
	// retry attempt number for this task, ie., 2 for the second attempt
	RetryAttempt uint32 `protobuf:"varint,3,opt,name=retry_attempt,json=retryAttempt,proto3" json:"retry_attempt,omitempty"`
	// Phase associated with the event
	Phase core.TaskExecution_Phase `protobuf:"varint,4,opt,name=phase,proto3,enum=flyteidl.core.TaskExecution_Phase" json:"phase,omitempty"`
	// id of the process that sent this event, mainly for trace debugging
	ProducerId string `protobuf:"bytes,5,opt,name=producer_id,json=producerId,proto3" json:"producer_id,omitempty"`
	// log information for the task execution
	Logs []*core.TaskLog `protobuf:"bytes,6,rep,name=logs,proto3" json:"logs,omitempty"`
	// This timestamp represents when the original event occurred, it is generated
	// by the executor of the task.
	OccurredAt *timestamp.Timestamp `protobuf:"bytes,7,opt,name=occurred_at,json=occurredAt,proto3" json:"occurred_at,omitempty"`
	// URI of the input file, it encodes all the information
	// including Cloud source provider. ie., s3://...
	InputUri string `protobuf:"bytes,8,opt,name=input_uri,json=inputUri,proto3" json:"input_uri,omitempty"`
	// Types that are valid to be assigned to OutputResult:
	//	*TaskExecutionEvent_OutputUri
	//	*TaskExecutionEvent_Error
	OutputResult isTaskExecutionEvent_OutputResult `protobuf_oneof:"output_result"`
	// Custom data that the task plugin sends back. This is extensible to allow various plugins in the system.
	CustomInfo *_struct.Struct `protobuf:"bytes,11,opt,name=custom_info,json=customInfo,proto3" json:"custom_info,omitempty"`
	// Some phases, like RUNNING, can send multiple events with changed metadata (new logs, additional custom_info, etc)
	// that should be recorded regardless of the lack of phase change.
	// The version field should be incremented when metadata changes across the duration of an individual phase.
	PhaseVersion         uint32   `protobuf:"varint,12,opt,name=phase_version,json=phaseVersion,proto3" json:"phase_version,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Plugin specific execution event information. For tasks like Python, Hive, Spark, DynamicJob.

func (*TaskExecutionEvent) Descriptor

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

func (*TaskExecutionEvent) GetCustomInfo

func (m *TaskExecutionEvent) GetCustomInfo() *_struct.Struct

func (*TaskExecutionEvent) GetError

func (m *TaskExecutionEvent) GetError() *core.ExecutionError

func (*TaskExecutionEvent) GetInputUri

func (m *TaskExecutionEvent) GetInputUri() string

func (*TaskExecutionEvent) GetLogs

func (m *TaskExecutionEvent) GetLogs() []*core.TaskLog

func (*TaskExecutionEvent) GetOccurredAt

func (m *TaskExecutionEvent) GetOccurredAt() *timestamp.Timestamp

func (*TaskExecutionEvent) GetOutputResult

func (m *TaskExecutionEvent) GetOutputResult() isTaskExecutionEvent_OutputResult

func (*TaskExecutionEvent) GetOutputUri

func (m *TaskExecutionEvent) GetOutputUri() string

func (*TaskExecutionEvent) GetParentNodeExecutionId

func (m *TaskExecutionEvent) GetParentNodeExecutionId() *core.NodeExecutionIdentifier

func (*TaskExecutionEvent) GetPhase

func (*TaskExecutionEvent) GetPhaseVersion

func (m *TaskExecutionEvent) GetPhaseVersion() uint32

func (*TaskExecutionEvent) GetProducerId

func (m *TaskExecutionEvent) GetProducerId() string

func (*TaskExecutionEvent) GetRetryAttempt

func (m *TaskExecutionEvent) GetRetryAttempt() uint32

func (*TaskExecutionEvent) GetTaskId

func (m *TaskExecutionEvent) GetTaskId() *core.Identifier

func (*TaskExecutionEvent) ProtoMessage

func (*TaskExecutionEvent) ProtoMessage()

func (*TaskExecutionEvent) Reset

func (m *TaskExecutionEvent) Reset()

func (*TaskExecutionEvent) String

func (m *TaskExecutionEvent) String() string

func (*TaskExecutionEvent) Validate

func (m *TaskExecutionEvent) Validate() error

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

func (*TaskExecutionEvent) XXX_DiscardUnknown

func (m *TaskExecutionEvent) XXX_DiscardUnknown()

func (*TaskExecutionEvent) XXX_Marshal

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

func (*TaskExecutionEvent) XXX_Merge

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

func (*TaskExecutionEvent) XXX_OneofWrappers added in v0.16.1

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*TaskExecutionEvent) XXX_Size

func (m *TaskExecutionEvent) XXX_Size() int

func (*TaskExecutionEvent) XXX_Unmarshal

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

type TaskExecutionEventValidationError

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

TaskExecutionEventValidationError is the validation error returned by TaskExecutionEvent.Validate if the designated constraints aren't met.

func (TaskExecutionEventValidationError) Cause

Cause function returns cause value.

func (TaskExecutionEventValidationError) Error

Error satisfies the builtin error interface

func (TaskExecutionEventValidationError) ErrorName

ErrorName returns error name.

func (TaskExecutionEventValidationError) Field

Field function returns field value.

func (TaskExecutionEventValidationError) Key

Key function returns key value.

func (TaskExecutionEventValidationError) Reason

Reason function returns reason value.

type TaskExecutionEvent_Error

type TaskExecutionEvent_Error struct {
	Error *core.ExecutionError `protobuf:"bytes,10,opt,name=error,proto3,oneof"`
}

type TaskExecutionEvent_OutputUri

type TaskExecutionEvent_OutputUri struct {
	OutputUri string `protobuf:"bytes,9,opt,name=output_uri,json=outputUri,proto3,oneof"`
}

type WorkflowExecutionEvent

type WorkflowExecutionEvent struct {
	// Workflow execution id
	ExecutionId *core.WorkflowExecutionIdentifier `protobuf:"bytes,1,opt,name=execution_id,json=executionId,proto3" json:"execution_id,omitempty"`
	// the id of the originator (Propeller) of the event
	ProducerId string                       `protobuf:"bytes,2,opt,name=producer_id,json=producerId,proto3" json:"producer_id,omitempty"`
	Phase      core.WorkflowExecution_Phase `protobuf:"varint,3,opt,name=phase,proto3,enum=flyteidl.core.WorkflowExecution_Phase" json:"phase,omitempty"`
	// This timestamp represents when the original event occurred, it is generated
	// by the executor of the workflow.
	OccurredAt *timestamp.Timestamp `protobuf:"bytes,4,opt,name=occurred_at,json=occurredAt,proto3" json:"occurred_at,omitempty"`
	// Types that are valid to be assigned to OutputResult:
	//	*WorkflowExecutionEvent_OutputUri
	//	*WorkflowExecutionEvent_Error
	OutputResult         isWorkflowExecutionEvent_OutputResult `protobuf_oneof:"output_result"`
	XXX_NoUnkeyedLiteral struct{}                              `json:"-"`
	XXX_unrecognized     []byte                                `json:"-"`
	XXX_sizecache        int32                                 `json:"-"`
}

func (*WorkflowExecutionEvent) Descriptor

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

func (*WorkflowExecutionEvent) GetError

func (*WorkflowExecutionEvent) GetExecutionId

func (*WorkflowExecutionEvent) GetOccurredAt

func (m *WorkflowExecutionEvent) GetOccurredAt() *timestamp.Timestamp

func (*WorkflowExecutionEvent) GetOutputResult

func (m *WorkflowExecutionEvent) GetOutputResult() isWorkflowExecutionEvent_OutputResult

func (*WorkflowExecutionEvent) GetOutputUri

func (m *WorkflowExecutionEvent) GetOutputUri() string

func (*WorkflowExecutionEvent) GetPhase

func (*WorkflowExecutionEvent) GetProducerId

func (m *WorkflowExecutionEvent) GetProducerId() string

func (*WorkflowExecutionEvent) ProtoMessage

func (*WorkflowExecutionEvent) ProtoMessage()

func (*WorkflowExecutionEvent) Reset

func (m *WorkflowExecutionEvent) Reset()

func (*WorkflowExecutionEvent) String

func (m *WorkflowExecutionEvent) String() string

func (*WorkflowExecutionEvent) Validate

func (m *WorkflowExecutionEvent) Validate() error

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

func (*WorkflowExecutionEvent) XXX_DiscardUnknown

func (m *WorkflowExecutionEvent) XXX_DiscardUnknown()

func (*WorkflowExecutionEvent) XXX_Marshal

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

func (*WorkflowExecutionEvent) XXX_Merge

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

func (*WorkflowExecutionEvent) XXX_OneofWrappers added in v0.16.1

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*WorkflowExecutionEvent) XXX_Size

func (m *WorkflowExecutionEvent) XXX_Size() int

func (*WorkflowExecutionEvent) XXX_Unmarshal

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

type WorkflowExecutionEventValidationError

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

WorkflowExecutionEventValidationError is the validation error returned by WorkflowExecutionEvent.Validate if the designated constraints aren't met.

func (WorkflowExecutionEventValidationError) Cause

Cause function returns cause value.

func (WorkflowExecutionEventValidationError) Error

Error satisfies the builtin error interface

func (WorkflowExecutionEventValidationError) ErrorName

ErrorName returns error name.

func (WorkflowExecutionEventValidationError) Field

Field function returns field value.

func (WorkflowExecutionEventValidationError) Key

Key function returns key value.

func (WorkflowExecutionEventValidationError) Reason

Reason function returns reason value.

type WorkflowExecutionEvent_Error

type WorkflowExecutionEvent_Error struct {
	Error *core.ExecutionError `protobuf:"bytes,6,opt,name=error,proto3,oneof"`
}

type WorkflowExecutionEvent_OutputUri

type WorkflowExecutionEvent_OutputUri struct {
	OutputUri string `protobuf:"bytes,5,opt,name=output_uri,json=outputUri,proto3,oneof"`
}

type WorkflowNodeMetadata

type WorkflowNodeMetadata struct {
	ExecutionId          *core.WorkflowExecutionIdentifier `protobuf:"bytes,1,opt,name=execution_id,json=executionId,proto3" json:"execution_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                          `json:"-"`
	XXX_unrecognized     []byte                            `json:"-"`
	XXX_sizecache        int32                             `json:"-"`
}

For Workflow Nodes we need to send information about the workflow that's launched

func (*WorkflowNodeMetadata) Descriptor

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

func (*WorkflowNodeMetadata) GetExecutionId

func (*WorkflowNodeMetadata) ProtoMessage

func (*WorkflowNodeMetadata) ProtoMessage()

func (*WorkflowNodeMetadata) Reset

func (m *WorkflowNodeMetadata) Reset()

func (*WorkflowNodeMetadata) String

func (m *WorkflowNodeMetadata) String() string

func (*WorkflowNodeMetadata) Validate

func (m *WorkflowNodeMetadata) Validate() error

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

func (*WorkflowNodeMetadata) XXX_DiscardUnknown

func (m *WorkflowNodeMetadata) XXX_DiscardUnknown()

func (*WorkflowNodeMetadata) XXX_Marshal

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

func (*WorkflowNodeMetadata) XXX_Merge

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

func (*WorkflowNodeMetadata) XXX_Size

func (m *WorkflowNodeMetadata) XXX_Size() int

func (*WorkflowNodeMetadata) XXX_Unmarshal

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

type WorkflowNodeMetadataValidationError

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

WorkflowNodeMetadataValidationError is the validation error returned by WorkflowNodeMetadata.Validate if the designated constraints aren't met.

func (WorkflowNodeMetadataValidationError) Cause

Cause function returns cause value.

func (WorkflowNodeMetadataValidationError) Error

Error satisfies the builtin error interface

func (WorkflowNodeMetadataValidationError) ErrorName

ErrorName returns error name.

func (WorkflowNodeMetadataValidationError) Field

Field function returns field value.

func (WorkflowNodeMetadataValidationError) Key

Key function returns key value.

func (WorkflowNodeMetadataValidationError) Reason

Reason function returns reason value.

Jump to

Keyboard shortcuts

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