event

package
v0.18.0 Latest Latest
Warning

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

Go to latest
Published: Jul 30, 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
	//	*NodeExecutionEvent_TaskNodeMetadata
	TargetMetadata isNodeExecutionEvent_TargetMetadata `protobuf_oneof:"target_metadata"`
	// [To be deprecated] 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"`
	// Specifies the parent node of the current node execution. Node executions at level zero will not have a parent node.
	ParentNodeMetadata *ParentNodeExecutionMetadata `protobuf:"bytes,10,opt,name=parent_node_metadata,json=parentNodeMetadata,proto3" json:"parent_node_metadata,omitempty"`
	// Retry group to indicate grouping of nodes by retries
	RetryGroup string `protobuf:"bytes,11,opt,name=retry_group,json=retryGroup,proto3" json:"retry_group,omitempty"`
	// Identifier of the node in the original workflow/graph
	// This maps to value of WorkflowTemplate.nodes[X].id
	SpecNodeId string `protobuf:"bytes,12,opt,name=spec_node_id,json=specNodeId,proto3" json:"spec_node_id,omitempty"`
	// Friendly readable name for the node
	NodeName             string   `protobuf:"bytes,13,opt,name=node_name,json=nodeName,proto3" json:"node_name,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) GetNodeName added in v0.17.37

func (m *NodeExecutionEvent) GetNodeName() 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) GetParentNodeMetadata added in v0.17.37

func (m *NodeExecutionEvent) GetParentNodeMetadata() *ParentNodeExecutionMetadata

func (*NodeExecutionEvent) GetParentTaskMetadata

func (m *NodeExecutionEvent) GetParentTaskMetadata() *ParentTaskExecutionMetadata

func (*NodeExecutionEvent) GetPhase

func (*NodeExecutionEvent) GetProducerId

func (m *NodeExecutionEvent) GetProducerId() string

func (*NodeExecutionEvent) GetRetryGroup added in v0.17.37

func (m *NodeExecutionEvent) GetRetryGroup() string

func (*NodeExecutionEvent) GetSpecNodeId added in v0.17.37

func (m *NodeExecutionEvent) GetSpecNodeId() string

func (*NodeExecutionEvent) GetTargetMetadata

func (m *NodeExecutionEvent) GetTargetMetadata() isNodeExecutionEvent_TargetMetadata

func (*NodeExecutionEvent) GetTaskNodeMetadata added in v0.17.38

func (m *NodeExecutionEvent) GetTaskNodeMetadata() *TaskNodeMetadata

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.4.20

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_TaskNodeMetadata added in v0.17.38

type NodeExecutionEvent_TaskNodeMetadata struct {
	TaskNodeMetadata *TaskNodeMetadata `protobuf:"bytes,14,opt,name=task_node_metadata,json=taskNodeMetadata,proto3,oneof"`
}

type NodeExecutionEvent_WorkflowNodeMetadata

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

type ParentNodeExecutionMetadata added in v0.17.37

type ParentNodeExecutionMetadata struct {
	// Unique identifier of the parent node id within the execution
	// This is value of core.NodeExecutionIdentifier.node_id of the parent node
	NodeId               string   `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ParentNodeExecutionMetadata) Descriptor added in v0.17.37

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

func (*ParentNodeExecutionMetadata) GetNodeId added in v0.17.37

func (m *ParentNodeExecutionMetadata) GetNodeId() string

func (*ParentNodeExecutionMetadata) ProtoMessage added in v0.17.37

func (*ParentNodeExecutionMetadata) ProtoMessage()

func (*ParentNodeExecutionMetadata) Reset added in v0.17.37

func (m *ParentNodeExecutionMetadata) Reset()

func (*ParentNodeExecutionMetadata) String added in v0.17.37

func (m *ParentNodeExecutionMetadata) String() string

func (*ParentNodeExecutionMetadata) Validate added in v0.17.37

func (m *ParentNodeExecutionMetadata) Validate() error

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

func (*ParentNodeExecutionMetadata) XXX_DiscardUnknown added in v0.17.37

