workflow

package
v0.2.0-b7 Latest Latest
Warning

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

 Go to latest Published: Aug 22, 2025 License: Apache-2.0 Imports: 27 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	QueueService_EnqueueAction_FullMethodName  = "/flyteidl.workflow.QueueService/EnqueueAction"
	QueueService_AbortQueuedRun_FullMethodName = "/flyteidl.workflow.QueueService/AbortQueuedRun"
)
View Source 
const (
	RunService_CreateRun_FullMethodName          = "/flyteidl.workflow.RunService/CreateRun"
	RunService_AbortRun_FullMethodName           = "/flyteidl.workflow.RunService/AbortRun"
	RunService_GetRunDetails_FullMethodName      = "/flyteidl.workflow.RunService/GetRunDetails"
	RunService_WatchRunDetails_FullMethodName    = "/flyteidl.workflow.RunService/WatchRunDetails"
	RunService_GetActionDetails_FullMethodName   = "/flyteidl.workflow.RunService/GetActionDetails"
	RunService_WatchActionDetails_FullMethodName = "/flyteidl.workflow.RunService/WatchActionDetails"
	RunService_GetActionData_FullMethodName      = "/flyteidl.workflow.RunService/GetActionData"
	RunService_ListRuns_FullMethodName           = "/flyteidl.workflow.RunService/ListRuns"
	RunService_WatchRuns_FullMethodName          = "/flyteidl.workflow.RunService/WatchRuns"
	RunService_ListActions_FullMethodName        = "/flyteidl.workflow.RunService/ListActions"
	RunService_WatchActions_FullMethodName       = "/flyteidl.workflow.RunService/WatchActions"
	RunService_WatchClusterEvents_FullMethodName = "/flyteidl.workflow.RunService/WatchClusterEvents"
)
View Source 
const (
	StateService_Put_FullMethodName   = "/flyteidl.workflow.StateService/Put"
	StateService_Get_FullMethodName   = "/flyteidl.workflow.StateService/Get"
	StateService_Watch_FullMethodName = "/flyteidl.workflow.StateService/Watch"
)
View Source 
const (
	TaskService_DeployTask_FullMethodName     = "/flyteidl.workflow.TaskService/DeployTask"
	TaskService_GetTaskDetails_FullMethodName = "/flyteidl.workflow.TaskService/GetTaskDetails"
	TaskService_ListTasks_FullMethodName      = "/flyteidl.workflow.TaskService/ListTasks"
)
View Source 
const (
	RunLogsService_TailLogs_FullMethodName = "/flyteidl.workflow.RunLogsService/TailLogs"
)

Variables

View Source 
var (
	Phase_name = map[int32]string{
		0: "PHASE_UNSPECIFIED",
		1: "PHASE_QUEUED",
		2: "PHASE_WAITING_FOR_RESOURCES",
		3: "PHASE_INITIALIZING",
		4: "PHASE_RUNNING",
		5: "PHASE_SUCCEEDED",
		6: "PHASE_FAILED",
		7: "PHASE_ABORTED",
		8: "PHASE_TIMED_OUT",
	}
	Phase_value = map[string]int32{
		"PHASE_UNSPECIFIED":           0,
		"PHASE_QUEUED":                1,
		"PHASE_WAITING_FOR_RESOURCES": 2,
		"PHASE_INITIALIZING":          3,
		"PHASE_RUNNING":               4,
		"PHASE_SUCCEEDED":             5,
		"PHASE_FAILED":                6,
		"PHASE_ABORTED":               7,
		"PHASE_TIMED_OUT":             8,
	}
)

Enum value maps for Phase.

View Source 
var (
	ErrorInfo_Kind_name = map[int32]string{
		0: "KIND_UNSPECIFIED",
		1: "KIND_USER",
		2: "KIND_SYSTEM",
	}
	ErrorInfo_Kind_value = map[string]int32{
		"KIND_UNSPECIFIED": 0,
		"KIND_USER":        1,
		"KIND_SYSTEM":      2,
	}
)

Enum value maps for ErrorInfo_Kind.

View Source 
var File_workflow_common_proto protoreflect.FileDescriptor
View Source 
var File_workflow_environment_proto protoreflect.FileDescriptor
View Source 
var File_workflow_node_execution_service_proto protoreflect.FileDescriptor
View Source 
var File_workflow_queue_service_proto protoreflect.FileDescriptor
View Source 
var File_workflow_run_definition_proto protoreflect.FileDescriptor
View Source 
var File_workflow_run_logs_service_proto protoreflect.FileDescriptor
View Source 
var File_workflow_run_service_proto protoreflect.FileDescriptor
View Source 
var File_workflow_state_service_proto protoreflect.FileDescriptor
View Source 
var File_workflow_task_definition_proto protoreflect.FileDescriptor
View Source 
var File_workflow_task_service_proto protoreflect.FileDescriptor
View Source 
var NodeExecutionService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "flyteidl.workflow.NodeExecutionService",
	HandlerType: (*NodeExecutionServiceServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams:     []grpc.StreamDesc{},
	Metadata:    "workflow/node_execution_service.proto",
}

NodeExecutionService_ServiceDesc is the grpc.ServiceDesc for NodeExecutionService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var QueueService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "flyteidl.workflow.QueueService",
	HandlerType: (*QueueServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "EnqueueAction",
			Handler:    _QueueService_EnqueueAction_Handler,
		},
		{
			MethodName: "AbortQueuedRun",
			Handler:    _QueueService_AbortQueuedRun_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "workflow/queue_service.proto",
}

QueueService_ServiceDesc is the grpc.ServiceDesc for QueueService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var RunLogsService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "flyteidl.workflow.RunLogsService",
	HandlerType: (*RunLogsServiceServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "TailLogs",
			Handler:       _RunLogsService_TailLogs_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "workflow/run_logs_service.proto",
}

RunLogsService_ServiceDesc is the grpc.ServiceDesc for RunLogsService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var RunService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "flyteidl.workflow.RunService",
	HandlerType: (*RunServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CreateRun",
			Handler:    _RunService_CreateRun_Handler,
		},
		{
			MethodName: "AbortRun",
			Handler:    _RunService_AbortRun_Handler,
		},
		{
			MethodName: "GetRunDetails",
			Handler:    _RunService_GetRunDetails_Handler,
		},
		{
			MethodName: "GetActionDetails",
			Handler:    _RunService_GetActionDetails_Handler,
		},
		{
			MethodName: "GetActionData",
			Handler:    _RunService_GetActionData_Handler,
		},
		{
			MethodName: "ListRuns",
			Handler:    _RunService_ListRuns_Handler,
		},
		{
			MethodName: "ListActions",
			Handler:    _RunService_ListActions_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "WatchRunDetails",
			Handler:       _RunService_WatchRunDetails_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "WatchActionDetails",
			Handler:       _RunService_WatchActionDetails_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "WatchRuns",
			Handler:       _RunService_WatchRuns_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "WatchActions",
			Handler:       _RunService_WatchActions_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "WatchClusterEvents",
			Handler:       _RunService_WatchClusterEvents_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "workflow/run_service.proto",
}

