event

package
v0.17.0 Latest Latest
Warning

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

 Go to latest Published: Jan 24, 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 (m *NodeExecutionEvent) GetId() *core.NodeExecutionIdentifier

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 (m *NodeExecutionEvent) GetPhase() core.NodeExecution_Phase

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

func (e NodeExecutionEventValidationError) Cause() error

Cause function returns cause value.

func (NodeExecutionEventValidationError) Error 

func (e NodeExecutionEventValidationError) Error() string

Error satisfies the builtin error interface

func (NodeExecutionEventValidationError) ErrorName 

func (e NodeExecutionEventValidationError) ErrorName() string

ErrorName returns error name.

func (NodeExecutionEventValidationError) Field 

func (e NodeExecutionEventValidationError) Field() string

Field function returns field value.

func (NodeExecutionEventValidationError) Key 

func (e NodeExecutionEventValidationError) Key() bool

Key function returns key value.

func (NodeExecutionEventValidationError) Reason 

func (e NodeExecutionEventValidationError) Reason() string

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 (m *ParentTaskExecutionMetadata) GetId() *core.TaskExecutionIdentifier

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 

func (e ParentTaskExecutionMetadataValidationError) Cause() error

Cause function returns cause value.

func (ParentTaskExecutionMetadataValidationError) Error 

func (e ParentTaskExecutionMetadataValidationError) Error() string

Error satisfies the builtin error interface

func (ParentTaskExecutionMetadataValidationError) ErrorName 

func (e ParentTaskExecutionMetadataValidationError) ErrorName() string

ErrorName returns error name.

func (ParentTaskExecutionMetadataValidationError) Field 

func (e ParentTaskExecutionMetadataValidationError) Field() string

Field function returns field value.

func (ParentTaskExecutionMetadataValidationError) Key 

func (e ParentTaskExecutionMetadataValidationError) Key() bool

Key function returns key value.

func (ParentTaskExecutionMetadataValidationError) Reason 

func (e ParentTaskExecutionMetadataValidationError) Reason() string

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 (m *TaskExecutionEvent) GetPhase() core.TaskExecution_Phase

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 

func (e TaskExecutionEventValidationError) Cause() error

Cause function returns cause value.

func (TaskExecutionEventValidationError) Error 

func (e TaskExecutionEventValidationError) Error() string

Error satisfies the builtin error interface

func (TaskExecutionEventValidationError) ErrorName 

func (e TaskExecutionEventValidationError) ErrorName() string

ErrorName returns error name.

func (TaskExecutionEventValidationError) Field 

func (e TaskExecutionEventValidationError) Field() string

Field function returns field value.

func (TaskExecutionEventValidationError) Key 

func (e TaskExecutionEventValidationError) Key() bool

Key function returns key value.

func (TaskExecutionEventValidationError) Reason 

func (e TaskExecutionEventValidationError) Reason() string

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 (m *WorkflowExecutionEvent) GetError() *core.ExecutionError

func (*WorkflowExecutionEvent) GetExecutionId 

func (m *WorkflowExecutionEvent) GetExecutionId() *core.WorkflowExecutionIdentifier

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 (m *WorkflowExecutionEvent) GetPhase() core.WorkflowExecution_Phase

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 

func (e WorkflowExecutionEventValidationError) Cause() error

Cause function returns cause value.

func (WorkflowExecutionEventValidationError) Error 

func (e WorkflowExecutionEventValidationError) Error() string

Error satisfies the builtin error interface

func (WorkflowExecutionEventValidationError) ErrorName 

func (e WorkflowExecutionEventValidationError) ErrorName() string

ErrorName returns error name.

func (WorkflowExecutionEventValidationError) Field 

func (e WorkflowExecutionEventValidationError) Field() string

Field function returns field value.

func (WorkflowExecutionEventValidationError) Key 

func (e WorkflowExecutionEventValidationError) Key() bool

Key function returns key value.

func (WorkflowExecutionEventValidationError) Reason 

func (e WorkflowExecutionEventValidationError) Reason() string

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 (m *WorkflowNodeMetadata) GetExecutionId() *core.WorkflowExecutionIdentifier

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 

func (e WorkflowNodeMetadataValidationError) Cause() error

Cause function returns cause value.

func (WorkflowNodeMetadataValidationError) Error 

func (e WorkflowNodeMetadataValidationError) Error() string

Error satisfies the builtin error interface

func (WorkflowNodeMetadataValidationError) ErrorName 

func (e WorkflowNodeMetadataValidationError) ErrorName() string

ErrorName returns error name.

func (WorkflowNodeMetadataValidationError) Field 

func (e WorkflowNodeMetadataValidationError) Field() string

Field function returns field value.

func (WorkflowNodeMetadataValidationError) Key 

func (e WorkflowNodeMetadataValidationError) Key() bool

Key function returns key value.

func (WorkflowNodeMetadataValidationError) Reason 

func (e WorkflowNodeMetadataValidationError) Reason() string

Reason function returns reason value.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.