func (m *ParentNodeExecutionMetadata) XXX_DiscardUnknown()

func (*ParentNodeExecutionMetadata) XXX_Marshal added in v0.17.37

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

func (*ParentNodeExecutionMetadata) XXX_Merge added in v0.17.37

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

func (*ParentNodeExecutionMetadata) XXX_Size added in v0.17.37

func (m *ParentNodeExecutionMetadata) XXX_Size() int

func (*ParentNodeExecutionMetadata) XXX_Unmarshal added in v0.17.37

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

type ParentNodeExecutionMetadataValidationError added in v0.17.37

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

ParentNodeExecutionMetadataValidationError is the validation error returned by ParentNodeExecutionMetadata.Validate if the designated constraints aren't met.

func (ParentNodeExecutionMetadataValidationError) Cause added in v0.17.37

Cause function returns cause value.

func (ParentNodeExecutionMetadataValidationError) Error added in v0.17.37

Error satisfies the builtin error interface

func (ParentNodeExecutionMetadataValidationError) ErrorName added in v0.17.37

ErrorName returns error name.

func (ParentNodeExecutionMetadataValidationError) Field added in v0.17.37

Field function returns field value.

func (ParentNodeExecutionMetadataValidationError) Key added in v0.17.37

Key function returns key value.

func (ParentNodeExecutionMetadataValidationError) Reason added in v0.17.37

Reason function returns reason value.

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.4.20

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 TaskNodeMetadata added in v0.17.38

type TaskNodeMetadata struct {
	// Captures the status of caching for this execution.
	CacheStatus core.CatalogCacheStatus `` /* 133-byte string literal not displayed */
	// This structure carries the catalog artifact information
	CatalogKey           *core.CatalogMetadata `protobuf:"bytes,2,opt,name=catalog_key,json=catalogKey,proto3" json:"catalog_key,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*TaskNodeMetadata) Descriptor added in v0.17.38

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

func (*TaskNodeMetadata) GetCacheStatus added in v0.17.38

func (m *TaskNodeMetadata) GetCacheStatus() core.CatalogCacheStatus

func (*TaskNodeMetadata) GetCatalogKey added in v0.17.38

func (m *TaskNodeMetadata) GetCatalogKey() *core.CatalogMetadata

func (*TaskNodeMetadata) ProtoMessage added in v0.17.38

func (*TaskNodeMetadata) ProtoMessage()

func (*TaskNodeMetadata) Reset added in v0.17.38

func (m *TaskNodeMetadata) Reset()

func (*TaskNodeMetadata) String added in v0.17.38

func (m *TaskNodeMetadata) String() string

func (*TaskNodeMetadata) Validate added in v0.17.38

func (m *TaskNodeMetadata) Validate() error

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

func (*TaskNodeMetadata) XXX_DiscardUnknown added in v0.17.38

func (m *TaskNodeMetadata) XXX_DiscardUnknown()

func (*TaskNodeMetadata) XXX_Marshal added in v0.17.38

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

func (*TaskNodeMetadata) XXX_Merge added in v0.17.38

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

func (*TaskNodeMetadata) XXX_Size added in v0.17.38

func (m *TaskNodeMetadata) XXX_Size() int

func (*TaskNodeMetadata) XXX_Unmarshal added in v0.17.38

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

type TaskNodeMetadataValidationError added in v0.17.38

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

TaskNodeMetadataValidationError is the validation error returned by TaskNodeMetadata.Validate if the designated constraints aren't met.

func (TaskNodeMetadataValidationError) Cause added in v0.17.38

Cause function returns cause value.

func (TaskNodeMetadataValidationError) Error added in v0.17.38

Error satisfies the builtin error interface

func (TaskNodeMetadataValidationError) ErrorName added in v0.17.38

ErrorName returns error name.

func (TaskNodeMetadataValidationError) Field added in v0.17.38

Field function returns field value.

func (TaskNodeMetadataValidationError) Key added in v0.17.38

Key function returns key value.

func (TaskNodeMetadataValidationError) Reason added in v0.17.38

Reason function returns reason value.

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.4.20

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