RunService_ServiceDesc is the grpc.ServiceDesc for RunService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var StateService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "flyteidl.workflow.StateService",
	HandlerType: (*StateServiceServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Put",
			Handler:       _StateService_Put_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
		{
			StreamName:    "Get",
			Handler:       _StateService_Get_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
		{
			StreamName:    "Watch",
			Handler:       _StateService_Watch_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "workflow/state_service.proto",
}

StateService_ServiceDesc is the grpc.ServiceDesc for StateService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var TaskService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "flyteidl.workflow.TaskService",
	HandlerType: (*TaskServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "DeployTask",
			Handler:    _TaskService_DeployTask_Handler,
		},
		{
			MethodName: "GetTaskDetails",
			Handler:    _TaskService_GetTaskDetails_Handler,
		},
		{
			MethodName: "ListTasks",
			Handler:    _TaskService_ListTasks_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "workflow/task_service.proto",
}

TaskService_ServiceDesc is the grpc.ServiceDesc for TaskService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterNodeExecutionServiceServer 

func RegisterNodeExecutionServiceServer(s grpc.ServiceRegistrar, srv NodeExecutionServiceServer)

func RegisterQueueServiceServer 

func RegisterQueueServiceServer(s grpc.ServiceRegistrar, srv QueueServiceServer)

func RegisterRunLogsServiceServer 

func RegisterRunLogsServiceServer(s grpc.ServiceRegistrar, srv RunLogsServiceServer)

func RegisterRunServiceServer 

func RegisterRunServiceServer(s grpc.ServiceRegistrar, srv RunServiceServer)

func RegisterStateServiceServer 

func RegisterStateServiceServer(s grpc.ServiceRegistrar, srv StateServiceServer)

func RegisterTaskServiceServer 

func RegisterTaskServiceServer(s grpc.ServiceRegistrar, srv TaskServiceServer)

Types

type AbortInfo 

type AbortInfo struct {

	// Reason provided for the abort.
	Reason string `protobuf:"bytes,1,opt,name=reason,proto3" json:"reason,omitempty"`
	// Identity that aborted the run.
	AbortedBy *common.EnrichedIdentity `protobuf:"bytes,2,opt,name=aborted_by,json=abortedBy,proto3" json:"aborted_by,omitempty"`
	// contains filtered or unexported fields
}

AbortInfo captures details of an aborted run.

func (*AbortInfo) Descriptor deprecated 

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

Deprecated: Use AbortInfo.ProtoReflect.Descriptor instead.

func (*AbortInfo) GetAbortedBy 

func (x *AbortInfo) GetAbortedBy() *common.EnrichedIdentity

func (*AbortInfo) GetReason 

func (x *AbortInfo) GetReason() string

func (*AbortInfo) ProtoMessage 

func (*AbortInfo) ProtoMessage()

func (*AbortInfo) ProtoReflect 

func (x *AbortInfo) ProtoReflect() protoreflect.Message

func (*AbortInfo) Reset 

func (x *AbortInfo) Reset()

func (*AbortInfo) String 

func (x *AbortInfo) String() string

func (*AbortInfo) Validate 

func (m *AbortInfo) Validate() error

Validate checks the field values on AbortInfo with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*AbortInfo) ValidateAll 

func (m *AbortInfo) ValidateAll() error

ValidateAll checks the field values on AbortInfo with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in AbortInfoMultiError, or nil if none found.

type AbortInfoMultiError 

type AbortInfoMultiError []error

AbortInfoMultiError is an error wrapping multiple validation errors returned by AbortInfo.ValidateAll() if the designated constraints aren't met.

func (AbortInfoMultiError) AllErrors 

func (m AbortInfoMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (AbortInfoMultiError) Error 

func (m AbortInfoMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type AbortInfoValidationError 

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

AbortInfoValidationError is the validation error returned by AbortInfo.Validate if the designated constraints aren't met.

func (AbortInfoValidationError) Cause 

func (e AbortInfoValidationError) Cause() error

Cause function returns cause value.

func (AbortInfoValidationError) Error 

func (e AbortInfoValidationError) Error() string

Error satisfies the builtin error interface

func (AbortInfoValidationError) ErrorName 

func (e AbortInfoValidationError) ErrorName() string

ErrorName returns error name.

func (AbortInfoValidationError) Field 

func (e AbortInfoValidationError) Field() string

Field function returns field value.

func (AbortInfoValidationError) Key 

func (e AbortInfoValidationError) Key() bool

Key function returns key value.

func (AbortInfoValidationError) Reason 

func (e AbortInfoValidationError) Reason() string

Reason function returns reason value.

type AbortQueuedRunRequest 

type AbortQueuedRunRequest struct {

	// the unique identifier for the run to be aborted.
	RunId *common.RunIdentifier `protobuf:"bytes,1,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	// contains filtered or unexported fields
}

request message for aborting a run.

func (*AbortQueuedRunRequest) Descriptor deprecated 

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

Deprecated: Use AbortQueuedRunRequest.ProtoReflect.Descriptor instead.

func (*AbortQueuedRunRequest) GetRunId 

func (x *AbortQueuedRunRequest) GetRunId() *common.RunIdentifier

func (*AbortQueuedRunRequest) ProtoMessage 

func (*AbortQueuedRunRequest) ProtoMessage()

func (*AbortQueuedRunRequest) ProtoReflect 

func (x *AbortQueuedRunRequest) ProtoReflect() protoreflect.Message

func (*AbortQueuedRunRequest) Reset 

func (x *AbortQueuedRunRequest) Reset()

func (*AbortQueuedRunRequest) String 

func (x *AbortQueuedRunRequest) String() string

func (*AbortQueuedRunRequest) Validate 

func (m *AbortQueuedRunRequest) Validate() error

Validate checks the field values on AbortQueuedRunRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*AbortQueuedRunRequest) ValidateAll 

func (m *AbortQueuedRunRequest) ValidateAll() error

ValidateAll checks the field values on AbortQueuedRunRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in AbortQueuedRunRequestMultiError, or nil if none found.

type AbortQueuedRunRequestMultiError 

type AbortQueuedRunRequestMultiError []error

AbortQueuedRunRequestMultiError is an error wrapping multiple validation errors returned by AbortQueuedRunRequest.ValidateAll() if the designated constraints aren't met.

func (AbortQueuedRunRequestMultiError) AllErrors 

func (m AbortQueuedRunRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (AbortQueuedRunRequestMultiError) Error 

func (m AbortQueuedRunRequestMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type AbortQueuedRunRequestValidationError 

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

AbortQueuedRunRequestValidationError is the validation error returned by AbortQueuedRunRequest.Validate if the designated constraints aren't met.

func (AbortQueuedRunRequestValidationError) Cause 

func (e AbortQueuedRunRequestValidationError) Cause() error

Cause function returns cause value.

func (AbortQueuedRunRequestValidationError) Error 

func (e AbortQueuedRunRequestValidationError) Error() string

Error satisfies the builtin error interface

func (AbortQueuedRunRequestValidationError) ErrorName 

func (e AbortQueuedRunRequestValidationError) ErrorName() string

ErrorName returns error name.

func (AbortQueuedRunRequestValidationError) Field 

func (e AbortQueuedRunRequestValidationError) Field() string

Field function returns field value.

func (AbortQueuedRunRequestValidationError) Key 

func (e AbortQueuedRunRequestValidationError) Key() bool

Key function returns key value.

func (AbortQueuedRunRequestValidationError) Reason 

func (e AbortQueuedRunRequestValidationError) Reason() string

Reason function returns reason value.

type AbortQueuedRunResponse 

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

response message for aborting a run.

func (*AbortQueuedRunResponse) Descriptor deprecated 

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

Deprecated: Use AbortQueuedRunResponse.ProtoReflect.Descriptor instead.

func (*AbortQueuedRunResponse) ProtoMessage 

func (*AbortQueuedRunResponse) ProtoMessage()

func (*AbortQueuedRunResponse) ProtoReflect 

func (x *AbortQueuedRunResponse) ProtoReflect() protoreflect.Message

func (*AbortQueuedRunResponse) Reset 

func (x *AbortQueuedRunResponse) Reset()

func (*AbortQueuedRunResponse) String 

func (x *AbortQueuedRunResponse) String() string

func (*AbortQueuedRunResponse) Validate 

func (m *AbortQueuedRunResponse) Validate() error

Validate checks the field values on AbortQueuedRunResponse with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*AbortQueuedRunResponse) ValidateAll 

func (m *AbortQueuedRunResponse) ValidateAll() error

ValidateAll checks the field values on AbortQueuedRunResponse with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in AbortQueuedRunResponseMultiError, or nil if none found.

type AbortQueuedRunResponseMultiError 

type AbortQueuedRunResponseMultiError []error

AbortQueuedRunResponseMultiError is an error wrapping multiple validation errors returned by AbortQueuedRunResponse.ValidateAll() if the designated constraints aren't met.

func (AbortQueuedRunResponseMultiError) AllErrors 

func (m AbortQueuedRunResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (AbortQueuedRunResponseMultiError) Error 

func (m AbortQueuedRunResponseMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type AbortQueuedRunResponseValidationError 

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

AbortQueuedRunResponseValidationError is the validation error returned by AbortQueuedRunResponse.Validate if the designated constraints aren't met.

func (AbortQueuedRunResponseValidationError) Cause 

func (e AbortQueuedRunResponseValidationError) Cause() error

Cause function returns cause value.

func (AbortQueuedRunResponseValidationError) Error 

func (e AbortQueuedRunResponseValidationError) Error() string

Error satisfies the builtin error interface

func (AbortQueuedRunResponseValidationError) ErrorName 

func (e AbortQueuedRunResponseValidationError) ErrorName() string

ErrorName returns error name.

func (AbortQueuedRunResponseValidationError) Field 

func (e AbortQueuedRunResponseValidationError) Field() string

Field function returns field value.

func (AbortQueuedRunResponseValidationError) Key 

func (e AbortQueuedRunResponseValidationError) Key() bool

Key function returns key value.

func (AbortQueuedRunResponseValidationError) Reason 

func (e AbortQueuedRunResponseValidationError) Reason() string

Reason function returns reason value.

type AbortRunRequest 

type AbortRunRequest struct {

	// Run to abort.
	RunId *common.RunIdentifier `protobuf:"bytes,1,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	// contains filtered or unexported fields
}

Request message for aborting a run.

func (*AbortRunRequest) Descriptor deprecated 

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

Deprecated: Use AbortRunRequest.ProtoReflect.Descriptor instead.

func (*AbortRunRequest) GetRunId 

func (x *AbortRunRequest) GetRunId() *common.RunIdentifier

func (*AbortRunRequest) ProtoMessage 

func (*AbortRunRequest) ProtoMessage()

func (*AbortRunRequest) ProtoReflect 

func (x *AbortRunRequest) ProtoReflect() protoreflect.Message

func (*AbortRunRequest) Reset 

func (x *AbortRunRequest) Reset()

func (*AbortRunRequest) String 

func (x *AbortRunRequest) String() string

func (*AbortRunRequest) Validate 

func (m *AbortRunRequest) Validate() error

Validate checks the field values on AbortRunRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*AbortRunRequest) ValidateAll 

func (m *AbortRunRequest) ValidateAll() error

ValidateAll checks the field values on AbortRunRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in AbortRunRequestMultiError, or nil if none found.

type AbortRunRequestMultiError 

type AbortRunRequestMultiError []error

AbortRunRequestMultiError is an error wrapping multiple validation errors returned by AbortRunRequest.ValidateAll() if the designated constraints aren't met.

func (AbortRunRequestMultiError) AllErrors 

func (m AbortRunRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (AbortRunRequestMultiError) Error 

func (m AbortRunRequestMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type AbortRunRequestValidationError 

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

AbortRunRequestValidationError is the validation error returned by AbortRunRequest.Validate if the designated constraints aren't met.

func (AbortRunRequestValidationError) Cause 

func (e AbortRunRequestValidationError) Cause() error

Cause function returns cause value.

func (AbortRunRequestValidationError) Error 

func (e AbortRunRequestValidationError) Error() string

Error satisfies the builtin error interface

func (AbortRunRequestValidationError) ErrorName 

func (e AbortRunRequestValidationError) ErrorName() string

ErrorName returns error name.

func (AbortRunRequestValidationError) Field 

func (e AbortRunRequestValidationError) Field() string

Field function returns field value.

func (AbortRunRequestValidationError) Key 

func (e AbortRunRequestValidationError) Key() bool

Key function returns key value.

func (AbortRunRequestValidationError) Reason 

func (e AbortRunRequestValidationError) Reason() string

Reason function returns reason value.

type AbortRunResponse 

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

Response message for aborting a run.

func (*AbortRunResponse) Descriptor deprecated 

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

Deprecated: Use AbortRunResponse.ProtoReflect.Descriptor instead.

func (*AbortRunResponse) ProtoMessage 

func (*AbortRunResponse) ProtoMessage()

func (*AbortRunResponse) ProtoReflect 

func (x *AbortRunResponse) ProtoReflect() protoreflect.Message

func (*AbortRunResponse) Reset 

func (x *AbortRunResponse) Reset()

func (*AbortRunResponse) String 

func (x *AbortRunResponse) String() string

func (*AbortRunResponse) Validate 

func (m *AbortRunResponse) Validate() error

Validate checks the field values on AbortRunResponse with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*AbortRunResponse) ValidateAll 

func (m *AbortRunResponse) ValidateAll() error

ValidateAll checks the field values on AbortRunResponse with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in AbortRunResponseMultiError, or nil if none found.

type AbortRunResponseMultiError 

type AbortRunResponseMultiError []error

AbortRunResponseMultiError is an error wrapping multiple validation errors returned by AbortRunResponse.ValidateAll() if the designated constraints aren't met.

func (AbortRunResponseMultiError) AllErrors 

func (m AbortRunResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (AbortRunResponseMultiError) Error 

func (m AbortRunResponseMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type AbortRunResponseValidationError 

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

AbortRunResponseValidationError is the validation error returned by AbortRunResponse.Validate if the designated constraints aren't met.

func (AbortRunResponseValidationError) Cause 

func (e AbortRunResponseValidationError) Cause() error

Cause function returns cause value.

func (AbortRunResponseValidationError) Error 

func (e AbortRunResponseValidationError) Error() string

Error satisfies the builtin error interface

func (AbortRunResponseValidationError) ErrorName 

func (e AbortRunResponseValidationError) ErrorName() string

ErrorName returns error name.

func (AbortRunResponseValidationError) Field 

func (e AbortRunResponseValidationError) Field() string

Field function returns field value.

func (AbortRunResponseValidationError) Key 

func (e AbortRunResponseValidationError) Key() bool

Key function returns key value.

func (AbortRunResponseValidationError) Reason 

func (e AbortRunResponseValidationError) Reason() string

Reason function returns reason value.

type Action 

type Action struct {

	// Id for this action.
	Id *common.ActionIdentifier `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Metadata for this action.
	Metadata *ActionMetadata `protobuf:"bytes,2,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// Last known status.
	Status *ActionStatus `protobuf:"bytes,3,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

Lightweight representation of an action.

func (*Action) Descriptor deprecated 

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

Deprecated: Use Action.ProtoReflect.Descriptor instead.

func (*Action) GetId 

func (x *Action) GetId() *common.ActionIdentifier

func (*Action) GetMetadata 

func (x *Action) GetMetadata() *ActionMetadata

func (*Action) GetStatus 

func (x *Action) GetStatus() *ActionStatus

func (*Action) ProtoMessage 

func (*Action) ProtoMessage()

func (*Action) ProtoReflect 

func (x *Action) ProtoReflect() protoreflect.Message

func (*Action) Reset 

func (x *Action) Reset()

func (*Action) String 

func (x *Action) String() string

func (*Action) Validate 

func (m *Action) Validate() error

Validate checks the field values on Action with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*Action) ValidateAll 

func (m *Action) ValidateAll() error

ValidateAll checks the field values on Action with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in ActionMultiError, or nil if none found.

type ActionAttempt 

type ActionAttempt struct {

	// Last known phase.
	Phase Phase `protobuf:"varint,1,opt,name=phase,proto3,enum=flyteidl.workflow.Phase" json:"phase,omitempty"`
	// Time the attempt started.
	StartTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	// Time the attempt ended, if applicable.
	EndTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=end_time,json=endTime,proto3,oneof" json:"end_time,omitempty"`
	// Error info for the attempt, if failed.
	ErrorInfo *ErrorInfo `protobuf:"bytes,4,opt,name=error_info,json=errorInfo,proto3,oneof" json:"error_info,omitempty"`
	// The attempt number, starting with 1.
	Attempt uint32 `protobuf:"varint,5,opt,name=attempt,proto3" json:"attempt,omitempty"`
	// Log references.
	LogInfo []*core.TaskLog `protobuf:"bytes,6,rep,name=log_info,json=logInfo,proto3" json:"log_info,omitempty"`
	// Output references.
	Outputs *OutputReferences `protobuf:"bytes,7,opt,name=outputs,proto3" json:"outputs,omitempty"`
	// Indicates whether logs are available for tailing. It doesn't necessarily indicate the logs are present, but that
	// we have the info we need to look them up.
	LogsAvailable bool `protobuf:"varint,8,opt,name=logs_available,json=logsAvailable,proto3" json:"logs_available,omitempty"`
	// cache status of the action attempt
	CacheStatus core.CatalogCacheStatus `` /* 133-byte string literal not displayed */
	// Cluster events like k8s events in a human-readable form.
	ClusterEvents []*ClusterEvent `protobuf:"bytes,10,rep,name=cluster_events,json=clusterEvents,proto3" json:"cluster_events,omitempty"`
	// History of phase transitions.
	PhaseTransitions []*PhaseTransition `protobuf:"bytes,11,rep,name=phase_transitions,json=phaseTransitions,proto3" json:"phase_transitions,omitempty"`
	// The cluster this attempt is assigned to.
	Cluster string `protobuf:"bytes,12,opt,name=cluster,proto3" json:"cluster,omitempty"`
	// Contains corresponding k8s pods and containers information for this action attempt.
	LogContext *core.LogContext `protobuf:"bytes,13,opt,name=log_context,json=logContext,proto3" json:"log_context,omitempty"`
	// contains filtered or unexported fields
}

ActionAttempt is a single attempt of an action.

func (*ActionAttempt) Descriptor deprecated 

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

Deprecated: Use ActionAttempt.ProtoReflect.Descriptor instead.

func (*ActionAttempt) GetAttempt 

func (x *ActionAttempt) GetAttempt() uint32

func (*ActionAttempt) GetCacheStatus 

func (x *ActionAttempt) GetCacheStatus() core.CatalogCacheStatus

func (*ActionAttempt) GetCluster 

func (x *ActionAttempt) GetCluster() string

func (*ActionAttempt) GetClusterEvents 

func (x *ActionAttempt) GetClusterEvents() []*ClusterEvent

func (*ActionAttempt) GetEndTime 

func (x *ActionAttempt) GetEndTime() *timestamppb.Timestamp

func (*ActionAttempt) GetErrorInfo 

func (x *ActionAttempt) GetErrorInfo() *ErrorInfo

func (*ActionAttempt) GetLogContext 

func (x *ActionAttempt) GetLogContext() *core.LogContext

func (*ActionAttempt) GetLogInfo 

func (x *ActionAttempt) GetLogInfo() []*core.TaskLog

func (*ActionAttempt) GetLogsAvailable 

func (x *ActionAttempt) GetLogsAvailable() bool

func (*ActionAttempt) GetOutputs 

func (x *ActionAttempt) GetOutputs() *OutputReferences

func (*ActionAttempt) GetPhase 

func (x *ActionAttempt) GetPhase() Phase

func (*ActionAttempt) GetPhaseTransitions 

func (x *ActionAttempt) GetPhaseTransitions() []*PhaseTransition

func (*ActionAttempt) GetStartTime 

func (x *ActionAttempt) GetStartTime() *timestamppb.Timestamp

func (*ActionAttempt) ProtoMessage 

func (*ActionAttempt) ProtoMessage()

func (*ActionAttempt) ProtoReflect 

func (x *ActionAttempt) ProtoReflect() protoreflect.Message

func (*ActionAttempt) Reset 

func (x *ActionAttempt) Reset()

func (*ActionAttempt) String 

func (x *ActionAttempt) String() string

func (*ActionAttempt) Validate 

func (m *ActionAttempt) Validate() error

Validate checks the field values on ActionAttempt with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*ActionAttempt) ValidateAll 

func (m *ActionAttempt) ValidateAll() error

ValidateAll checks the field values on ActionAttempt with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in ActionAttemptMultiError, or nil if none found.

type ActionAttemptMultiError 

type ActionAttemptMultiError []error

ActionAttemptMultiError is an error wrapping multiple validation errors returned by ActionAttempt.ValidateAll() if the designated constraints aren't met.

func (ActionAttemptMultiError) AllErrors 

func (m ActionAttemptMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ActionAttemptMultiError) Error 

func (m ActionAttemptMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type ActionAttemptValidationError 

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

ActionAttemptValidationError is the validation error returned by ActionAttempt.Validate if the designated constraints aren't met.

func (ActionAttemptValidationError) Cause 

func (e ActionAttemptValidationError) Cause() error

Cause function returns cause value.

func (ActionAttemptValidationError) Error 

func (e ActionAttemptValidationError) Error() string

Error satisfies the builtin error interface

func (ActionAttemptValidationError) ErrorName 

func (e ActionAttemptValidationError) ErrorName() string

ErrorName returns error name.

func (ActionAttemptValidationError) Field 

func (e ActionAttemptValidationError) Field() string

Field function returns field value.

func (ActionAttemptValidationError) Key 

func (e ActionAttemptValidationError) Key() bool

Key function returns key value.

func (ActionAttemptValidationError) Reason 

func (e ActionAttemptValidationError) Reason() string

Reason function returns reason value.

type ActionDetails 

type ActionDetails struct {

	// Id for this action.
	Id *common.ActionIdentifier `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Metadata for this action.
	Metadata *ActionMetadata `protobuf:"bytes,2,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// Last known status.
	Status *ActionStatus `protobuf:"bytes,3,opt,name=status,proto3" json:"status,omitempty"`
	// Types that are assignable to Result:
	//
	//	*ActionDetails_ErrorInfo
	//	*ActionDetails_AbortInfo
	Result isActionDetails_Result `protobuf_oneof:"result"`
	// Fully resolved spec. Merges user submitted task spec with platform defaults.
	ResolvedTaskSpec *TaskSpec `protobuf:"bytes,6,opt,name=resolved_task_spec,json=resolvedTaskSpec,proto3" json:"resolved_task_spec,omitempty"`
	// List of action attempts.
	Attempts []*ActionAttempt `protobuf:"bytes,7,rep,name=attempts,proto3" json:"attempts,omitempty"`
	// contains filtered or unexported fields
}

ActionDetails is the full details of an action.

func (*ActionDetails) Descriptor deprecated 

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

Deprecated: Use ActionDetails.ProtoReflect.Descriptor instead.

func (*ActionDetails) GetAbortInfo 

func (x *ActionDetails) GetAbortInfo() *AbortInfo

func (*ActionDetails) GetAttempts 

func (x *ActionDetails) GetAttempts() []*ActionAttempt

func (*ActionDetails) GetErrorInfo 

func (x *ActionDetails) GetErrorInfo() *ErrorInfo

func (*ActionDetails) GetId 

func (x *ActionDetails) GetId() *common.ActionIdentifier

func (*ActionDetails) GetMetadata 

func (x *ActionDetails) GetMetadata() *ActionMetadata

func (*ActionDetails) GetResolvedTaskSpec 

func (x *ActionDetails) GetResolvedTaskSpec() *TaskSpec

func (*ActionDetails) GetResult 

func (m *ActionDetails) GetResult() isActionDetails_Result

func (*ActionDetails) GetStatus 

func (x *ActionDetails) GetStatus() *ActionStatus

func (*ActionDetails) ProtoMessage 

func (*ActionDetails) ProtoMessage()

func (*ActionDetails) ProtoReflect 

func (x *ActionDetails) ProtoReflect() protoreflect.Message

func (*ActionDetails) Reset 

func (x *ActionDetails) Reset()

func (*ActionDetails) String 

func (x *ActionDetails) String() string

func (*ActionDetails) Validate 

func (m *ActionDetails) Validate() error

Validate checks the field values on ActionDetails with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*ActionDetails) ValidateAll 

func (m *ActionDetails) ValidateAll() error

ValidateAll checks the field values on ActionDetails with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in ActionDetailsMultiError, or nil if none found.

type ActionDetailsMultiError 

type ActionDetailsMultiError []error

ActionDetailsMultiError is an error wrapping multiple validation errors returned by ActionDetails.ValidateAll() if the designated constraints aren't met.

func (ActionDetailsMultiError) AllErrors 

func (m ActionDetailsMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ActionDetailsMultiError) Error 

func (m ActionDetailsMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type ActionDetailsValidationError 

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

ActionDetailsValidationError is the validation error returned by ActionDetails.Validate if the designated constraints aren't met.

func (ActionDetailsValidationError) Cause 

func (e ActionDetailsValidationError) Cause() error

Cause function returns cause value.

func (ActionDetailsValidationError) Error 

func (e ActionDetailsValidationError) Error() string

Error satisfies the builtin error interface

func (ActionDetailsValidationError) ErrorName 

func (e ActionDetailsValidationError) ErrorName() string

ErrorName returns error name.

func (ActionDetailsValidationError) Field 

func (e ActionDetailsValidationError) Field() string

Field function returns field value.

func (ActionDetailsValidationError) Key 

func (e ActionDetailsValidationError) Key() bool

Key function returns key value.

func (ActionDetailsValidationError) Reason 

func (e ActionDetailsValidationError) Reason() string

Reason function returns reason value.

type ActionDetails_AbortInfo 

type ActionDetails_AbortInfo struct {
	// Abort info for the action, if aborted.
	AbortInfo *AbortInfo `protobuf:"bytes,5,opt,name=abort_info,json=abortInfo,proto3,oneof"`
}

type ActionDetails_ErrorInfo 

type ActionDetails_ErrorInfo struct {
	// Error info for the action, if failed.
	ErrorInfo *ErrorInfo `protobuf:"bytes,4,opt,name=error_info,json=errorInfo,proto3,oneof"`
}

type ActionEvent 

type ActionEvent struct {

	// The action id.
	Id *common.ActionIdentifier `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// The attempt number.
	Attempt uint32 `protobuf:"varint,2,opt,name=attempt,proto3" json:"attempt,omitempty"`
	// The phase for this attempt.
	Phase Phase `protobuf:"varint,3,opt,name=phase,proto3,enum=flyteidl.workflow.Phase" json:"phase,omitempty"`
	// The version of this attempt and phase.
	Version uint32 `protobuf:"varint,4,opt,name=version,proto3" json:"version,omitempty"`
	// Time the attempt started.
	//
	// Deprecated: Marked as deprecated in workflow/run_definition.proto.
	StartTime *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	// Timestamp when the event occurred, as recorded by the underlying platform (e.g. Kubernetes).
	UpdatedTime *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=updated_time,json=updatedTime,proto3" json:"updated_time,omitempty"`
	// Time the attempt ended, if applicable.
	//
	// Deprecated: Marked as deprecated in workflow/run_definition.proto.
	EndTime *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=end_time,json=endTime,proto3,oneof" json:"end_time,omitempty"`
	// Error info for the attempt, if failed.
	ErrorInfo *ErrorInfo `protobuf:"bytes,8,opt,name=error_info,json=errorInfo,proto3,oneof" json:"error_info,omitempty"`
	// Log references.
	LogInfo []*core.TaskLog `protobuf:"bytes,9,rep,name=log_info,json=logInfo,proto3" json:"log_info,omitempty"`
	// Metadata to associate containers with logs.
	LogContext *core.LogContext `protobuf:"bytes,10,opt,name=log_context,json=logContext,proto3" json:"log_context,omitempty"`
	// The cluster this attempt is running on.
	Cluster string `protobuf:"bytes,11,opt,name=cluster,proto3" json:"cluster,omitempty"`
	// Output references.
	Outputs *OutputReferences `protobuf:"bytes,12,opt,name=outputs,proto3" json:"outputs,omitempty"`
	// cache status of the action attempt
	CacheStatus core.CatalogCacheStatus `` /* 134-byte string literal not displayed */
	// Cluster events like k8s events in a human-readable form.
	ClusterEvents []*ClusterEvent `protobuf:"bytes,14,rep,name=cluster_events,json=clusterEvents,proto3" json:"cluster_events,omitempty"`
	// Timestamp when the event was observed and reported by the executor
	ReportedTime *timestamppb.Timestamp `protobuf:"bytes,15,opt,name=reported_time,json=reportedTime,proto3" json:"reported_time,omitempty"`
	// contains filtered or unexported fields
}

Event payload for an action

func (*ActionEvent) Descriptor deprecated 

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

Deprecated: Use ActionEvent.ProtoReflect.Descriptor instead.

func (*ActionEvent) GetAttempt 

func (x *ActionEvent) GetAttempt() uint32

func (*ActionEvent) GetCacheStatus 

func (x *ActionEvent) GetCacheStatus() core.CatalogCacheStatus

func (*ActionEvent) GetCluster 

func (x *ActionEvent) GetCluster() string

func (*ActionEvent) GetClusterEvents 

func (x *ActionEvent) GetClusterEvents() []*ClusterEvent

func (*ActionEvent) GetEndTime deprecated 

func (x *ActionEvent) GetEndTime() *timestamppb.Timestamp

Deprecated: Marked as deprecated in workflow/run_definition.proto.

func (*ActionEvent) GetErrorInfo 

func (x *ActionEvent) GetErrorInfo() *ErrorInfo

func (*ActionEvent) GetId 

func (x *ActionEvent) GetId() *common.ActionIdentifier

func (*ActionEvent) GetLogContext 

func (x *ActionEvent) GetLogContext() *core.LogContext

func (*ActionEvent) GetLogInfo 

func (x *ActionEvent) GetLogInfo() []*core.TaskLog

func (*ActionEvent) GetOutputs 

func (x *ActionEvent) GetOutputs() *OutputReferences

func (*ActionEvent) GetPhase 

func (x *ActionEvent) GetPhase() Phase

func (*ActionEvent) GetReportedTime 

func (x *ActionEvent) GetReportedTime() *timestamppb.Timestamp

func (*ActionEvent) GetStartTime deprecated 

func (x *ActionEvent) GetStartTime() *timestamppb.Timestamp

Deprecated: Marked as deprecated in workflow/run_definition.proto.

func (*ActionEvent) GetUpdatedTime 

func (x *ActionEvent) GetUpdatedTime() *timestamppb.Timestamp

func (*ActionEvent) GetVersion 

func (x *ActionEvent) GetVersion() uint32

func (*ActionEvent) ProtoMessage 

func (*ActionEvent) ProtoMessage()

func (*ActionEvent) ProtoReflect 

func (x *ActionEvent) ProtoReflect() protoreflect.Message

func (*ActionEvent) Reset 

func (x *ActionEvent) Reset()

func (*ActionEvent) String 

func (x *ActionEvent) String() string

func (*ActionEvent) Validate 

func (m *ActionEvent) Validate() error

Validate checks the field values on ActionEvent with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*ActionEvent) ValidateAll 

func (m *ActionEvent) ValidateAll() error

ValidateAll checks the field values on ActionEvent with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in ActionEventMultiError, or nil if none found.

type ActionEventMultiError 

type ActionEventMultiError []error

ActionEventMultiError is an error wrapping multiple validation errors returned by ActionEvent.ValidateAll() if the designated constraints aren't met.

func (ActionEventMultiError) AllErrors 

func (m ActionEventMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ActionEventMultiError) Error 

func (m ActionEventMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type ActionEventValidationError 

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

ActionEventValidationError is the validation error returned by ActionEvent.Validate if the designated constraints aren't met.

func (ActionEventValidationError) Cause 

func (e ActionEventValidationError) Cause() error

Cause function returns cause value.

func (ActionEventValidationError) Error 

func (e ActionEventValidationError) Error() string

Error satisfies the builtin error interface

func (ActionEventValidationError) ErrorName 

func (e ActionEventValidationError) ErrorName() string

ErrorName returns error name.

func (ActionEventValidationError) Field 

func (e ActionEventValidationError) Field() string

Field function returns field value.

func (ActionEventValidationError) Key 

func (e ActionEventValidationError) Key() bool

Key function returns key value.

func (ActionEventValidationError) Reason 

func (e ActionEventValidationError) Reason() string

Reason function returns reason value.

type ActionMetadata 

type ActionMetadata struct {

	// Parent action if not the root.
	Parent string `protobuf:"bytes,3,opt,name=parent,proto3" json:"parent,omitempty"`
	// Group this action belongs to, if applicable.
	Group string `protobuf:"bytes,5,opt,name=group,proto3" json:"group,omitempty"`
	// Identity that executed this run.
	ExecutedBy *common.EnrichedIdentity `protobuf:"bytes,6,opt,name=executed_by,json=executedBy,proto3" json:"executed_by,omitempty"`
	// Types that are assignable to Spec:
	//
	//	*ActionMetadata_Task
	//	*ActionMetadata_Trace
	//	*ActionMetadata_Condition
	Spec isActionMetadata_Spec `protobuf_oneof:"spec"`
	// contains filtered or unexported fields
}

Static, lightweight metadata about an action.

func (*ActionMetadata) Descriptor deprecated 

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

Deprecated: Use ActionMetadata.ProtoReflect.Descriptor instead.

func (*ActionMetadata) GetCondition 

func (x *ActionMetadata) GetCondition() *ConditionActionMetadata

func (*ActionMetadata) GetExecutedBy 

func (x *ActionMetadata) GetExecutedBy() *common.EnrichedIdentity

func (*ActionMetadata) GetGroup 

func (x *ActionMetadata) GetGroup() string

func (*ActionMetadata) GetParent 

func (x *ActionMetadata) GetParent() string

func (*ActionMetadata) GetSpec 

func (m *ActionMetadata) GetSpec() isActionMetadata_Spec

func (*ActionMetadata) GetTask 

func (x *ActionMetadata) GetTask() *TaskActionMetadata

func (*ActionMetadata) GetTrace 

func (x *ActionMetadata) GetTrace() *TraceActionMetadata

func (*ActionMetadata) ProtoMessage 

func (*ActionMetadata) ProtoMessage()

func (*ActionMetadata) ProtoReflect 

func (x *ActionMetadata) ProtoReflect() protoreflect.Message

func (*ActionMetadata) Reset 

func (x *ActionMetadata) Reset()

func (*ActionMetadata) String 

func (x *ActionMetadata) String() string

func (*ActionMetadata) Validate 

func (m *ActionMetadata) Validate() error

Validate checks the field values on ActionMetadata with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*ActionMetadata) ValidateAll 

func (m *ActionMetadata) ValidateAll() error

ValidateAll checks the field values on ActionMetadata with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in ActionMetadataMultiError, or nil if none found.

type ActionMetadataMultiError 

type ActionMetadataMultiError []error

ActionMetadataMultiError is an error wrapping multiple validation errors returned by ActionMetadata.ValidateAll() if the designated constraints aren't met.

func (ActionMetadataMultiError) AllErrors 

func (m ActionMetadataMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ActionMetadataMultiError) Error 

func (m ActionMetadataMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type ActionMetadataValidationError 

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

ActionMetadataValidationError is the validation error returned by ActionMetadata.Validate if the designated constraints aren't met.

func (ActionMetadataValidationError) Cause 

func (e ActionMetadataValidationError) Cause() error

Cause function returns cause value.

func (ActionMetadataValidationError) Error 

func (e ActionMetadataValidationError) Error() string

Error satisfies the builtin error interface

func (ActionMetadataValidationError) ErrorName 

func (e ActionMetadataValidationError) ErrorName() string

ErrorName returns error name.

func (ActionMetadataValidationError) Field 

func (e ActionMetadataValidationError) Field() string

Field function returns field value.

func (ActionMetadataValidationError) Key 

func (e ActionMetadataValidationError) Key() bool

Key function returns key value.

func (ActionMetadataValidationError) Reason 

func (e ActionMetadataValidationError) Reason() string

Reason function returns reason value.

type ActionMetadata_Condition 

type ActionMetadata_Condition struct {
	// Condition action.
	Condition *ConditionActionMetadata `protobuf:"bytes,9,opt,name=condition,proto3,oneof"`
}

type ActionMetadata_Task 

type ActionMetadata_Task struct {
	// Task action.
	Task *TaskActionMetadata `protobuf:"bytes,7,opt,name=task,proto3,oneof"`
}

type ActionMetadata_Trace 

type ActionMetadata_Trace struct {
	// Trace action.
	Trace *TraceActionMetadata `protobuf:"bytes,8,opt,name=trace,proto3,oneof"`
}

type ActionMultiError 

type ActionMultiError []error

ActionMultiError is an error wrapping multiple validation errors returned by Action.ValidateAll() if the designated constraints aren't met.

func (ActionMultiError) AllErrors 

func (m ActionMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ActionMultiError) Error 

func (m ActionMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type ActionStatus 

type ActionStatus struct {

	// Last known phase.
	Phase Phase `protobuf:"varint,1,opt,name=phase,proto3,enum=flyteidl.workflow.Phase" json:"phase,omitempty"`
	// Time the action started.
	StartTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	// Time the action ended, if applicable.
	EndTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=end_time,json=endTime,proto3,oneof" json:"end_time,omitempty"`
	// Number of action attempts.
	Attempts uint32 `protobuf:"varint,4,opt,name=attempts,proto3" json:"attempts,omitempty"`
	// cache status of the action's latest attempt
	CacheStatus core.CatalogCacheStatus `` /* 133-byte string literal not displayed */
	// contains filtered or unexported fields
}

Lightweight status of an action. For more detailed status see ActionDetails.

func (*ActionStatus) Descriptor deprecated 

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

Deprecated: Use ActionStatus.ProtoReflect.Descriptor instead.

func (*ActionStatus) GetAttempts 

func (x *ActionStatus) GetAttempts() uint32

func (*ActionStatus) GetCacheStatus 

func (x *ActionStatus) GetCacheStatus() core.CatalogCacheStatus

func (*ActionStatus) GetEndTime 

func (x *ActionStatus) GetEndTime() *timestamppb.Timestamp

func (*ActionStatus) GetPhase 

func (x *ActionStatus) GetPhase() Phase

func (*ActionStatus) GetStartTime 

func (x *ActionStatus) GetStartTime() *timestamppb.Timestamp

func (*ActionStatus) ProtoMessage 

func (*ActionStatus) ProtoMessage()

func (*ActionStatus) ProtoReflect 

func (x *ActionStatus) ProtoReflect() protoreflect.Message

func (*ActionStatus) Reset 

func (x *ActionStatus) Reset()

func (*ActionStatus) String 

func (x *ActionStatus) String() string

func (*ActionStatus) Validate 

func (m *ActionStatus) Validate() error

Validate checks the field values on ActionStatus with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*ActionStatus) ValidateAll 

func (m *ActionStatus) ValidateAll() error

ValidateAll checks the field values on ActionStatus with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in ActionStatusMultiError, or nil if none found.

type ActionStatusMultiError 

type ActionStatusMultiError []error

ActionStatusMultiError is an error wrapping multiple validation errors returned by ActionStatus.ValidateAll() if the designated constraints aren't met.

func (ActionStatusMultiError) AllErrors 

func (m ActionStatusMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ActionStatusMultiError) Error 

func (m ActionStatusMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type ActionStatusValidationError 

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

ActionStatusValidationError is the validation error returned by ActionStatus.Validate if the designated constraints aren't met.

func (ActionStatusValidationError) Cause 

func (e ActionStatusValidationError) Cause() error

Cause function returns cause value.

func (ActionStatusValidationError) Error 

func (e ActionStatusValidationError) Error() string

Error satisfies the builtin error interface

func (ActionStatusValidationError) ErrorName 

func (e ActionStatusValidationError) ErrorName() string

ErrorName returns error name.

func (ActionStatusValidationError) Field 

func (e ActionStatusValidationError) Field() string

Field function returns field value.

func (ActionStatusValidationError) Key 

func (e ActionStatusValidationError) Key() bool

Key function returns key value.

func (ActionStatusValidationError) Reason 

func (e ActionStatusValidationError) Reason() string

Reason function returns reason value.

type ActionUpdate 

type ActionUpdate struct {

	// A unique identifier for the action. `nil` is used as a sentinel value; for example,
	ActionId *common.ActionIdentifier `protobuf:"bytes,1,opt,name=action_id,json=actionId,proto3" json:"action_id,omitempty"`
	// the current phase of the action.
	Phase Phase `protobuf:"varint,2,opt,name=phase,proto3,enum=flyteidl.workflow.Phase" json:"phase,omitempty"`
	// the error associated with the action (if exists).
	Error *core.ExecutionError `protobuf:"bytes,3,opt,name=error,proto3,oneof" json:"error,omitempty"`
	// the output uri for the action
	OutputUri string `protobuf:"bytes,4,opt,name=output_uri,json=outputUri,proto3" json:"output_uri,omitempty"`
	// contains filtered or unexported fields
}

message to represent an update to the state of an action.

func (*ActionUpdate) Descriptor deprecated 

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

Deprecated: Use ActionUpdate.ProtoReflect.Descriptor instead.

func (*ActionUpdate) GetActionId 

func (x *ActionUpdate) GetActionId() *common.ActionIdentifier

func (*ActionUpdate) GetError 

func (x *ActionUpdate) GetError() *core.ExecutionError

func (*ActionUpdate) GetOutputUri 

func (x *ActionUpdate) GetOutputUri() string

func (*ActionUpdate) GetPhase 

func (x *ActionUpdate) GetPhase() Phase

func (*ActionUpdate) ProtoMessage 

func (*ActionUpdate) ProtoMessage()

func (*ActionUpdate) ProtoReflect 

func (x *ActionUpdate) ProtoReflect() protoreflect.Message

func (*ActionUpdate) Reset 

func (x *ActionUpdate) Reset()

func (*ActionUpdate) String 

func (x *ActionUpdate) String() string

func (*ActionUpdate) Validate 

func (m *ActionUpdate) Validate() error

Validate checks the field values on ActionUpdate with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*ActionUpdate) ValidateAll 

func (m *ActionUpdate) ValidateAll() error

ValidateAll checks the field values on ActionUpdate with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in ActionUpdateMultiError, or nil if none found.

type ActionUpdateMultiError 

type ActionUpdateMultiError []error

ActionUpdateMultiError is an error wrapping multiple validation errors returned by ActionUpdate.ValidateAll() if the designated constraints aren't met.

func (ActionUpdateMultiError) AllErrors 

func (m ActionUpdateMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ActionUpdateMultiError) Error 

func (m ActionUpdateMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type ActionUpdateValidationError 

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

ActionUpdateValidationError is the validation error returned by ActionUpdate.Validate if the designated constraints aren't met.

func (ActionUpdateValidationError) Cause 

func (e ActionUpdateValidationError) Cause() error

Cause function returns cause value.

func (ActionUpdateValidationError) Error 

func (e ActionUpdateValidationError) Error() string

Error satisfies the builtin error interface

func (ActionUpdateValidationError) ErrorName 

func (e ActionUpdateValidationError) ErrorName() string

ErrorName returns error name.

func (ActionUpdateValidationError) Field 

func (e ActionUpdateValidationError) Field() string

Field function returns field value.

func (ActionUpdateValidationError) Key 

func (e ActionUpdateValidationError) Key() bool

Key function returns key value.

func (ActionUpdateValidationError) Reason 

func (e ActionUpdateValidationError) Reason() string

Reason function returns reason value.

type ActionValidationError 

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

ActionValidationError is the validation error returned by Action.Validate if the designated constraints aren't met.

func (ActionValidationError) Cause 

func (e ActionValidationError) Cause() error

Cause function returns cause value.

func (ActionValidationError) Error 

func (e ActionValidationError) Error() string

Error satisfies the builtin error interface

func (ActionValidationError) ErrorName 

func (e ActionValidationError) ErrorName() string

ErrorName returns error name.

func (ActionValidationError) Field 

func (e ActionValidationError) Field() string

Field function returns field value.

func (ActionValidationError) Key 

func (e ActionValidationError) Key() bool

Key function returns key value.

func (ActionValidationError) Reason 

func (e ActionValidationError) Reason() string

Reason function returns reason value.

type Annotations 

type Annotations struct {

	// Map of custom annotations to be applied to the execution resource.
	Values map[string]string `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

Annotation values to be applied to an execution resource. In the future a mode (e.g. OVERRIDE, APPEND, etc) can be defined to specify how to merge annotations defined at registration and execution time.

func (*Annotations) Descriptor deprecated 

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

Deprecated: Use Annotations.ProtoReflect.Descriptor instead.

func (*Annotations) GetValues 

func (x *Annotations) GetValues() map[string]string

func (*Annotations) ProtoMessage 

func (*Annotations) ProtoMessage()

func (*Annotations) ProtoReflect 

func (x *Annotations) ProtoReflect() protoreflect.Message

func (*Annotations) Reset 

func (x *Annotations) Reset()

func (*Annotations) String 

func (x *Annotations) String() string

func (*Annotations) Validate 

func (m *Annotations) Validate() error

Validate checks the field values on Annotations with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*Annotations) ValidateAll 

func (m *Annotations) ValidateAll() error

ValidateAll checks the field values on Annotations with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in AnnotationsMultiError, or nil if none found.

type AnnotationsMultiError 

type AnnotationsMultiError []error

AnnotationsMultiError is an error wrapping multiple validation errors returned by Annotations.ValidateAll() if the designated constraints aren't met.

func (AnnotationsMultiError) AllErrors 

func (m AnnotationsMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (AnnotationsMultiError) Error 

func (m AnnotationsMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type AnnotationsValidationError 

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

AnnotationsValidationError is the validation error returned by Annotations.Validate if the designated constraints aren't met.

func (AnnotationsValidationError) Cause 

func (e AnnotationsValidationError) Cause() error

Cause function returns cause value.

func (AnnotationsValidationError) Error 

func (e AnnotationsValidationError) Error() string

Error satisfies the builtin error interface

func (AnnotationsValidationError) ErrorName 

func (e AnnotationsValidationError) ErrorName() string

ErrorName returns error name.

func (AnnotationsValidationError) Field 

func (e AnnotationsValidationError) Field() string

Field function returns field value.

func (AnnotationsValidationError) Key 

func (e AnnotationsValidationError) Key() bool

Key function returns key value.

func (AnnotationsValidationError) Reason 

func (e AnnotationsValidationError) Reason() string

Reason function returns reason value.

type ClusterEvent 

type ClusterEvent struct {

	// occurred_at is the timestamp indicating the instant that this reason happened.
	OccurredAt *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=occurred_at,json=occurredAt,proto3" json:"occurred_at,omitempty"`
	// message is the explanation for the most recent phase transition or status update.
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*ClusterEvent) Descriptor deprecated 

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

Deprecated: Use ClusterEvent.ProtoReflect.Descriptor instead.

func (*ClusterEvent) GetMessage 

func (x *ClusterEvent) GetMessage() string

func (*ClusterEvent) GetOccurredAt 

func (x *ClusterEvent) GetOccurredAt() *timestamppb.Timestamp

func (*ClusterEvent) ProtoMessage 

func (*ClusterEvent) ProtoMessage()

func (*ClusterEvent) ProtoReflect 

func (x *ClusterEvent) ProtoReflect() protoreflect.Message

func (*ClusterEvent) Reset 

func (x *ClusterEvent) Reset()

func (*ClusterEvent) String 

func (x *ClusterEvent) String() string

func (*ClusterEvent) Validate 

func (m *ClusterEvent) Validate() error

Validate checks the field values on ClusterEvent with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*ClusterEvent) ValidateAll 

func (m *ClusterEvent) ValidateAll() error

ValidateAll checks the field values on ClusterEvent with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in ClusterEventMultiError, or nil if none found.

type ClusterEventMultiError 

type ClusterEventMultiError []error

ClusterEventMultiError is an error wrapping multiple validation errors returned by ClusterEvent.ValidateAll() if the designated constraints aren't met.

func (ClusterEventMultiError) AllErrors 

func (m ClusterEventMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ClusterEventMultiError) Error 

func (m ClusterEventMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type ClusterEventValidationError 

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

ClusterEventValidationError is the validation error returned by ClusterEvent.Validate if the designated constraints aren't met.

func (ClusterEventValidationError) Cause 

func (e ClusterEventValidationError) Cause() error

Cause function returns cause value.

func (ClusterEventValidationError) Error 

func (e ClusterEventValidationError) Error() string

Error satisfies the builtin error interface

func (ClusterEventValidationError) ErrorName 

func (e ClusterEventValidationError) ErrorName() string

ErrorName returns error name.

func (ClusterEventValidationError) Field 

func (e ClusterEventValidationError) Field() string

Field function returns field value.

func (ClusterEventValidationError) Key 

func (e ClusterEventValidationError) Key() bool

Key function returns key value.

func (ClusterEventValidationError) Reason 

func (e ClusterEventValidationError) Reason() string

Reason function returns reason value.

type ConditionAction 

type ConditionAction struct {

	// Name is the unique identifier for the action. It must be unique within the defined scope below.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Types that are assignable to Scope:
	//
	//	*ConditionAction_RunId
	//	*ConditionAction_ActionId
	//	*ConditionAction_Global
	Scope isConditionAction_Scope `protobuf_oneof:"scope"`
	// Type is the type of the value the condition is expected. This can be used to properly render
	// a UI element for the condition or validate when a value is received that it is of the expected
	// type.
	Type *core.LiteralType `protobuf:"bytes,6,opt,name=type,proto3" json:"type,omitempty"`
	// Prompt is the prompt that will be shown to the user when the condition is awaited.
	Prompt string `protobuf:"bytes,7,opt,name=prompt,proto3" json:"prompt,omitempty"`
	// Description is a description of the condition. This can be used to provide additional
	// information to the user about the condition.
	Description string `protobuf:"bytes,8,opt,name=description,proto3" json:"description,omitempty"`
	// contains filtered or unexported fields
}

ConditionAction is used to define a condition that can be evaluated at runtime. It can be used to await a signal from an external system and can carry a value.

func (*ConditionAction) Descriptor deprecated 

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

Deprecated: Use ConditionAction.ProtoReflect.Descriptor instead.

func (*ConditionAction) GetActionId 

func (x *ConditionAction) GetActionId() string

func (*ConditionAction) GetDescription 

func (x *ConditionAction) GetDescription() string

func (*ConditionAction) GetGlobal 

func (x *ConditionAction) GetGlobal() bool

func (*ConditionAction) GetName 

func (x *ConditionAction) GetName() string

func (*ConditionAction) GetPrompt 

func (x *ConditionAction) GetPrompt() string

func (*ConditionAction) GetRunId 

func (x *ConditionAction) GetRunId() string

func (*ConditionAction) GetScope 

func (m *ConditionAction) GetScope() isConditionAction_Scope

func (*ConditionAction) GetType 

func (x *ConditionAction) GetType() *core.LiteralType

func (*ConditionAction) ProtoMessage 

func (*ConditionAction) ProtoMessage()

func (*ConditionAction) ProtoReflect 

func (x *ConditionAction) ProtoReflect() protoreflect.Message

func (*ConditionAction) Reset 

func (x *ConditionAction) Reset()

func (*ConditionAction) String 

func (x *ConditionAction) String() string

func (*ConditionAction) Validate 

func (m *ConditionAction) Validate() error

Validate checks the field values on ConditionAction with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*ConditionAction) ValidateAll 

func (m *ConditionAction) ValidateAll() error

ValidateAll checks the field values on ConditionAction with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in ConditionActionMultiError, or nil if none found.

type ConditionActionMetadata 

type ConditionActionMetadata struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Types that are assignable to Scope:
	//
	//	*ConditionActionMetadata_RunId
	//	*ConditionActionMetadata_ActionId
	//	*ConditionActionMetadata_Global
	Scope isConditionActionMetadata_Scope `protobuf_oneof:"scope"`
	// contains filtered or unexported fields
}

func (*ConditionActionMetadata) Descriptor deprecated 

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

Deprecated: Use ConditionActionMetadata.ProtoReflect.Descriptor instead.

func (*ConditionActionMetadata) GetActionId 

func (x *ConditionActionMetadata) GetActionId() string

func (*ConditionActionMetadata) GetGlobal 

func (x *ConditionActionMetadata) GetGlobal() bool

func (*ConditionActionMetadata) GetName 

func (x *ConditionActionMetadata) GetName() string

func (*ConditionActionMetadata) GetRunId 

func (x *ConditionActionMetadata) GetRunId() string

func (*ConditionActionMetadata) GetScope 

func (m *ConditionActionMetadata) GetScope() isConditionActionMetadata_Scope

func (*ConditionActionMetadata) ProtoMessage 

func (*ConditionActionMetadata) ProtoMessage()

func (*ConditionActionMetadata) ProtoReflect 

func (x *ConditionActionMetadata) ProtoReflect() protoreflect.Message

func (*ConditionActionMetadata) Reset 

func (x *ConditionActionMetadata) Reset()

func (*ConditionActionMetadata) String 

func (x *ConditionActionMetadata) String() string

func (*ConditionActionMetadata) Validate 

func (m *ConditionActionMetadata) Validate() error

Validate checks the field values on ConditionActionMetadata with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*ConditionActionMetadata) ValidateAll 

func (m *ConditionActionMetadata) ValidateAll() error

ValidateAll checks the field values on ConditionActionMetadata with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in ConditionActionMetadataMultiError, or nil if none found.

type ConditionActionMetadataMultiError 

type ConditionActionMetadataMultiError []error

ConditionActionMetadataMultiError is an error wrapping multiple validation errors returned by ConditionActionMetadata.ValidateAll() if the designated constraints aren't met.

func (ConditionActionMetadataMultiError) AllErrors 

func (m ConditionActionMetadataMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ConditionActionMetadataMultiError) Error 

func (m ConditionActionMetadataMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type ConditionActionMetadataValidationError 

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

ConditionActionMetadataValidationError is the validation error returned by ConditionActionMetadata.Validate if the designated constraints aren't met.

func (ConditionActionMetadataValidationError) Cause 

func (e ConditionActionMetadataValidationError) Cause() error

Cause function returns cause value.

func (ConditionActionMetadataValidationError) Error 

func (e ConditionActionMetadataValidationError) Error() string

Error satisfies the builtin error interface

func (ConditionActionMetadataValidationError) ErrorName 

func (e ConditionActionMetadataValidationError) ErrorName() string

ErrorName returns error name.

func (ConditionActionMetadataValidationError) Field 

func (e ConditionActionMetadataValidationError) Field() string

Field function returns field value.

func (ConditionActionMetadataValidationError) Key 

func (e ConditionActionMetadataValidationError) Key() bool

Key function returns key value.

func (ConditionActionMetadataValidationError) Reason 

func (e ConditionActionMetadataValidationError) Reason() string

Reason function returns reason value.

type ConditionActionMetadata_ActionId 

type ConditionActionMetadata_ActionId struct {
	// ActionId is the unique identifier for the action this action is associated with.
	ActionId string `protobuf:"bytes,3,opt,name=action_id,json=actionId,proto3,oneof"`
}

type ConditionActionMetadata_Global 

type ConditionActionMetadata_Global struct {
	// Global indicates the condition is global and can be used across all runs and actions.
	Global bool `protobuf:"varint,4,opt,name=global,proto3,oneof"`
}

type ConditionActionMetadata_RunId 

type ConditionActionMetadata_RunId struct {
	// RunId is the unique identifier for the run this action is associated with.
	RunId string `protobuf:"bytes,2,opt,name=run_id,json=runId,proto3,oneof"`
}

type ConditionActionMultiError 

type ConditionActionMultiError []error

ConditionActionMultiError is an error wrapping multiple validation errors returned by ConditionAction.ValidateAll() if the designated constraints aren't met.

func (ConditionActionMultiError) AllErrors 

func (m ConditionActionMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ConditionActionMultiError) Error 

func (m ConditionActionMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type ConditionActionValidationError 

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

ConditionActionValidationError is the validation error returned by ConditionAction.Validate if the designated constraints aren't met.

func (ConditionActionValidationError) Cause 

func (e ConditionActionValidationError) Cause() error

Cause function returns cause value.

func (ConditionActionValidationError) Error 

func (e ConditionActionValidationError) Error() string

Error satisfies the builtin error interface

func (ConditionActionValidationError) ErrorName 

func (e ConditionActionValidationError) ErrorName() string

ErrorName returns error name.

func (ConditionActionValidationError) Field 

func (e ConditionActionValidationError) Field() string

Field function returns field value.

func (ConditionActionValidationError) Key 

func (e ConditionActionValidationError) Key() bool

Key function returns key value.

func (ConditionActionValidationError) Reason 

func (e ConditionActionValidationError) Reason() string

Reason function returns reason value.

type ConditionAction_ActionId 

type ConditionAction_ActionId struct {
	// ActionId is the unique identifier for the action this action is associated with.
	ActionId string `protobuf:"bytes,3,opt,name=action_id,json=actionId,proto3,oneof"`
}

type ConditionAction_Global 

type ConditionAction_Global struct {
	// Global indicates the condition is global and can be used across all runs and actions.
	Global bool `protobuf:"varint,4,opt,name=global,proto3,oneof"`
}

type ConditionAction_RunId 

type ConditionAction_RunId struct {
	// RunId is the unique identifier for the run this action is associated with.
	RunId string `protobuf:"bytes,2,opt,name=run_id,json=runId,proto3,oneof"`
}

type ControlMessage 

type ControlMessage struct {

	// a sentinel value to indicate the end of a stream. this is used to disambiguate between a control message and a
	// regular message. When a watch begins the service will return the existing state of all actions, then a sentinel value,
	// before continuing on with ongoing updates. this sequence disambiguates the current state from new updates.
	Sentinel bool `protobuf:"varint,1,opt,name=sentinel,proto3" json:"sentinel,omitempty"`
	// contains filtered or unexported fields
}

func (*ControlMessage) Descriptor deprecated 

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

Deprecated: Use ControlMessage.ProtoReflect.Descriptor instead.

func (*ControlMessage) GetSentinel 

func (x *ControlMessage) GetSentinel() bool

func (*ControlMessage) ProtoMessage 

func (*ControlMessage) ProtoMessage()

func (*ControlMessage) ProtoReflect 

func (x *ControlMessage) ProtoReflect() protoreflect.Message

func (*ControlMessage) Reset 

func (x *ControlMessage) Reset()

func (*ControlMessage) String 

func (x *ControlMessage) String() string

func (*ControlMessage) Validate 

func (m *ControlMessage) Validate() error

Validate checks the field values on ControlMessage with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*ControlMessage) ValidateAll 

func (m *ControlMessage) ValidateAll() error

ValidateAll checks the field values on ControlMessage with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in ControlMessageMultiError, or nil if none found.

type ControlMessageMultiError 

type ControlMessageMultiError []error

ControlMessageMultiError is an error wrapping multiple validation errors returned by ControlMessage.ValidateAll() if the designated constraints aren't met.

func (ControlMessageMultiError) AllErrors 

func (m ControlMessageMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ControlMessageMultiError) Error 

func (m ControlMessageMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type ControlMessageValidationError 

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

ControlMessageValidationError is the validation error returned by ControlMessage.Validate if the designated constraints aren't met.

func (ControlMessageValidationError) Cause 

func (e ControlMessageValidationError) Cause() error

Cause function returns cause value.

func (ControlMessageValidationError) Error 

func (e ControlMessageValidationError) Error() string

Error satisfies the builtin error interface

func (ControlMessageValidationError) ErrorName 

func (e ControlMessageValidationError) ErrorName() string

ErrorName returns error name.

func (ControlMessageValidationError) Field 

func (e ControlMessageValidationError) Field() string

Field function returns field value.

func (ControlMessageValidationError) Key 

func (e ControlMessageValidationError) Key() bool

Key function returns key value.

func (ControlMessageValidationError) Reason 

func (e ControlMessageValidationError) Reason() string

Reason function returns reason value.

type CreateRunRequest 

type CreateRunRequest struct {

	// Types that are assignable to Id:
	//
	//	*CreateRunRequest_RunId
	//	*CreateRunRequest_ProjectId
	Id isCreateRunRequest_Id `protobuf_oneof:"id"`
	// The task to run.
	//
	// Types that are assignable to Task:
	//
	//	*CreateRunRequest_TaskId
	//	*CreateRunRequest_TaskSpec
	Task isCreateRunRequest_Task `protobuf_oneof:"task"`
	// Inputs to use.
	Inputs *Inputs `protobuf:"bytes,4,opt,name=inputs,proto3" json:"inputs,omitempty"`
	// The run spec to use.
	RunSpec *RunSpec `protobuf:"bytes,5,opt,name=run_spec,json=runSpec,proto3" json:"run_spec,omitempty"`
	// contains filtered or unexported fields
}

Request message for creating a run.

func (*CreateRunRequest) Descriptor deprecated 

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

Deprecated: Use CreateRunRequest.ProtoReflect.Descriptor instead.

func (*CreateRunRequest) GetId 

func (m *CreateRunRequest) GetId() isCreateRunRequest_Id

func (*CreateRunRequest) GetInputs 

func (x *CreateRunRequest) GetInputs() *Inputs

func (*CreateRunRequest) GetProjectId 

func (x *CreateRunRequest) GetProjectId() *common.ProjectIdentifier

func (*CreateRunRequest) GetRunId 

func (x *CreateRunRequest) GetRunId() *common.RunIdentifier

func (*CreateRunRequest) GetRunSpec 

func (x *CreateRunRequest) GetRunSpec() *RunSpec

func (*CreateRunRequest) GetTask 

func (m *CreateRunRequest) GetTask() isCreateRunRequest_Task

func (*CreateRunRequest) GetTaskId 

func (x *CreateRunRequest) GetTaskId() *TaskIdentifier

func (*CreateRunRequest) GetTaskSpec 

func (x *CreateRunRequest) GetTaskSpec() *TaskSpec

func (*CreateRunRequest) ProtoMessage 

func (*CreateRunRequest) ProtoMessage()

func (*CreateRunRequest) ProtoReflect 

func (x *CreateRunRequest) ProtoReflect() protoreflect.Message

func (*CreateRunRequest) Reset 

func (x *CreateRunRequest) Reset()

func (*CreateRunRequest) String 

func (x *CreateRunRequest) String() string

func (*CreateRunRequest) Validate 

func (m *CreateRunRequest) Validate() error

Validate checks the field values on CreateRunRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*CreateRunRequest) ValidateAll 

func (m *CreateRunRequest) ValidateAll() error

ValidateAll checks the field values on CreateRunRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in CreateRunRequestMultiError, or nil if none found.

type CreateRunRequestMultiError 

type CreateRunRequestMultiError []error

CreateRunRequestMultiError is an error wrapping multiple validation errors returned by CreateRunRequest.ValidateAll() if the designated constraints aren't met.

func (CreateRunRequestMultiError) AllErrors 

func (m CreateRunRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (CreateRunRequestMultiError) Error 

func (m CreateRunRequestMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type CreateRunRequestValidationError 

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

CreateRunRequestValidationError is the validation error returned by CreateRunRequest.Validate if the designated constraints aren't met.

func (CreateRunRequestValidationError) Cause 

func (e CreateRunRequestValidationError) Cause() error

Cause function returns cause value.

func (CreateRunRequestValidationError) Error 

func (e CreateRunRequestValidationError) Error() string

Error satisfies the builtin error interface

func (CreateRunRequestValidationError) ErrorName 

func (e CreateRunRequestValidationError) ErrorName() string

ErrorName returns error name.

func (CreateRunRequestValidationError) Field 

func (e CreateRunRequestValidationError) Field() string

Field function returns field value.

func (CreateRunRequestValidationError) Key 

func (e CreateRunRequestValidationError) Key() bool

Key function returns key value.

func (CreateRunRequestValidationError) Reason 

func (e CreateRunRequestValidationError) Reason() string

Reason function returns reason value.

type CreateRunRequest_ProjectId 

type CreateRunRequest_ProjectId struct {
	// The project id for this run. Run name will be generated.
	ProjectId *common.ProjectIdentifier `protobuf:"bytes,6,opt,name=project_id,json=projectId,proto3,oneof"`
}

type CreateRunRequest_RunId 

type CreateRunRequest_RunId struct {
	// The user provided run id.
	RunId *common.RunIdentifier `protobuf:"bytes,1,opt,name=run_id,json=runId,proto3,oneof"`
}

type CreateRunRequest_TaskId 

type CreateRunRequest_TaskId struct {
	// The task id to use.
	TaskId *TaskIdentifier `protobuf:"bytes,2,opt,name=task_id,json=taskId,proto3,oneof"`
}

type CreateRunRequest_TaskSpec 

type CreateRunRequest_TaskSpec struct {
	// The task spec to use.
	TaskSpec *TaskSpec `protobuf:"bytes,3,opt,name=task_spec,json=taskSpec,proto3,oneof"`
}

type CreateRunResponse 

type CreateRunResponse struct {
	Run *Run `protobuf:"bytes,1,opt,name=run,proto3" json:"run,omitempty"`
	// contains filtered or unexported fields
}

Response message for creating a run.

func (*CreateRunResponse) Descriptor deprecated 

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

Deprecated: Use CreateRunResponse.ProtoReflect.Descriptor instead.

func (*CreateRunResponse) GetRun 

func (x *CreateRunResponse) GetRun() *Run

func (*CreateRunResponse) ProtoMessage 

func (*CreateRunResponse) ProtoMessage()

func (*CreateRunResponse) ProtoReflect 

func (x *CreateRunResponse) ProtoReflect() protoreflect.Message

func (*CreateRunResponse) Reset 

func (x *CreateRunResponse) Reset()

func (*CreateRunResponse) String 

func (x *CreateRunResponse) String() string

func (*CreateRunResponse) Validate 

func (m *CreateRunResponse) Validate() error

Validate checks the field values on CreateRunResponse with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*CreateRunResponse) ValidateAll 

func (m *CreateRunResponse) ValidateAll() error

ValidateAll checks the field values on CreateRunResponse with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in CreateRunResponseMultiError, or nil if none found.

type CreateRunResponseMultiError 

type CreateRunResponseMultiError []error

CreateRunResponseMultiError is an error wrapping multiple validation errors returned by CreateRunResponse.ValidateAll() if the designated constraints aren't met.

func (CreateRunResponseMultiError) AllErrors 

func (m CreateRunResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (CreateRunResponseMultiError) Error 

func (m CreateRunResponseMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type CreateRunResponseValidationError 

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

CreateRunResponseValidationError is the validation error returned by CreateRunResponse.Validate if the designated constraints aren't met.

func (CreateRunResponseValidationError) Cause 

func (e CreateRunResponseValidationError) Cause() error

Cause function returns cause value.

func (CreateRunResponseValidationError) Error 

func (e CreateRunResponseValidationError) Error() string

Error satisfies the builtin error interface

func (CreateRunResponseValidationError) ErrorName 

func (e CreateRunResponseValidationError) ErrorName() string

ErrorName returns error name.

func (CreateRunResponseValidationError) Field 

func (e CreateRunResponseValidationError) Field() string

Field function returns field value.

func (CreateRunResponseValidationError) Key 

func (e CreateRunResponseValidationError) Key() bool

Key function returns key value.

func (CreateRunResponseValidationError) Reason 

func (e CreateRunResponseValidationError) Reason() string

Reason function returns reason value.

type DeployTaskRequest 

type DeployTaskRequest struct {

	// The user provided task id.
	TaskId *TaskIdentifier `protobuf:"bytes,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	// Specification for the task.
	Spec *TaskSpec `protobuf:"bytes,2,opt,name=spec,proto3" json:"spec,omitempty"`
	// contains filtered or unexported fields
}

Request message for deploying a task.

func (*DeployTaskRequest) Descriptor deprecated 

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

Deprecated: Use DeployTaskRequest.ProtoReflect.Descriptor instead.

func (*DeployTaskRequest) GetSpec 

func (x *DeployTaskRequest) GetSpec() *TaskSpec

func (*DeployTaskRequest) GetTaskId 

func (x *DeployTaskRequest) GetTaskId() *TaskIdentifier

func (*DeployTaskRequest) ProtoMessage 

func (*DeployTaskRequest) ProtoMessage()

func (*DeployTaskRequest) ProtoReflect 

func (x *DeployTaskRequest) ProtoReflect() protoreflect.Message

func (*DeployTaskRequest) Reset 

func (x *DeployTaskRequest) Reset()

func (*DeployTaskRequest) String 

func (x *DeployTaskRequest) String() string

func (*DeployTaskRequest) Validate 

func (m *DeployTaskRequest) Validate() error

Validate checks the field values on DeployTaskRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*DeployTaskRequest) ValidateAll 

func (m *DeployTaskRequest) ValidateAll() error

ValidateAll checks the field values on DeployTaskRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in DeployTaskRequestMultiError, or nil if none found.

type DeployTaskRequestMultiError 

type DeployTaskRequestMultiError []error

DeployTaskRequestMultiError is an error wrapping multiple validation errors returned by DeployTaskRequest.ValidateAll() if the designated constraints aren't met.

func (DeployTaskRequestMultiError) AllErrors 

func (m DeployTaskRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (DeployTaskRequestMultiError) Error 

func (m DeployTaskRequestMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type DeployTaskRequestValidationError 

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

DeployTaskRequestValidationError is the validation error returned by DeployTaskRequest.Validate if the designated constraints aren't met.

func (DeployTaskRequestValidationError) Cause 

func (e DeployTaskRequestValidationError) Cause() error

Cause function returns cause value.

func (DeployTaskRequestValidationError) Error 

func (e DeployTaskRequestValidationError) Error() string

Error satisfies the builtin error interface

func (DeployTaskRequestValidationError) ErrorName 

func (e DeployTaskRequestValidationError) ErrorName() string

ErrorName returns error name.

func (DeployTaskRequestValidationError) Field 

func (e DeployTaskRequestValidationError) Field() string

Field function returns field value.

func (DeployTaskRequestValidationError) Key 

func (e DeployTaskRequestValidationError) Key() bool

Key function returns key value.

func (DeployTaskRequestValidationError) Reason 

func (e DeployTaskRequestValidationError) Reason() string

Reason function returns reason value.

type DeployTaskResponse 

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

Response message for deploying a task.

func (*DeployTaskResponse) Descriptor deprecated 

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

Deprecated: Use DeployTaskResponse.ProtoReflect.Descriptor instead.

func (*DeployTaskResponse) ProtoMessage 

func (*DeployTaskResponse) ProtoMessage()

func (*DeployTaskResponse) ProtoReflect 

func (x *DeployTaskResponse) ProtoReflect() protoreflect.Message

func (*DeployTaskResponse) Reset 

func (x *DeployTaskResponse) Reset()

func (*DeployTaskResponse) String 

func (x *DeployTaskResponse) String() string

func (*DeployTaskResponse) Validate 

func (m *DeployTaskResponse) Validate() error

Validate checks the field values on DeployTaskResponse with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*DeployTaskResponse) ValidateAll 

func (m *DeployTaskResponse) ValidateAll() error

ValidateAll checks the field values on DeployTaskResponse with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in DeployTaskResponseMultiError, or nil if none found.

type DeployTaskResponseMultiError 

type DeployTaskResponseMultiError []error

DeployTaskResponseMultiError is an error wrapping multiple validation errors returned by DeployTaskResponse.ValidateAll() if the designated constraints aren't met.

func (DeployTaskResponseMultiError) AllErrors 

func (m DeployTaskResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (DeployTaskResponseMultiError) Error 

func (m DeployTaskResponseMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type DeployTaskResponseValidationError 

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

DeployTaskResponseValidationError is the validation error returned by DeployTaskResponse.Validate if the designated constraints aren't met.

func (DeployTaskResponseValidationError) Cause 

func (e DeployTaskResponseValidationError) Cause() error

Cause function returns cause value.

func (DeployTaskResponseValidationError) Error 

func (e DeployTaskResponseValidationError) Error() string

Error satisfies the builtin error interface

func (DeployTaskResponseValidationError) ErrorName 

func (e DeployTaskResponseValidationError) ErrorName() string

ErrorName returns error name.

func (DeployTaskResponseValidationError) Field 

func (e DeployTaskResponseValidationError) Field() string

Field function returns field value.

func (DeployTaskResponseValidationError) Key 

func (e DeployTaskResponseValidationError) Key() bool

Key function returns key value.

func (DeployTaskResponseValidationError) Reason 

func (e DeployTaskResponseValidationError) Reason() string

Reason function returns reason value.

type EnqueueActionRequest 

type EnqueueActionRequest struct {

	// the unique identifier for the action.
	ActionId *common.ActionIdentifier `protobuf:"bytes,1,opt,name=action_id,json=actionId,proto3" json:"action_id,omitempty"`
	// an optional name for the parent action, if it exists. the remaining run metadata (ex. org,
	// project, domain) will be the same as the action_id defined above.
	ParentActionName *string `protobuf:"bytes,2,opt,name=parent_action_name,json=parentActionName,proto3,oneof" json:"parent_action_name,omitempty"`
	// Optional run spec passed in by the root action to be utilized by all downstream actions in the run.
	RunSpec *RunSpec `protobuf:"bytes,3,opt,name=run_spec,json=runSpec,proto3" json:"run_spec,omitempty"`
	// the path to the input data for this action.
	InputUri string `protobuf:"bytes,6,opt,name=input_uri,json=inputUri,proto3" json:"input_uri,omitempty"`
	// the run base path this action should write its output to.
	RunOutputBase string `protobuf:"bytes,7,opt,name=run_output_base,json=runOutputBase,proto3" json:"run_output_base,omitempty"`
	// group this action belongs to, if applicable.
	Group string `protobuf:"bytes,8,opt,name=group,proto3" json:"group,omitempty"`
	// subject that created the run, if known.
	Subject string `protobuf:"bytes,9,opt,name=subject,proto3" json:"subject,omitempty"`
	// Types that are assignable to Spec:
	//
	//	*EnqueueActionRequest_Task
	//	*EnqueueActionRequest_Trace
	//	*EnqueueActionRequest_Condition
	Spec isEnqueueActionRequest_Spec `protobuf_oneof:"spec"`
	// contains filtered or unexported fields
}

request message for queuing an action.

func (*EnqueueActionRequest) Descriptor deprecated 

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

Deprecated: Use EnqueueActionRequest.ProtoReflect.Descriptor instead.

func (*EnqueueActionRequest) GetActionId 

func (x *EnqueueActionRequest) GetActionId() *common.ActionIdentifier

func (*EnqueueActionRequest) GetCondition 

func (x *EnqueueActionRequest) GetCondition() *ConditionAction

func (*EnqueueActionRequest) GetGroup 

func (x *EnqueueActionRequest) GetGroup() string

func (*EnqueueActionRequest) GetInputUri 

func (x *EnqueueActionRequest) GetInputUri() string

func (*EnqueueActionRequest) GetParentActionName 

func (x *EnqueueActionRequest) GetParentActionName() string

func (*EnqueueActionRequest) GetRunOutputBase 

func (x *EnqueueActionRequest) GetRunOutputBase() string

func (*EnqueueActionRequest) GetRunSpec 

func (x *EnqueueActionRequest) GetRunSpec() *RunSpec

func (*EnqueueActionRequest) GetSpec 

func (m *EnqueueActionRequest) GetSpec() isEnqueueActionRequest_Spec

func (*EnqueueActionRequest) GetSubject 

func (x *EnqueueActionRequest) GetSubject() string

func (*EnqueueActionRequest) GetTask 

func (x *EnqueueActionRequest) GetTask() *TaskAction

func (*EnqueueActionRequest) GetTrace 

func (x *EnqueueActionRequest) GetTrace() *TraceAction

func (*EnqueueActionRequest) ProtoMessage 

func (*EnqueueActionRequest) ProtoMessage()

func (*EnqueueActionRequest) ProtoReflect 

func (x *EnqueueActionRequest) ProtoReflect() protoreflect.Message

func (*EnqueueActionRequest) Reset 

func (x *EnqueueActionRequest) Reset()

func (*EnqueueActionRequest) String 

func (x *EnqueueActionRequest) String() string

func (*EnqueueActionRequest) Validate 

func (m *EnqueueActionRequest) Validate() error

Validate checks the field values on EnqueueActionRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*EnqueueActionRequest) ValidateAll 

func (m *EnqueueActionRequest) ValidateAll() error

ValidateAll checks the field values on EnqueueActionRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in EnqueueActionRequestMultiError, or nil if none found.

type EnqueueActionRequestMultiError 

type EnqueueActionRequestMultiError []error

EnqueueActionRequestMultiError is an error wrapping multiple validation errors returned by EnqueueActionRequest.ValidateAll() if the designated constraints aren't met.

func (EnqueueActionRequestMultiError) AllErrors 

func (m EnqueueActionRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (EnqueueActionRequestMultiError) Error 

func (m EnqueueActionRequestMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type EnqueueActionRequestValidationError 

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

EnqueueActionRequestValidationError is the validation error returned by EnqueueActionRequest.Validate if the designated constraints aren't met.

func (EnqueueActionRequestValidationError) Cause 

func (e EnqueueActionRequestValidationError) Cause() error

Cause function returns cause value.

func (EnqueueActionRequestValidationError) Error 

func (e EnqueueActionRequestValidationError) Error() string

Error satisfies the builtin error interface

func (EnqueueActionRequestValidationError) ErrorName 

func (e EnqueueActionRequestValidationError) ErrorName() string

ErrorName returns error name.

func (EnqueueActionRequestValidationError) Field 

func (e EnqueueActionRequestValidationError) Field() string

Field function returns field value.

func (EnqueueActionRequestValidationError) Key 

func (e EnqueueActionRequestValidationError) Key() bool

Key function returns key value.

func (EnqueueActionRequestValidationError) Reason 

func (e EnqueueActionRequestValidationError) Reason() string

Reason function returns reason value.

type EnqueueActionRequest_Condition 

type EnqueueActionRequest_Condition struct {
	Condition *ConditionAction `protobuf:"bytes,12,opt,name=condition,proto3,oneof"`
}

type EnqueueActionRequest_Task 

type EnqueueActionRequest_Task struct {
	// TODO(haytham): Uncomment when we update all code paths to use this.
	// option (validate.required) = true;
	Task *TaskAction `protobuf:"bytes,10,opt,name=task,proto3,oneof"`
}

type EnqueueActionRequest_Trace 

type EnqueueActionRequest_Trace struct {
	Trace *TraceAction `protobuf:"bytes,11,opt,name=trace,proto3,oneof"`
}

type EnqueueActionResponse 

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

response message for queuing an action.

func (*EnqueueActionResponse) Descriptor deprecated 

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

Deprecated: Use EnqueueActionResponse.ProtoReflect.Descriptor instead.

func (*EnqueueActionResponse) ProtoMessage 

func (*EnqueueActionResponse) ProtoMessage()

func (*EnqueueActionResponse) ProtoReflect 

func (x *EnqueueActionResponse) ProtoReflect() protoreflect.Message

func (*EnqueueActionResponse) Reset 

func (x *EnqueueActionResponse) Reset()

func (*EnqueueActionResponse) String 

func (x *EnqueueActionResponse) String() string

func (*EnqueueActionResponse) Validate 

func (m *EnqueueActionResponse) Validate() error

Validate checks the field values on EnqueueActionResponse with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*EnqueueActionResponse) ValidateAll 

func (m *EnqueueActionResponse) ValidateAll() error

ValidateAll checks the field values on EnqueueActionResponse with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in EnqueueActionResponseMultiError, or nil if none found.

type EnqueueActionResponseMultiError 

type EnqueueActionResponseMultiError []error

EnqueueActionResponseMultiError is an error wrapping multiple validation errors returned by EnqueueActionResponse.ValidateAll() if the designated constraints aren't met.

func (EnqueueActionResponseMultiError) AllErrors 

func (m EnqueueActionResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (EnqueueActionResponseMultiError) Error 

func (m EnqueueActionResponseMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type EnqueueActionResponseValidationError 

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

EnqueueActionResponseValidationError is the validation error returned by EnqueueActionResponse.Validate if the designated constraints aren't met.

func (EnqueueActionResponseValidationError) Cause 

func (e EnqueueActionResponseValidationError) Cause() error

Cause function returns cause value.

func (EnqueueActionResponseValidationError) Error 

func (e EnqueueActionResponseValidationError) Error() string

Error satisfies the builtin error interface

func (EnqueueActionResponseValidationError) ErrorName 

func (e EnqueueActionResponseValidationError) ErrorName() string

ErrorName returns error name.

func (EnqueueActionResponseValidationError) Field 

func (e EnqueueActionResponseValidationError) Field() string

Field function returns field value.

func (EnqueueActionResponseValidationError) Key 

func (e EnqueueActionResponseValidationError) Key() bool

Key function returns key value.

func (EnqueueActionResponseValidationError) Reason 

func (e EnqueueActionResponseValidationError) Reason() string

Reason function returns reason value.

type EnrichedAction 

type EnrichedAction struct {

	// The action itself.
	Action *Action `protobuf:"bytes,1,opt,name=action,proto3" json:"action,omitempty"`
	// Whether this action meets specified filters of the request or not.
	// If an action that was previously meeting the filter but no longer does, will be sent with this flag set to false
	MeetsFilter bool `protobuf:"varint,2,opt,name=meets_filter,json=meetsFilter,proto3" json:"meets_filter,omitempty"`
	// Child phase info for this action (Map of phase to counts of children in given phase)
	ChildrenPhaseCounts map[int32]int32 `` /* 210-byte string literal not displayed */
	// contains filtered or unexported fields
}

EnrichedAction is a wrapper around Action that contains additional information

func (*EnrichedAction) Descriptor deprecated 

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

Deprecated: Use EnrichedAction.ProtoReflect.Descriptor instead.

func (*EnrichedAction) GetAction 

func (x *EnrichedAction) GetAction() *Action

func (*EnrichedAction) GetChildrenPhaseCounts 

func (x *EnrichedAction) GetChildrenPhaseCounts() map[int32]int32

func (*EnrichedAction) GetMeetsFilter 

func (x *EnrichedAction) GetMeetsFilter() bool

func (*EnrichedAction) ProtoMessage 

func (*EnrichedAction) ProtoMessage()

func (*EnrichedAction) ProtoReflect 

func (x *EnrichedAction) ProtoReflect() protoreflect.Message

func (*EnrichedAction) Reset 

func (x *EnrichedAction) Reset()

func (*EnrichedAction) String 

func (x *EnrichedAction) String() string

func (*EnrichedAction) Validate 

func (m *EnrichedAction) Validate() error

Validate checks the field values on EnrichedAction with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*EnrichedAction) ValidateAll 

func (m *EnrichedAction) ValidateAll() error

ValidateAll checks the field values on EnrichedAction with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in EnrichedActionMultiError, or nil if none found.

type EnrichedActionMultiError 

type EnrichedActionMultiError []error

EnrichedActionMultiError is an error wrapping multiple validation errors returned by EnrichedAction.ValidateAll() if the designated constraints aren't met.

func (EnrichedActionMultiError) AllErrors 

func (m EnrichedActionMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (EnrichedActionMultiError) Error 

func (m EnrichedActionMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type EnrichedActionValidationError 

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

EnrichedActionValidationError is the validation error returned by EnrichedAction.Validate if the designated constraints aren't met.

func (EnrichedActionValidationError) Cause 

func (e EnrichedActionValidationError) Cause() error

Cause function returns cause value.

func (EnrichedActionValidationError) Error 

func (e EnrichedActionValidationError) Error() string

Error satisfies the builtin error interface

func (EnrichedActionValidationError) ErrorName 

func (e EnrichedActionValidationError) ErrorName() string

ErrorName returns error name.

func (EnrichedActionValidationError) Field 

func (e EnrichedActionValidationError) Field() string

Field function returns field value.

func (EnrichedActionValidationError) Key 

func (e EnrichedActionValidationError) Key() bool

Key function returns key value.

func (EnrichedActionValidationError) Reason 

func (e EnrichedActionValidationError) Reason() string

Reason function returns reason value.

type Environment 

type Environment struct {

	// Name of the environment.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

Environment for a task.

func (*Environment) Descriptor deprecated 

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

Deprecated: Use Environment.ProtoReflect.Descriptor instead.

func (*Environment) GetName 

func (x *Environment) GetName() string

func (*Environment) ProtoMessage 

func (*Environment) ProtoMessage()

func (*Environment) ProtoReflect 

func (x *Environment) ProtoReflect() protoreflect.Message

func (*Environment) Reset 

func (x *Environment) Reset()

func (*Environment) String 

func (x *Environment) String() string

func (*Environment) Validate 

func (m *Environment) Validate() error

Validate checks the field values on Environment with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*Environment) ValidateAll 

func (m *Environment) ValidateAll() error

ValidateAll checks the field values on Environment with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in EnvironmentMultiError, or nil if none found.

type EnvironmentMultiError 

type EnvironmentMultiError []error

EnvironmentMultiError is an error wrapping multiple validation errors returned by Environment.ValidateAll() if the designated constraints aren't met.

func (EnvironmentMultiError) AllErrors 

func (m EnvironmentMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (EnvironmentMultiError) Error 

func (m EnvironmentMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type EnvironmentValidationError 

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

EnvironmentValidationError is the validation error returned by Environment.Validate if the designated constraints aren't met.

func (EnvironmentValidationError) Cause 

func (e EnvironmentValidationError) Cause() error

Cause function returns cause value.

func (EnvironmentValidationError) Error 

func (e EnvironmentValidationError) Error() string

Error satisfies the builtin error interface

func (EnvironmentValidationError) ErrorName 

func (e EnvironmentValidationError) ErrorName() string

ErrorName returns error name.

func (EnvironmentValidationError) Field 

func (e EnvironmentValidationError) Field() string

Field function returns field value.

func (EnvironmentValidationError) Key 

func (e EnvironmentValidationError) Key() bool

Key function returns key value.

func (EnvironmentValidationError) Reason 

func (e EnvironmentValidationError) Reason() string

Reason function returns reason value.

type Envs 

type Envs struct {

	// Map of custom environment variables to be applied to the execution resource.
	Values []*core.KeyValuePair `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

Environment variable values to be applied to an execution resource. In the future a mode (e.g. OVERRIDE, APPEND, etc) can be defined to specify how to merge environment variables defined at registration and execution time.

func (*Envs) Descriptor deprecated 

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

Deprecated: Use Envs.ProtoReflect.Descriptor instead.

func (*Envs) GetValues 

func (x *Envs) GetValues() []*core.KeyValuePair

func (*Envs) ProtoMessage 

func (*Envs) ProtoMessage()

func (*Envs) ProtoReflect 

func (x *Envs) ProtoReflect() protoreflect.Message

func (*Envs) Reset 

func (x *Envs) Reset()

func (*Envs) String 

func (x *Envs) String() string

func (*Envs) Validate 

func (m *Envs) Validate() error

Validate checks the field values on Envs with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*Envs) ValidateAll 

func (m *Envs) ValidateAll() error

ValidateAll checks the field values on Envs with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in EnvsMultiError, or nil if none found.

type EnvsMultiError 

type EnvsMultiError []error

EnvsMultiError is an error wrapping multiple validation errors returned by Envs.ValidateAll() if the designated constraints aren't met.

func (EnvsMultiError) AllErrors 

func (m EnvsMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (EnvsMultiError) Error 

func (m EnvsMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type EnvsValidationError 

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

EnvsValidationError is the validation error returned by Envs.Validate if the designated constraints aren't met.

func (EnvsValidationError) Cause 

func (e EnvsValidationError) Cause() error

Cause function returns cause value.

func (EnvsValidationError) Error 

func (e EnvsValidationError) Error() string

Error satisfies the builtin error interface

func (EnvsValidationError) ErrorName 

func (e EnvsValidationError) ErrorName() string

ErrorName returns error name.

func (EnvsValidationError) Field 

func (e EnvsValidationError) Field() string

Field function returns field value.

func (EnvsValidationError) Key 

func (e EnvsValidationError) Key() bool

Key function returns key value.

func (EnvsValidationError) Reason 

func (e EnvsValidationError) Reason() string

Reason function returns reason value.

type ErrorInfo 

type ErrorInfo struct {

	// Error message.
	Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	// Error kind.
	Kind ErrorInfo_Kind `protobuf:"varint,2,opt,name=kind,proto3,enum=flyteidl.workflow.ErrorInfo_Kind" json:"kind,omitempty"`
	// contains filtered or unexported fields
}

ErrorInfo captures details of an error.

func (*ErrorInfo) Descriptor deprecated 

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

Deprecated: Use ErrorInfo.ProtoReflect.Descriptor instead.

func (*ErrorInfo) GetKind 

func (x *ErrorInfo) GetKind() ErrorInfo_Kind

func (*ErrorInfo) GetMessage 

func (x *ErrorInfo) GetMessage() string

func (*ErrorInfo) ProtoMessage 

func (*ErrorInfo) ProtoMessage()

func (*ErrorInfo) ProtoReflect 

func (x *ErrorInfo) ProtoReflect() protoreflect.Message

func (*ErrorInfo) Reset 

func (x *ErrorInfo) Reset()

func (*ErrorInfo) String 

func (x *ErrorInfo) String() string

func (*ErrorInfo) Validate 

func (m *ErrorInfo) Validate() error

Validate checks the field values on ErrorInfo with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*ErrorInfo) ValidateAll 

func (m *ErrorInfo) ValidateAll() error

ValidateAll checks the field values on ErrorInfo with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in ErrorInfoMultiError, or nil if none found.

type ErrorInfoMultiError 

type ErrorInfoMultiError []error

ErrorInfoMultiError is an error wrapping multiple validation errors returned by ErrorInfo.ValidateAll() if the designated constraints aren't met.

func (ErrorInfoMultiError) AllErrors 

func (m ErrorInfoMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ErrorInfoMultiError) Error 

func (m ErrorInfoMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type ErrorInfoValidationError 

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

ErrorInfoValidationError is the validation error returned by ErrorInfo.Validate if the designated constraints aren't met.

func (ErrorInfoValidationError) Cause 

func (e ErrorInfoValidationError) Cause() error

Cause function returns cause value.

func (ErrorInfoValidationError) Error 

func (e ErrorInfoValidationError) Error() string

Error satisfies the builtin error interface

func (ErrorInfoValidationError) ErrorName 

func (e ErrorInfoValidationError) ErrorName() string

ErrorName returns error name.

func (ErrorInfoValidationError) Field 

func (e ErrorInfoValidationError) Field() string

Field function returns field value.

func (ErrorInfoValidationError) Key 

func (e ErrorInfoValidationError) Key() bool

Key function returns key value.

func (ErrorInfoValidationError) Reason 

func (e ErrorInfoValidationError) Reason() string

Reason function returns reason value.

type ErrorInfo_Kind 

type ErrorInfo_Kind int32
const (
	ErrorInfo_KIND_UNSPECIFIED ErrorInfo_Kind = 0
	ErrorInfo_KIND_USER        ErrorInfo_Kind = 1
	ErrorInfo_KIND_SYSTEM      ErrorInfo_Kind = 2
)

func (ErrorInfo_Kind) Descriptor 

func (ErrorInfo_Kind) Descriptor() protoreflect.EnumDescriptor

func (ErrorInfo_Kind) Enum 

func (x ErrorInfo_Kind) Enum() *ErrorInfo_Kind

func (ErrorInfo_Kind) EnumDescriptor deprecated 

func (ErrorInfo_Kind) EnumDescriptor() ([]byte, []int)

Deprecated: Use ErrorInfo_Kind.Descriptor instead.

func (ErrorInfo_Kind) Number 

func (x ErrorInfo_Kind) Number() protoreflect.EnumNumber

func (ErrorInfo_Kind) String 

func (x ErrorInfo_Kind) String() string

func (ErrorInfo_Kind) Type 

func (ErrorInfo_Kind) Type() protoreflect.EnumType

type GetActionDataRequest 

type GetActionDataRequest struct {

	// Action to query.
	ActionId *common.ActionIdentifier `protobuf:"bytes,1,opt,name=action_id,json=actionId,proto3" json:"action_id,omitempty"`
	// contains filtered or unexported fields
}

Request message for querying action data.

func (*GetActionDataRequest) Descriptor deprecated 

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

Deprecated: Use GetActionDataRequest.ProtoReflect.Descriptor instead.

func (*GetActionDataRequest) GetActionId 

func (x *GetActionDataRequest) GetActionId() *common.ActionIdentifier

func (*GetActionDataRequest) ProtoMessage 

func (*GetActionDataRequest) ProtoMessage()

func (*GetActionDataRequest) ProtoReflect 

func (x *GetActionDataRequest) ProtoReflect() protoreflect.Message

func (*GetActionDataRequest) Reset 

func (x *GetActionDataRequest) Reset()

func (*GetActionDataRequest) String 

func (x *GetActionDataRequest) String() string

func (*GetActionDataRequest) Validate 

func (m *GetActionDataRequest) Validate() error

Validate checks the field values on GetActionDataRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*GetActionDataRequest) ValidateAll 

func (m *GetActionDataRequest) ValidateAll() error

ValidateAll checks the field values on GetActionDataRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in GetActionDataRequestMultiError, or nil if none found.

type GetActionDataRequestMultiError 

type GetActionDataRequestMultiError []error

GetActionDataRequestMultiError is an error wrapping multiple validation errors returned by GetActionDataRequest.ValidateAll() if the designated constraints aren't met.

func (GetActionDataRequestMultiError) AllErrors 

func (m GetActionDataRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (GetActionDataRequestMultiError) Error 

func (m GetActionDataRequestMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type GetActionDataRequestValidationError 

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

GetActionDataRequestValidationError is the validation error returned by GetActionDataRequest.Validate if the designated constraints aren't met.

func (GetActionDataRequestValidationError) Cause 

func (e GetActionDataRequestValidationError) Cause() error

Cause function returns cause value.

func (GetActionDataRequestValidationError) Error 

func (e GetActionDataRequestValidationError) Error() string

Error satisfies the builtin error interface

func (GetActionDataRequestValidationError) ErrorName 

func (e GetActionDataRequestValidationError) ErrorName() string

ErrorName returns error name.

func (GetActionDataRequestValidationError) Field 

func (e GetActionDataRequestValidationError) Field() string

Field function returns field value.

func (GetActionDataRequestValidationError) Key 

func (e GetActionDataRequestValidationError) Key() bool

Key function returns key value.

func (GetActionDataRequestValidationError) Reason 

func (e GetActionDataRequestValidationError) Reason() string

Reason function returns reason value.

type GetActionDataResponse 

type GetActionDataResponse struct {

	// Inputs for the action.
	Inputs *Inputs `protobuf:"bytes,1,opt,name=inputs,proto3" json:"inputs,omitempty"`
	// Outputs for the action.
	Outputs *Outputs `protobuf:"bytes,2,opt,name=outputs,proto3" json:"outputs,omitempty"`
	// contains filtered or unexported fields
}

Response message for querying action data.

func (*GetActionDataResponse) Descriptor deprecated 

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

Deprecated: Use GetActionDataResponse.ProtoReflect.Descriptor instead.

func (*GetActionDataResponse) GetInputs 

func (x *GetActionDataResponse) GetInputs() *Inputs

func (*GetActionDataResponse) GetOutputs 

func (x *GetActionDataResponse) GetOutputs() *Outputs

func (*GetActionDataResponse) ProtoMessage 

func (*GetActionDataResponse) ProtoMessage()

func (*GetActionDataResponse) ProtoReflect 

func (x *GetActionDataResponse) ProtoReflect() protoreflect.Message

func (*GetActionDataResponse) Reset 

func (x *GetActionDataResponse) Reset()

func (*GetActionDataResponse) String 

func (x *GetActionDataResponse) String() string

func (*GetActionDataResponse) Validate 

func (m *GetActionDataResponse) Validate() error

Validate checks the field values on GetActionDataResponse with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*GetActionDataResponse) ValidateAll 

func (m *GetActionDataResponse) ValidateAll() error

ValidateAll checks the field values on GetActionDataResponse with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in GetActionDataResponseMultiError, or nil if none found.

type GetActionDataResponseMultiError 

type GetActionDataResponseMultiError []error

GetActionDataResponseMultiError is an error wrapping multiple validation errors returned by GetActionDataResponse.ValidateAll() if the designated constraints aren't met.

func (GetActionDataResponseMultiError) AllErrors 

func (m GetActionDataResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (GetActionDataResponseMultiError) Error 

func (m GetActionDataResponseMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type GetActionDataResponseValidationError 

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

GetActionDataResponseValidationError is the validation error returned by GetActionDataResponse.Validate if the designated constraints aren't met.

func (GetActionDataResponseValidationError) Cause 

func (e GetActionDataResponseValidationError) Cause() error

Cause function returns cause value.

func (GetActionDataResponseValidationError) Error 

func (e GetActionDataResponseValidationError) Error() string

Error satisfies the builtin error interface

func (GetActionDataResponseValidationError) ErrorName 

func (e GetActionDataResponseValidationError) ErrorName() string

ErrorName returns error name.

func (GetActionDataResponseValidationError) Field 

func (e GetActionDataResponseValidationError) Field() string

Field function returns field value.

func (GetActionDataResponseValidationError) Key 

func (e GetActionDataResponseValidationError) Key() bool

Key function returns key value.

func (GetActionDataResponseValidationError) Reason 

func (e GetActionDataResponseValidationError) Reason() string

Reason function returns reason value.

type GetActionDetailsRequest 

type GetActionDetailsRequest struct {

	// Action to query.
	ActionId *common.ActionIdentifier `protobuf:"bytes,1,opt,name=action_id,json=actionId,proto3" json:"action_id,omitempty"`
	// contains filtered or unexported fields
}

Request message for getting detailed information about an action.

func (*GetActionDetailsRequest) Descriptor deprecated 

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

Deprecated: Use GetActionDetailsRequest.ProtoReflect.Descriptor instead.

func (*GetActionDetailsRequest) GetActionId 

func (x *GetActionDetailsRequest) GetActionId() *common.ActionIdentifier

func (*GetActionDetailsRequest) ProtoMessage 

func (*GetActionDetailsRequest) ProtoMessage()

func (*GetActionDetailsRequest) ProtoReflect 

func (x *GetActionDetailsRequest) ProtoReflect() protoreflect.Message

func (*GetActionDetailsRequest) Reset 

func (x *GetActionDetailsRequest) Reset()

func (*GetActionDetailsRequest) String 

func (x *GetActionDetailsRequest) String() string

func (*GetActionDetailsRequest) Validate 

func (m *GetActionDetailsRequest) Validate() error

Validate checks the field values on GetActionDetailsRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*GetActionDetailsRequest) ValidateAll 

func (m *GetActionDetailsRequest) ValidateAll() error

ValidateAll checks the field values on GetActionDetailsRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in GetActionDetailsRequestMultiError, or nil if none found.

type GetActionDetailsRequestMultiError 

type GetActionDetailsRequestMultiError []error

GetActionDetailsRequestMultiError is an error wrapping multiple validation errors returned by GetActionDetailsRequest.ValidateAll() if the designated constraints aren't met.

func (GetActionDetailsRequestMultiError) AllErrors 

func (m GetActionDetailsRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (GetActionDetailsRequestMultiError) Error 

func (m GetActionDetailsRequestMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type GetActionDetailsRequestValidationError 

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

GetActionDetailsRequestValidationError is the validation error returned by GetActionDetailsRequest.Validate if the designated constraints aren't met.

func (GetActionDetailsRequestValidationError) Cause 

func (e GetActionDetailsRequestValidationError) Cause() error

Cause function returns cause value.

func (GetActionDetailsRequestValidationError) Error 

func (e GetActionDetailsRequestValidationError) Error() string

Error satisfies the builtin error interface

func (GetActionDetailsRequestValidationError) ErrorName 

func (e GetActionDetailsRequestValidationError) ErrorName() string

ErrorName returns error name.

func (GetActionDetailsRequestValidationError) Field 

func (e GetActionDetailsRequestValidationError) Field() string

Field function returns field value.

func (GetActionDetailsRequestValidationError) Key 

func (e GetActionDetailsRequestValidationError) Key() bool

Key function returns key value.

func (GetActionDetailsRequestValidationError) Reason 

func (e GetActionDetailsRequestValidationError) Reason() string

Reason function returns reason value.

type GetActionDetailsResponse 

type GetActionDetailsResponse struct {

	// Detailed information about the action.
	Details *ActionDetails `protobuf:"bytes,1,opt,name=details,proto3" json:"details,omitempty"`
	// contains filtered or unexported fields
}

Response message for getting detailed information about an action.

func (*GetActionDetailsResponse) Descriptor deprecated 

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

Deprecated: Use GetActionDetailsResponse.ProtoReflect.Descriptor instead.

func (*GetActionDetailsResponse) GetDetails 

func (x *GetActionDetailsResponse) GetDetails() *ActionDetails

func (*GetActionDetailsResponse) ProtoMessage 

func (*GetActionDetailsResponse) ProtoMessage()

func (*GetActionDetailsResponse) ProtoReflect 

func (x *GetActionDetailsResponse) ProtoReflect() protoreflect.Message

func (*GetActionDetailsResponse) Reset 

func (x *GetActionDetailsResponse) Reset()

func (*GetActionDetailsResponse) String 

func (x *GetActionDetailsResponse) String() string

func (*GetActionDetailsResponse) Validate 

func (m *GetActionDetailsResponse) Validate() error

Validate checks the field values on GetActionDetailsResponse with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*GetActionDetailsResponse) ValidateAll 

func (m *GetActionDetailsResponse) ValidateAll() error

ValidateAll checks the field values on GetActionDetailsResponse with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in GetActionDetailsResponseMultiError, or nil if none found.

type GetActionDetailsResponseMultiError 

type GetActionDetailsResponseMultiError []error

GetActionDetailsResponseMultiError is an error wrapping multiple validation errors returned by GetActionDetailsResponse.ValidateAll() if the designated constraints aren't met.

func (GetActionDetailsResponseMultiError) AllErrors 

func (m GetActionDetailsResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (GetActionDetailsResponseMultiError) Error 

func (m GetActionDetailsResponseMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type GetActionDetailsResponseValidationError 

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

GetActionDetailsResponseValidationError is the validation error returned by GetActionDetailsResponse.Validate if the designated constraints aren't met.

func (GetActionDetailsResponseValidationError) Cause 

func (e GetActionDetailsResponseValidationError) Cause() error

Cause function returns cause value.

func (GetActionDetailsResponseValidationError) Error 

func (e GetActionDetailsResponseValidationError) Error() string

Error satisfies the builtin error interface

func (GetActionDetailsResponseValidationError) ErrorName 

func (e GetActionDetailsResponseValidationError) ErrorName() string

ErrorName returns error name.

func (GetActionDetailsResponseValidationError) Field 

func (e GetActionDetailsResponseValidationError) Field() string

Field function returns field value.

func (GetActionDetailsResponseValidationError) Key 

func (e GetActionDetailsResponseValidationError) Key() bool

Key function returns key value.

func (GetActionDetailsResponseValidationError) Reason 

func (e GetActionDetailsResponseValidationError) Reason() string

Reason function returns reason value.

type GetRequest 

type GetRequest struct {

	// a unique identifier for the action.
	ActionId *common.ActionIdentifier `protobuf:"bytes,1,opt,name=action_id,json=actionId,proto3" json:"action_id,omitempty"`
	// contains filtered or unexported fields
}

request message to get the state of an action.

func (*GetRequest) Descriptor deprecated 

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

Deprecated: Use GetRequest.ProtoReflect.Descriptor instead.

func (*GetRequest) GetActionId 

func (x *GetRequest) GetActionId() *common.ActionIdentifier

func (*GetRequest) ProtoMessage 

func (*GetRequest) ProtoMessage()

func (*GetRequest) ProtoReflect 

func (x *GetRequest) ProtoReflect() protoreflect.Message

func (*GetRequest) Reset 

func (x *GetRequest) Reset()

func (*GetRequest) String 

func (x *GetRequest) String() string

func (*GetRequest) Validate 

func (m *GetRequest) Validate() error

Validate checks the field values on GetRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*GetRequest) ValidateAll 

func (m *GetRequest) ValidateAll() error

ValidateAll checks the field values on GetRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in GetRequestMultiError, or nil if none found.

type GetRequestMultiError 

type GetRequestMultiError []error

GetRequestMultiError is an error wrapping multiple validation errors returned by GetRequest.ValidateAll() if the designated constraints aren't met.

func (GetRequestMultiError) AllErrors 

func (m GetRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (GetRequestMultiError) Error 

func (m GetRequestMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type GetRequestValidationError 

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

GetRequestValidationError is the validation error returned by GetRequest.Validate if the designated constraints aren't met.

func (GetRequestValidationError) Cause 

func (e GetRequestValidationError) Cause() error

Cause function returns cause value.

func (GetRequestValidationError) Error 

func (e GetRequestValidationError) Error() string

Error satisfies the builtin error interface

func (GetRequestValidationError) ErrorName 

func (e GetRequestValidationError) ErrorName() string

ErrorName returns error name.

func (GetRequestValidationError) Field 

func (e GetRequestValidationError) Field() string

Field function returns field value.

func (GetRequestValidationError) Key 

func (e GetRequestValidationError) Key() bool

Key function returns key value.

func (GetRequestValidationError) Reason 

func (e GetRequestValidationError) Reason() string

Reason function returns reason value.

type GetResponse 

type GetResponse struct {

	// a unique identifier for the action.
	ActionId *common.ActionIdentifier `protobuf:"bytes,1,opt,name=action_id,json=actionId,proto3" json:"action_id,omitempty"`
	// The result.
	Status *status.Status `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`
	// a json serialized `NodeStatus` object.
	State string `protobuf:"bytes,3,opt,name=state,proto3" json:"state,omitempty"`
	// contains filtered or unexported fields
}

response message for getting the state of an action.

func (*GetResponse) Descriptor deprecated 

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

Deprecated: Use GetResponse.ProtoReflect.Descriptor instead.

func (*GetResponse) GetActionId 

func (x *GetResponse) GetActionId() *common.ActionIdentifier

func (*GetResponse) GetState 

func (x *GetResponse) GetState() string

func (*GetResponse) GetStatus 

func (x *GetResponse) GetStatus() *status.Status

func (*GetResponse) ProtoMessage 

func (*GetResponse) ProtoMessage()

func (*GetResponse) ProtoReflect 

func (x *GetResponse) ProtoReflect() protoreflect.Message

func (*GetResponse) Reset 

func (x *GetResponse) Reset()

func (*GetResponse) String 

func (x *GetResponse) String() string

func (*GetResponse) Validate 

func (m *GetResponse) Validate() error

Validate checks the field values on GetResponse with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*GetResponse) ValidateAll 

func (m *GetResponse) ValidateAll() error

ValidateAll checks the field values on GetResponse with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in GetResponseMultiError, or nil if none found.

type GetResponseMultiError 

type GetResponseMultiError []error

GetResponseMultiError is an error wrapping multiple validation errors returned by GetResponse.ValidateAll() if the designated constraints aren't met.

func (GetResponseMultiError) AllErrors 

func (m GetResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (GetResponseMultiError) Error 

func (m GetResponseMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type GetResponseValidationError 

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

GetResponseValidationError is the validation error returned by GetResponse.Validate if the designated constraints aren't met.

func (GetResponseValidationError) Cause 

func (e GetResponseValidationError) Cause() error

Cause function returns cause value.

func (GetResponseValidationError) Error 

func (e GetResponseValidationError) Error() string

Error satisfies the builtin error interface

func (GetResponseValidationError) ErrorName 

func (e GetResponseValidationError) ErrorName() string

ErrorName returns error name.

func (GetResponseValidationError) Field 

func (e GetResponseValidationError) Field() string

Field function returns field value.

func (GetResponseValidationError) Key 

func (e GetResponseValidationError) Key() bool

Key function returns key value.

func (GetResponseValidationError) Reason 

func (e GetResponseValidationError) Reason() string

Reason function returns reason value.

type GetRunDetailsRequest 

type GetRunDetailsRequest struct {

	// Run to query.
	RunId *common.RunIdentifier `protobuf:"bytes,1,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	// contains filtered or unexported fields
}

Request message for getting detailed information about a run.

func (*GetRunDetailsRequest) Descriptor deprecated 

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

Deprecated: Use GetRunDetailsRequest.ProtoReflect.Descriptor instead.

func (*GetRunDetailsRequest) GetRunId 

func (x *GetRunDetailsRequest) GetRunId() *common.RunIdentifier

func (*GetRunDetailsRequest) ProtoMessage 

func (*GetRunDetailsRequest) ProtoMessage()

func (*GetRunDetailsRequest) ProtoReflect 

func (x *GetRunDetailsRequest) ProtoReflect() protoreflect.Message

func (*GetRunDetailsRequest) Reset 

func (x *GetRunDetailsRequest) Reset()

func (*GetRunDetailsRequest) String 

func (x *GetRunDetailsRequest) String() string

func (*GetRunDetailsRequest) Validate 

func (m *GetRunDetailsRequest) Validate() error

Validate checks the field values on GetRunDetailsRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*GetRunDetailsRequest) ValidateAll 

func (m *GetRunDetailsRequest) ValidateAll() error

ValidateAll checks the field values on GetRunDetailsRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in GetRunDetailsRequestMultiError, or nil if none found.

type GetRunDetailsRequestMultiError 

type GetRunDetailsRequestMultiError []error

GetRunDetailsRequestMultiError is an error wrapping multiple validation errors returned by GetRunDetailsRequest.ValidateAll() if the designated constraints aren't met.

func (GetRunDetailsRequestMultiError) AllErrors 

func (m GetRunDetailsRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (GetRunDetailsRequestMultiError) Error 

func (m GetRunDetailsRequestMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type GetRunDetailsRequestValidationError 

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

GetRunDetailsRequestValidationError is the validation error returned by GetRunDetailsRequest.Validate if the designated constraints aren't met.

func (GetRunDetailsRequestValidationError) Cause 

func (e GetRunDetailsRequestValidationError) Cause() error

Cause function returns cause value.

func (GetRunDetailsRequestValidationError) Error 

func (e GetRunDetailsRequestValidationError) Error() string

Error satisfies the builtin error interface

func (GetRunDetailsRequestValidationError) ErrorName 

func (e GetRunDetailsRequestValidationError) ErrorName() string

ErrorName returns error name.

func (GetRunDetailsRequestValidationError) Field 

func (e GetRunDetailsRequestValidationError) Field() string

Field function returns field value.

func (GetRunDetailsRequestValidationError) Key 

func (e GetRunDetailsRequestValidationError) Key() bool

Key function returns key value.

func (GetRunDetailsRequestValidationError) Reason 

func (e GetRunDetailsRequestValidationError) Reason() string

Reason function returns reason value.

type GetRunDetailsResponse 

type GetRunDetailsResponse struct {

	// Detailed information about the run.
	Details *RunDetails `protobuf:"bytes,1,opt,name=details,proto3" json:"details,omitempty"`
	// contains filtered or unexported fields
}

Response message for getting detailed information about a run.

func (*GetRunDetailsResponse) Descriptor deprecated 

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

Deprecated: Use GetRunDetailsResponse.ProtoReflect.Descriptor instead.

func (*GetRunDetailsResponse) GetDetails 

func (x *GetRunDetailsResponse) GetDetails() *RunDetails

func (*GetRunDetailsResponse) ProtoMessage 

func (*GetRunDetailsResponse) ProtoMessage()

func (*GetRunDetailsResponse) ProtoReflect 

func (x *GetRunDetailsResponse) ProtoReflect() protoreflect.Message

func (*GetRunDetailsResponse) Reset 

func (x *GetRunDetailsResponse) Reset()

func (*GetRunDetailsResponse) String 

func (x *GetRunDetailsResponse) String() string

func (*GetRunDetailsResponse) Validate 

func (m *GetRunDetailsResponse) Validate() error

Validate checks the field values on GetRunDetailsResponse with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*GetRunDetailsResponse) ValidateAll 

func (m *GetRunDetailsResponse) ValidateAll() error

ValidateAll checks the field values on GetRunDetailsResponse with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in GetRunDetailsResponseMultiError, or nil if none found.

type GetRunDetailsResponseMultiError 

type GetRunDetailsResponseMultiError []error

GetRunDetailsResponseMultiError is an error wrapping multiple validation errors returned by GetRunDetailsResponse.ValidateAll() if the designated constraints aren't met.

func (GetRunDetailsResponseMultiError) AllErrors 

func (m GetRunDetailsResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (GetRunDetailsResponseMultiError) Error 

func (m GetRunDetailsResponseMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type GetRunDetailsResponseValidationError 

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

GetRunDetailsResponseValidationError is the validation error returned by GetRunDetailsResponse.Validate if the designated constraints aren't met.

func (GetRunDetailsResponseValidationError) Cause 

func (e GetRunDetailsResponseValidationError) Cause() error

Cause function returns cause value.

func (GetRunDetailsResponseValidationError) Error 

func (e GetRunDetailsResponseValidationError) Error() string

Error satisfies the builtin error interface

func (GetRunDetailsResponseValidationError) ErrorName 

func (e GetRunDetailsResponseValidationError) ErrorName() string

ErrorName returns error name.

func (GetRunDetailsResponseValidationError) Field 

func (e GetRunDetailsResponseValidationError) Field() string

Field function returns field value.

func (GetRunDetailsResponseValidationError) Key 

func (e GetRunDetailsResponseValidationError) Key() bool

Key function returns key value.

func (GetRunDetailsResponseValidationError) Reason 

func (e GetRunDetailsResponseValidationError) Reason() string

Reason function returns reason value.

type GetTaskDetailsRequest 

type GetTaskDetailsRequest struct {

	// Id of the task.
	TaskId *TaskIdentifier `protobuf:"bytes,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	// contains filtered or unexported fields
}

Request message for getting detailed information about a task.

func (*GetTaskDetailsRequest) Descriptor deprecated 

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

Deprecated: Use GetTaskDetailsRequest.ProtoReflect.Descriptor instead.

func (*GetTaskDetailsRequest) GetTaskId 

func (x *GetTaskDetailsRequest) GetTaskId() *TaskIdentifier

func (*GetTaskDetailsRequest) ProtoMessage 

func (*GetTaskDetailsRequest) ProtoMessage()

func (*GetTaskDetailsRequest) ProtoReflect 

func (x *GetTaskDetailsRequest) ProtoReflect() protoreflect.Message

func (*GetTaskDetailsRequest) Reset 

func (x *GetTaskDetailsRequest) Reset()

func (*GetTaskDetailsRequest) String 

func (x *GetTaskDetailsRequest) String() string

func (*GetTaskDetailsRequest) Validate 

func (m *GetTaskDetailsRequest) Validate() error

Validate checks the field values on GetTaskDetailsRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*GetTaskDetailsRequest) ValidateAll 

func (m *GetTaskDetailsRequest) ValidateAll() error

ValidateAll checks the field values on GetTaskDetailsRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in GetTaskDetailsRequestMultiError, or nil if none found.

type GetTaskDetailsRequestMultiError 

type GetTaskDetailsRequestMultiError []error

GetTaskDetailsRequestMultiError is an error wrapping multiple validation errors returned by GetTaskDetailsRequest.ValidateAll() if the designated constraints aren't met.

func (GetTaskDetailsRequestMultiError) AllErrors 

func (m GetTaskDetailsRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (GetTaskDetailsRequestMultiError) Error 

func (m GetTaskDetailsRequestMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type GetTaskDetailsRequestValidationError 

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

GetTaskDetailsRequestValidationError is the validation error returned by GetTaskDetailsRequest.Validate if the designated constraints aren't met.

func (GetTaskDetailsRequestValidationError) Cause 

func (e GetTaskDetailsRequestValidationError) Cause() error

Cause function returns cause value.

func (GetTaskDetailsRequestValidationError) Error 

func (e GetTaskDetailsRequestValidationError) Error() string

Error satisfies the builtin error interface

func (GetTaskDetailsRequestValidationError) ErrorName 

func (e GetTaskDetailsRequestValidationError) ErrorName() string

ErrorName returns error name.

func (GetTaskDetailsRequestValidationError) Field 

func (e GetTaskDetailsRequestValidationError) Field() string

Field function returns field value.

func (GetTaskDetailsRequestValidationError) Key 

func (e GetTaskDetailsRequestValidationError) Key() bool

Key function returns key value.

func (GetTaskDetailsRequestValidationError) Reason 

func (e GetTaskDetailsRequestValidationError) Reason() string

Reason function returns reason value.

type GetTaskDetailsResponse 

type GetTaskDetailsResponse struct {

	// Detailed information about the task.
	Details *TaskDetails `protobuf:"bytes,1,opt,name=details,proto3" json:"details,omitempty"`
	// contains filtered or unexported fields
}

Response message for deploying a task.

func (*GetTaskDetailsResponse) Descriptor deprecated 

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

Deprecated: Use GetTaskDetailsResponse.ProtoReflect.Descriptor instead.

func (*GetTaskDetailsResponse) GetDetails 

func (x *GetTaskDetailsResponse) GetDetails() *TaskDetails

func (*GetTaskDetailsResponse) ProtoMessage 

func (*GetTaskDetailsResponse) ProtoMessage()

func (*GetTaskDetailsResponse) ProtoReflect 

func (x *GetTaskDetailsResponse) ProtoReflect() protoreflect.Message

func (*GetTaskDetailsResponse) Reset 

func (x *GetTaskDetailsResponse) Reset()

func (*GetTaskDetailsResponse) String 

func (x *GetTaskDetailsResponse) String() string

func (*GetTaskDetailsResponse) Validate 

func (m *GetTaskDetailsResponse) Validate() error

Validate checks the field values on GetTaskDetailsResponse with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*GetTaskDetailsResponse) ValidateAll 

func (m *GetTaskDetailsResponse) ValidateAll() error

ValidateAll checks the field values on GetTaskDetailsResponse with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in GetTaskDetailsResponseMultiError, or nil if none found.

type GetTaskDetailsResponseMultiError 

type GetTaskDetailsResponseMultiError []error

GetTaskDetailsResponseMultiError is an error wrapping multiple validation errors returned by GetTaskDetailsResponse.ValidateAll() if the designated constraints aren't met.

func (GetTaskDetailsResponseMultiError) AllErrors 

func (m GetTaskDetailsResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (GetTaskDetailsResponseMultiError) Error 

func (m GetTaskDetailsResponseMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type GetTaskDetailsResponseValidationError 

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

GetTaskDetailsResponseValidationError is the validation error returned by GetTaskDetailsResponse.Validate if the designated constraints aren't met.

func (GetTaskDetailsResponseValidationError) Cause 

func (e GetTaskDetailsResponseValidationError) Cause() error

Cause function returns cause value.

func (GetTaskDetailsResponseValidationError) Error 

func (e GetTaskDetailsResponseValidationError) Error() string

Error satisfies the builtin error interface

func (GetTaskDetailsResponseValidationError) ErrorName 

func (e GetTaskDetailsResponseValidationError) ErrorName() string

ErrorName returns error name.

func (GetTaskDetailsResponseValidationError) Field 

func (e GetTaskDetailsResponseValidationError) Field() string

Field function returns field value.

func (GetTaskDetailsResponseValidationError) Key 

func (e GetTaskDetailsResponseValidationError) Key() bool

Key function returns key value.

func (GetTaskDetailsResponseValidationError) Reason 

func (e GetTaskDetailsResponseValidationError) Reason() string

Reason function returns reason value.

type Inputs 

type Inputs struct {

	// Ordered inputs.
	Literals []*NamedLiteral `protobuf:"bytes,1,rep,name=literals,proto3" json:"literals,omitempty"`
	// Context for the action. If an action receives context, it'll automatically pass it to any actions it spawns.
	// Context will not be used for cache key computation.
	// Examples for context include:
	//   - User-provided metadata that is not part of the action's inputs.
	//   - Information about the environment the action is running in (e.g. cluster, region, etc.)
	//   - Tracing information about the action
	Context []*core.KeyValuePair `protobuf:"bytes,2,rep,name=context,proto3" json:"context,omitempty"`
	// contains filtered or unexported fields
}

Input payload for an action.

func (*Inputs) Descriptor deprecated 

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

Deprecated: Use Inputs.ProtoReflect.Descriptor instead.

func (*Inputs) GetContext 

func (x *Inputs) GetContext() []*core.KeyValuePair

func (*Inputs) GetLiterals 

func (x *Inputs) GetLiterals() []*NamedLiteral

func (*Inputs) ProtoMessage 

func (*Inputs) ProtoMessage()

func (*Inputs) ProtoReflect 

func (x *Inputs) ProtoReflect() protoreflect.Message

func (*Inputs) Reset 

func (x *Inputs) Reset()

func (*Inputs) String 

func (x *Inputs) String() string

func (*Inputs) Validate 

func (m *Inputs) Validate() error

Validate checks the field values on Inputs with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*Inputs) ValidateAll 

func (m *Inputs) ValidateAll() error

ValidateAll checks the field values on Inputs with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in InputsMultiError, or nil if none found.

type InputsMultiError 

type InputsMultiError []error

InputsMultiError is an error wrapping multiple validation errors returned by Inputs.ValidateAll() if the designated constraints aren't met.

func (InputsMultiError) AllErrors 

func (m InputsMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (InputsMultiError) Error 

func (m InputsMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type InputsValidationError 

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

InputsValidationError is the validation error returned by Inputs.Validate if the designated constraints aren't met.

func (InputsValidationError) Cause 

func (e InputsValidationError) Cause() error

Cause function returns cause value.

func (InputsValidationError) Error 

func (e InputsValidationError) Error() string

Error satisfies the builtin error interface

func (InputsValidationError) ErrorName 

func (e InputsValidationError) ErrorName() string

ErrorName returns error name.

func (InputsValidationError) Field 

func (e InputsValidationError) Field() string

Field function returns field value.

func (InputsValidationError) Key 

func (e InputsValidationError) Key() bool

Key function returns key value.

func (InputsValidationError) Reason 

func (e InputsValidationError) Reason() string

Reason function returns reason value.

type Labels 

type Labels struct {

	// Map of custom labels to be applied to the execution resource.
	Values map[string]string `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

Label values to be applied to an execution resource. In the future a mode (e.g. OVERRIDE, APPEND, etc) can be defined to specify how to merge labels defined at registration and execution time.

func (*Labels) Descriptor deprecated 

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

Deprecated: Use Labels.ProtoReflect.Descriptor instead.

func (*Labels) GetValues 

func (x *Labels) GetValues() map[string]string

func (*Labels) ProtoMessage 

func (*Labels) ProtoMessage()

func (*Labels) ProtoReflect 

func (x *Labels) ProtoReflect() protoreflect.Message

func (*Labels) Reset 

func (x *Labels) Reset()

func (*Labels) String 

func (x *Labels) String() string

func (*Labels) Validate 

func (m *Labels) Validate() error

Validate checks the field values on Labels with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*Labels) ValidateAll 

func (m *Labels) ValidateAll() error

ValidateAll checks the field values on Labels with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in LabelsMultiError, or nil if none found.

type LabelsMultiError 

type LabelsMultiError []error

LabelsMultiError is an error wrapping multiple validation errors returned by Labels.ValidateAll() if the designated constraints aren't met.

func (LabelsMultiError) AllErrors 

func (m LabelsMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (LabelsMultiError) Error 

func (m LabelsMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type LabelsValidationError 

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

LabelsValidationError is the validation error returned by Labels.Validate if the designated constraints aren't met.

func (LabelsValidationError) Cause 

func (e LabelsValidationError) Cause() error

Cause function returns cause value.

func (LabelsValidationError) Error 

func (e LabelsValidationError) Error() string

Error satisfies the builtin error interface

func (LabelsValidationError) ErrorName 

func (e LabelsValidationError) ErrorName() string

ErrorName returns error name.

func (LabelsValidationError) Field 

func (e LabelsValidationError) Field() string

Field function returns field value.

func (LabelsValidationError) Key 

func (e LabelsValidationError) Key() bool

Key function returns key value.

func (LabelsValidationError) Reason 

func (e LabelsValidationError) Reason() string

Reason function returns reason value.

type ListActionsRequest 

type ListActionsRequest struct {

	// Common list request parameters.
	Request *common.ListRequest `protobuf:"bytes,1,opt,name=request,proto3" json:"request,omitempty"`
	// Run identifier for filtering actions.
	RunId *common.RunIdentifier `protobuf:"bytes,2,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	// contains filtered or unexported fields
}

Request message for listing actions.

func (*ListActionsRequest) Descriptor deprecated 

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

Deprecated: Use ListActionsRequest.ProtoReflect.Descriptor instead.

func (*ListActionsRequest) GetRequest 

func (x *ListActionsRequest) GetRequest() *common.ListRequest

func (*ListActionsRequest) GetRunId 

func (x *ListActionsRequest) GetRunId() *common.RunIdentifier

func (*ListActionsRequest) ProtoMessage 

func (*ListActionsRequest) ProtoMessage()

func (*ListActionsRequest) ProtoReflect 

func (x *ListActionsRequest) ProtoReflect() protoreflect.Message

func (*ListActionsRequest) Reset 

func (x *ListActionsRequest) Reset()

func (*ListActionsRequest) String 

func (x *ListActionsRequest) String() string

func (*ListActionsRequest) Validate 

func (m *ListActionsRequest) Validate() error

Validate checks the field values on ListActionsRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*ListActionsRequest) ValidateAll 

func (m *ListActionsRequest) ValidateAll() error

ValidateAll checks the field values on ListActionsRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in ListActionsRequestMultiError, or nil if none found.

type ListActionsRequestMultiError 

type ListActionsRequestMultiError []error

ListActionsRequestMultiError is an error wrapping multiple validation errors returned by ListActionsRequest.ValidateAll() if the designated constraints aren't met.

func (ListActionsRequestMultiError) AllErrors 

func (m ListActionsRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ListActionsRequestMultiError) Error 

func (m ListActionsRequestMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type ListActionsRequestValidationError 

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

ListActionsRequestValidationError is the validation error returned by ListActionsRequest.Validate if the designated constraints aren't met.

func (ListActionsRequestValidationError) Cause 

func (e ListActionsRequestValidationError) Cause() error

Cause function returns cause value.

func (ListActionsRequestValidationError) Error 

func (e ListActionsRequestValidationError) Error() string

Error satisfies the builtin error interface

func (ListActionsRequestValidationError) ErrorName 

func (e ListActionsRequestValidationError) ErrorName() string

ErrorName returns error name.

func (ListActionsRequestValidationError) Field 

func (e ListActionsRequestValidationError) Field() string

Field function returns field value.

func (ListActionsRequestValidationError) Key 

func (e ListActionsRequestValidationError) Key() bool

Key function returns key value.

func (ListActionsRequestValidationError) Reason 

func (e ListActionsRequestValidationError) Reason() string

Reason function returns reason value.

type ListActionsResponse 

type ListActionsResponse struct {

	// List of actions matching the filter criteria.
	Actions []*Action `protobuf:"bytes,1,rep,name=actions,proto3" json:"actions,omitempty"`
	// Token for fetching the next page of results, if any.
	Token string `protobuf:"bytes,2,opt,name=token,proto3" json:"token,omitempty"`
	// contains filtered or unexported fields
}

Response message for listing actions.

func (*ListActionsResponse) Descriptor deprecated 

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

Deprecated: Use ListActionsResponse.ProtoReflect.Descriptor instead.

func (*ListActionsResponse) GetActions 

func (x *ListActionsResponse) GetActions() []*Action

func (*ListActionsResponse) GetToken 

func (x *ListActionsResponse) GetToken() string

func (*ListActionsResponse) ProtoMessage 

func (*ListActionsResponse) ProtoMessage()

func (*ListActionsResponse) ProtoReflect 

func (x *ListActionsResponse) ProtoReflect() protoreflect.Message

func (*ListActionsResponse) Reset 

func (x *ListActionsResponse) Reset()

func (*ListActionsResponse) String 

func (x *ListActionsResponse) String() string

func (*ListActionsResponse) Validate 

func (m *ListActionsResponse) Validate() error

Validate checks the field values on ListActionsResponse with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*ListActionsResponse) ValidateAll 

func (m *ListActionsResponse) ValidateAll() error

ValidateAll checks the field values on ListActionsResponse with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in ListActionsResponseMultiError, or nil if none found.

type ListActionsResponseMultiError 

type ListActionsResponseMultiError []error

ListActionsResponseMultiError is an error wrapping multiple validation errors returned by ListActionsResponse.ValidateAll() if the designated constraints aren't met.

func (ListActionsResponseMultiError) AllErrors 

func (m ListActionsResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ListActionsResponseMultiError) Error 

func (m ListActionsResponseMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type ListActionsResponseValidationError 

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

ListActionsResponseValidationError is the validation error returned by ListActionsResponse.Validate if the designated constraints aren't met.

func (ListActionsResponseValidationError) Cause 

func (e ListActionsResponseValidationError) Cause() error

Cause function returns cause value.

func (ListActionsResponseValidationError) Error 

func (e ListActionsResponseValidationError) Error() string

Error satisfies the builtin error interface

func (ListActionsResponseValidationError) ErrorName 

func (e ListActionsResponseValidationError) ErrorName() string

ErrorName returns error name.

func (ListActionsResponseValidationError) Field 

func (e ListActionsResponseValidationError) Field() string

Field function returns field value.

func (ListActionsResponseValidationError) Key 

func (e ListActionsResponseValidationError) Key() bool

Key function returns key value.

func (ListActionsResponseValidationError) Reason 

func (e ListActionsResponseValidationError) Reason() string

Reason function returns reason value.

type ListRunsRequest 

type ListRunsRequest struct {

	// Common list request parameters.
	Request *common.ListRequest `protobuf:"bytes,1,opt,name=request,proto3" json:"request,omitempty"`
	// Types that are assignable to ScopeBy:
	//
	//	*ListRunsRequest_Org
	//	*ListRunsRequest_ProjectId
	ScopeBy isListRunsRequest_ScopeBy `protobuf_oneof:"scope_by"`
	// contains filtered or unexported fields
}

Request message for listing runs.

func (*ListRunsRequest) Descriptor deprecated 

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

Deprecated: Use ListRunsRequest.ProtoReflect.Descriptor instead.

func (*ListRunsRequest) GetOrg 

func (x *ListRunsRequest) GetOrg() string

func (*ListRunsRequest) GetProjectId 

func (x *ListRunsRequest) GetProjectId() *common.ProjectIdentifier

func (*ListRunsRequest) GetRequest 

func (x *ListRunsRequest) GetRequest() *common.ListRequest

func (*ListRunsRequest) GetScopeBy 

func (m *ListRunsRequest) GetScopeBy() isListRunsRequest_ScopeBy

func (*ListRunsRequest) ProtoMessage 

func (*ListRunsRequest) ProtoMessage()

func (*ListRunsRequest) ProtoReflect 

func (x *ListRunsRequest) ProtoReflect() protoreflect.Message

func (*ListRunsRequest) Reset 

func (x *ListRunsRequest) Reset()

func (*ListRunsRequest) String 

func (x *ListRunsRequest) String() string

func (*ListRunsRequest) Validate 

func (m *ListRunsRequest) Validate() error

Validate checks the field values on ListRunsRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*ListRunsRequest) ValidateAll 

func (m *ListRunsRequest) ValidateAll() error

ValidateAll checks the field values on ListRunsRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in ListRunsRequestMultiError, or nil if none found.

type ListRunsRequestMultiError 

type ListRunsRequestMultiError []error

ListRunsRequestMultiError is an error wrapping multiple validation errors returned by ListRunsRequest.ValidateAll() if the designated constraints aren't met.

func (ListRunsRequestMultiError) AllErrors 

func (m ListRunsRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ListRunsRequestMultiError) Error 

func (m ListRunsRequestMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type ListRunsRequestValidationError 

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

ListRunsRequestValidationError is the validation error returned by ListRunsRequest.Validate if the designated constraints aren't met.

func (ListRunsRequestValidationError) Cause 

func (e ListRunsRequestValidationError) Cause() error

Cause function returns cause value.

func (ListRunsRequestValidationError) Error 

func (e ListRunsRequestValidationError) Error() string

Error satisfies the builtin error interface

func (ListRunsRequestValidationError) ErrorName 

func (e ListRunsRequestValidationError) ErrorName() string

ErrorName returns error name.

func (ListRunsRequestValidationError) Field 

func (e ListRunsRequestValidationError) Field() string

Field function returns field value.

func (ListRunsRequestValidationError) Key 

func (e ListRunsRequestValidationError) Key() bool

Key function returns key value.

func (ListRunsRequestValidationError) Reason 

func (e ListRunsRequestValidationError) Reason() string

Reason function returns reason value.

type ListRunsRequest_Org 

type ListRunsRequest_Org struct {
	// Organization name for filtering runs.
	Org string `protobuf:"bytes,2,opt,name=org,proto3,oneof"`
}

type ListRunsRequest_ProjectId 

type ListRunsRequest_ProjectId struct {
	// Project identifier for filtering runs.
	ProjectId *common.ProjectIdentifier `protobuf:"bytes,4,opt,name=project_id,json=projectId,proto3,oneof"`
}

type ListRunsResponse 

type ListRunsResponse struct {

	// List of runs matching the filter criteria.
	Runs []*Run `protobuf:"bytes,1,rep,name=runs,proto3" json:"runs,omitempty"`
	// Token for fetching the next page of results, if any.
	Token string `protobuf:"bytes,2,opt,name=token,proto3" json:"token,omitempty"`
	// contains filtered or unexported fields
}

Response message for listing runs.

func (*ListRunsResponse) Descriptor deprecated 

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

Deprecated: Use ListRunsResponse.ProtoReflect.Descriptor instead.

func (*ListRunsResponse) GetRuns 

func (x *ListRunsResponse) GetRuns() []*Run

func (*ListRunsResponse) GetToken 

func (x *ListRunsResponse) GetToken() string

func (*ListRunsResponse) ProtoMessage 

func (*ListRunsResponse) ProtoMessage()

func (*ListRunsResponse) ProtoReflect 

func (x *ListRunsResponse) ProtoReflect() protoreflect.Message

func (*ListRunsResponse) Reset 

func (x *ListRunsResponse) Reset()

func (*ListRunsResponse) String 

func (x *ListRunsResponse) String() string

func (*ListRunsResponse) Validate 

func (m *ListRunsResponse) Validate() error

Validate checks the field values on ListRunsResponse with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*ListRunsResponse) ValidateAll 

func (m *ListRunsResponse) ValidateAll() error

ValidateAll checks the field values on ListRunsResponse with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in ListRunsResponseMultiError, or nil if none found.

type ListRunsResponseMultiError 

type ListRunsResponseMultiError []error

ListRunsResponseMultiError is an error wrapping multiple validation errors returned by ListRunsResponse.ValidateAll() if the designated constraints aren't met.

func (ListRunsResponseMultiError) AllErrors 

func (m ListRunsResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ListRunsResponseMultiError) Error 

func (m ListRunsResponseMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type ListRunsResponseValidationError 

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

ListRunsResponseValidationError is the validation error returned by ListRunsResponse.Validate if the designated constraints aren't met.

func (ListRunsResponseValidationError) Cause 

func (e ListRunsResponseValidationError) Cause() error

Cause function returns cause value.

func (ListRunsResponseValidationError) Error 

func (e ListRunsResponseValidationError) Error() string

Error satisfies the builtin error interface

func (ListRunsResponseValidationError) ErrorName 

func (e ListRunsResponseValidationError) ErrorName() string

ErrorName returns error name.

func (ListRunsResponseValidationError) Field 

func (e ListRunsResponseValidationError) Field() string

Field function returns field value.

func (ListRunsResponseValidationError) Key 

func (e ListRunsResponseValidationError) Key() bool

Key function returns key value.

func (ListRunsResponseValidationError) Reason 

func (e ListRunsResponseValidationError) Reason() string

Reason function returns reason value.

type ListTasksRequest 

type ListTasksRequest struct {

	// Common list request parameters.
	Request *common.ListRequest `protobuf:"bytes,1,opt,name=request,proto3" json:"request,omitempty"`
	// Types that are assignable to ScopeBy:
	//
	//	*ListTasksRequest_Org
	//	*ListTasksRequest_ProjectId
	ScopeBy isListTasksRequest_ScopeBy `protobuf_oneof:"scope_by"`
	// Known filters for listing tasks.
	KnownFilters []*ListTasksRequest_KnownFilter `protobuf:"bytes,4,rep,name=known_filters,json=knownFilters,proto3" json:"known_filters,omitempty"`
	// contains filtered or unexported fields
}

func (*ListTasksRequest) Descriptor deprecated 

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

Deprecated: Use ListTasksRequest.ProtoReflect.Descriptor instead.

func (*ListTasksRequest) GetKnownFilters 

func (x *ListTasksRequest) GetKnownFilters() []*ListTasksRequest_KnownFilter

func (*ListTasksRequest) GetOrg 

func (x *ListTasksRequest) GetOrg() string

func (*ListTasksRequest) GetProjectId 

func (x *ListTasksRequest) GetProjectId() *common.ProjectIdentifier

func (*ListTasksRequest) GetRequest 

func (x *ListTasksRequest) GetRequest() *common.ListRequest

func (*ListTasksRequest) GetScopeBy 

func (m *ListTasksRequest) GetScopeBy() isListTasksRequest_ScopeBy

func (*ListTasksRequest) ProtoMessage 

func (*ListTasksRequest) ProtoMessage()

func (*ListTasksRequest) ProtoReflect 

func (x *ListTasksRequest) ProtoReflect() protoreflect.Message

func (*ListTasksRequest) Reset 

func (x *ListTasksRequest) Reset()

func (*ListTasksRequest) String 

func (x *ListTasksRequest) String() string

func (*ListTasksRequest) Validate 

func (m *ListTasksRequest) Validate() error

Validate checks the field values on ListTasksRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*ListTasksRequest) ValidateAll 

func (m *ListTasksRequest) ValidateAll() error

ValidateAll checks the field values on ListTasksRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in ListTasksRequestMultiError, or nil if none found.

type ListTasksRequestMultiError 

type ListTasksRequestMultiError []error

ListTasksRequestMultiError is an error wrapping multiple validation errors returned by ListTasksRequest.ValidateAll() if the designated constraints aren't met.

func (ListTasksRequestMultiError) AllErrors 

func (m ListTasksRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ListTasksRequestMultiError) Error 

func (m ListTasksRequestMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type ListTasksRequestValidationError 

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

ListTasksRequestValidationError is the validation error returned by ListTasksRequest.Validate if the designated constraints aren't met.

func (ListTasksRequestValidationError) Cause 

func (e ListTasksRequestValidationError) Cause() error

Cause function returns cause value.

func (ListTasksRequestValidationError) Error 

func (e ListTasksRequestValidationError) Error() string

Error satisfies the builtin error interface

func (ListTasksRequestValidationError) ErrorName 

func (e ListTasksRequestValidationError) ErrorName() string

ErrorName returns error name.

func (ListTasksRequestValidationError) Field 

func (e ListTasksRequestValidationError) Field() string

Field function returns field value.

func (ListTasksRequestValidationError) Key 

func (e ListTasksRequestValidationError) Key() bool

Key function returns key value.

func (ListTasksRequestValidationError) Reason 

func (e ListTasksRequestValidationError) Reason() string

Reason function returns reason value.

type ListTasksRequest_KnownFilter 

type ListTasksRequest_KnownFilter struct {

	// Types that are assignable to FilterBy:
	//
	//	*ListTasksRequest_KnownFilter_DeployedBy
	FilterBy isListTasksRequest_KnownFilter_FilterBy `protobuf_oneof:"filter_by"`
	// contains filtered or unexported fields
}

func (*ListTasksRequest_KnownFilter) Descriptor deprecated 

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

Deprecated: Use ListTasksRequest_KnownFilter.ProtoReflect.Descriptor instead.

func (*ListTasksRequest_KnownFilter) GetDeployedBy 

func (x *ListTasksRequest_KnownFilter) GetDeployedBy() string

func (*ListTasksRequest_KnownFilter) GetFilterBy 

func (m *ListTasksRequest_KnownFilter) GetFilterBy() isListTasksRequest_KnownFilter_FilterBy

func (*ListTasksRequest_KnownFilter) ProtoMessage 

func (*ListTasksRequest_KnownFilter) ProtoMessage()

func (*ListTasksRequest_KnownFilter) ProtoReflect 

func (x *ListTasksRequest_KnownFilter) ProtoReflect() protoreflect.Message

func (*ListTasksRequest_KnownFilter) Reset 

func (x *ListTasksRequest_KnownFilter) Reset()

func (*ListTasksRequest_KnownFilter) String 

func (x *ListTasksRequest_KnownFilter) String() string

func (*ListTasksRequest_KnownFilter) Validate 

func (m *ListTasksRequest_KnownFilter) Validate() error

Validate checks the field values on ListTasksRequest_KnownFilter with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*ListTasksRequest_KnownFilter) ValidateAll 

func (m *ListTasksRequest_KnownFilter) ValidateAll() error

ValidateAll checks the field values on ListTasksRequest_KnownFilter with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in ListTasksRequest_KnownFilterMultiError, or nil if none found.

type ListTasksRequest_KnownFilterMultiError 

type ListTasksRequest_KnownFilterMultiError []error

ListTasksRequest_KnownFilterMultiError is an error wrapping multiple validation errors returned by ListTasksRequest_KnownFilter.ValidateAll() if the designated constraints aren't met.

func (ListTasksRequest_KnownFilterMultiError) AllErrors 

func (m ListTasksRequest_KnownFilterMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ListTasksRequest_KnownFilterMultiError) Error 

func (m ListTasksRequest_KnownFilterMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type ListTasksRequest_KnownFilterValidationError 

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

ListTasksRequest_KnownFilterValidationError is the validation error returned by ListTasksRequest_KnownFilter.Validate if the designated constraints aren't met.

func (ListTasksRequest_KnownFilterValidationError) Cause 

func (e ListTasksRequest_KnownFilterValidationError) Cause() error

Cause function returns cause value.

func (ListTasksRequest_KnownFilterValidationError) Error 

func (e ListTasksRequest_KnownFilterValidationError) Error() string

Error satisfies the builtin error interface

func (ListTasksRequest_KnownFilterValidationError) ErrorName 

func (e ListTasksRequest_KnownFilterValidationError) ErrorName() string

ErrorName returns error name.

func (ListTasksRequest_KnownFilterValidationError) Field 

func (e ListTasksRequest_KnownFilterValidationError) Field() string

Field function returns field value.

func (ListTasksRequest_KnownFilterValidationError) Key 

func (e ListTasksRequest_KnownFilterValidationError) Key() bool

Key function returns key value.

func (ListTasksRequest_KnownFilterValidationError) Reason 

func (e ListTasksRequest_KnownFilterValidationError) Reason() string

Reason function returns reason value.

type ListTasksRequest_KnownFilter_DeployedBy 

type ListTasksRequest_KnownFilter_DeployedBy struct {
	// Filter by user
	DeployedBy string `protobuf:"bytes,1,opt,name=deployed_by,json=deployedBy,proto3,oneof"`
}

type ListTasksRequest_Org 

type ListTasksRequest_Org struct {
	// Organization name for filtering.
	Org string `protobuf:"bytes,2,opt,name=org,proto3,oneof"`
}

type ListTasksRequest_ProjectId 

type ListTasksRequest_ProjectId struct {
	// Project identifier for filtering.
	ProjectId *common.ProjectIdentifier `protobuf:"bytes,3,opt,name=project_id,json=projectId,proto3,oneof"`
}

type ListTasksResponse 

type ListTasksResponse struct {
	Tasks []*Task `protobuf:"bytes,1,rep,name=tasks,proto3" json:"tasks,omitempty"`
	// Pagination token for the next page of tasks.
	Token string `protobuf:"bytes,2,opt,name=token,proto3" json:"token,omitempty"`
	// contains filtered or unexported fields
}

func (*ListTasksResponse) Descriptor deprecated 

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

Deprecated: Use ListTasksResponse.ProtoReflect.Descriptor instead.

func (*ListTasksResponse) GetTasks 

func (x *ListTasksResponse) GetTasks() []*Task

func (*ListTasksResponse) GetToken 

func (x *ListTasksResponse) GetToken() string

func (*ListTasksResponse) ProtoMessage 

func (*ListTasksResponse) ProtoMessage()

func (*ListTasksResponse) ProtoReflect 

func (x *ListTasksResponse) ProtoReflect() protoreflect.Message

func (*ListTasksResponse) Reset 

func (x *ListTasksResponse) Reset()

func (*ListTasksResponse) String 

func (x *ListTasksResponse) String() string

func (*ListTasksResponse) Validate 

func (m *ListTasksResponse) Validate() error

Validate checks the field values on ListTasksResponse with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*ListTasksResponse) ValidateAll 

func (m *ListTasksResponse) ValidateAll() error

ValidateAll checks the field values on ListTasksResponse with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in ListTasksResponseMultiError, or nil if none found.

type ListTasksResponseMultiError 

type ListTasksResponseMultiError []error

ListTasksResponseMultiError is an error wrapping multiple validation errors returned by ListTasksResponse.ValidateAll() if the designated constraints aren't met.

func (ListTasksResponseMultiError) AllErrors 

func (m ListTasksResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ListTasksResponseMultiError) Error 

func (m ListTasksResponseMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type ListTasksResponseValidationError 

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

ListTasksResponseValidationError is the validation error returned by ListTasksResponse.Validate if the designated constraints aren't met.

func (ListTasksResponseValidationError) Cause 

func (e ListTasksResponseValidationError) Cause() error

Cause function returns cause value.

func (ListTasksResponseValidationError) Error 

func (e ListTasksResponseValidationError) Error() string

Error satisfies the builtin error interface

func (ListTasksResponseValidationError) ErrorName 

func (e ListTasksResponseValidationError) ErrorName() string

ErrorName returns error name.

func (ListTasksResponseValidationError) Field 

func (e ListTasksResponseValidationError) Field() string

Field function returns field value.

func (ListTasksResponseValidationError) Key 

func (e ListTasksResponseValidationError) Key() bool

Key function returns key value.

func (ListTasksResponseValidationError) Reason 

func (e ListTasksResponseValidationError) Reason() string

Reason function returns reason value.

type NamedLiteral 

type NamedLiteral struct {

	// Name of the literal.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Literal value.
	Value *core.Literal `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

Named literal value.

func (*NamedLiteral) Descriptor deprecated 

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

Deprecated: Use NamedLiteral.ProtoReflect.Descriptor instead.

func (*NamedLiteral) GetName 

func (x *NamedLiteral) GetName() string

func (*NamedLiteral) GetValue 

func (x *NamedLiteral) GetValue() *core.Literal

func (*NamedLiteral) ProtoMessage 

func (*NamedLiteral) ProtoMessage()

func (*NamedLiteral) ProtoReflect 

func (x *NamedLiteral) ProtoReflect() protoreflect.Message

func (*NamedLiteral) Reset 

func (x *NamedLiteral) Reset()

func (*NamedLiteral) String 

func (x *NamedLiteral) String() string

func (*NamedLiteral) Validate 

func (m *NamedLiteral) Validate() error

Validate checks the field values on NamedLiteral with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*NamedLiteral) ValidateAll 

func (m *NamedLiteral) ValidateAll() error

ValidateAll checks the field values on NamedLiteral with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in NamedLiteralMultiError, or nil if none found.

type NamedLiteralMultiError 

type NamedLiteralMultiError []error

NamedLiteralMultiError is an error wrapping multiple validation errors returned by NamedLiteral.ValidateAll() if the designated constraints aren't met.

func (NamedLiteralMultiError) AllErrors 

func (m NamedLiteralMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (NamedLiteralMultiError) Error 

func (m NamedLiteralMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type NamedLiteralValidationError 

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

NamedLiteralValidationError is the validation error returned by NamedLiteral.Validate if the designated constraints aren't met.

func (NamedLiteralValidationError) Cause 

func (e NamedLiteralValidationError) Cause() error

Cause function returns cause value.

func (NamedLiteralValidationError) Error 

func (e NamedLiteralValidationError) Error() string

Error satisfies the builtin error interface

func (NamedLiteralValidationError) ErrorName 

func (e NamedLiteralValidationError) ErrorName() string

ErrorName returns error name.

func (NamedLiteralValidationError) Field 

func (e NamedLiteralValidationError) Field() string

Field function returns field value.

func (NamedLiteralValidationError) Key 

func (e NamedLiteralValidationError) Key() bool

Key function returns key value.

func (NamedLiteralValidationError) Reason 

func (e NamedLiteralValidationError) Reason() string

Reason function returns reason value.

type NamedParameter 

type NamedParameter struct {
	Name      string          `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Parameter *core.Parameter `protobuf:"bytes,2,opt,name=parameter,proto3" json:"parameter,omitempty"`
	// contains filtered or unexported fields
}

func (*NamedParameter) Descriptor deprecated 

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

Deprecated: Use NamedParameter.ProtoReflect.Descriptor instead.

func (*NamedParameter) GetName 

func (x *NamedParameter) GetName() string

func (*NamedParameter) GetParameter 

func (x *NamedParameter) GetParameter() *core.Parameter

func (*NamedParameter) ProtoMessage 

func (*NamedParameter) ProtoMessage()

func (*NamedParameter) ProtoReflect 

func (x *NamedParameter) ProtoReflect() protoreflect.Message

func (*NamedParameter) Reset 

func (x *NamedParameter) Reset()

func (*NamedParameter) String 

func (x *NamedParameter) String() string

func (*NamedParameter) Validate 

func (m *NamedParameter) Validate() error

Validate checks the field values on NamedParameter with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*NamedParameter) ValidateAll 

func (m *NamedParameter) ValidateAll() error

ValidateAll checks the field values on NamedParameter with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in NamedParameterMultiError, or nil if none found.

type NamedParameterMultiError 

type NamedParameterMultiError []error

NamedParameterMultiError is an error wrapping multiple validation errors returned by NamedParameter.ValidateAll() if the designated constraints aren't met.

func (NamedParameterMultiError) AllErrors 

func (m NamedParameterMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (NamedParameterMultiError) Error 

func (m NamedParameterMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type NamedParameterValidationError 

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

NamedParameterValidationError is the validation error returned by NamedParameter.Validate if the designated constraints aren't met.

func (NamedParameterValidationError) Cause 

func (e NamedParameterValidationError) Cause() error

Cause function returns cause value.

func (NamedParameterValidationError) Error 

func (e NamedParameterValidationError) Error() string

Error satisfies the builtin error interface

func (NamedParameterValidationError) ErrorName 

func (e NamedParameterValidationError) ErrorName() string

ErrorName returns error name.

func (NamedParameterValidationError) Field 

func (e NamedParameterValidationError) Field() string

Field function returns field value.

func (NamedParameterValidationError) Key 

func (e NamedParameterValidationError) Key() bool

Key function returns key value.

func (NamedParameterValidationError) Reason 

func (e NamedParameterValidationError) Reason() string

Reason function returns reason value.

type NodeExecutionServiceClient 

type NodeExecutionServiceClient interface {
}

NodeExecutionServiceClient is the client API for NodeExecutionService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewNodeExecutionServiceClient 

func NewNodeExecutionServiceClient(cc grpc.ClientConnInterface) NodeExecutionServiceClient

type NodeExecutionServiceServer 

type NodeExecutionServiceServer interface {
}

NodeExecutionServiceServer is the server API for NodeExecutionService service. All implementations should embed UnimplementedNodeExecutionServiceServer for forward compatibility

type OutputReferences 

type OutputReferences struct {

	// The output uri.
	OutputUri string `protobuf:"bytes,1,opt,name=output_uri,json=outputUri,proto3" json:"output_uri,omitempty"`
	// Native URI to HTML report
	ReportUri string `protobuf:"bytes,2,opt,name=report_uri,json=reportUri,proto3" json:"report_uri,omitempty"`
	// contains filtered or unexported fields
}

Output references.

func (*OutputReferences) Descriptor deprecated 

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

Deprecated: Use OutputReferences.ProtoReflect.Descriptor instead.

func (*OutputReferences) GetOutputUri 

func (x *OutputReferences) GetOutputUri() string

func (*OutputReferences) GetReportUri 

func (x *OutputReferences) GetReportUri() string

func (*OutputReferences) ProtoMessage 

func (*OutputReferences) ProtoMessage()

func (*OutputReferences) ProtoReflect 

func (x *OutputReferences) ProtoReflect() protoreflect.Message

func (*OutputReferences) Reset 

func (x *OutputReferences) Reset()

func (*OutputReferences) String 

func (x *OutputReferences) String() string

func (*OutputReferences) Validate 

func (m *OutputReferences) Validate() error

Validate checks the field values on OutputReferences with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*OutputReferences) ValidateAll 

func (m *OutputReferences) ValidateAll() error

ValidateAll checks the field values on OutputReferences with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in OutputReferencesMultiError, or nil if none found.

type OutputReferencesMultiError 

type OutputReferencesMultiError []error

OutputReferencesMultiError is an error wrapping multiple validation errors returned by OutputReferences.ValidateAll() if the designated constraints aren't met.

func (OutputReferencesMultiError) AllErrors 

func (m OutputReferencesMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (OutputReferencesMultiError) Error 

func (m OutputReferencesMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type OutputReferencesValidationError 

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

OutputReferencesValidationError is the validation error returned by OutputReferences.Validate if the designated constraints aren't met.

func (OutputReferencesValidationError) Cause 

func (e OutputReferencesValidationError) Cause() error

Cause function returns cause value.

func (OutputReferencesValidationError) Error 

func (e OutputReferencesValidationError) Error() string

Error satisfies the builtin error interface

func (OutputReferencesValidationError) ErrorName 

func (e OutputReferencesValidationError) ErrorName() string

ErrorName returns error name.

func (OutputReferencesValidationError) Field 

func (e OutputReferencesValidationError) Field() string

Field function returns field value.

func (OutputReferencesValidationError) Key 

func (e OutputReferencesValidationError) Key() bool

Key function returns key value.

func (OutputReferencesValidationError) Reason 

func (e OutputReferencesValidationError) Reason() string

Reason function returns reason value.

type Outputs 

type Outputs struct {

	// Ordered outputs.
	Literals []*NamedLiteral `protobuf:"bytes,1,rep,name=literals,proto3" json:"literals,omitempty"`
	// contains filtered or unexported fields
}

Output payload for an action.

func (*Outputs) Descriptor deprecated 

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

Deprecated: Use Outputs.ProtoReflect.Descriptor instead.

func (*Outputs) GetLiterals 

func (x *Outputs) GetLiterals() []*NamedLiteral

func (*Outputs) ProtoMessage 

func (*Outputs) ProtoMessage()

func (*Outputs) ProtoReflect 

func (x *Outputs) ProtoReflect() protoreflect.Message

func (*Outputs) Reset 

func (x *Outputs) Reset()

func (*Outputs) String 

func (x *Outputs) String() string

func (*Outputs) Validate 

func (m *Outputs) Validate() error

Validate checks the field values on Outputs with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*Outputs) ValidateAll 

func (m *Outputs) ValidateAll() error

ValidateAll checks the field values on Outputs with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in OutputsMultiError, or nil if none found.

type OutputsMultiError 

type OutputsMultiError []error

OutputsMultiError is an error wrapping multiple validation errors returned by Outputs.ValidateAll() if the designated constraints aren't met.

func (OutputsMultiError) AllErrors 

func (m OutputsMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (OutputsMultiError) Error 

func (m OutputsMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type OutputsValidationError 

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

OutputsValidationError is the validation error returned by Outputs.Validate if the designated constraints aren't met.

func (OutputsValidationError) Cause 

func (e OutputsValidationError) Cause() error

Cause function returns cause value.

func (OutputsValidationError) Error 

func (e OutputsValidationError) Error() string

Error satisfies the builtin error interface

func (OutputsValidationError) ErrorName 

func (e OutputsValidationError) ErrorName() string

ErrorName returns error name.

func (OutputsValidationError) Field 

func (e OutputsValidationError) Field() string

Field function returns field value.

func (OutputsValidationError) Key 

func (e OutputsValidationError) Key() bool

Key function returns key value.

func (OutputsValidationError) Reason 

func (e OutputsValidationError) Reason() string

Reason function returns reason value.

type Phase 

type Phase int32

TODO: define phase transitions 

const (
	Phase_PHASE_UNSPECIFIED           Phase = 0
	Phase_PHASE_QUEUED                Phase = 1
	Phase_PHASE_WAITING_FOR_RESOURCES Phase = 2
	Phase_PHASE_INITIALIZING          Phase = 3
	Phase_PHASE_RUNNING               Phase = 4
	Phase_PHASE_SUCCEEDED             Phase = 5
	Phase_PHASE_FAILED                Phase = 6
	Phase_PHASE_ABORTED               Phase = 7
	Phase_PHASE_TIMED_OUT             Phase = 8
)

func (Phase) Descriptor 

func (Phase) Descriptor() protoreflect.EnumDescriptor

func (Phase) Enum 

func (x Phase) Enum() *Phase

func (Phase) EnumDescriptor deprecated 

func (Phase) EnumDescriptor() ([]byte, []int)

Deprecated: Use Phase.Descriptor instead.

func (Phase) Number 

func (x Phase) Number() protoreflect.EnumNumber

func (Phase) String 

func (x Phase) String() string

func (Phase) Type 

func (Phase) Type() protoreflect.EnumType

type PhaseTransition 

type PhaseTransition struct {

	// The phase.
	Phase Phase `protobuf:"varint,1,opt,name=phase,proto3,enum=flyteidl.workflow.Phase" json:"phase,omitempty"`
	// Time this phase started.
	StartTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	// Time this phase ended, if applicable. For terminal phases, start time will equal end time.
	EndTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=end_time,json=endTime,proto3,oneof" json:"end_time,omitempty"`
	// contains filtered or unexported fields
}

func (*PhaseTransition) Descriptor deprecated 

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

Deprecated: Use PhaseTransition.ProtoReflect.Descriptor instead.

func (*PhaseTransition) GetEndTime 

func (x *PhaseTransition) GetEndTime() *timestamppb.Timestamp

func (*PhaseTransition) GetPhase 

func (x *PhaseTransition) GetPhase() Phase

func (*PhaseTransition) GetStartTime 

func (x *PhaseTransition) GetStartTime() *timestamppb.Timestamp

func (*PhaseTransition) ProtoMessage 

func (*PhaseTransition) ProtoMessage()

func (*PhaseTransition) ProtoReflect 

func (x *PhaseTransition) ProtoReflect() protoreflect.Message

func (*PhaseTransition) Reset 

func (x *PhaseTransition) Reset()

func (*PhaseTransition) String 

func (x *PhaseTransition) String() string

func (*PhaseTransition) Validate 

func (m *PhaseTransition) Validate() error

Validate checks the field values on PhaseTransition with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*PhaseTransition) ValidateAll 

func (m *PhaseTransition) ValidateAll() error

ValidateAll checks the field values on PhaseTransition with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in PhaseTransitionMultiError, or nil if none found.

type PhaseTransitionMultiError 

type PhaseTransitionMultiError []error

PhaseTransitionMultiError is an error wrapping multiple validation errors returned by PhaseTransition.ValidateAll() if the designated constraints aren't met.

func (PhaseTransitionMultiError) AllErrors 

func (m PhaseTransitionMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (PhaseTransitionMultiError) Error 

func (m PhaseTransitionMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type PhaseTransitionValidationError 

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

PhaseTransitionValidationError is the validation error returned by PhaseTransition.Validate if the designated constraints aren't met.

func (PhaseTransitionValidationError) Cause 

func (e PhaseTransitionValidationError) Cause() error

Cause function returns cause value.

func (PhaseTransitionValidationError) Error 

func (e PhaseTransitionValidationError) Error() string

Error satisfies the builtin error interface

func (PhaseTransitionValidationError) ErrorName 

func (e PhaseTransitionValidationError) ErrorName() string

ErrorName returns error name.

func (PhaseTransitionValidationError) Field 

func (e PhaseTransitionValidationError) Field() string

Field function returns field value.

func (PhaseTransitionValidationError) Key 

func (e PhaseTransitionValidationError) Key() bool

Key function returns key value.

func (PhaseTransitionValidationError) Reason 

func (e PhaseTransitionValidationError) Reason() string

Reason function returns reason value.

type PutRequest 

type PutRequest struct {

	// a unique identifier for the action.
	ActionId *common.ActionIdentifier `protobuf:"bytes,1,opt,name=action_id,json=actionId,proto3" json:"action_id,omitempty"`
	// optional name of the parent action if this is a nested action.
	ParentActionName *string `protobuf:"bytes,2,opt,name=parent_action_name,json=parentActionName,proto3,oneof" json:"parent_action_name,omitempty"`
	// currently we will store state as a json serialized `NodeStatus` object. this will be required
	// to seamlessly integrate with existing FlytePropeller node execution logic. we can update this
	// to be a subset of fields in the future if there are necessary performance improvements.
	State string `protobuf:"bytes,3,opt,name=state,proto3" json:"state,omitempty"`
	// contains filtered or unexported fields
}

request message to put the state of an action.

func (*PutRequest) Descriptor deprecated 

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

Deprecated: Use PutRequest.ProtoReflect.Descriptor instead.

func (*PutRequest) GetActionId 

func (x *PutRequest) GetActionId() *common.ActionIdentifier

func (*PutRequest) GetParentActionName 

func (x *PutRequest) GetParentActionName() string

func (*PutRequest) GetState 

func (x *PutRequest) GetState() string

func (*PutRequest) ProtoMessage 

func (*PutRequest) ProtoMessage()

func (*PutRequest) ProtoReflect 

func (x *PutRequest) ProtoReflect() protoreflect.Message

func (*PutRequest) Reset 

func (x *PutRequest) Reset()

func (*PutRequest) String 

func (x *PutRequest) String() string

func (*PutRequest) Validate 

func (m *PutRequest) Validate() error

Validate checks the field values on PutRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*PutRequest) ValidateAll 

func (m *PutRequest) ValidateAll() error

ValidateAll checks the field values on PutRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in PutRequestMultiError, or nil if none found.

type PutRequestMultiError 

type PutRequestMultiError []error

PutRequestMultiError is an error wrapping multiple validation errors returned by PutRequest.ValidateAll() if the designated constraints aren't met.

func (PutRequestMultiError) AllErrors 

func (m PutRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (PutRequestMultiError) Error 

func (m PutRequestMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type PutRequestValidationError 

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

PutRequestValidationError is the validation error returned by PutRequest.Validate if the designated constraints aren't met.

func (PutRequestValidationError) Cause 

func (e PutRequestValidationError) Cause() error

Cause function returns cause value.

func (PutRequestValidationError) Error 

func (e PutRequestValidationError) Error() string

Error satisfies the builtin error interface

func (PutRequestValidationError) ErrorName 

func (e PutRequestValidationError) ErrorName() string

ErrorName returns error name.

func (PutRequestValidationError) Field 

func (e PutRequestValidationError) Field() string

Field function returns field value.

func (PutRequestValidationError) Key 

func (e PutRequestValidationError) Key() bool

Key function returns key value.

func (PutRequestValidationError) Reason 

func (e PutRequestValidationError) Reason() string

Reason function returns reason value.

type PutResponse 

type PutResponse struct {

	// a unique identifier for the action.
	ActionId *common.ActionIdentifier `protobuf:"bytes,1,opt,name=action_id,json=actionId,proto3" json:"action_id,omitempty"`
	// The result.
	Status *status.Status `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

response message for putting the state of an action.

func (*PutResponse) Descriptor deprecated 

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

Deprecated: Use PutResponse.ProtoReflect.Descriptor instead.

func (*PutResponse) GetActionId 

func (x *PutResponse) GetActionId() *common.ActionIdentifier

func (*PutResponse) GetStatus 

func (x *PutResponse) GetStatus() *status.Status

func (*PutResponse) ProtoMessage 

func (*PutResponse) ProtoMessage()

func (*PutResponse) ProtoReflect 

func (x *PutResponse) ProtoReflect() protoreflect.Message

func (*PutResponse) Reset 

func (x *PutResponse) Reset()

func (*PutResponse) String 

func (x *PutResponse) String() string

func (*PutResponse) Validate 

func (m *PutResponse) Validate() error

Validate checks the field values on PutResponse with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*PutResponse) ValidateAll 

func (m *PutResponse) ValidateAll() error

ValidateAll checks the field values on PutResponse with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in PutResponseMultiError, or nil if none found.

type PutResponseMultiError 

type PutResponseMultiError []error

PutResponseMultiError is an error wrapping multiple validation errors returned by PutResponse.ValidateAll() if the designated constraints aren't met.

func (PutResponseMultiError) AllErrors 

func (m PutResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (PutResponseMultiError) Error 

func (m PutResponseMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type PutResponseValidationError 

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

PutResponseValidationError is the validation error returned by PutResponse.Validate if the designated constraints aren't met.

func (PutResponseValidationError) Cause 

func (e PutResponseValidationError) Cause() error

Cause function returns cause value.

func (PutResponseValidationError) Error 

func (e PutResponseValidationError) Error() string

Error satisfies the builtin error interface

func (PutResponseValidationError) ErrorName 

func (e PutResponseValidationError) ErrorName() string

ErrorName returns error name.

func (PutResponseValidationError) Field 

func (e PutResponseValidationError) Field() string

Field function returns field value.

func (PutResponseValidationError) Key 

func (e PutResponseValidationError) Key() bool

Key function returns key value.

func (PutResponseValidationError) Reason 

func (e PutResponseValidationError) Reason() string

Reason function returns reason value.

type QueueServiceClient 

type QueueServiceClient interface {
	// queue a new action for execution.
	EnqueueAction(ctx context.Context, in *EnqueueActionRequest, opts ...grpc.CallOption) (*EnqueueActionResponse, error)
	// abort a queued run.
	AbortQueuedRun(ctx context.Context, in *AbortQueuedRunRequest, opts ...grpc.CallOption) (*AbortQueuedRunResponse, error)
}

QueueServiceClient is the client API for QueueService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewQueueServiceClient 

func NewQueueServiceClient(cc grpc.ClientConnInterface) QueueServiceClient

type QueueServiceServer 

type QueueServiceServer interface {
	// queue a new action for execution.
	EnqueueAction(context.Context, *EnqueueActionRequest) (*EnqueueActionResponse, error)
	// abort a queued run.
	AbortQueuedRun(context.Context, *AbortQueuedRunRequest) (*AbortQueuedRunResponse, error)
}

QueueServiceServer is the server API for QueueService service. All implementations should embed UnimplementedQueueServiceServer for forward compatibility

type Run 

type Run struct {

	// Lightweight information about the root action.
	Action *Action `protobuf:"bytes,1,opt,name=action,proto3" json:"action,omitempty"`
	// contains filtered or unexported fields
}

func (*Run) Descriptor deprecated 

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

Deprecated: Use Run.ProtoReflect.Descriptor instead.

func (*Run) GetAction 

func (x *Run) GetAction() *Action

func (*Run) ProtoMessage 

func (*Run) ProtoMessage()

func (*Run) ProtoReflect 

func (x *Run) ProtoReflect() protoreflect.Message

func (*Run) Reset 

func (x *Run) Reset()

func (*Run) String 

func (x *Run) String() string

func (*Run) Validate 

func (m *Run) Validate() error

Validate checks the field values on Run with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*Run) ValidateAll 

func (m *Run) ValidateAll() error

ValidateAll checks the field values on Run with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in RunMultiError, or nil if none found.

type RunDetails 

type RunDetails struct {

	// Run spec.
	RunSpec *RunSpec `protobuf:"bytes,1,opt,name=run_spec,json=runSpec,proto3" json:"run_spec,omitempty"`
	// Detailed information about the root action.
	Action *ActionDetails `protobuf:"bytes,2,opt,name=action,proto3" json:"action,omitempty"`
	// contains filtered or unexported fields
}

func (*RunDetails) Descriptor deprecated 

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

Deprecated: Use RunDetails.ProtoReflect.Descriptor instead.

func (*RunDetails) GetAction 

func (x *RunDetails) GetAction() *ActionDetails

func (*RunDetails) GetRunSpec 

func (x *RunDetails) GetRunSpec() *RunSpec

func (*RunDetails) ProtoMessage 

func (*RunDetails) ProtoMessage()

func (*RunDetails) ProtoReflect 

func (x *RunDetails) ProtoReflect() protoreflect.Message

func (*RunDetails) Reset 

func (x *RunDetails) Reset()

func (*RunDetails) String 

func (x *RunDetails) String() string

func (*RunDetails) Validate 

func (m *RunDetails) Validate() error

Validate checks the field values on RunDetails with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*RunDetails) ValidateAll 

func (m *RunDetails) ValidateAll() error

ValidateAll checks the field values on RunDetails with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in RunDetailsMultiError, or nil if none found.

type RunDetailsMultiError 

type RunDetailsMultiError []error

RunDetailsMultiError is an error wrapping multiple validation errors returned by RunDetails.ValidateAll() if the designated constraints aren't met.

func (RunDetailsMultiError) AllErrors 

func (m RunDetailsMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (RunDetailsMultiError) Error 

func (m RunDetailsMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type RunDetailsValidationError 

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

RunDetailsValidationError is the validation error returned by RunDetails.Validate if the designated constraints aren't met.

func (RunDetailsValidationError) Cause 

func (e RunDetailsValidationError) Cause() error

Cause function returns cause value.

func (RunDetailsValidationError) Error 

func (e RunDetailsValidationError) Error() string

Error satisfies the builtin error interface

func (RunDetailsValidationError) ErrorName 

func (e RunDetailsValidationError) ErrorName() string

ErrorName returns error name.

func (RunDetailsValidationError) Field 

func (e RunDetailsValidationError) Field() string

Field function returns field value.

func (RunDetailsValidationError) Key 

func (e RunDetailsValidationError) Key() bool

Key function returns key value.

func (RunDetailsValidationError) Reason 

func (e RunDetailsValidationError) Reason() string

Reason function returns reason value.

type RunLogsServiceClient 

type RunLogsServiceClient interface {
	TailLogs(ctx context.Context, in *TailLogsRequest, opts ...grpc.CallOption) (RunLogsService_TailLogsClient, error)
}

RunLogsServiceClient is the client API for RunLogsService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewRunLogsServiceClient 

func NewRunLogsServiceClient(cc grpc.ClientConnInterface) RunLogsServiceClient

type RunLogsServiceServer 

type RunLogsServiceServer interface {
	TailLogs(*TailLogsRequest, RunLogsService_TailLogsServer) error
}

RunLogsServiceServer is the server API for RunLogsService service. All implementations should embed UnimplementedRunLogsServiceServer for forward compatibility

type RunLogsService_TailLogsClient 

type RunLogsService_TailLogsClient interface {
	Recv() (*TailLogsResponse, error)
	grpc.ClientStream
}

type RunLogsService_TailLogsServer 

type RunLogsService_TailLogsServer interface {
	Send(*TailLogsResponse) error
	grpc.ServerStream
}

type RunMultiError 

type RunMultiError []error

RunMultiError is an error wrapping multiple validation errors returned by Run.ValidateAll() if the designated constraints aren't met.

func (RunMultiError) AllErrors 

func (m RunMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (RunMultiError) Error 

func (m RunMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type RunServiceClient 

type RunServiceClient interface {
	// Create a new run of the given task.
	CreateRun(ctx context.Context, in *CreateRunRequest, opts ...grpc.CallOption) (*CreateRunResponse, error)
	// Abort a run.
	AbortRun(ctx context.Context, in *AbortRunRequest, opts ...grpc.CallOption) (*AbortRunResponse, error)
	// Get detailed information about a run.
	GetRunDetails(ctx context.Context, in *GetRunDetailsRequest, opts ...grpc.CallOption) (*GetRunDetailsResponse, error)
	// Stream detailed information updates about a run. The call will terminate when the run reaches a terminal phase.
	WatchRunDetails(ctx context.Context, in *WatchRunDetailsRequest, opts ...grpc.CallOption) (RunService_WatchRunDetailsClient, error)
	// Get detailed information about an action.
	GetActionDetails(ctx context.Context, in *GetActionDetailsRequest, opts ...grpc.CallOption) (*GetActionDetailsResponse, error)
	// Stream detailed information updates about an action. The call will terminate when the action reaches a terminal phase.
	WatchActionDetails(ctx context.Context, in *WatchActionDetailsRequest, opts ...grpc.CallOption) (RunService_WatchActionDetailsClient, error)
	// Get input and output for an action.
	GetActionData(ctx context.Context, in *GetActionDataRequest, opts ...grpc.CallOption) (*GetActionDataResponse, error)
	// List runs based on the provided filter criteria.
	ListRuns(ctx context.Context, in *ListRunsRequest, opts ...grpc.CallOption) (*ListRunsResponse, error)
	// Stream updates for runs based on the provided filter criteria. Responses may include newly discovered
	// runs or updates to existing ones from the point of invocation.
	WatchRuns(ctx context.Context, in *WatchRunsRequest, opts ...grpc.CallOption) (RunService_WatchRunsClient, error)
	// List all actions for a given run.
	ListActions(ctx context.Context, in *ListActionsRequest, opts ...grpc.CallOption) (*ListActionsResponse, error)
	// Stream updates for actions given a run. Responses may include newly discovered nested runs or updates
	// to  existing ones from the point of invocation.
	WatchActions(ctx context.Context, in *WatchActionsRequest, opts ...grpc.CallOption) (RunService_WatchActionsClient, error)
	// Stream of k8s cluster events in human readable form
	WatchClusterEvents(ctx context.Context, in *WatchClusterEventsRequest, opts ...grpc.CallOption) (RunService_WatchClusterEventsClient, error)
}

RunServiceClient is the client API for RunService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewRunServiceClient 

func NewRunServiceClient(cc grpc.ClientConnInterface) RunServiceClient

type RunServiceServer 

type RunServiceServer interface {
	// Create a new run of the given task.
	CreateRun(context.Context, *CreateRunRequest) (*CreateRunResponse, error)
	// Abort a run.
	AbortRun(context.Context, *AbortRunRequest) (*AbortRunResponse, error)
	// Get detailed information about a run.
	GetRunDetails(context.Context, *GetRunDetailsRequest) (*GetRunDetailsResponse, error)
	// Stream detailed information updates about a run. The call will terminate when the run reaches a terminal phase.
	WatchRunDetails(*WatchRunDetailsRequest, RunService_WatchRunDetailsServer) error
	// Get detailed information about an action.
	GetActionDetails(context.Context, *GetActionDetailsRequest) (*GetActionDetailsResponse, error)
	// Stream detailed information updates about an action. The call will terminate when the action reaches a terminal phase.
	WatchActionDetails(*WatchActionDetailsRequest, RunService_WatchActionDetailsServer) error
	// Get input and output for an action.
	GetActionData(context.Context, *GetActionDataRequest) (*GetActionDataResponse, error)
	// List runs based on the provided filter criteria.
	ListRuns(context.Context, *ListRunsRequest) (*ListRunsResponse, error)
	// Stream updates for runs based on the provided filter criteria. Responses may include newly discovered
	// runs or updates to existing ones from the point of invocation.
	WatchRuns(*WatchRunsRequest, RunService_WatchRunsServer) error
	// List all actions for a given run.
	ListActions(context.Context, *ListActionsRequest) (*ListActionsResponse, error)
	// Stream updates for actions given a run. Responses may include newly discovered nested runs or updates
	// to  existing ones from the point of invocation.
	WatchActions(*WatchActionsRequest, RunService_WatchActionsServer) error
	// Stream of k8s cluster events in human readable form
	WatchClusterEvents(*WatchClusterEventsRequest, RunService_WatchClusterEventsServer) error
}

RunServiceServer is the server API for RunService service. All implementations should embed UnimplementedRunServiceServer for forward compatibility

type RunService_WatchActionDetailsClient 

type RunService_WatchActionDetailsClient interface {
	Recv() (*WatchActionDetailsResponse, error)
	grpc.ClientStream
}

type RunService_WatchActionDetailsServer 

type RunService_WatchActionDetailsServer interface {
	Send(*WatchActionDetailsResponse) error
	grpc.ServerStream
}

type RunService_WatchActionsClient 

type RunService_WatchActionsClient interface {
	Recv() (*WatchActionsResponse, error)
	grpc.ClientStream
}

type RunService_WatchActionsServer 

type RunService_WatchActionsServer interface {
	Send(*WatchActionsResponse) error
	grpc.ServerStream
}

type RunService_WatchClusterEventsClient 

type RunService_WatchClusterEventsClient interface {
	Recv() (*WatchClusterEventsResponse, error)
	grpc.ClientStream
}

type RunService_WatchClusterEventsServer 

type RunService_WatchClusterEventsServer interface {
	Send(*WatchClusterEventsResponse) error
	grpc.ServerStream
}

type RunService_WatchRunDetailsClient 

type RunService_WatchRunDetailsClient interface {
	Recv() (*WatchRunDetailsResponse, error)
	grpc.ClientStream
}

type RunService_WatchRunDetailsServer 

type RunService_WatchRunDetailsServer interface {
	Send(*WatchRunDetailsResponse) error
	grpc.ServerStream
}

type RunService_WatchRunsClient 

type RunService_WatchRunsClient interface {
	Recv() (*WatchRunsResponse, error)
	grpc.ClientStream
}

type RunService_WatchRunsServer 

type RunService_WatchRunsServer interface {
	Send(*WatchRunsResponse) error
	grpc.ServerStream
}

type RunSpec 

type RunSpec struct {

	// Labels to apply to the run.
	Labels *Labels `protobuf:"bytes,1,opt,name=labels,proto3" json:"labels,omitempty"`
	// Annotations to apply to the run.
	Annotations *Annotations `protobuf:"bytes,2,opt,name=annotations,proto3" json:"annotations,omitempty"`
	// Envs to apply to the run.
	Envs *Envs `protobuf:"bytes,3,opt,name=envs,proto3" json:"envs,omitempty"`
	// Explicit override for executing this run as interruptible or not. If not set, use the default.
	Interruptible *wrapperspb.BoolValue `protobuf:"bytes,4,opt,name=interruptible,proto3" json:"interruptible,omitempty"`
	// If true, recompute outputs for this run and overwrite any existing cache.
	OverwriteCache bool `protobuf:"varint,5,opt,name=overwrite_cache,json=overwriteCache,proto3" json:"overwrite_cache,omitempty"`
	// the specific cluster that this action should be executed on. this value will be used as the
	// default for all actions in the run unless overridden.
	Cluster string `protobuf:"bytes,6,opt,name=cluster,proto3" json:"cluster,omitempty"`
	// contains filtered or unexported fields
}

func (*RunSpec) Descriptor deprecated 

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

Deprecated: Use RunSpec.ProtoReflect.Descriptor instead.

func (*RunSpec) GetAnnotations 

func (x *RunSpec) GetAnnotations() *Annotations

func (*RunSpec) GetCluster 

func (x *RunSpec) GetCluster() string

func (*RunSpec) GetEnvs 

func (x *RunSpec) GetEnvs() *Envs

func (*RunSpec) GetInterruptible 

func (x *RunSpec) GetInterruptible() *wrapperspb.BoolValue

func (*RunSpec) GetLabels 

func (x *RunSpec) GetLabels() *Labels

func (*RunSpec) GetOverwriteCache 

func (x *RunSpec) GetOverwriteCache() bool

func (*RunSpec) ProtoMessage 

func (*RunSpec) ProtoMessage()

func (*RunSpec) ProtoReflect 

func (x *RunSpec) ProtoReflect() protoreflect.Message

func (*RunSpec) Reset 

func (x *RunSpec) Reset()

func (*RunSpec) String 

func (x *RunSpec) String() string

func (*RunSpec) Validate 

func (m *RunSpec) Validate() error

Validate checks the field values on RunSpec with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*RunSpec) ValidateAll 

func (m *RunSpec) ValidateAll() error

ValidateAll checks the field values on RunSpec with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in RunSpecMultiError, or nil if none found.

type RunSpecMultiError 

type RunSpecMultiError []error

RunSpecMultiError is an error wrapping multiple validation errors returned by RunSpec.ValidateAll() if the designated constraints aren't met.

func (RunSpecMultiError) AllErrors 

func (m RunSpecMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (RunSpecMultiError) Error 

func (m RunSpecMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type RunSpecValidationError 

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

RunSpecValidationError is the validation error returned by RunSpec.Validate if the designated constraints aren't met.

func (RunSpecValidationError) Cause 

func (e RunSpecValidationError) Cause() error

Cause function returns cause value.

func (RunSpecValidationError) Error 

func (e RunSpecValidationError) Error() string

Error satisfies the builtin error interface

func (RunSpecValidationError) ErrorName 

func (e RunSpecValidationError) ErrorName() string

ErrorName returns error name.

func (RunSpecValidationError) Field 

func (e RunSpecValidationError) Field() string

Field function returns field value.

func (RunSpecValidationError) Key 

func (e RunSpecValidationError) Key() bool

Key function returns key value.

func (RunSpecValidationError) Reason 

func (e RunSpecValidationError) Reason() string

Reason function returns reason value.

type RunValidationError 

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

RunValidationError is the validation error returned by Run.Validate if the designated constraints aren't met.

func (RunValidationError) Cause 

func (e RunValidationError) Cause() error

Cause function returns cause value.

func (RunValidationError) Error 

func (e RunValidationError) Error() string

Error satisfies the builtin error interface

func (RunValidationError) ErrorName 

func (e RunValidationError) ErrorName() string

ErrorName returns error name.

func (RunValidationError) Field 

func (e RunValidationError) Field() string

Field function returns field value.

func (RunValidationError) Key 

func (e RunValidationError) Key() bool

Key function returns key value.

func (RunValidationError) Reason 

func (e RunValidationError) Reason() string

Reason function returns reason value.

type StateServiceClient 

type StateServiceClient interface {
	// put the state of an action.
	Put(ctx context.Context, opts ...grpc.CallOption) (StateService_PutClient, error)
	// get the state of an action.
	Get(ctx context.Context, opts ...grpc.CallOption) (StateService_GetClient, error)
	// watch for updates to the state of actions. this api guarantees at-least-once delivery semantics.
	Watch(ctx context.Context, in *WatchRequest, opts ...grpc.CallOption) (StateService_WatchClient, error)
}

StateServiceClient is the client API for StateService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewStateServiceClient 

func NewStateServiceClient(cc grpc.ClientConnInterface) StateServiceClient

type StateServiceServer 

type StateServiceServer interface {
	// put the state of an action.
	Put(StateService_PutServer) error
	// get the state of an action.
	Get(StateService_GetServer) error
	// watch for updates to the state of actions. this api guarantees at-least-once delivery semantics.
	Watch(*WatchRequest, StateService_WatchServer) error
}

StateServiceServer is the server API for StateService service. All implementations should embed UnimplementedStateServiceServer for forward compatibility

type StateService_GetClient 

type StateService_GetClient interface {
	Send(*GetRequest) error
	Recv() (*GetResponse, error)
	grpc.ClientStream
}

type StateService_GetServer 

type StateService_GetServer interface {
	Send(*GetResponse) error
	Recv() (*GetRequest, error)
	grpc.ServerStream
}

type StateService_PutClient 

type StateService_PutClient interface {
	Send(*PutRequest) error
	Recv() (*PutResponse, error)
	grpc.ClientStream
}

type StateService_PutServer 

type StateService_PutServer interface {
	Send(*PutResponse) error
	Recv() (*PutRequest, error)
	grpc.ServerStream
}

type StateService_WatchClient 

type StateService_WatchClient interface {
	Recv() (*WatchResponse, error)
	grpc.ClientStream
}

type StateService_WatchServer 

type StateService_WatchServer interface {
	Send(*WatchResponse) error
	grpc.ServerStream
}

type TailLogsRequest 

type TailLogsRequest struct {

	// The action id.
	ActionId *common.ActionIdentifier `protobuf:"bytes,1,opt,name=action_id,json=actionId,proto3" json:"action_id,omitempty"`
	// The attempt number.
	Attempt uint32 `protobuf:"varint,2,opt,name=attempt,proto3" json:"attempt,omitempty"`
	// contains filtered or unexported fields
}

Request message for tailing logs.

func (*TailLogsRequest) Descriptor deprecated 

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

Deprecated: Use TailLogsRequest.ProtoReflect.Descriptor instead.

func (*TailLogsRequest) GetActionId 

func (x *TailLogsRequest) GetActionId() *common.ActionIdentifier

func (*TailLogsRequest) GetAttempt 

func (x *TailLogsRequest) GetAttempt() uint32

func (*TailLogsRequest) ProtoMessage 

func (*TailLogsRequest) ProtoMessage()

func (*TailLogsRequest) ProtoReflect 

func (x *TailLogsRequest) ProtoReflect() protoreflect.Message

func (*TailLogsRequest) Reset 

func (x *TailLogsRequest) Reset()

func (*TailLogsRequest) String 

func (x *TailLogsRequest) String() string

func (*TailLogsRequest) Validate 

func (m *TailLogsRequest) Validate() error

Validate checks the field values on TailLogsRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*TailLogsRequest) ValidateAll 

func (m *TailLogsRequest) ValidateAll() error

ValidateAll checks the field values on TailLogsRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in TailLogsRequestMultiError, or nil if none found.

type TailLogsRequestMultiError 

type TailLogsRequestMultiError []error

TailLogsRequestMultiError is an error wrapping multiple validation errors returned by TailLogsRequest.ValidateAll() if the designated constraints aren't met.

func (TailLogsRequestMultiError) AllErrors 

func (m TailLogsRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (TailLogsRequestMultiError) Error 

func (m TailLogsRequestMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type TailLogsRequestValidationError 

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

TailLogsRequestValidationError is the validation error returned by TailLogsRequest.Validate if the designated constraints aren't met.

func (TailLogsRequestValidationError) Cause 

func (e TailLogsRequestValidationError) Cause() error

Cause function returns cause value.

func (TailLogsRequestValidationError) Error 

func (e TailLogsRequestValidationError) Error() string

Error satisfies the builtin error interface

func (TailLogsRequestValidationError) ErrorName 

func (e TailLogsRequestValidationError) ErrorName() string

ErrorName returns error name.

func (TailLogsRequestValidationError) Field 

func (e TailLogsRequestValidationError) Field() string

Field function returns field value.

func (TailLogsRequestValidationError) Key 

func (e TailLogsRequestValidationError) Key() bool

Key function returns key value.

func (TailLogsRequestValidationError) Reason 

func (e TailLogsRequestValidationError) Reason() string

Reason function returns reason value.

type TailLogsResponse 

type TailLogsResponse struct {

	// One or more batches of logs.
	Logs []*TailLogsResponse_Logs `protobuf:"bytes,1,rep,name=logs,proto3" json:"logs,omitempty"`
	// contains filtered or unexported fields
}

Reponse message for tailing logs.

func (*TailLogsResponse) Descriptor deprecated 

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

Deprecated: Use TailLogsResponse.ProtoReflect.Descriptor instead.

func (*TailLogsResponse) GetLogs 

func (x *TailLogsResponse) GetLogs() []*TailLogsResponse_Logs

func (*TailLogsResponse) ProtoMessage 

func (*TailLogsResponse) ProtoMessage()

func (*TailLogsResponse) ProtoReflect 

func (x *TailLogsResponse) ProtoReflect() protoreflect.Message

func (*TailLogsResponse) Reset 

func (x *TailLogsResponse) Reset()

func (*TailLogsResponse) String 

func (x *TailLogsResponse) String() string

func (*TailLogsResponse) Validate 

func (m *TailLogsResponse) Validate() error

Validate checks the field values on TailLogsResponse with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*TailLogsResponse) ValidateAll 

func (m *TailLogsResponse) ValidateAll() error

ValidateAll checks the field values on TailLogsResponse with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in TailLogsResponseMultiError, or nil if none found.

type TailLogsResponseMultiError 

type TailLogsResponseMultiError []error

TailLogsResponseMultiError is an error wrapping multiple validation errors returned by TailLogsResponse.ValidateAll() if the designated constraints aren't met.

func (TailLogsResponseMultiError) AllErrors 

func (m TailLogsResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (TailLogsResponseMultiError) Error 

func (m TailLogsResponseMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type TailLogsResponseValidationError 

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

TailLogsResponseValidationError is the validation error returned by TailLogsResponse.Validate if the designated constraints aren't met.

func (TailLogsResponseValidationError) Cause 

func (e TailLogsResponseValidationError) Cause() error

Cause function returns cause value.

func (TailLogsResponseValidationError) Error 

func (e TailLogsResponseValidationError) Error() string

Error satisfies the builtin error interface

func (TailLogsResponseValidationError) ErrorName 

func (e TailLogsResponseValidationError) ErrorName() string

ErrorName returns error name.

func (TailLogsResponseValidationError) Field 

func (e TailLogsResponseValidationError) Field() string

Field function returns field value.

func (TailLogsResponseValidationError) Key 

func (e TailLogsResponseValidationError) Key() bool

Key function returns key value.

func (TailLogsResponseValidationError) Reason 

func (e TailLogsResponseValidationError) Reason() string

Reason function returns reason value.

type TailLogsResponse_Logs 

type TailLogsResponse_Logs struct {

	// Structured log lines.
	Lines []*dataplane.LogLine `protobuf:"bytes,1,rep,name=lines,proto3" json:"lines,omitempty"`
	// contains filtered or unexported fields
}

A batch of logs.

func (*TailLogsResponse_Logs) Descriptor deprecated 

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

Deprecated: Use TailLogsResponse_Logs.ProtoReflect.Descriptor instead.

func (*TailLogsResponse_Logs) GetLines 

func (x *TailLogsResponse_Logs) GetLines() []*dataplane.LogLine

func (*TailLogsResponse_Logs) ProtoMessage 

func (*TailLogsResponse_Logs) ProtoMessage()

func (*TailLogsResponse_Logs) ProtoReflect 

func (x *TailLogsResponse_Logs) ProtoReflect() protoreflect.Message

func (*TailLogsResponse_Logs) Reset 

func (x *TailLogsResponse_Logs) Reset()

func (*TailLogsResponse_Logs) String 

func (x *TailLogsResponse_Logs) String() string

func (*TailLogsResponse_Logs) Validate 

func (m *TailLogsResponse_Logs) Validate() error

Validate checks the field values on TailLogsResponse_Logs with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*TailLogsResponse_Logs) ValidateAll 

func (m *TailLogsResponse_Logs) ValidateAll() error

ValidateAll checks the field values on TailLogsResponse_Logs with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in TailLogsResponse_LogsMultiError, or nil if none found.

type TailLogsResponse_LogsMultiError 

type TailLogsResponse_LogsMultiError []error

TailLogsResponse_LogsMultiError is an error wrapping multiple validation errors returned by TailLogsResponse_Logs.ValidateAll() if the designated constraints aren't met.

func (TailLogsResponse_LogsMultiError) AllErrors 

func (m TailLogsResponse_LogsMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (TailLogsResponse_LogsMultiError) Error 

func (m TailLogsResponse_LogsMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type TailLogsResponse_LogsValidationError 

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

TailLogsResponse_LogsValidationError is the validation error returned by TailLogsResponse_Logs.Validate if the designated constraints aren't met.

func (TailLogsResponse_LogsValidationError) Cause 

func (e TailLogsResponse_LogsValidationError) Cause() error

Cause function returns cause value.

func (TailLogsResponse_LogsValidationError) Error 

func (e TailLogsResponse_LogsValidationError) Error() string

Error satisfies the builtin error interface

func (TailLogsResponse_LogsValidationError) ErrorName 

func (e TailLogsResponse_LogsValidationError) ErrorName() string

ErrorName returns error name.

func (TailLogsResponse_LogsValidationError) Field 

func (e TailLogsResponse_LogsValidationError) Field() string

Field function returns field value.

func (TailLogsResponse_LogsValidationError) Key 

func (e TailLogsResponse_LogsValidationError) Key() bool

Key function returns key value.

func (TailLogsResponse_LogsValidationError) Reason 

func (e TailLogsResponse_LogsValidationError) Reason() string

Reason function returns reason value.

type Task 

type Task struct {

	// Id for this task.
	TaskId *TaskIdentifier `protobuf:"bytes,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	// Metadata for this task.
	Metadata *TaskMetadata `protobuf:"bytes,2,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

Lightweight representation of a task.

func (*Task) Descriptor deprecated 

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

Deprecated: Use Task.ProtoReflect.Descriptor instead.

func (*Task) GetMetadata 

func (x *Task) GetMetadata() *TaskMetadata

func (*Task) GetTaskId 

func (x *Task) GetTaskId() *TaskIdentifier

func (*Task) ProtoMessage 

func (*Task) ProtoMessage()

func (*Task) ProtoReflect 

func (x *Task) ProtoReflect() protoreflect.Message

func (*Task) Reset 

func (x *Task) Reset()

func (*Task) String 

func (x *Task) String() string

func (*Task) Validate 

func (m *Task) Validate() error

Validate checks the field values on Task with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*Task) ValidateAll 

func (m *Task) ValidateAll() error

ValidateAll checks the field values on Task with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in TaskMultiError, or nil if none found.

type TaskAction 

type TaskAction struct {

	// a unique identifier for the task this action is associated with, if applicable.
	Id *TaskIdentifier `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// the definition of the task to be executed.
	Spec *TaskSpec `protobuf:"bytes,2,opt,name=spec,proto3" json:"spec,omitempty"`
	// Enables caching when set and specifies the cache version to use.
	CacheKey *wrapperspb.StringValue `protobuf:"bytes,3,opt,name=cache_key,json=cacheKey,proto3" json:"cache_key,omitempty"`
	// the specific cluster that this action should be executed on. if not set, the cluster from the
	// `RunSpec` will be used.
	Cluster string `protobuf:"bytes,4,opt,name=cluster,proto3" json:"cluster,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskAction) Descriptor deprecated 

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

Deprecated: Use TaskAction.ProtoReflect.Descriptor instead.

func (*TaskAction) GetCacheKey 

func (x *TaskAction) GetCacheKey() *wrapperspb.StringValue

func (*TaskAction) GetCluster 

func (x *TaskAction) GetCluster() string

func (*TaskAction) GetId 

func (x *TaskAction) GetId() *TaskIdentifier

func (*TaskAction) GetSpec 

func (x *TaskAction) GetSpec() *TaskSpec

func (*TaskAction) ProtoMessage 

func (*TaskAction) ProtoMessage()

func (*TaskAction) ProtoReflect 

func (x *TaskAction) ProtoReflect() protoreflect.Message

func (*TaskAction) Reset 

func (x *TaskAction) Reset()

func (*TaskAction) String 

func (x *TaskAction) String() string

func (*TaskAction) Validate 

func (m *TaskAction) Validate() error

Validate checks the field values on TaskAction with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*TaskAction) ValidateAll 

func (m *TaskAction) ValidateAll() error

ValidateAll checks the field values on TaskAction with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in TaskActionMultiError, or nil if none found.

type TaskActionMetadata 

type TaskActionMetadata struct {

	// Id of the task this action is associated with.
	Id *TaskIdentifier `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Extensible task type.
	TaskType string `protobuf:"bytes,2,opt,name=task_type,json=taskType,proto3" json:"task_type,omitempty"`
	// The short name for this task.
	ShortName string `protobuf:"bytes,3,opt,name=short_name,json=shortName,proto3" json:"short_name,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskActionMetadata) Descriptor deprecated 

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

Deprecated: Use TaskActionMetadata.ProtoReflect.Descriptor instead.

func (*TaskActionMetadata) GetId 

func (x *TaskActionMetadata) GetId() *TaskIdentifier

func (*TaskActionMetadata) GetShortName 

func (x *TaskActionMetadata) GetShortName() string

func (*TaskActionMetadata) GetTaskType 

func (x *TaskActionMetadata) GetTaskType() string

func (*TaskActionMetadata) ProtoMessage 

func (*TaskActionMetadata) ProtoMessage()

func (*TaskActionMetadata) ProtoReflect 

func (x *TaskActionMetadata) ProtoReflect() protoreflect.Message

func (*TaskActionMetadata) Reset 

func (x *TaskActionMetadata) Reset()

func (*TaskActionMetadata) String 

func (x *TaskActionMetadata) String() string

func (*TaskActionMetadata) Validate 

func (m *TaskActionMetadata) Validate() error

Validate checks the field values on TaskActionMetadata with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*TaskActionMetadata) ValidateAll 

func (m *TaskActionMetadata) ValidateAll() error

ValidateAll checks the field values on TaskActionMetadata with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in TaskActionMetadataMultiError, or nil if none found.

type TaskActionMetadataMultiError 

type TaskActionMetadataMultiError []error

TaskActionMetadataMultiError is an error wrapping multiple validation errors returned by TaskActionMetadata.ValidateAll() if the designated constraints aren't met.

func (TaskActionMetadataMultiError) AllErrors 

func (m TaskActionMetadataMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (TaskActionMetadataMultiError) Error 

func (m TaskActionMetadataMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type TaskActionMetadataValidationError 

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

TaskActionMetadataValidationError is the validation error returned by TaskActionMetadata.Validate if the designated constraints aren't met.

func (TaskActionMetadataValidationError) Cause 

func (e TaskActionMetadataValidationError) Cause() error

Cause function returns cause value.

func (TaskActionMetadataValidationError) Error 

func (e TaskActionMetadataValidationError) Error() string

Error satisfies the builtin error interface

func (TaskActionMetadataValidationError) ErrorName 

func (e TaskActionMetadataValidationError) ErrorName() string

ErrorName returns error name.

func (TaskActionMetadataValidationError) Field 

func (e TaskActionMetadataValidationError) Field() string

Field function returns field value.

func (TaskActionMetadataValidationError) Key 

func (e TaskActionMetadataValidationError) Key() bool

Key function returns key value.

func (TaskActionMetadataValidationError) Reason 

func (e TaskActionMetadataValidationError) Reason() string

Reason function returns reason value.

type TaskActionMultiError 

type TaskActionMultiError []error

TaskActionMultiError is an error wrapping multiple validation errors returned by TaskAction.ValidateAll() if the designated constraints aren't met.

func (TaskActionMultiError) AllErrors 

func (m TaskActionMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (TaskActionMultiError) Error 

func (m TaskActionMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type TaskActionValidationError 

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

TaskActionValidationError is the validation error returned by TaskAction.Validate if the designated constraints aren't met.

func (TaskActionValidationError) Cause 

func (e TaskActionValidationError) Cause() error

Cause function returns cause value.

func (TaskActionValidationError) Error 

func (e TaskActionValidationError) Error() string

Error satisfies the builtin error interface

func (TaskActionValidationError) ErrorName 

func (e TaskActionValidationError) ErrorName() string

ErrorName returns error name.

func (TaskActionValidationError) Field 

func (e TaskActionValidationError) Field() string

Field function returns field value.

func (TaskActionValidationError) Key 

func (e TaskActionValidationError) Key() bool

Key function returns key value.

func (TaskActionValidationError) Reason 

func (e TaskActionValidationError) Reason() string

Reason function returns reason value.

type TaskDetails 

type TaskDetails struct {

	// Id for this task.
	TaskId *TaskIdentifier `protobuf:"bytes,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	// Metadata for this task.
	Metadata *TaskMetadata `protobuf:"bytes,2,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// Specification for this task.
	Spec *TaskSpec `protobuf:"bytes,3,opt,name=spec,proto3" json:"spec,omitempty"`
	// contains filtered or unexported fields
}

Detailed information about a task.

func (*TaskDetails) Descriptor deprecated 

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

Deprecated: Use TaskDetails.ProtoReflect.Descriptor instead.

func (*TaskDetails) GetMetadata 

func (x *TaskDetails) GetMetadata() *TaskMetadata

func (*TaskDetails) GetSpec 

func (x *TaskDetails) GetSpec() *TaskSpec

func (*TaskDetails) GetTaskId 

func (x *TaskDetails) GetTaskId() *TaskIdentifier

func (*TaskDetails) ProtoMessage 

func (*TaskDetails) ProtoMessage()

func (*TaskDetails) ProtoReflect 

func (x *TaskDetails) ProtoReflect() protoreflect.Message

func (*TaskDetails) Reset 

func (x *TaskDetails) Reset()

func (*TaskDetails) String 

func (x *TaskDetails) String() string

func (*TaskDetails) Validate 

func (m *TaskDetails) Validate() error

Validate checks the field values on TaskDetails with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*TaskDetails) ValidateAll 

func (m *TaskDetails) ValidateAll() error

ValidateAll checks the field values on TaskDetails with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in TaskDetailsMultiError, or nil if none found.

type TaskDetailsMultiError 

type TaskDetailsMultiError []error

TaskDetailsMultiError is an error wrapping multiple validation errors returned by TaskDetails.ValidateAll() if the designated constraints aren't met.

func (TaskDetailsMultiError) AllErrors 

func (m TaskDetailsMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (TaskDetailsMultiError) Error 

func (m TaskDetailsMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type TaskDetailsValidationError 

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

TaskDetailsValidationError is the validation error returned by TaskDetails.Validate if the designated constraints aren't met.

func (TaskDetailsValidationError) Cause 

func (e TaskDetailsValidationError) Cause() error

Cause function returns cause value.

func (TaskDetailsValidationError) Error 

func (e TaskDetailsValidationError) Error() string

Error satisfies the builtin error interface

func (TaskDetailsValidationError) ErrorName 

func (e TaskDetailsValidationError) ErrorName() string

ErrorName returns error name.

func (TaskDetailsValidationError) Field 

func (e TaskDetailsValidationError) Field() string

Field function returns field value.

func (TaskDetailsValidationError) Key 

func (e TaskDetailsValidationError) Key() bool

Key function returns key value.

func (TaskDetailsValidationError) Reason 

func (e TaskDetailsValidationError) Reason() string

Reason function returns reason value.

type TaskIdentifier 

type TaskIdentifier struct {

	// Org this task belongs to.
	Org string `protobuf:"bytes,1,opt,name=org,proto3" json:"org,omitempty"`
	// Project this task belongs to.
	Project string `protobuf:"bytes,2,opt,name=project,proto3" json:"project,omitempty"`
	// Domain this task belongs to.
	Domain string `protobuf:"bytes,3,opt,name=domain,proto3" json:"domain,omitempty"`
	// Unique name of the task. Should not be interpreted/parsed. Use `short_name` and `environment_name` for user facing names.
	Name string `protobuf:"bytes,4,opt,name=name,proto3" json:"name,omitempty"`
	// Version of the task.
	Version string `protobuf:"bytes,5,opt,name=version,proto3" json:"version,omitempty"`
	// contains filtered or unexported fields
}

TaskIdentifier is the unique identifier for a task.

func (*TaskIdentifier) Descriptor deprecated 

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

Deprecated: Use TaskIdentifier.ProtoReflect.Descriptor instead.

func (*TaskIdentifier) GetDomain 

func (x *TaskIdentifier) GetDomain() string

func (*TaskIdentifier) GetName 

func (x *TaskIdentifier) GetName() string

func (*TaskIdentifier) GetOrg 

func (x *TaskIdentifier) GetOrg() string

func (*TaskIdentifier) GetProject 

func (x *TaskIdentifier) GetProject() string

func (*TaskIdentifier) GetVersion 

func (x *TaskIdentifier) GetVersion() string

func (*TaskIdentifier) ProtoMessage 

func (*TaskIdentifier) ProtoMessage()

func (*TaskIdentifier) ProtoReflect 

func (x *TaskIdentifier) ProtoReflect() protoreflect.Message

func (*TaskIdentifier) Reset 

func (x *TaskIdentifier) Reset()

func (*TaskIdentifier) String 

func (x *TaskIdentifier) String() string

func (*TaskIdentifier) Validate 

func (m *TaskIdentifier) Validate() error

Validate checks the field values on TaskIdentifier with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*TaskIdentifier) ValidateAll 

func (m *TaskIdentifier) ValidateAll() error

ValidateAll checks the field values on TaskIdentifier with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in TaskIdentifierMultiError, or nil if none found.

type TaskIdentifierMultiError 

type TaskIdentifierMultiError []error

TaskIdentifierMultiError is an error wrapping multiple validation errors returned by TaskIdentifier.ValidateAll() if the designated constraints aren't met.

func (TaskIdentifierMultiError) AllErrors 

func (m TaskIdentifierMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (TaskIdentifierMultiError) Error 

func (m TaskIdentifierMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type TaskIdentifierValidationError 

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

TaskIdentifierValidationError is the validation error returned by TaskIdentifier.Validate if the designated constraints aren't met.

func (TaskIdentifierValidationError) Cause 

func (e TaskIdentifierValidationError) Cause() error

Cause function returns cause value.

func (TaskIdentifierValidationError) Error 

func (e TaskIdentifierValidationError) Error() string

Error satisfies the builtin error interface

func (TaskIdentifierValidationError) ErrorName 

func (e TaskIdentifierValidationError) ErrorName() string

ErrorName returns error name.

func (TaskIdentifierValidationError) Field 

func (e TaskIdentifierValidationError) Field() string

Field function returns field value.

func (TaskIdentifierValidationError) Key 

func (e TaskIdentifierValidationError) Key() bool

Key function returns key value.

func (TaskIdentifierValidationError) Reason 

func (e TaskIdentifierValidationError) Reason() string

Reason function returns reason value.

type TaskMetadata 

type TaskMetadata struct {

	// Identity that deployed the task.
	DeployedBy *common.EnrichedIdentity `protobuf:"bytes,1,opt,name=deployed_by,json=deployedBy,proto3" json:"deployed_by,omitempty"`
	// The short name for this task
	ShortName string `protobuf:"bytes,2,opt,name=short_name,json=shortName,proto3" json:"short_name,omitempty"`
	// The time the task was deployed
	DeployedAt *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=deployed_at,json=deployedAt,proto3" json:"deployed_at,omitempty"`
	// The environment name for this task, if present.
	EnvironmentName string `protobuf:"bytes,4,opt,name=environment_name,json=environmentName,proto3" json:"environment_name,omitempty"`
	// contains filtered or unexported fields
}

TaskMetadata is static, lightweight metadata about a task.

func (*TaskMetadata) Descriptor deprecated 

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

Deprecated: Use TaskMetadata.ProtoReflect.Descriptor instead.

func (*TaskMetadata) GetDeployedAt 

func (x *TaskMetadata) GetDeployedAt() *timestamppb.Timestamp

func (*TaskMetadata) GetDeployedBy 

func (x *TaskMetadata) GetDeployedBy() *common.EnrichedIdentity

func (*TaskMetadata) GetEnvironmentName 

func (x *TaskMetadata) GetEnvironmentName() string

func (*TaskMetadata) GetShortName 

func (x *TaskMetadata) GetShortName() string

func (*TaskMetadata) ProtoMessage 

func (*TaskMetadata) ProtoMessage()

func (*TaskMetadata) ProtoReflect 

func (x *TaskMetadata) ProtoReflect() protoreflect.Message

func (*TaskMetadata) Reset 

func (x *TaskMetadata) Reset()

func (*TaskMetadata) String 

func (x *TaskMetadata) String() string

func (*TaskMetadata) Validate 

func (m *TaskMetadata) Validate() error

Validate checks the field values on TaskMetadata with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*TaskMetadata) ValidateAll 

func (m *TaskMetadata) ValidateAll() error

ValidateAll checks the field values on TaskMetadata with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in TaskMetadataMultiError, or nil if none found.

type TaskMetadataMultiError 

type TaskMetadataMultiError []error

TaskMetadataMultiError is an error wrapping multiple validation errors returned by TaskMetadata.ValidateAll() if the designated constraints aren't met.

func (TaskMetadataMultiError) AllErrors 

func (m TaskMetadataMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (TaskMetadataMultiError) Error 

func (m TaskMetadataMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type TaskMetadataValidationError 

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

TaskMetadataValidationError is the validation error returned by TaskMetadata.Validate if the designated constraints aren't met.

func (TaskMetadataValidationError) Cause 

func (e TaskMetadataValidationError) Cause() error

Cause function returns cause value.

func (TaskMetadataValidationError) Error 

func (e TaskMetadataValidationError) Error() string

Error satisfies the builtin error interface

func (TaskMetadataValidationError) ErrorName 

func (e TaskMetadataValidationError) ErrorName() string

ErrorName returns error name.

func (TaskMetadataValidationError) Field 

func (e TaskMetadataValidationError) Field() string

Field function returns field value.

func (TaskMetadataValidationError) Key 

func (e TaskMetadataValidationError) Key() bool

Key function returns key value.

func (TaskMetadataValidationError) Reason 

func (e TaskMetadataValidationError) Reason() string

Reason function returns reason value.

type TaskMultiError 

type TaskMultiError []error

TaskMultiError is an error wrapping multiple validation errors returned by Task.ValidateAll() if the designated constraints aren't met.

func (TaskMultiError) AllErrors 

func (m TaskMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (TaskMultiError) Error 

func (m TaskMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type TaskName 

type TaskName struct {

	// Org this task belongs to.
	Org string `protobuf:"bytes,1,opt,name=org,proto3" json:"org,omitempty"`
	// Project this task belongs to.
	Project string `protobuf:"bytes,2,opt,name=project,proto3" json:"project,omitempty"`
	// Domain this task belongs to.
	Domain string `protobuf:"bytes,3,opt,name=domain,proto3" json:"domain,omitempty"`
	// Unique name of the task. Should not be interpreted/parsed. Use `short_name` and `environment_name` for user facing names.
	Name string `protobuf:"bytes,4,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

Name of a task. It may have multiple versions deployed.

func (*TaskName) Descriptor deprecated 

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

Deprecated: Use TaskName.ProtoReflect.Descriptor instead.

func (*TaskName) GetDomain 

func (x *TaskName) GetDomain() string

func (*TaskName) GetName 

func (x *TaskName) GetName() string

func (*TaskName) GetOrg 

func (x *TaskName) GetOrg() string

func (*TaskName) GetProject 

func (x *TaskName) GetProject() string

func (*TaskName) ProtoMessage 

func (*TaskName) ProtoMessage()

func (*TaskName) ProtoReflect 

func (x *TaskName) ProtoReflect() protoreflect.Message

func (*TaskName) Reset 

func (x *TaskName) Reset()

func (*TaskName) String 

func (x *TaskName) String() string

func (*TaskName) Validate 

func (m *TaskName) Validate() error

Validate checks the field values on TaskName with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*TaskName) ValidateAll 

func (m *TaskName) ValidateAll() error

ValidateAll checks the field values on TaskName with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in TaskNameMultiError, or nil if none found.

type TaskNameMultiError 

type TaskNameMultiError []error

TaskNameMultiError is an error wrapping multiple validation errors returned by TaskName.ValidateAll() if the designated constraints aren't met.

func (TaskNameMultiError) AllErrors 

func (m TaskNameMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (TaskNameMultiError) Error 

func (m TaskNameMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type TaskNameValidationError 

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

TaskNameValidationError is the validation error returned by TaskName.Validate if the designated constraints aren't met.

func (TaskNameValidationError) Cause 

func (e TaskNameValidationError) Cause() error

Cause function returns cause value.

func (TaskNameValidationError) Error 

func (e TaskNameValidationError) Error() string

Error satisfies the builtin error interface

func (TaskNameValidationError) ErrorName 

func (e TaskNameValidationError) ErrorName() string

ErrorName returns error name.

func (TaskNameValidationError) Field 

func (e TaskNameValidationError) Field() string

Field function returns field value.

func (TaskNameValidationError) Key 

func (e TaskNameValidationError) Key() bool

Key function returns key value.

func (TaskNameValidationError) Reason 

func (e TaskNameValidationError) Reason() string

Reason function returns reason value.

type TaskServiceClient 

type TaskServiceClient interface {
	// Deploy a task.
	DeployTask(ctx context.Context, in *DeployTaskRequest, opts ...grpc.CallOption) (*DeployTaskResponse, error)
	// Get detailed information about a task.
	GetTaskDetails(ctx context.Context, in *GetTaskDetailsRequest, opts ...grpc.CallOption) (*GetTaskDetailsResponse, error)
	// Lists tasks, one per task name, returning the latest version and who it was deployed by.
	ListTasks(ctx context.Context, in *ListTasksRequest, opts ...grpc.CallOption) (*ListTasksResponse, error)
}

TaskServiceClient is the client API for TaskService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewTaskServiceClient 

func NewTaskServiceClient(cc grpc.ClientConnInterface) TaskServiceClient

type TaskServiceServer 

type TaskServiceServer interface {
	// Deploy a task.
	DeployTask(context.Context, *DeployTaskRequest) (*DeployTaskResponse, error)
	// Get detailed information about a task.
	GetTaskDetails(context.Context, *GetTaskDetailsRequest) (*GetTaskDetailsResponse, error)
	// Lists tasks, one per task name, returning the latest version and who it was deployed by.
	ListTasks(context.Context, *ListTasksRequest) (*ListTasksResponse, error)
}

TaskServiceServer is the server API for TaskService service. All implementations should embed UnimplementedTaskServiceServer for forward compatibility

type TaskSpec 

type TaskSpec struct {

	// The template for this task.
	TaskTemplate *core.TaskTemplate `protobuf:"bytes,1,opt,name=task_template,json=taskTemplate,proto3" json:"task_template,omitempty"`
	// Ordered default inputs.
	// These can be overridden when an run is created.
	// Client should not send required=true flag in underlying flyteidl.core.Parameter.
	DefaultInputs []*NamedParameter `protobuf:"bytes,2,rep,name=default_inputs,json=defaultInputs,proto3" json:"default_inputs,omitempty"`
	// User facing display name for this task. Not required to be unique.
	ShortName string `protobuf:"bytes,3,opt,name=short_name,json=shortName,proto3" json:"short_name,omitempty"`
	// Optional environment for this task. Note, some tasks may not be run in the context of an environment.
	Environment *Environment `protobuf:"bytes,4,opt,name=environment,proto3" json:"environment,omitempty"`
	// contains filtered or unexported fields
}

Specification for a task.

func (*TaskSpec) Descriptor deprecated 

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

Deprecated: Use TaskSpec.ProtoReflect.Descriptor instead.

func (*TaskSpec) GetDefaultInputs 

func (x *TaskSpec) GetDefaultInputs() []*NamedParameter

func (*TaskSpec) GetEnvironment 

func (x *TaskSpec) GetEnvironment() *Environment

func (*TaskSpec) GetShortName 

func (x *TaskSpec) GetShortName() string

func (*TaskSpec) GetTaskTemplate 

func (x *TaskSpec) GetTaskTemplate() *core.TaskTemplate

func (*TaskSpec) ProtoMessage 

func (*TaskSpec) ProtoMessage()

func (*TaskSpec) ProtoReflect 

func (x *TaskSpec) ProtoReflect() protoreflect.Message

func (*TaskSpec) Reset 

func (x *TaskSpec) Reset()

func (*TaskSpec) String 

func (x *TaskSpec) String() string

func (*TaskSpec) Validate 

func (m *TaskSpec) Validate() error

Validate checks the field values on TaskSpec with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*TaskSpec) ValidateAll 

func (m *TaskSpec) ValidateAll() error

ValidateAll checks the field values on TaskSpec with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in TaskSpecMultiError, or nil if none found.

type TaskSpecMultiError 

type TaskSpecMultiError []error

TaskSpecMultiError is an error wrapping multiple validation errors returned by TaskSpec.ValidateAll() if the designated constraints aren't met.

func (TaskSpecMultiError) AllErrors 

func (m TaskSpecMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (TaskSpecMultiError) Error 

func (m TaskSpecMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type TaskSpecValidationError 

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

TaskSpecValidationError is the validation error returned by TaskSpec.Validate if the designated constraints aren't met.

func (TaskSpecValidationError) Cause 

func (e TaskSpecValidationError) Cause() error

Cause function returns cause value.

func (TaskSpecValidationError) Error 

func (e TaskSpecValidationError) Error() string

Error satisfies the builtin error interface

func (TaskSpecValidationError) ErrorName 

func (e TaskSpecValidationError) ErrorName() string

ErrorName returns error name.

func (TaskSpecValidationError) Field 

func (e TaskSpecValidationError) Field() string

Field function returns field value.

func (TaskSpecValidationError) Key 

func (e TaskSpecValidationError) Key() bool

Key function returns key value.

func (TaskSpecValidationError) Reason 

func (e TaskSpecValidationError) Reason() string

Reason function returns reason value.

type TaskValidationError 

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

TaskValidationError is the validation error returned by Task.Validate if the designated constraints aren't met.

func (TaskValidationError) Cause 

func (e TaskValidationError) Cause() error

Cause function returns cause value.

func (TaskValidationError) Error 

func (e TaskValidationError) Error() string

Error satisfies the builtin error interface

func (TaskValidationError) ErrorName 

func (e TaskValidationError) ErrorName() string

ErrorName returns error name.

func (TaskValidationError) Field 

func (e TaskValidationError) Field() string

Field function returns field value.

func (TaskValidationError) Key 

func (e TaskValidationError) Key() bool

Key function returns key value.

func (TaskValidationError) Reason 

func (e TaskValidationError) Reason() string

Reason function returns reason value.

type TraceAction 

type TraceAction struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Last known phase.
	Phase Phase `protobuf:"varint,2,opt,name=phase,proto3,enum=flyteidl.workflow.Phase" json:"phase,omitempty"`
	// Time the attempt started.
	StartTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	// Time the attempt ended, if applicable.
	EndTime *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=end_time,json=endTime,proto3,oneof" json:"end_time,omitempty"`
	// Output references.
	Outputs *OutputReferences `protobuf:"bytes,5,opt,name=outputs,proto3" json:"outputs,omitempty"`
	// contains filtered or unexported fields
}

TraceAction is used to define a trace action that can be used to track the execution of an action that's managed by the local worker. This can be used to bring determinism to code that's otherwise not deterministic (e.g. current time).

func (*TraceAction) Descriptor deprecated 

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

Deprecated: Use TraceAction.ProtoReflect.Descriptor instead.

func (*TraceAction) GetEndTime 

func (x *TraceAction) GetEndTime() *timestamppb.Timestamp

func (*TraceAction) GetName 

func (x *TraceAction) GetName() string

func (*TraceAction) GetOutputs 

func (x *TraceAction) GetOutputs() *OutputReferences

func (*TraceAction) GetPhase 

func (x *TraceAction) GetPhase() Phase

func (*TraceAction) GetStartTime 

func (x *TraceAction) GetStartTime() *timestamppb.Timestamp

func (*TraceAction) ProtoMessage 

func (*TraceAction) ProtoMessage()

func (*TraceAction) ProtoReflect 

func (x *TraceAction) ProtoReflect() protoreflect.Message

func (*TraceAction) Reset 

func (x *TraceAction) Reset()

func (*TraceAction) String 

func (x *TraceAction) String() string

func (*TraceAction) Validate 

func (m *TraceAction) Validate() error

Validate checks the field values on TraceAction with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*TraceAction) ValidateAll 

func (m *TraceAction) ValidateAll() error

ValidateAll checks the field values on TraceAction with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in TraceActionMultiError, or nil if none found.

type TraceActionMetadata 

type TraceActionMetadata struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*TraceActionMetadata) Descriptor deprecated 

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

Deprecated: Use TraceActionMetadata.ProtoReflect.Descriptor instead.

func (*TraceActionMetadata) GetName 

func (x *TraceActionMetadata) GetName() string

func (*TraceActionMetadata) ProtoMessage 

func (*TraceActionMetadata) ProtoMessage()

func (*TraceActionMetadata) ProtoReflect 

func (x *TraceActionMetadata) ProtoReflect() protoreflect.Message

func (*TraceActionMetadata) Reset 

func (x *TraceActionMetadata) Reset()

func (*TraceActionMetadata) String 

func (x *TraceActionMetadata) String() string

func (*TraceActionMetadata) Validate 

func (m *TraceActionMetadata) Validate() error

Validate checks the field values on TraceActionMetadata with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*TraceActionMetadata) ValidateAll 

func (m *TraceActionMetadata) ValidateAll() error

ValidateAll checks the field values on TraceActionMetadata with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in TraceActionMetadataMultiError, or nil if none found.

type TraceActionMetadataMultiError 

type TraceActionMetadataMultiError []error

TraceActionMetadataMultiError is an error wrapping multiple validation errors returned by TraceActionMetadata.ValidateAll() if the designated constraints aren't met.

func (TraceActionMetadataMultiError) AllErrors 

func (m TraceActionMetadataMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (TraceActionMetadataMultiError) Error 

func (m TraceActionMetadataMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type TraceActionMetadataValidationError 

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

TraceActionMetadataValidationError is the validation error returned by TraceActionMetadata.Validate if the designated constraints aren't met.

func (TraceActionMetadataValidationError) Cause 

func (e TraceActionMetadataValidationError) Cause() error

Cause function returns cause value.

func (TraceActionMetadataValidationError) Error 

func (e TraceActionMetadataValidationError) Error() string

Error satisfies the builtin error interface

func (TraceActionMetadataValidationError) ErrorName 

func (e TraceActionMetadataValidationError) ErrorName() string

ErrorName returns error name.

func (TraceActionMetadataValidationError) Field 

func (e TraceActionMetadataValidationError) Field() string

Field function returns field value.

func (TraceActionMetadataValidationError) Key 

func (e TraceActionMetadataValidationError) Key() bool

Key function returns key value.

func (TraceActionMetadataValidationError) Reason 

func (e TraceActionMetadataValidationError) Reason() string

Reason function returns reason value.

type TraceActionMultiError 

type TraceActionMultiError []error

TraceActionMultiError is an error wrapping multiple validation errors returned by TraceAction.ValidateAll() if the designated constraints aren't met.

func (TraceActionMultiError) AllErrors 

func (m TraceActionMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (TraceActionMultiError) Error 

func (m TraceActionMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type TraceActionValidationError 

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

TraceActionValidationError is the validation error returned by TraceAction.Validate if the designated constraints aren't met.

func (TraceActionValidationError) Cause 

func (e TraceActionValidationError) Cause() error

Cause function returns cause value.

func (TraceActionValidationError) Error 

func (e TraceActionValidationError) Error() string

Error satisfies the builtin error interface

func (TraceActionValidationError) ErrorName 

func (e TraceActionValidationError) ErrorName() string

ErrorName returns error name.

func (TraceActionValidationError) Field 

func (e TraceActionValidationError) Field() string

Field function returns field value.

func (TraceActionValidationError) Key 

func (e TraceActionValidationError) Key() bool

Key function returns key value.

func (TraceActionValidationError) Reason 

func (e TraceActionValidationError) Reason() string

Reason function returns reason value.

type UnimplementedNodeExecutionServiceServer 

type UnimplementedNodeExecutionServiceServer struct {
}

UnimplementedNodeExecutionServiceServer should be embedded to have forward compatible implementations.

type UnimplementedQueueServiceServer 

type UnimplementedQueueServiceServer struct {
}

UnimplementedQueueServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedQueueServiceServer) AbortQueuedRun 

func (UnimplementedQueueServiceServer) AbortQueuedRun(context.Context, *AbortQueuedRunRequest) (*AbortQueuedRunResponse, error)

func (UnimplementedQueueServiceServer) EnqueueAction 

func (UnimplementedQueueServiceServer) EnqueueAction(context.Context, *EnqueueActionRequest) (*EnqueueActionResponse, error)

type UnimplementedRunLogsServiceServer 

type UnimplementedRunLogsServiceServer struct {
}

UnimplementedRunLogsServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedRunLogsServiceServer) TailLogs 

func (UnimplementedRunLogsServiceServer) TailLogs(*TailLogsRequest, RunLogsService_TailLogsServer) error

type UnimplementedRunServiceServer 

type UnimplementedRunServiceServer struct {
}

UnimplementedRunServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedRunServiceServer) AbortRun 

func (UnimplementedRunServiceServer) AbortRun(context.Context, *AbortRunRequest) (*AbortRunResponse, error)

func (UnimplementedRunServiceServer) CreateRun 

func (UnimplementedRunServiceServer) CreateRun(context.Context, *CreateRunRequest) (*CreateRunResponse, error)

func (UnimplementedRunServiceServer) GetActionData 

func (UnimplementedRunServiceServer) GetActionData(context.Context, *GetActionDataRequest) (*GetActionDataResponse, error)

func (UnimplementedRunServiceServer) GetActionDetails 

func (UnimplementedRunServiceServer) GetActionDetails(context.Context, *GetActionDetailsRequest) (*GetActionDetailsResponse, error)

func (UnimplementedRunServiceServer) GetRunDetails 

func (UnimplementedRunServiceServer) GetRunDetails(context.Context, *GetRunDetailsRequest) (*GetRunDetailsResponse, error)

func (UnimplementedRunServiceServer) ListActions 

func (UnimplementedRunServiceServer) ListActions(context.Context, *ListActionsRequest) (*ListActionsResponse, error)

func (UnimplementedRunServiceServer) ListRuns 

func (UnimplementedRunServiceServer) ListRuns(context.Context, *ListRunsRequest) (*ListRunsResponse, error)

func (UnimplementedRunServiceServer) WatchActionDetails 

func (UnimplementedRunServiceServer) WatchActionDetails(*WatchActionDetailsRequest, RunService_WatchActionDetailsServer) error

func (UnimplementedRunServiceServer) WatchActions 

func (UnimplementedRunServiceServer) WatchActions(*WatchActionsRequest, RunService_WatchActionsServer) error

func (UnimplementedRunServiceServer) WatchClusterEvents 

func (UnimplementedRunServiceServer) WatchClusterEvents(*WatchClusterEventsRequest, RunService_WatchClusterEventsServer) error

func (UnimplementedRunServiceServer) WatchRunDetails 

func (UnimplementedRunServiceServer) WatchRunDetails(*WatchRunDetailsRequest, RunService_WatchRunDetailsServer) error

func (UnimplementedRunServiceServer) WatchRuns 

func (UnimplementedRunServiceServer) WatchRuns(*WatchRunsRequest, RunService_WatchRunsServer) error

type UnimplementedStateServiceServer 

type UnimplementedStateServiceServer struct {
}

UnimplementedStateServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedStateServiceServer) Get 

func (UnimplementedStateServiceServer) Get(StateService_GetServer) error

func (UnimplementedStateServiceServer) Put 

func (UnimplementedStateServiceServer) Put(StateService_PutServer) error

func (UnimplementedStateServiceServer) Watch 

func (UnimplementedStateServiceServer) Watch(*WatchRequest, StateService_WatchServer) error

type UnimplementedTaskServiceServer 

type UnimplementedTaskServiceServer struct {
}

UnimplementedTaskServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedTaskServiceServer) DeployTask 

func (UnimplementedTaskServiceServer) DeployTask(context.Context, *DeployTaskRequest) (*DeployTaskResponse, error)

func (UnimplementedTaskServiceServer) GetTaskDetails 

func (UnimplementedTaskServiceServer) GetTaskDetails(context.Context, *GetTaskDetailsRequest) (*GetTaskDetailsResponse, error)

func (UnimplementedTaskServiceServer) ListTasks 

func (UnimplementedTaskServiceServer) ListTasks(context.Context, *ListTasksRequest) (*ListTasksResponse, error)

type UnsafeNodeExecutionServiceServer 

type UnsafeNodeExecutionServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeNodeExecutionServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to NodeExecutionServiceServer will result in compilation errors.

type UnsafeQueueServiceServer 

type UnsafeQueueServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeQueueServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to QueueServiceServer will result in compilation errors.

type UnsafeRunLogsServiceServer 

type UnsafeRunLogsServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeRunLogsServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to RunLogsServiceServer will result in compilation errors.

type UnsafeRunServiceServer 

type UnsafeRunServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeRunServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to RunServiceServer will result in compilation errors.

type UnsafeStateServiceServer 

type UnsafeStateServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeStateServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to StateServiceServer will result in compilation errors.

type UnsafeTaskServiceServer 

type UnsafeTaskServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeTaskServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to TaskServiceServer will result in compilation errors.

type WatchActionDetailsRequest 

type WatchActionDetailsRequest struct {

	// Action to query.
	ActionId *common.ActionIdentifier `protobuf:"bytes,1,opt,name=action_id,json=actionId,proto3" json:"action_id,omitempty"`
	// contains filtered or unexported fields
}

Request message for watching detailed information about an action.

func (*WatchActionDetailsRequest) Descriptor deprecated 

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

Deprecated: Use WatchActionDetailsRequest.ProtoReflect.Descriptor instead.

func (*WatchActionDetailsRequest) GetActionId 

func (x *WatchActionDetailsRequest) GetActionId() *common.ActionIdentifier

func (*WatchActionDetailsRequest) ProtoMessage 

func (*WatchActionDetailsRequest) ProtoMessage()

func (*WatchActionDetailsRequest) ProtoReflect 

func (x *WatchActionDetailsRequest) ProtoReflect() protoreflect.Message

func (*WatchActionDetailsRequest) Reset 

func (x *WatchActionDetailsRequest) Reset()

func (*WatchActionDetailsRequest) String 

func (x *WatchActionDetailsRequest) String() string

func (*WatchActionDetailsRequest) Validate 

func (m *WatchActionDetailsRequest) Validate() error

Validate checks the field values on WatchActionDetailsRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*WatchActionDetailsRequest) ValidateAll 

func (m *WatchActionDetailsRequest) ValidateAll() error

ValidateAll checks the field values on WatchActionDetailsRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in WatchActionDetailsRequestMultiError, or nil if none found.

type WatchActionDetailsRequestMultiError 

type WatchActionDetailsRequestMultiError []error

WatchActionDetailsRequestMultiError is an error wrapping multiple validation errors returned by WatchActionDetailsRequest.ValidateAll() if the designated constraints aren't met.

func (WatchActionDetailsRequestMultiError) AllErrors 

func (m WatchActionDetailsRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (WatchActionDetailsRequestMultiError) Error 

func (m WatchActionDetailsRequestMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type WatchActionDetailsRequestValidationError 

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

WatchActionDetailsRequestValidationError is the validation error returned by WatchActionDetailsRequest.Validate if the designated constraints aren't met.

func (WatchActionDetailsRequestValidationError) Cause 

func (e WatchActionDetailsRequestValidationError) Cause() error

Cause function returns cause value.

func (WatchActionDetailsRequestValidationError) Error 

func (e WatchActionDetailsRequestValidationError) Error() string

Error satisfies the builtin error interface

func (WatchActionDetailsRequestValidationError) ErrorName 

func (e WatchActionDetailsRequestValidationError) ErrorName() string

ErrorName returns error name.

func (WatchActionDetailsRequestValidationError) Field 

func (e WatchActionDetailsRequestValidationError) Field() string

Field function returns field value.

func (WatchActionDetailsRequestValidationError) Key 

func (e WatchActionDetailsRequestValidationError) Key() bool

Key function returns key value.

func (WatchActionDetailsRequestValidationError) Reason 

func (e WatchActionDetailsRequestValidationError) Reason() string

Reason function returns reason value.

type WatchActionDetailsResponse 

type WatchActionDetailsResponse struct {

	// Detailed information about the action.
	Details *ActionDetails `protobuf:"bytes,1,opt,name=details,proto3" json:"details,omitempty"`
	// contains filtered or unexported fields
}

Response message for watching detailed information about an action.

func (*WatchActionDetailsResponse) Descriptor deprecated 

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

Deprecated: Use WatchActionDetailsResponse.ProtoReflect.Descriptor instead.

func (*WatchActionDetailsResponse) GetDetails 

func (x *WatchActionDetailsResponse) GetDetails() *ActionDetails

func (*WatchActionDetailsResponse) ProtoMessage 

func (*WatchActionDetailsResponse) ProtoMessage()

func (*WatchActionDetailsResponse) ProtoReflect 

func (x *WatchActionDetailsResponse) ProtoReflect() protoreflect.Message

func (*WatchActionDetailsResponse) Reset 

func (x *WatchActionDetailsResponse) Reset()

func (*WatchActionDetailsResponse) String 

func (x *WatchActionDetailsResponse) String() string

func (*WatchActionDetailsResponse) Validate 

func (m *WatchActionDetailsResponse) Validate() error

Validate checks the field values on WatchActionDetailsResponse with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*WatchActionDetailsResponse) ValidateAll 

func (m *WatchActionDetailsResponse) ValidateAll() error

ValidateAll checks the field values on WatchActionDetailsResponse with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in WatchActionDetailsResponseMultiError, or nil if none found.

type WatchActionDetailsResponseMultiError 

type WatchActionDetailsResponseMultiError []error

WatchActionDetailsResponseMultiError is an error wrapping multiple validation errors returned by WatchActionDetailsResponse.ValidateAll() if the designated constraints aren't met.

func (WatchActionDetailsResponseMultiError) AllErrors 

func (m WatchActionDetailsResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (WatchActionDetailsResponseMultiError) Error 

func (m WatchActionDetailsResponseMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type WatchActionDetailsResponseValidationError 

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

WatchActionDetailsResponseValidationError is the validation error returned by WatchActionDetailsResponse.Validate if the designated constraints aren't met.

func (WatchActionDetailsResponseValidationError) Cause 

func (e WatchActionDetailsResponseValidationError) Cause() error

Cause function returns cause value.

func (WatchActionDetailsResponseValidationError) Error 

func (e WatchActionDetailsResponseValidationError) Error() string

Error satisfies the builtin error interface

func (WatchActionDetailsResponseValidationError) ErrorName 

func (e WatchActionDetailsResponseValidationError) ErrorName() string

ErrorName returns error name.

func (WatchActionDetailsResponseValidationError) Field 

func (e WatchActionDetailsResponseValidationError) Field() string

Field function returns field value.

func (WatchActionDetailsResponseValidationError) Key 

func (e WatchActionDetailsResponseValidationError) Key() bool

Key function returns key value.

func (WatchActionDetailsResponseValidationError) Reason 

func (e WatchActionDetailsResponseValidationError) Reason() string

Reason function returns reason value.

type WatchActionsRequest 

type WatchActionsRequest struct {

	// Run identifier for filtering actions.
	RunId *common.RunIdentifier `protobuf:"bytes,1,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	// Optional filter(s) criteria for actions.
	// Valid filter fields include:
	// - NAME (must use function CONTAINS_CASE_INSENSITIVE): the value is whatever string to match to. This will cast all strings to lowercase and match.
	// - PHASE (must use function VALUE_IN): the value is the stringified integer of the enum of the phase and you can pass multiple phases (i.e. ["1", "4"])
	Filter []*common.Filter `protobuf:"bytes,2,rep,name=filter,proto3" json:"filter,omitempty"`
	// contains filtered or unexported fields
}

Request message for watching actions.

func (*WatchActionsRequest) Descriptor deprecated 

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

Deprecated: Use WatchActionsRequest.ProtoReflect.Descriptor instead.

func (*WatchActionsRequest) GetFilter 

func (x *WatchActionsRequest) GetFilter() []*common.Filter

func (*WatchActionsRequest) GetRunId 

func (x *WatchActionsRequest) GetRunId() *common.RunIdentifier

func (*WatchActionsRequest) ProtoMessage 

func (*WatchActionsRequest) ProtoMessage()

func (*WatchActionsRequest) ProtoReflect 

func (x *WatchActionsRequest) ProtoReflect() protoreflect.Message

func (*WatchActionsRequest) Reset 

func (x *WatchActionsRequest) Reset()

func (*WatchActionsRequest) String 

func (x *WatchActionsRequest) String() string

func (*WatchActionsRequest) Validate 

func (m *WatchActionsRequest) Validate() error

Validate checks the field values on WatchActionsRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*WatchActionsRequest) ValidateAll 

func (m *WatchActionsRequest) ValidateAll() error

ValidateAll checks the field values on WatchActionsRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in WatchActionsRequestMultiError, or nil if none found.

type WatchActionsRequestMultiError 

type WatchActionsRequestMultiError []error

WatchActionsRequestMultiError is an error wrapping multiple validation errors returned by WatchActionsRequest.ValidateAll() if the designated constraints aren't met.

func (WatchActionsRequestMultiError) AllErrors 

func (m WatchActionsRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (WatchActionsRequestMultiError) Error 

func (m WatchActionsRequestMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type WatchActionsRequestValidationError 

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

WatchActionsRequestValidationError is the validation error returned by WatchActionsRequest.Validate if the designated constraints aren't met.

func (WatchActionsRequestValidationError) Cause 

func (e WatchActionsRequestValidationError) Cause() error

Cause function returns cause value.

func (WatchActionsRequestValidationError) Error 

func (e WatchActionsRequestValidationError) Error() string

Error satisfies the builtin error interface

func (WatchActionsRequestValidationError) ErrorName 

func (e WatchActionsRequestValidationError) ErrorName() string

ErrorName returns error name.

func (WatchActionsRequestValidationError) Field 

func (e WatchActionsRequestValidationError) Field() string

Field function returns field value.

func (WatchActionsRequestValidationError) Key 

func (e WatchActionsRequestValidationError) Key() bool

Key function returns key value.

func (WatchActionsRequestValidationError) Reason 

func (e WatchActionsRequestValidationError) Reason() string

Reason function returns reason value.

type WatchActionsResponse 

type WatchActionsResponse struct {

	// New or updated actions matching the filter criteria. Enriched with children status counts
	EnrichedActions []*EnrichedAction `protobuf:"bytes,1,rep,name=enriched_actions,json=enrichedActions,proto3" json:"enriched_actions,omitempty"`
	// contains filtered or unexported fields
}

Response message for watching actions, comes with enriched action metadata.

func (*WatchActionsResponse) Descriptor deprecated 

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

Deprecated: Use WatchActionsResponse.ProtoReflect.Descriptor instead.

func (*WatchActionsResponse) GetEnrichedActions 

func (x *WatchActionsResponse) GetEnrichedActions() []*EnrichedAction

func (*WatchActionsResponse) ProtoMessage 

func (*WatchActionsResponse) ProtoMessage()

func (*WatchActionsResponse) ProtoReflect 

func (x *WatchActionsResponse) ProtoReflect() protoreflect.Message

func (*WatchActionsResponse) Reset 

func (x *WatchActionsResponse) Reset()

func (*WatchActionsResponse) String 

func (x *WatchActionsResponse) String() string

func (*WatchActionsResponse) Validate 

func (m *WatchActionsResponse) Validate() error

Validate checks the field values on WatchActionsResponse with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*WatchActionsResponse) ValidateAll 

func (m *WatchActionsResponse) ValidateAll() error

ValidateAll checks the field values on WatchActionsResponse with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in WatchActionsResponseMultiError, or nil if none found.

type WatchActionsResponseMultiError 

type WatchActionsResponseMultiError []error

WatchActionsResponseMultiError is an error wrapping multiple validation errors returned by WatchActionsResponse.ValidateAll() if the designated constraints aren't met.

func (WatchActionsResponseMultiError) AllErrors 

func (m WatchActionsResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (WatchActionsResponseMultiError) Error 

func (m WatchActionsResponseMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type WatchActionsResponseValidationError 

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

WatchActionsResponseValidationError is the validation error returned by WatchActionsResponse.Validate if the designated constraints aren't met.

func (WatchActionsResponseValidationError) Cause 

func (e WatchActionsResponseValidationError) Cause() error

Cause function returns cause value.

func (WatchActionsResponseValidationError) Error 

func (e WatchActionsResponseValidationError) Error() string

Error satisfies the builtin error interface

func (WatchActionsResponseValidationError) ErrorName 

func (e WatchActionsResponseValidationError) ErrorName() string

ErrorName returns error name.

func (WatchActionsResponseValidationError) Field 

func (e WatchActionsResponseValidationError) Field() string

Field function returns field value.

func (WatchActionsResponseValidationError) Key 

func (e WatchActionsResponseValidationError) Key() bool

Key function returns key value.

func (WatchActionsResponseValidationError) Reason 

func (e WatchActionsResponseValidationError) Reason() string

Reason function returns reason value.

type WatchClusterEventsRequest 

type WatchClusterEventsRequest struct {
	Id      *common.ActionIdentifier `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Attempt uint32                   `protobuf:"varint,2,opt,name=attempt,proto3" json:"attempt,omitempty"`
	// contains filtered or unexported fields
}

func (*WatchClusterEventsRequest) Descriptor deprecated 

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

Deprecated: Use WatchClusterEventsRequest.ProtoReflect.Descriptor instead.

func (*WatchClusterEventsRequest) GetAttempt 

func (x *WatchClusterEventsRequest) GetAttempt() uint32

func (*WatchClusterEventsRequest) GetId 

func (x *WatchClusterEventsRequest) GetId() *common.ActionIdentifier

func (*WatchClusterEventsRequest) ProtoMessage 

func (*WatchClusterEventsRequest) ProtoMessage()

func (*WatchClusterEventsRequest) ProtoReflect 

func (x *WatchClusterEventsRequest) ProtoReflect() protoreflect.Message

func (*WatchClusterEventsRequest) Reset 

func (x *WatchClusterEventsRequest) Reset()

func (*WatchClusterEventsRequest) String 

func (x *WatchClusterEventsRequest) String() string

func (*WatchClusterEventsRequest) Validate 

func (m *WatchClusterEventsRequest) Validate() error

Validate checks the field values on WatchClusterEventsRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*WatchClusterEventsRequest) ValidateAll 

func (m *WatchClusterEventsRequest) ValidateAll() error

ValidateAll checks the field values on WatchClusterEventsRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in WatchClusterEventsRequestMultiError, or nil if none found.

type WatchClusterEventsRequestMultiError 

type WatchClusterEventsRequestMultiError []error

WatchClusterEventsRequestMultiError is an error wrapping multiple validation errors returned by WatchClusterEventsRequest.ValidateAll() if the designated constraints aren't met.

func (WatchClusterEventsRequestMultiError) AllErrors 

func (m WatchClusterEventsRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (WatchClusterEventsRequestMultiError) Error 

func (m WatchClusterEventsRequestMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type WatchClusterEventsRequestValidationError 

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

WatchClusterEventsRequestValidationError is the validation error returned by WatchClusterEventsRequest.Validate if the designated constraints aren't met.

func (WatchClusterEventsRequestValidationError) Cause 

func (e WatchClusterEventsRequestValidationError) Cause() error

Cause function returns cause value.

func (WatchClusterEventsRequestValidationError) Error 

func (e WatchClusterEventsRequestValidationError) Error() string

Error satisfies the builtin error interface

func (WatchClusterEventsRequestValidationError) ErrorName 

func (e WatchClusterEventsRequestValidationError) ErrorName() string

ErrorName returns error name.

func (WatchClusterEventsRequestValidationError) Field 

func (e WatchClusterEventsRequestValidationError) Field() string

Field function returns field value.

func (WatchClusterEventsRequestValidationError) Key 

func (e WatchClusterEventsRequestValidationError) Key() bool

Key function returns key value.

func (WatchClusterEventsRequestValidationError) Reason 

func (e WatchClusterEventsRequestValidationError) Reason() string

Reason function returns reason value.

type WatchClusterEventsResponse 

type WatchClusterEventsResponse struct {
	ClusterEvents []*ClusterEvent `protobuf:"bytes,1,rep,name=cluster_events,json=clusterEvents,proto3" json:"cluster_events,omitempty"`
	// contains filtered or unexported fields
}

func (*WatchClusterEventsResponse) Descriptor deprecated 

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

Deprecated: Use WatchClusterEventsResponse.ProtoReflect.Descriptor instead.

func (*WatchClusterEventsResponse) GetClusterEvents 

func (x *WatchClusterEventsResponse) GetClusterEvents() []*ClusterEvent

func (*WatchClusterEventsResponse) ProtoMessage 

func (*WatchClusterEventsResponse) ProtoMessage()

func (*WatchClusterEventsResponse) ProtoReflect 

func (x *WatchClusterEventsResponse) ProtoReflect() protoreflect.Message

func (*WatchClusterEventsResponse) Reset 

func (x *WatchClusterEventsResponse) Reset()

func (*WatchClusterEventsResponse) String 

func (x *WatchClusterEventsResponse) String() string

func (*WatchClusterEventsResponse) Validate 

func (m *WatchClusterEventsResponse) Validate() error

Validate checks the field values on WatchClusterEventsResponse with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*WatchClusterEventsResponse) ValidateAll 

func (m *WatchClusterEventsResponse) ValidateAll() error

ValidateAll checks the field values on WatchClusterEventsResponse with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in WatchClusterEventsResponseMultiError, or nil if none found.

type WatchClusterEventsResponseMultiError 

type WatchClusterEventsResponseMultiError []error

WatchClusterEventsResponseMultiError is an error wrapping multiple validation errors returned by WatchClusterEventsResponse.ValidateAll() if the designated constraints aren't met.

func (WatchClusterEventsResponseMultiError) AllErrors 

func (m WatchClusterEventsResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (WatchClusterEventsResponseMultiError) Error 

func (m WatchClusterEventsResponseMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type WatchClusterEventsResponseValidationError 

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

WatchClusterEventsResponseValidationError is the validation error returned by WatchClusterEventsResponse.Validate if the designated constraints aren't met.

func (WatchClusterEventsResponseValidationError) Cause 

func (e WatchClusterEventsResponseValidationError) Cause() error

Cause function returns cause value.

func (WatchClusterEventsResponseValidationError) Error 

func (e WatchClusterEventsResponseValidationError) Error() string

Error satisfies the builtin error interface

func (WatchClusterEventsResponseValidationError) ErrorName 

func (e WatchClusterEventsResponseValidationError) ErrorName() string

ErrorName returns error name.

func (WatchClusterEventsResponseValidationError) Field 

func (e WatchClusterEventsResponseValidationError) Field() string

Field function returns field value.

func (WatchClusterEventsResponseValidationError) Key 

func (e WatchClusterEventsResponseValidationError) Key() bool

Key function returns key value.

func (WatchClusterEventsResponseValidationError) Reason 

func (e WatchClusterEventsResponseValidationError) Reason() string

Reason function returns reason value.

type WatchRequest 

type WatchRequest struct {

	// criteria for filtering which actions to watch.
	//
	// Types that are assignable to Filter:
	//
	//	*WatchRequest_ParentActionId
	Filter isWatchRequest_Filter `protobuf_oneof:"filter"`
	// contains filtered or unexported fields
}

request message for watching updates to the state of actions.

func (*WatchRequest) Descriptor deprecated 

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

Deprecated: Use WatchRequest.ProtoReflect.Descriptor instead.

func (*WatchRequest) GetFilter 

func (m *WatchRequest) GetFilter() isWatchRequest_Filter

func (*WatchRequest) GetParentActionId 

func (x *WatchRequest) GetParentActionId() *common.ActionIdentifier

func (*WatchRequest) ProtoMessage 

func (*WatchRequest) ProtoMessage()

func (*WatchRequest) ProtoReflect 

func (x *WatchRequest) ProtoReflect() protoreflect.Message

func (*WatchRequest) Reset 

func (x *WatchRequest) Reset()

func (*WatchRequest) String 

func (x *WatchRequest) String() string

func (*WatchRequest) Validate 

func (m *WatchRequest) Validate() error

Validate checks the field values on WatchRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*WatchRequest) ValidateAll 

func (m *WatchRequest) ValidateAll() error

ValidateAll checks the field values on WatchRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in WatchRequestMultiError, or nil if none found.

type WatchRequestMultiError 

type WatchRequestMultiError []error

WatchRequestMultiError is an error wrapping multiple validation errors returned by WatchRequest.ValidateAll() if the designated constraints aren't met.

func (WatchRequestMultiError) AllErrors 

func (m WatchRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (WatchRequestMultiError) Error 

func (m WatchRequestMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type WatchRequestValidationError 

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

WatchRequestValidationError is the validation error returned by WatchRequest.Validate if the designated constraints aren't met.

func (WatchRequestValidationError) Cause 

func (e WatchRequestValidationError) Cause() error

Cause function returns cause value.

func (WatchRequestValidationError) Error 

func (e WatchRequestValidationError) Error() string

Error satisfies the builtin error interface

func (WatchRequestValidationError) ErrorName 

func (e WatchRequestValidationError) ErrorName() string

ErrorName returns error name.

func (WatchRequestValidationError) Field 

func (e WatchRequestValidationError) Field() string

Field function returns field value.

func (WatchRequestValidationError) Key 

func (e WatchRequestValidationError) Key() bool

Key function returns key value.

func (WatchRequestValidationError) Reason 

func (e WatchRequestValidationError) Reason() string

Reason function returns reason value.

type WatchRequest_ParentActionId 

type WatchRequest_ParentActionId struct {
	// a unique identifier for the parent action to watch. this will result in updates for all child
	// actions.
	ParentActionId *common.ActionIdentifier `protobuf:"bytes,1,opt,name=parent_action_id,json=parentActionId,proto3,oneof"`
}

type WatchResponse 

type WatchResponse struct {

	// an update to the state of a specific action.
	//
	// Types that are assignable to Message:
	//
	//	*WatchResponse_ActionUpdate
	//	*WatchResponse_ControlMessage
	Message isWatchResponse_Message `protobuf_oneof:"message"`
	// contains filtered or unexported fields
}

response message for watching updates to the state of actions.

func (*WatchResponse) Descriptor deprecated 

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

Deprecated: Use WatchResponse.ProtoReflect.Descriptor instead.

func (*WatchResponse) GetActionUpdate 

func (x *WatchResponse) GetActionUpdate() *ActionUpdate

func (*WatchResponse) GetControlMessage 

func (x *WatchResponse) GetControlMessage() *ControlMessage

func (*WatchResponse) GetMessage 

func (m *WatchResponse) GetMessage() isWatchResponse_Message

func (*WatchResponse) ProtoMessage 

func (*WatchResponse) ProtoMessage()

func (*WatchResponse) ProtoReflect 

func (x *WatchResponse) ProtoReflect() protoreflect.Message

func (*WatchResponse) Reset 

func (x *WatchResponse) Reset()

func (*WatchResponse) String 

func (x *WatchResponse) String() string

func (*WatchResponse) Validate 

func (m *WatchResponse) Validate() error

Validate checks the field values on WatchResponse with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*WatchResponse) ValidateAll 

func (m *WatchResponse) ValidateAll() error

ValidateAll checks the field values on WatchResponse with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in WatchResponseMultiError, or nil if none found.

type WatchResponseMultiError 

type WatchResponseMultiError []error

WatchResponseMultiError is an error wrapping multiple validation errors returned by WatchResponse.ValidateAll() if the designated constraints aren't met.

func (WatchResponseMultiError) AllErrors 

func (m WatchResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (WatchResponseMultiError) Error 

func (m WatchResponseMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type WatchResponseValidationError 

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

WatchResponseValidationError is the validation error returned by WatchResponse.Validate if the designated constraints aren't met.

func (WatchResponseValidationError) Cause 

func (e WatchResponseValidationError) Cause() error

Cause function returns cause value.

func (WatchResponseValidationError) Error 

func (e WatchResponseValidationError) Error() string

Error satisfies the builtin error interface

func (WatchResponseValidationError) ErrorName 

func (e WatchResponseValidationError) ErrorName() string

ErrorName returns error name.

func (WatchResponseValidationError) Field 

func (e WatchResponseValidationError) Field() string

Field function returns field value.

func (WatchResponseValidationError) Key 

func (e WatchResponseValidationError) Key() bool

Key function returns key value.

func (WatchResponseValidationError) Reason 

func (e WatchResponseValidationError) Reason() string

Reason function returns reason value.

type WatchResponse_ActionUpdate 

type WatchResponse_ActionUpdate struct {
	ActionUpdate *ActionUpdate `protobuf:"bytes,1,opt,name=action_update,json=actionUpdate,proto3,oneof"`
}

type WatchResponse_ControlMessage 

type WatchResponse_ControlMessage struct {
	ControlMessage *ControlMessage `protobuf:"bytes,2,opt,name=control_message,json=controlMessage,proto3,oneof"`
}

type WatchRunDetailsRequest 

type WatchRunDetailsRequest struct {

	// Run to query.
	RunId *common.RunIdentifier `protobuf:"bytes,1,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	// contains filtered or unexported fields
}

Request message for watching detailed information about a run.

func (*WatchRunDetailsRequest) Descriptor deprecated 

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

Deprecated: Use WatchRunDetailsRequest.ProtoReflect.Descriptor instead.

func (*WatchRunDetailsRequest) GetRunId 

func (x *WatchRunDetailsRequest) GetRunId() *common.RunIdentifier

func (*WatchRunDetailsRequest) ProtoMessage 

func (*WatchRunDetailsRequest) ProtoMessage()

func (*WatchRunDetailsRequest) ProtoReflect 

func (x *WatchRunDetailsRequest) ProtoReflect() protoreflect.Message

func (*WatchRunDetailsRequest) Reset 

func (x *WatchRunDetailsRequest) Reset()

func (*WatchRunDetailsRequest) String 

func (x *WatchRunDetailsRequest) String() string

func (*WatchRunDetailsRequest) Validate 

func (m *WatchRunDetailsRequest) Validate() error

Validate checks the field values on WatchRunDetailsRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*WatchRunDetailsRequest) ValidateAll 

func (m *WatchRunDetailsRequest) ValidateAll() error

ValidateAll checks the field values on WatchRunDetailsRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in WatchRunDetailsRequestMultiError, or nil if none found.

type WatchRunDetailsRequestMultiError 

type WatchRunDetailsRequestMultiError []error

WatchRunDetailsRequestMultiError is an error wrapping multiple validation errors returned by WatchRunDetailsRequest.ValidateAll() if the designated constraints aren't met.

func (WatchRunDetailsRequestMultiError) AllErrors 

func (m WatchRunDetailsRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (WatchRunDetailsRequestMultiError) Error 

func (m WatchRunDetailsRequestMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type WatchRunDetailsRequestValidationError 

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

WatchRunDetailsRequestValidationError is the validation error returned by WatchRunDetailsRequest.Validate if the designated constraints aren't met.

func (WatchRunDetailsRequestValidationError) Cause 

func (e WatchRunDetailsRequestValidationError) Cause() error

Cause function returns cause value.

func (WatchRunDetailsRequestValidationError) Error 

func (e WatchRunDetailsRequestValidationError) Error() string

Error satisfies the builtin error interface

func (WatchRunDetailsRequestValidationError) ErrorName 

func (e WatchRunDetailsRequestValidationError) ErrorName() string

ErrorName returns error name.

func (WatchRunDetailsRequestValidationError) Field 

func (e WatchRunDetailsRequestValidationError) Field() string

Field function returns field value.

func (WatchRunDetailsRequestValidationError) Key 

func (e WatchRunDetailsRequestValidationError) Key() bool

Key function returns key value.

func (WatchRunDetailsRequestValidationError) Reason 

func (e WatchRunDetailsRequestValidationError) Reason() string

Reason function returns reason value.

type WatchRunDetailsResponse 

type WatchRunDetailsResponse struct {

	// Detailed information about the run.
	Details *RunDetails `protobuf:"bytes,1,opt,name=details,proto3" json:"details,omitempty"`
	// contains filtered or unexported fields
}

Response message for watching detailed information about a run.

func (*WatchRunDetailsResponse) Descriptor deprecated 

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

Deprecated: Use WatchRunDetailsResponse.ProtoReflect.Descriptor instead.

func (*WatchRunDetailsResponse) GetDetails 

func (x *WatchRunDetailsResponse) GetDetails() *RunDetails

func (*WatchRunDetailsResponse) ProtoMessage 

func (*WatchRunDetailsResponse) ProtoMessage()

func (*WatchRunDetailsResponse) ProtoReflect 

func (x *WatchRunDetailsResponse) ProtoReflect() protoreflect.Message

func (*WatchRunDetailsResponse) Reset 

func (x *WatchRunDetailsResponse) Reset()

func (*WatchRunDetailsResponse) String 

func (x *WatchRunDetailsResponse) String() string

func (*WatchRunDetailsResponse) Validate 

func (m *WatchRunDetailsResponse) Validate() error

Validate checks the field values on WatchRunDetailsResponse with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*WatchRunDetailsResponse) ValidateAll 

func (m *WatchRunDetailsResponse) ValidateAll() error

ValidateAll checks the field values on WatchRunDetailsResponse with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in WatchRunDetailsResponseMultiError, or nil if none found.

type WatchRunDetailsResponseMultiError 

type WatchRunDetailsResponseMultiError []error

WatchRunDetailsResponseMultiError is an error wrapping multiple validation errors returned by WatchRunDetailsResponse.ValidateAll() if the designated constraints aren't met.

func (WatchRunDetailsResponseMultiError) AllErrors 

func (m WatchRunDetailsResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (WatchRunDetailsResponseMultiError) Error 

func (m WatchRunDetailsResponseMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type WatchRunDetailsResponseValidationError 

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

WatchRunDetailsResponseValidationError is the validation error returned by WatchRunDetailsResponse.Validate if the designated constraints aren't met.

func (WatchRunDetailsResponseValidationError) Cause 

func (e WatchRunDetailsResponseValidationError) Cause() error

Cause function returns cause value.

func (WatchRunDetailsResponseValidationError) Error 

func (e WatchRunDetailsResponseValidationError) Error() string

Error satisfies the builtin error interface

func (WatchRunDetailsResponseValidationError) ErrorName 

func (e WatchRunDetailsResponseValidationError) ErrorName() string

ErrorName returns error name.

func (WatchRunDetailsResponseValidationError) Field 

func (e WatchRunDetailsResponseValidationError) Field() string

Field function returns field value.

func (WatchRunDetailsResponseValidationError) Key 

func (e WatchRunDetailsResponseValidationError) Key() bool

Key function returns key value.

func (WatchRunDetailsResponseValidationError) Reason 

func (e WatchRunDetailsResponseValidationError) Reason() string

Reason function returns reason value.

type WatchRunsRequest 

type WatchRunsRequest struct {

	// Types that are assignable to Target:
	//
	//	*WatchRunsRequest_Org
	//	*WatchRunsRequest_ClusterId
	//	*WatchRunsRequest_ProjectId
	//	*WatchRunsRequest_TaskId
	Target isWatchRunsRequest_Target `protobuf_oneof:"target"`
	// contains filtered or unexported fields
}

Request message for watching runs.

func (*WatchRunsRequest) Descriptor deprecated 

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

Deprecated: Use WatchRunsRequest.ProtoReflect.Descriptor instead.

func (*WatchRunsRequest) GetClusterId 

func (x *WatchRunsRequest) GetClusterId() *common.ClusterIdentifier

func (*WatchRunsRequest) GetOrg 

func (x *WatchRunsRequest) GetOrg() string

func (*WatchRunsRequest) GetProjectId 

func (x *WatchRunsRequest) GetProjectId() *common.ProjectIdentifier

func (*WatchRunsRequest) GetTarget 

func (m *WatchRunsRequest) GetTarget() isWatchRunsRequest_Target

func (*WatchRunsRequest) GetTaskId 

func (x *WatchRunsRequest) GetTaskId() *TaskIdentifier

func (*WatchRunsRequest) ProtoMessage 

func (*WatchRunsRequest) ProtoMessage()

func (*WatchRunsRequest) ProtoReflect 

func (x *WatchRunsRequest) ProtoReflect() protoreflect.Message

func (*WatchRunsRequest) Reset 

func (x *WatchRunsRequest) Reset()

func (*WatchRunsRequest) String 

func (x *WatchRunsRequest) String() string

func (*WatchRunsRequest) Validate 

func (m *WatchRunsRequest) Validate() error

Validate checks the field values on WatchRunsRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*WatchRunsRequest) ValidateAll 

func (m *WatchRunsRequest) ValidateAll() error

ValidateAll checks the field values on WatchRunsRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in WatchRunsRequestMultiError, or nil if none found.

type WatchRunsRequestMultiError 

type WatchRunsRequestMultiError []error

WatchRunsRequestMultiError is an error wrapping multiple validation errors returned by WatchRunsRequest.ValidateAll() if the designated constraints aren't met.

func (WatchRunsRequestMultiError) AllErrors 

func (m WatchRunsRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (WatchRunsRequestMultiError) Error 

func (m WatchRunsRequestMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type WatchRunsRequestValidationError 

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

WatchRunsRequestValidationError is the validation error returned by WatchRunsRequest.Validate if the designated constraints aren't met.

func (WatchRunsRequestValidationError) Cause 

func (e WatchRunsRequestValidationError) Cause() error

Cause function returns cause value.

func (WatchRunsRequestValidationError) Error 

func (e WatchRunsRequestValidationError) Error() string

Error satisfies the builtin error interface

func (WatchRunsRequestValidationError) ErrorName 

func (e WatchRunsRequestValidationError) ErrorName() string

ErrorName returns error name.

func (WatchRunsRequestValidationError) Field 

func (e WatchRunsRequestValidationError) Field() string

Field function returns field value.

func (WatchRunsRequestValidationError) Key 

func (e WatchRunsRequestValidationError) Key() bool

Key function returns key value.

func (WatchRunsRequestValidationError) Reason 

func (e WatchRunsRequestValidationError) Reason() string

Reason function returns reason value.

type WatchRunsRequest_ClusterId 

type WatchRunsRequest_ClusterId struct {
	// Cluster identifier for filtering runs.
	ClusterId *common.ClusterIdentifier `protobuf:"bytes,3,opt,name=cluster_id,json=clusterId,proto3,oneof"`
}

type WatchRunsRequest_Org 

type WatchRunsRequest_Org struct {
	// Organization name for filtering runs.
	Org string `protobuf:"bytes,2,opt,name=org,proto3,oneof"`
}

type WatchRunsRequest_ProjectId 

type WatchRunsRequest_ProjectId struct {
	// Project identifier for filtering runs.
	ProjectId *common.ProjectIdentifier `protobuf:"bytes,4,opt,name=project_id,json=projectId,proto3,oneof"`
}

type WatchRunsRequest_TaskId 

type WatchRunsRequest_TaskId struct {
	// Task identifier for filtering runs.
	TaskId *TaskIdentifier `protobuf:"bytes,5,opt,name=task_id,json=taskId,proto3,oneof"`
}

type WatchRunsResponse 

type WatchRunsResponse struct {

	// New or updated runs matching the filter criteria.
	Runs []*Run `protobuf:"bytes,1,rep,name=runs,proto3" json:"runs,omitempty"`
	// contains filtered or unexported fields
}

Response message for watching runs.

func (*WatchRunsResponse) Descriptor deprecated 

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

Deprecated: Use WatchRunsResponse.ProtoReflect.Descriptor instead.

func (*WatchRunsResponse) GetRuns 

func (x *WatchRunsResponse) GetRuns() []*Run

func (*WatchRunsResponse) ProtoMessage 

func (*WatchRunsResponse) ProtoMessage()

func (*WatchRunsResponse) ProtoReflect 

func (x *WatchRunsResponse) ProtoReflect() protoreflect.Message

func (*WatchRunsResponse) Reset 

func (x *WatchRunsResponse) Reset()

func (*WatchRunsResponse) String 

func (x *WatchRunsResponse) String() string

func (*WatchRunsResponse) Validate 

func (m *WatchRunsResponse) Validate() error

Validate checks the field values on WatchRunsResponse with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*WatchRunsResponse) ValidateAll 

func (m *WatchRunsResponse) ValidateAll() error

ValidateAll checks the field values on WatchRunsResponse with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in WatchRunsResponseMultiError, or nil if none found.

type WatchRunsResponseMultiError 

type WatchRunsResponseMultiError []error

WatchRunsResponseMultiError is an error wrapping multiple validation errors returned by WatchRunsResponse.ValidateAll() if the designated constraints aren't met.

func (WatchRunsResponseMultiError) AllErrors 

func (m WatchRunsResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (WatchRunsResponseMultiError) Error 

func (m WatchRunsResponseMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type WatchRunsResponseValidationError 

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

WatchRunsResponseValidationError is the validation error returned by WatchRunsResponse.Validate if the designated constraints aren't met.

func (WatchRunsResponseValidationError) Cause 

func (e WatchRunsResponseValidationError) Cause() error

Cause function returns cause value.

func (WatchRunsResponseValidationError) Error 

func (e WatchRunsResponseValidationError) Error() string

Error satisfies the builtin error interface

func (WatchRunsResponseValidationError) ErrorName 

func (e WatchRunsResponseValidationError) ErrorName() string

ErrorName returns error name.

func (WatchRunsResponseValidationError) Field 

func (e WatchRunsResponseValidationError) Field() string

Field function returns field value.

func (WatchRunsResponseValidationError) Key 

func (e WatchRunsResponseValidationError) Key() bool

Key function returns key value.

func (WatchRunsResponseValidationError) Reason 

func (e WatchRunsResponseValidationError) Reason() string

Reason function returns reason value.

type WorkerIdentifier 

type WorkerIdentifier struct {

	// the organization that this worker is associated with.
	Organization string `protobuf:"bytes,1,opt,name=organization,proto3" json:"organization,omitempty"`
	// the cluster this worker is part of.
	Cluster string `protobuf:"bytes,2,opt,name=cluster,proto3" json:"cluster,omitempty"`
	// the name for the worker, when combined with organization, and cluster this will form a unique
	// identifier for the worker.
	Name string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*WorkerIdentifier) Descriptor deprecated 

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

Deprecated: Use WorkerIdentifier.ProtoReflect.Descriptor instead.

func (*WorkerIdentifier) GetCluster 

func (x *WorkerIdentifier) GetCluster() string

func (*WorkerIdentifier) GetName 

func (x *WorkerIdentifier) GetName() string

func (*WorkerIdentifier) GetOrganization 

func (x *WorkerIdentifier) GetOrganization() string

func (*WorkerIdentifier) ProtoMessage 

func (*WorkerIdentifier) ProtoMessage()

func (*WorkerIdentifier) ProtoReflect 

func (x *WorkerIdentifier) ProtoReflect() protoreflect.Message

func (*WorkerIdentifier) Reset 

func (x *WorkerIdentifier) Reset()

func (*WorkerIdentifier) String 

func (x *WorkerIdentifier) String() string

func (*WorkerIdentifier) Validate 

func (m *WorkerIdentifier) Validate() error

Validate checks the field values on WorkerIdentifier with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*WorkerIdentifier) ValidateAll 

func (m *WorkerIdentifier) ValidateAll() error

ValidateAll checks the field values on WorkerIdentifier with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in WorkerIdentifierMultiError, or nil if none found.

type WorkerIdentifierMultiError 

type WorkerIdentifierMultiError []error

WorkerIdentifierMultiError is an error wrapping multiple validation errors returned by WorkerIdentifier.ValidateAll() if the designated constraints aren't met.

func (WorkerIdentifierMultiError) AllErrors 

func (m WorkerIdentifierMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (WorkerIdentifierMultiError) Error 

func (m WorkerIdentifierMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type WorkerIdentifierValidationError 

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

WorkerIdentifierValidationError is the validation error returned by WorkerIdentifier.Validate if the designated constraints aren't met.

func (WorkerIdentifierValidationError) Cause 

func (e WorkerIdentifierValidationError) Cause() error

Cause function returns cause value.

func (WorkerIdentifierValidationError) Error 

func (e WorkerIdentifierValidationError) Error() string

Error satisfies the builtin error interface

func (WorkerIdentifierValidationError) ErrorName 

func (e WorkerIdentifierValidationError) ErrorName() string

ErrorName returns error name.

func (WorkerIdentifierValidationError) Field 

func (e WorkerIdentifierValidationError) Field() string

Field function returns field value.

func (WorkerIdentifierValidationError) Key 

func (e WorkerIdentifierValidationError) Key() bool

Key function returns key value.

func (WorkerIdentifierValidationError) Reason 

func (e WorkerIdentifierValidationError) Reason() string

Reason function returns reason value.

Source Files

View all Source files

Directories

Path Synopsis

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.