contracts

package
v0.56.1 Latest Latest
Warning

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

 Go to latest Published: Mar 27, 2025 License: MIT Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	SDKS_name = map[int32]string{
		0: "UNKNOWN",
		1: "GO",
		2: "PYTHON",
		3: "TYPESCRIPT",
	}
	SDKS_value = map[string]int32{
		"UNKNOWN":    0,
		"GO":         1,
		"PYTHON":     2,
		"TYPESCRIPT": 3,
	}
)

Enum value maps for SDKS.

View Source 
var (
	ActionType_name = map[int32]string{
		0: "START_STEP_RUN",
		1: "CANCEL_STEP_RUN",
		2: "START_GET_GROUP_KEY",
	}
	ActionType_value = map[string]int32{
		"START_STEP_RUN":      0,
		"CANCEL_STEP_RUN":     1,
		"START_GET_GROUP_KEY": 2,
	}
)

Enum value maps for ActionType.

View Source 
var (
	GroupKeyActionEventType_name = map[int32]string{
		0: "GROUP_KEY_EVENT_TYPE_UNKNOWN",
		1: "GROUP_KEY_EVENT_TYPE_STARTED",
		2: "GROUP_KEY_EVENT_TYPE_COMPLETED",
		3: "GROUP_KEY_EVENT_TYPE_FAILED",
	}
	GroupKeyActionEventType_value = map[string]int32{
		"GROUP_KEY_EVENT_TYPE_UNKNOWN":   0,
		"GROUP_KEY_EVENT_TYPE_STARTED":   1,
		"GROUP_KEY_EVENT_TYPE_COMPLETED": 2,
		"GROUP_KEY_EVENT_TYPE_FAILED":    3,
	}
)

Enum value maps for GroupKeyActionEventType.

View Source 
var (
	StepActionEventType_name = map[int32]string{
		0: "STEP_EVENT_TYPE_UNKNOWN",
		1: "STEP_EVENT_TYPE_STARTED",
		2: "STEP_EVENT_TYPE_COMPLETED",
		3: "STEP_EVENT_TYPE_FAILED",
		4: "STEP_EVENT_TYPE_ACKNOWLEDGED",
	}
	StepActionEventType_value = map[string]int32{
		"STEP_EVENT_TYPE_UNKNOWN":      0,
		"STEP_EVENT_TYPE_STARTED":      1,
		"STEP_EVENT_TYPE_COMPLETED":    2,
		"STEP_EVENT_TYPE_FAILED":       3,
		"STEP_EVENT_TYPE_ACKNOWLEDGED": 4,
	}
)

Enum value maps for StepActionEventType.

View Source 
var (
	ResourceType_name = map[int32]string{
		0: "RESOURCE_TYPE_UNKNOWN",
		1: "RESOURCE_TYPE_STEP_RUN",
		2: "RESOURCE_TYPE_WORKFLOW_RUN",
	}
	ResourceType_value = map[string]int32{
		"RESOURCE_TYPE_UNKNOWN":      0,
		"RESOURCE_TYPE_STEP_RUN":     1,
		"RESOURCE_TYPE_WORKFLOW_RUN": 2,
	}
)

Enum value maps for ResourceType.

View Source 
var (
	ResourceEventType_name = map[int32]string{
		0: "RESOURCE_EVENT_TYPE_UNKNOWN",
		1: "RESOURCE_EVENT_TYPE_STARTED",
		2: "RESOURCE_EVENT_TYPE_COMPLETED",
		3: "RESOURCE_EVENT_TYPE_FAILED",
		4: "RESOURCE_EVENT_TYPE_CANCELLED",
		5: "RESOURCE_EVENT_TYPE_TIMED_OUT",
		6: "RESOURCE_EVENT_TYPE_STREAM",
	}
	ResourceEventType_value = map[string]int32{
		"RESOURCE_EVENT_TYPE_UNKNOWN":   0,
		"RESOURCE_EVENT_TYPE_STARTED":   1,
		"RESOURCE_EVENT_TYPE_COMPLETED": 2,
		"RESOURCE_EVENT_TYPE_FAILED":    3,
		"RESOURCE_EVENT_TYPE_CANCELLED": 4,
		"RESOURCE_EVENT_TYPE_TIMED_OUT": 5,
		"RESOURCE_EVENT_TYPE_STREAM":    6,
	}
)

Enum value maps for ResourceEventType.

View Source 
var (
	WorkflowRunEventType_name = map[int32]string{
		0: "WORKFLOW_RUN_EVENT_TYPE_FINISHED",
	}
	WorkflowRunEventType_value = map[string]int32{
		"WORKFLOW_RUN_EVENT_TYPE_FINISHED": 0,
	}
)

Enum value maps for WorkflowRunEventType.

View Source 
var Dispatcher_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "Dispatcher",
	HandlerType: (*DispatcherServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Register",
			Handler:    _Dispatcher_Register_Handler,
		},
		{
			MethodName: "Heartbeat",
			Handler:    _Dispatcher_Heartbeat_Handler,
		},
		{
			MethodName: "SendStepActionEvent",
			Handler:    _Dispatcher_SendStepActionEvent_Handler,
		},
		{
			MethodName: "SendGroupKeyActionEvent",
			Handler:    _Dispatcher_SendGroupKeyActionEvent_Handler,
		},
		{
			MethodName: "PutOverridesData",
			Handler:    _Dispatcher_PutOverridesData_Handler,
		},
		{
			MethodName: "Unsubscribe",
			Handler:    _Dispatcher_Unsubscribe_Handler,
		},
		{
			MethodName: "RefreshTimeout",
			Handler:    _Dispatcher_RefreshTimeout_Handler,
		},
		{
			MethodName: "ReleaseSlot",
			Handler:    _Dispatcher_ReleaseSlot_Handler,
		},
		{
			MethodName: "UpsertWorkerLabels",
			Handler:    _Dispatcher_UpsertWorkerLabels_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Listen",
			Handler:       _Dispatcher_Listen_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "ListenV2",
			Handler:       _Dispatcher_ListenV2_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "SubscribeToWorkflowEvents",
			Handler:       _Dispatcher_SubscribeToWorkflowEvents_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "SubscribeToWorkflowRuns",
			Handler:       _Dispatcher_SubscribeToWorkflowRuns_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "dispatcher.proto",
}

Dispatcher_ServiceDesc is the grpc.ServiceDesc for Dispatcher 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 File_dispatcher_proto protoreflect.FileDescriptor

Functions

func RegisterDispatcherServer 

func RegisterDispatcherServer(s grpc.ServiceRegistrar, srv DispatcherServer)

Types

type ActionEventResponse 

type ActionEventResponse struct {

	// the tenant id
	TenantId string `protobuf:"bytes,1,opt,name=tenantId,proto3" json:"tenantId,omitempty"`
	// the id of the worker
	WorkerId string `protobuf:"bytes,2,opt,name=workerId,proto3" json:"workerId,omitempty"`
	// contains filtered or unexported fields
}

func (*ActionEventResponse) Descriptor deprecated 

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

Deprecated: Use ActionEventResponse.ProtoReflect.Descriptor instead.

func (*ActionEventResponse) GetTenantId 

func (x *ActionEventResponse) GetTenantId() string

func (*ActionEventResponse) GetWorkerId 

func (x *ActionEventResponse) GetWorkerId() string

func (*ActionEventResponse) ProtoMessage 

func (*ActionEventResponse) ProtoMessage()

func (*ActionEventResponse) ProtoReflect 

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

func (*ActionEventResponse) Reset 

func (x *ActionEventResponse) Reset()

func (*ActionEventResponse) String 

func (x *ActionEventResponse) String() string

type ActionType 

type ActionType int32
const (
	ActionType_START_STEP_RUN      ActionType = 0
	ActionType_CANCEL_STEP_RUN     ActionType = 1
	ActionType_START_GET_GROUP_KEY ActionType = 2
)

func (ActionType) Descriptor 

func (ActionType) Descriptor() protoreflect.EnumDescriptor

func (ActionType) Enum 

func (x ActionType) Enum() *ActionType

func (ActionType) EnumDescriptor deprecated 

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

Deprecated: Use ActionType.Descriptor instead.

func (ActionType) Number 

func (x ActionType) Number() protoreflect.EnumNumber

func (ActionType) String 

func (x ActionType) String() string

func (ActionType) Type 

func (ActionType) Type() protoreflect.EnumType

type AssignedAction 

type AssignedAction struct {

	// the tenant id
	TenantId string `protobuf:"bytes,1,opt,name=tenantId,proto3" json:"tenantId,omitempty"`
	// the workflow run id (optional)
	WorkflowRunId string `protobuf:"bytes,2,opt,name=workflowRunId,proto3" json:"workflowRunId,omitempty"`
	// the get group key run id (optional)
	GetGroupKeyRunId string `protobuf:"bytes,3,opt,name=getGroupKeyRunId,proto3" json:"getGroupKeyRunId,omitempty"`
	// the job id
	JobId string `protobuf:"bytes,4,opt,name=jobId,proto3" json:"jobId,omitempty"`
	// the job name
	JobName string `protobuf:"bytes,5,opt,name=jobName,proto3" json:"jobName,omitempty"`
	// the job run id
	JobRunId string `protobuf:"bytes,6,opt,name=jobRunId,proto3" json:"jobRunId,omitempty"`
	// the step id
	StepId string `protobuf:"bytes,7,opt,name=stepId,proto3" json:"stepId,omitempty"`
	// the step run id
	StepRunId string `protobuf:"bytes,8,opt,name=stepRunId,proto3" json:"stepRunId,omitempty"`
	// the action id
	ActionId string `protobuf:"bytes,9,opt,name=actionId,proto3" json:"actionId,omitempty"`
	// the action type
	ActionType ActionType `protobuf:"varint,10,opt,name=actionType,proto3,enum=ActionType" json:"actionType,omitempty"`
	// the action payload
	ActionPayload string `protobuf:"bytes,11,opt,name=actionPayload,proto3" json:"actionPayload,omitempty"`
	// the step name
	StepName string `protobuf:"bytes,12,opt,name=stepName,proto3" json:"stepName,omitempty"`
	// the count number of the retry attempt
	RetryCount int32 `protobuf:"varint,13,opt,name=retryCount,proto3" json:"retryCount,omitempty"`
	// (optional) additional metadata set on the workflow
	AdditionalMetadata *string `protobuf:"bytes,14,opt,name=additional_metadata,json=additionalMetadata,proto3,oneof" json:"additional_metadata,omitempty"`
	// (optional) the child workflow index (if this is a child workflow)
	ChildWorkflowIndex *int32 `protobuf:"varint,15,opt,name=child_workflow_index,json=childWorkflowIndex,proto3,oneof" json:"child_workflow_index,omitempty"`
	// (optional) the child workflow key (if this is a child workflow)
	ChildWorkflowKey *string `protobuf:"bytes,16,opt,name=child_workflow_key,json=childWorkflowKey,proto3,oneof" json:"child_workflow_key,omitempty"`
	// (optional) the parent workflow run id (if this is a child workflow)
	ParentWorkflowRunId *string `` /* 129-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*AssignedAction) Descriptor deprecated 

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

Deprecated: Use AssignedAction.ProtoReflect.Descriptor instead.

func (*AssignedAction) GetActionId 

func (x *AssignedAction) GetActionId() string

func (*AssignedAction) GetActionPayload 

func (x *AssignedAction) GetActionPayload() string

func (*AssignedAction) GetActionType 

func (x *AssignedAction) GetActionType() ActionType

func (*AssignedAction) GetAdditionalMetadata 

func (x *AssignedAction) GetAdditionalMetadata() string

func (*AssignedAction) GetChildWorkflowIndex 

func (x *AssignedAction) GetChildWorkflowIndex() int32

func (*AssignedAction) GetChildWorkflowKey 

func (x *AssignedAction) GetChildWorkflowKey() string

func (*AssignedAction) GetGetGroupKeyRunId 

func (x *AssignedAction) GetGetGroupKeyRunId() string

func (*AssignedAction) GetJobId 

func (x *AssignedAction) GetJobId() string

func (*AssignedAction) GetJobName 

func (x *AssignedAction) GetJobName() string

func (*AssignedAction) GetJobRunId 

func (x *AssignedAction) GetJobRunId() string

func (*AssignedAction) GetParentWorkflowRunId 

func (x *AssignedAction) GetParentWorkflowRunId() string

func (*AssignedAction) GetRetryCount 

func (x *AssignedAction) GetRetryCount() int32

func (*AssignedAction) GetStepId 

func (x *AssignedAction) GetStepId() string

func (*AssignedAction) GetStepName 

func (x *AssignedAction) GetStepName() string

func (*AssignedAction) GetStepRunId 

func (x *AssignedAction) GetStepRunId() string

func (*AssignedAction) GetTenantId 

func (x *AssignedAction) GetTenantId() string

func (*AssignedAction) GetWorkflowRunId 

func (x *AssignedAction) GetWorkflowRunId() string

func (*AssignedAction) ProtoMessage 

func (*AssignedAction) ProtoMessage()

func (*AssignedAction) ProtoReflect 

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

func (*AssignedAction) Reset 

func (x *AssignedAction) Reset()

func (*AssignedAction) String 

func (x *AssignedAction) String() string

type DispatcherClient 

type DispatcherClient interface {
	Register(ctx context.Context, in *WorkerRegisterRequest, opts ...grpc.CallOption) (*WorkerRegisterResponse, error)
	Listen(ctx context.Context, in *WorkerListenRequest, opts ...grpc.CallOption) (Dispatcher_ListenClient, error)
	// ListenV2 is like listen, but implementation does not include heartbeats. This should only used by SDKs
	// against engine version v0.18.1+
	ListenV2(ctx context.Context, in *WorkerListenRequest, opts ...grpc.CallOption) (Dispatcher_ListenV2Client, error)
	// Heartbeat is a method for workers to send heartbeats to the dispatcher
	Heartbeat(ctx context.Context, in *HeartbeatRequest, opts ...grpc.CallOption) (*HeartbeatResponse, error)
	SubscribeToWorkflowEvents(ctx context.Context, in *SubscribeToWorkflowEventsRequest, opts ...grpc.CallOption) (Dispatcher_SubscribeToWorkflowEventsClient, error)
	SubscribeToWorkflowRuns(ctx context.Context, opts ...grpc.CallOption) (Dispatcher_SubscribeToWorkflowRunsClient, error)
	SendStepActionEvent(ctx context.Context, in *StepActionEvent, opts ...grpc.CallOption) (*ActionEventResponse, error)
	SendGroupKeyActionEvent(ctx context.Context, in *GroupKeyActionEvent, opts ...grpc.CallOption) (*ActionEventResponse, error)
	PutOverridesData(ctx context.Context, in *OverridesData, opts ...grpc.CallOption) (*OverridesDataResponse, error)
	Unsubscribe(ctx context.Context, in *WorkerUnsubscribeRequest, opts ...grpc.CallOption) (*WorkerUnsubscribeResponse, error)
	RefreshTimeout(ctx context.Context, in *RefreshTimeoutRequest, opts ...grpc.CallOption) (*RefreshTimeoutResponse, error)
	ReleaseSlot(ctx context.Context, in *ReleaseSlotRequest, opts ...grpc.CallOption) (*ReleaseSlotResponse, error)
	UpsertWorkerLabels(ctx context.Context, in *UpsertWorkerLabelsRequest, opts ...grpc.CallOption) (*UpsertWorkerLabelsResponse, error)
}

DispatcherClient is the client API for Dispatcher 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 NewDispatcherClient 

func NewDispatcherClient(cc grpc.ClientConnInterface) DispatcherClient

type DispatcherServer 

type DispatcherServer interface {
	Register(context.Context, *WorkerRegisterRequest) (*WorkerRegisterResponse, error)
	Listen(*WorkerListenRequest, Dispatcher_ListenServer) error
	// ListenV2 is like listen, but implementation does not include heartbeats. This should only used by SDKs
	// against engine version v0.18.1+
	ListenV2(*WorkerListenRequest, Dispatcher_ListenV2Server) error
	// Heartbeat is a method for workers to send heartbeats to the dispatcher
	Heartbeat(context.Context, *HeartbeatRequest) (*HeartbeatResponse, error)
	SubscribeToWorkflowEvents(*SubscribeToWorkflowEventsRequest, Dispatcher_SubscribeToWorkflowEventsServer) error
	SubscribeToWorkflowRuns(Dispatcher_SubscribeToWorkflowRunsServer) error
	SendStepActionEvent(context.Context, *StepActionEvent) (*ActionEventResponse, error)
	SendGroupKeyActionEvent(context.Context, *GroupKeyActionEvent) (*ActionEventResponse, error)
	PutOverridesData(context.Context, *OverridesData) (*OverridesDataResponse, error)
	Unsubscribe(context.Context, *WorkerUnsubscribeRequest) (*WorkerUnsubscribeResponse, error)
	RefreshTimeout(context.Context, *RefreshTimeoutRequest) (*RefreshTimeoutResponse, error)
	ReleaseSlot(context.Context, *ReleaseSlotRequest) (*ReleaseSlotResponse, error)
	UpsertWorkerLabels(context.Context, *UpsertWorkerLabelsRequest) (*UpsertWorkerLabelsResponse, error)
	// contains filtered or unexported methods
}

DispatcherServer is the server API for Dispatcher service. All implementations must embed UnimplementedDispatcherServer for forward compatibility

type Dispatcher_ListenClient 

type Dispatcher_ListenClient interface {
	Recv() (*AssignedAction, error)
	grpc.ClientStream
}

type Dispatcher_ListenServer 

type Dispatcher_ListenServer interface {
	Send(*AssignedAction) error
	grpc.ServerStream
}

type Dispatcher_ListenV2Client 

type Dispatcher_ListenV2Client interface {
	Recv() (*AssignedAction, error)
	grpc.ClientStream
}

type Dispatcher_ListenV2Server 

type Dispatcher_ListenV2Server interface {
	Send(*AssignedAction) error
	grpc.ServerStream
}

type Dispatcher_SubscribeToWorkflowEventsClient 

type Dispatcher_SubscribeToWorkflowEventsClient interface {
	Recv() (*WorkflowEvent, error)
	grpc.ClientStream
}

type Dispatcher_SubscribeToWorkflowEventsServer 

type Dispatcher_SubscribeToWorkflowEventsServer interface {
	Send(*WorkflowEvent) error
	grpc.ServerStream
}

type Dispatcher_SubscribeToWorkflowRunsClient 

type Dispatcher_SubscribeToWorkflowRunsClient interface {
	Send(*SubscribeToWorkflowRunsRequest) error
	Recv() (*WorkflowRunEvent, error)
	grpc.ClientStream
}

type Dispatcher_SubscribeToWorkflowRunsServer 

type Dispatcher_SubscribeToWorkflowRunsServer interface {
	Send(*WorkflowRunEvent) error
	Recv() (*SubscribeToWorkflowRunsRequest, error)
	grpc.ServerStream
}

type GroupKeyActionEvent 

type GroupKeyActionEvent struct {

	// the id of the worker
	WorkerId string `protobuf:"bytes,1,opt,name=workerId,proto3" json:"workerId,omitempty"`
	// the id of the job
	WorkflowRunId    string `protobuf:"bytes,2,opt,name=workflowRunId,proto3" json:"workflowRunId,omitempty"`
	GetGroupKeyRunId string `protobuf:"bytes,3,opt,name=getGroupKeyRunId,proto3" json:"getGroupKeyRunId,omitempty"`
	// the action id
	ActionId       string                 `protobuf:"bytes,4,opt,name=actionId,proto3" json:"actionId,omitempty"`
	EventTimestamp *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=eventTimestamp,proto3" json:"eventTimestamp,omitempty"`
	// the step event type
	EventType GroupKeyActionEventType `protobuf:"varint,6,opt,name=eventType,proto3,enum=GroupKeyActionEventType" json:"eventType,omitempty"`
	// the event payload
	EventPayload string `protobuf:"bytes,7,opt,name=eventPayload,proto3" json:"eventPayload,omitempty"`
	// contains filtered or unexported fields
}

func (*GroupKeyActionEvent) Descriptor deprecated 

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

Deprecated: Use GroupKeyActionEvent.ProtoReflect.Descriptor instead.

func (*GroupKeyActionEvent) GetActionId 

func (x *GroupKeyActionEvent) GetActionId() string

func (*GroupKeyActionEvent) GetEventPayload 

func (x *GroupKeyActionEvent) GetEventPayload() string

func (*GroupKeyActionEvent) GetEventTimestamp 

func (x *GroupKeyActionEvent) GetEventTimestamp() *timestamppb.Timestamp

func (*GroupKeyActionEvent) GetEventType 

func (x *GroupKeyActionEvent) GetEventType() GroupKeyActionEventType

func (*GroupKeyActionEvent) GetGetGroupKeyRunId 

func (x *GroupKeyActionEvent) GetGetGroupKeyRunId() string

func (*GroupKeyActionEvent) GetWorkerId 

func (x *GroupKeyActionEvent) GetWorkerId() string

func (*GroupKeyActionEvent) GetWorkflowRunId 

func (x *GroupKeyActionEvent) GetWorkflowRunId() string

func (*GroupKeyActionEvent) ProtoMessage 

func (*GroupKeyActionEvent) ProtoMessage()

func (*GroupKeyActionEvent) ProtoReflect 

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

func (*GroupKeyActionEvent) Reset 

func (x *GroupKeyActionEvent) Reset()

func (*GroupKeyActionEvent) String 

func (x *GroupKeyActionEvent) String() string

type GroupKeyActionEventType 

type GroupKeyActionEventType int32
const (
	GroupKeyActionEventType_GROUP_KEY_EVENT_TYPE_UNKNOWN   GroupKeyActionEventType = 0
	GroupKeyActionEventType_GROUP_KEY_EVENT_TYPE_STARTED   GroupKeyActionEventType = 1
	GroupKeyActionEventType_GROUP_KEY_EVENT_TYPE_COMPLETED GroupKeyActionEventType = 2
	GroupKeyActionEventType_GROUP_KEY_EVENT_TYPE_FAILED    GroupKeyActionEventType = 3
)

func (GroupKeyActionEventType) Descriptor 

func (GroupKeyActionEventType) Descriptor() protoreflect.EnumDescriptor

func (GroupKeyActionEventType) Enum 

func (x GroupKeyActionEventType) Enum() *GroupKeyActionEventType

func (GroupKeyActionEventType) EnumDescriptor deprecated 

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

Deprecated: Use GroupKeyActionEventType.Descriptor instead.

func (GroupKeyActionEventType) Number 

func (x GroupKeyActionEventType) Number() protoreflect.EnumNumber

func (GroupKeyActionEventType) String 

func (x GroupKeyActionEventType) String() string

func (GroupKeyActionEventType) Type 

func (GroupKeyActionEventType) Type() protoreflect.EnumType

type HeartbeatRequest 

type HeartbeatRequest struct {

	// the id of the worker
	WorkerId string `protobuf:"bytes,1,opt,name=workerId,proto3" json:"workerId,omitempty"`
	// heartbeatAt is the time the worker sent the heartbeat
	HeartbeatAt *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=heartbeatAt,proto3" json:"heartbeatAt,omitempty"`
	// contains filtered or unexported fields
}

func (*HeartbeatRequest) Descriptor deprecated 

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

Deprecated: Use HeartbeatRequest.ProtoReflect.Descriptor instead.

func (*HeartbeatRequest) GetHeartbeatAt 

func (x *HeartbeatRequest) GetHeartbeatAt() *timestamppb.Timestamp

func (*HeartbeatRequest) GetWorkerId 

func (x *HeartbeatRequest) GetWorkerId() string

func (*HeartbeatRequest) ProtoMessage 

func (*HeartbeatRequest) ProtoMessage()

func (*HeartbeatRequest) ProtoReflect 

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

func (*HeartbeatRequest) Reset 

func (x *HeartbeatRequest) Reset()

func (*HeartbeatRequest) String 

func (x *HeartbeatRequest) String() string

type HeartbeatResponse 

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

func (*HeartbeatResponse) Descriptor deprecated 

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

Deprecated: Use HeartbeatResponse.ProtoReflect.Descriptor instead.

func (*HeartbeatResponse) ProtoMessage 

func (*HeartbeatResponse) ProtoMessage()

func (*HeartbeatResponse) ProtoReflect 

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

func (*HeartbeatResponse) Reset 

func (x *HeartbeatResponse) Reset()

func (*HeartbeatResponse) String 

func (x *HeartbeatResponse) String() string

type OverridesData 

type OverridesData struct {

	// the step run id
	StepRunId string `protobuf:"bytes,1,opt,name=stepRunId,proto3" json:"stepRunId,omitempty"`
	// the path of the data to set
	Path string `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	// the value to set
	Value string `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	// the filename of the caller
	CallerFilename string `protobuf:"bytes,4,opt,name=callerFilename,proto3" json:"callerFilename,omitempty"`
	// contains filtered or unexported fields
}

func (*OverridesData) Descriptor deprecated 

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

Deprecated: Use OverridesData.ProtoReflect.Descriptor instead.

func (*OverridesData) GetCallerFilename 

func (x *OverridesData) GetCallerFilename() string

func (*OverridesData) GetPath 

func (x *OverridesData) GetPath() string

func (*OverridesData) GetStepRunId 

func (x *OverridesData) GetStepRunId() string

func (*OverridesData) GetValue 

func (x *OverridesData) GetValue() string

func (*OverridesData) ProtoMessage 

func (*OverridesData) ProtoMessage()

func (*OverridesData) ProtoReflect 

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

func (*OverridesData) Reset 

func (x *OverridesData) Reset()

func (*OverridesData) String 

func (x *OverridesData) String() string

type OverridesDataResponse 

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

func (*OverridesDataResponse) Descriptor deprecated 

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

Deprecated: Use OverridesDataResponse.ProtoReflect.Descriptor instead.

func (*OverridesDataResponse) ProtoMessage 

func (*OverridesDataResponse) ProtoMessage()

func (*OverridesDataResponse) ProtoReflect 

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

func (*OverridesDataResponse) Reset 

func (x *OverridesDataResponse) Reset()

func (*OverridesDataResponse) String 

func (x *OverridesDataResponse) String() string

type RefreshTimeoutRequest 

type RefreshTimeoutRequest struct {

	// the id of the step run to release
	StepRunId          string `protobuf:"bytes,1,opt,name=stepRunId,proto3" json:"stepRunId,omitempty"`
	IncrementTimeoutBy string `protobuf:"bytes,2,opt,name=incrementTimeoutBy,proto3" json:"incrementTimeoutBy,omitempty"`
	// contains filtered or unexported fields
}

func (*RefreshTimeoutRequest) Descriptor deprecated 

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

Deprecated: Use RefreshTimeoutRequest.ProtoReflect.Descriptor instead.

func (*RefreshTimeoutRequest) GetIncrementTimeoutBy 

func (x *RefreshTimeoutRequest) GetIncrementTimeoutBy() string

func (*RefreshTimeoutRequest) GetStepRunId 

func (x *RefreshTimeoutRequest) GetStepRunId() string

func (*RefreshTimeoutRequest) ProtoMessage 

func (*RefreshTimeoutRequest) ProtoMessage()

func (*RefreshTimeoutRequest) ProtoReflect 

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

func (*RefreshTimeoutRequest) Reset 

func (x *RefreshTimeoutRequest) Reset()

func (*RefreshTimeoutRequest) String 

func (x *RefreshTimeoutRequest) String() string

type RefreshTimeoutResponse 

type RefreshTimeoutResponse struct {
	TimeoutAt *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=timeoutAt,proto3" json:"timeoutAt,omitempty"`
	// contains filtered or unexported fields
}

func (*RefreshTimeoutResponse) Descriptor deprecated 

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

Deprecated: Use RefreshTimeoutResponse.ProtoReflect.Descriptor instead.

func (*RefreshTimeoutResponse) GetTimeoutAt 

func (x *RefreshTimeoutResponse) GetTimeoutAt() *timestamppb.Timestamp

func (*RefreshTimeoutResponse) ProtoMessage 

func (*RefreshTimeoutResponse) ProtoMessage()

func (*RefreshTimeoutResponse) ProtoReflect 

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

func (*RefreshTimeoutResponse) Reset 

func (x *RefreshTimeoutResponse) Reset()

func (*RefreshTimeoutResponse) String 

func (x *RefreshTimeoutResponse) String() string

type ReleaseSlotRequest 

type ReleaseSlotRequest struct {

	// the id of the step run to release
	StepRunId string `protobuf:"bytes,1,opt,name=stepRunId,proto3" json:"stepRunId,omitempty"`
	// contains filtered or unexported fields
}

func (*ReleaseSlotRequest) Descriptor deprecated 

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

Deprecated: Use ReleaseSlotRequest.ProtoReflect.Descriptor instead.

func (*ReleaseSlotRequest) GetStepRunId 

func (x *ReleaseSlotRequest) GetStepRunId() string

func (*ReleaseSlotRequest) ProtoMessage 

func (*ReleaseSlotRequest) ProtoMessage()

func (*ReleaseSlotRequest) ProtoReflect 

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

func (*ReleaseSlotRequest) Reset 

func (x *ReleaseSlotRequest) Reset()

func (*ReleaseSlotRequest) String 

func (x *ReleaseSlotRequest) String() string

type ReleaseSlotResponse 

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

func (*ReleaseSlotResponse) Descriptor deprecated 

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

Deprecated: Use ReleaseSlotResponse.ProtoReflect.Descriptor instead.

func (*ReleaseSlotResponse) ProtoMessage 

func (*ReleaseSlotResponse) ProtoMessage()

func (*ReleaseSlotResponse) ProtoReflect 

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

func (*ReleaseSlotResponse) Reset 

func (x *ReleaseSlotResponse) Reset()

func (*ReleaseSlotResponse) String 

func (x *ReleaseSlotResponse) String() string

type ResourceEventType 

type ResourceEventType int32
const (
	ResourceEventType_RESOURCE_EVENT_TYPE_UNKNOWN   ResourceEventType = 0
	ResourceEventType_RESOURCE_EVENT_TYPE_STARTED   ResourceEventType = 1
	ResourceEventType_RESOURCE_EVENT_TYPE_COMPLETED ResourceEventType = 2
	ResourceEventType_RESOURCE_EVENT_TYPE_FAILED    ResourceEventType = 3
	ResourceEventType_RESOURCE_EVENT_TYPE_CANCELLED ResourceEventType = 4
	ResourceEventType_RESOURCE_EVENT_TYPE_TIMED_OUT ResourceEventType = 5
	ResourceEventType_RESOURCE_EVENT_TYPE_STREAM    ResourceEventType = 6
)

func (ResourceEventType) Descriptor 

func (ResourceEventType) Descriptor() protoreflect.EnumDescriptor

func (ResourceEventType) Enum 

func (x ResourceEventType) Enum() *ResourceEventType

func (ResourceEventType) EnumDescriptor deprecated 

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

Deprecated: Use ResourceEventType.Descriptor instead.

func (ResourceEventType) Number 

func (x ResourceEventType) Number() protoreflect.EnumNumber

func (ResourceEventType) String 

func (x ResourceEventType) String() string

func (ResourceEventType) Type 

func (ResourceEventType) Type() protoreflect.EnumType

type ResourceType 

type ResourceType int32
const (
	ResourceType_RESOURCE_TYPE_UNKNOWN      ResourceType = 0
	ResourceType_RESOURCE_TYPE_STEP_RUN     ResourceType = 1
	ResourceType_RESOURCE_TYPE_WORKFLOW_RUN ResourceType = 2
)

func (ResourceType) Descriptor 

func (ResourceType) Descriptor() protoreflect.EnumDescriptor

func (ResourceType) Enum 

func (x ResourceType) Enum() *ResourceType

func (ResourceType) EnumDescriptor deprecated 

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

Deprecated: Use ResourceType.Descriptor instead.

func (ResourceType) Number 

func (x ResourceType) Number() protoreflect.EnumNumber

func (ResourceType) String 

func (x ResourceType) String() string

func (ResourceType) Type 

func (ResourceType) Type() protoreflect.EnumType

type RuntimeInfo 

type RuntimeInfo struct {
	SdkVersion      *string `protobuf:"bytes,1,opt,name=sdkVersion,proto3,oneof" json:"sdkVersion,omitempty"`
	Language        *SDKS   `protobuf:"varint,2,opt,name=language,proto3,enum=SDKS,oneof" json:"language,omitempty"`
	LanguageVersion *string `protobuf:"bytes,3,opt,name=languageVersion,proto3,oneof" json:"languageVersion,omitempty"`
	Os              *string `protobuf:"bytes,4,opt,name=os,proto3,oneof" json:"os,omitempty"`
	Extra           *string `protobuf:"bytes,5,opt,name=extra,proto3,oneof" json:"extra,omitempty"`
	// contains filtered or unexported fields
}

func (*RuntimeInfo) Descriptor deprecated 

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

Deprecated: Use RuntimeInfo.ProtoReflect.Descriptor instead.

func (*RuntimeInfo) GetExtra 

func (x *RuntimeInfo) GetExtra() string

func (*RuntimeInfo) GetLanguage 

func (x *RuntimeInfo) GetLanguage() SDKS

func (*RuntimeInfo) GetLanguageVersion 

func (x *RuntimeInfo) GetLanguageVersion() string

func (*RuntimeInfo) GetOs 

func (x *RuntimeInfo) GetOs() string

func (*RuntimeInfo) GetSdkVersion 

func (x *RuntimeInfo) GetSdkVersion() string

func (*RuntimeInfo) ProtoMessage 

func (*RuntimeInfo) ProtoMessage()

func (*RuntimeInfo) ProtoReflect 

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

func (*RuntimeInfo) Reset 

func (x *RuntimeInfo) Reset()

func (*RuntimeInfo) String 

func (x *RuntimeInfo) String() string

type SDKS 

type SDKS int32
const (
	SDKS_UNKNOWN    SDKS = 0
	SDKS_GO         SDKS = 1
	SDKS_PYTHON     SDKS = 2
	SDKS_TYPESCRIPT SDKS = 3
)

func (SDKS) Descriptor 

func (SDKS) Descriptor() protoreflect.EnumDescriptor

func (SDKS) Enum 

func (x SDKS) Enum() *SDKS

func (SDKS) EnumDescriptor deprecated 

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

Deprecated: Use SDKS.Descriptor instead.

func (SDKS) Number 

func (x SDKS) Number() protoreflect.EnumNumber

func (SDKS) String 

func (x SDKS) String() string

func (SDKS) Type 

func (SDKS) Type() protoreflect.EnumType

type StepActionEvent 

type StepActionEvent struct {

	// the id of the worker
	WorkerId string `protobuf:"bytes,1,opt,name=workerId,proto3" json:"workerId,omitempty"`
	// the id of the job
	JobId string `protobuf:"bytes,2,opt,name=jobId,proto3" json:"jobId,omitempty"`
	// the job run id
	JobRunId string `protobuf:"bytes,3,opt,name=jobRunId,proto3" json:"jobRunId,omitempty"`
	// the id of the step
	StepId string `protobuf:"bytes,4,opt,name=stepId,proto3" json:"stepId,omitempty"`
	// the step run id
	StepRunId string `protobuf:"bytes,5,opt,name=stepRunId,proto3" json:"stepRunId,omitempty"`
	// the action id
	ActionId       string                 `protobuf:"bytes,6,opt,name=actionId,proto3" json:"actionId,omitempty"`
	EventTimestamp *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=eventTimestamp,proto3" json:"eventTimestamp,omitempty"`
	// the step event type
	EventType StepActionEventType `protobuf:"varint,8,opt,name=eventType,proto3,enum=StepActionEventType" json:"eventType,omitempty"`
	// the event payload
	EventPayload string `protobuf:"bytes,9,opt,name=eventPayload,proto3" json:"eventPayload,omitempty"`
	// the retry count
	RetryCount *int32 `protobuf:"varint,10,opt,name=retryCount,proto3,oneof" json:"retryCount,omitempty"`
	// contains filtered or unexported fields
}

func (*StepActionEvent) Descriptor deprecated 

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

Deprecated: Use StepActionEvent.ProtoReflect.Descriptor instead.

func (*StepActionEvent) GetActionId 

func (x *StepActionEvent) GetActionId() string

func (*StepActionEvent) GetEventPayload 

func (x *StepActionEvent) GetEventPayload() string

func (*StepActionEvent) GetEventTimestamp 

func (x *StepActionEvent) GetEventTimestamp() *timestamppb.Timestamp

func (*StepActionEvent) GetEventType 

func (x *StepActionEvent) GetEventType() StepActionEventType

func (*StepActionEvent) GetJobId 

func (x *StepActionEvent) GetJobId() string

func (*StepActionEvent) GetJobRunId 

func (x *StepActionEvent) GetJobRunId() string

func (*StepActionEvent) GetRetryCount 

func (x *StepActionEvent) GetRetryCount() int32

func (*StepActionEvent) GetStepId 

func (x *StepActionEvent) GetStepId() string

func (*StepActionEvent) GetStepRunId 

func (x *StepActionEvent) GetStepRunId() string

func (*StepActionEvent) GetWorkerId 

func (x *StepActionEvent) GetWorkerId() string

func (*StepActionEvent) ProtoMessage 

func (*StepActionEvent) ProtoMessage()

func (*StepActionEvent) ProtoReflect 

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

func (*StepActionEvent) Reset 

func (x *StepActionEvent) Reset()

func (*StepActionEvent) String 

func (x *StepActionEvent) String() string

type StepActionEventType 

type StepActionEventType int32
const (
	StepActionEventType_STEP_EVENT_TYPE_UNKNOWN      StepActionEventType = 0
	StepActionEventType_STEP_EVENT_TYPE_STARTED      StepActionEventType = 1
	StepActionEventType_STEP_EVENT_TYPE_COMPLETED    StepActionEventType = 2
	StepActionEventType_STEP_EVENT_TYPE_FAILED       StepActionEventType = 3
	StepActionEventType_STEP_EVENT_TYPE_ACKNOWLEDGED StepActionEventType = 4
)

func (StepActionEventType) Descriptor 

func (StepActionEventType) Descriptor() protoreflect.EnumDescriptor

func (StepActionEventType) Enum 

func (x StepActionEventType) Enum() *StepActionEventType

func (StepActionEventType) EnumDescriptor deprecated 

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

Deprecated: Use StepActionEventType.Descriptor instead.

func (StepActionEventType) Number 

func (x StepActionEventType) Number() protoreflect.EnumNumber

func (StepActionEventType) String 

func (x StepActionEventType) String() string

func (StepActionEventType) Type 

func (StepActionEventType) Type() protoreflect.EnumType

type StepRunResult 

type StepRunResult struct {
	StepRunId      string  `protobuf:"bytes,1,opt,name=stepRunId,proto3" json:"stepRunId,omitempty"`
	StepReadableId string  `protobuf:"bytes,2,opt,name=stepReadableId,proto3" json:"stepReadableId,omitempty"`
	JobRunId       string  `protobuf:"bytes,3,opt,name=jobRunId,proto3" json:"jobRunId,omitempty"`
	Error          *string `protobuf:"bytes,4,opt,name=error,proto3,oneof" json:"error,omitempty"`
	Output         *string `protobuf:"bytes,5,opt,name=output,proto3,oneof" json:"output,omitempty"`
	// contains filtered or unexported fields
}

func (*StepRunResult) Descriptor deprecated 

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

Deprecated: Use StepRunResult.ProtoReflect.Descriptor instead.

func (*StepRunResult) GetError 

func (x *StepRunResult) GetError() string

func (*StepRunResult) GetJobRunId 

func (x *StepRunResult) GetJobRunId() string

func (*StepRunResult) GetOutput 

func (x *StepRunResult) GetOutput() string

func (*StepRunResult) GetStepReadableId 

func (x *StepRunResult) GetStepReadableId() string

func (*StepRunResult) GetStepRunId 

func (x *StepRunResult) GetStepRunId() string

func (*StepRunResult) ProtoMessage 

func (*StepRunResult) ProtoMessage()

func (*StepRunResult) ProtoReflect 

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

func (*StepRunResult) Reset 

func (x *StepRunResult) Reset()

func (*StepRunResult) String 

func (x *StepRunResult) String() string

type SubscribeToWorkflowEventsRequest 

type SubscribeToWorkflowEventsRequest struct {

	// the id of the workflow run
	WorkflowRunId *string `protobuf:"bytes,1,opt,name=workflowRunId,proto3,oneof" json:"workflowRunId,omitempty"`
	// the key of the additional meta field to subscribe to
	AdditionalMetaKey *string `protobuf:"bytes,2,opt,name=additionalMetaKey,proto3,oneof" json:"additionalMetaKey,omitempty"`
	// the value of the additional meta field to subscribe to
	AdditionalMetaValue *string `protobuf:"bytes,3,opt,name=additionalMetaValue,proto3,oneof" json:"additionalMetaValue,omitempty"`
	// contains filtered or unexported fields
}

func (*SubscribeToWorkflowEventsRequest) Descriptor deprecated 

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

Deprecated: Use SubscribeToWorkflowEventsRequest.ProtoReflect.Descriptor instead.

func (*SubscribeToWorkflowEventsRequest) GetAdditionalMetaKey 

func (x *SubscribeToWorkflowEventsRequest) GetAdditionalMetaKey() string

func (*SubscribeToWorkflowEventsRequest) GetAdditionalMetaValue 

func (x *SubscribeToWorkflowEventsRequest) GetAdditionalMetaValue() string

func (*SubscribeToWorkflowEventsRequest) GetWorkflowRunId 

func (x *SubscribeToWorkflowEventsRequest) GetWorkflowRunId() string

func (*SubscribeToWorkflowEventsRequest) ProtoMessage 

func (*SubscribeToWorkflowEventsRequest) ProtoMessage()

func (*SubscribeToWorkflowEventsRequest) ProtoReflect 

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

func (*SubscribeToWorkflowEventsRequest) Reset 

func (x *SubscribeToWorkflowEventsRequest) Reset()

func (*SubscribeToWorkflowEventsRequest) String 

func (x *SubscribeToWorkflowEventsRequest) String() string

type SubscribeToWorkflowRunsRequest 

type SubscribeToWorkflowRunsRequest struct {

	// the id of the workflow run
	WorkflowRunId string `protobuf:"bytes,1,opt,name=workflowRunId,proto3" json:"workflowRunId,omitempty"`
	// contains filtered or unexported fields
}

func (*SubscribeToWorkflowRunsRequest) Descriptor deprecated 

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

Deprecated: Use SubscribeToWorkflowRunsRequest.ProtoReflect.Descriptor instead.

func (*SubscribeToWorkflowRunsRequest) GetWorkflowRunId 

func (x *SubscribeToWorkflowRunsRequest) GetWorkflowRunId() string

func (*SubscribeToWorkflowRunsRequest) ProtoMessage 

func (*SubscribeToWorkflowRunsRequest) ProtoMessage()

func (*SubscribeToWorkflowRunsRequest) ProtoReflect 

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

func (*SubscribeToWorkflowRunsRequest) Reset 

func (x *SubscribeToWorkflowRunsRequest) Reset()

func (*SubscribeToWorkflowRunsRequest) String 

func (x *SubscribeToWorkflowRunsRequest) String() string

type UnimplementedDispatcherServer 

type UnimplementedDispatcherServer struct {
}

UnimplementedDispatcherServer must be embedded to have forward compatible implementations.

func (UnimplementedDispatcherServer) Heartbeat 

func (UnimplementedDispatcherServer) Heartbeat(context.Context, *HeartbeatRequest) (*HeartbeatResponse, error)

func (UnimplementedDispatcherServer) Listen 

func (UnimplementedDispatcherServer) Listen(*WorkerListenRequest, Dispatcher_ListenServer) error

func (UnimplementedDispatcherServer) ListenV2 

func (UnimplementedDispatcherServer) ListenV2(*WorkerListenRequest, Dispatcher_ListenV2Server) error

func (UnimplementedDispatcherServer) PutOverridesData 

func (UnimplementedDispatcherServer) PutOverridesData(context.Context, *OverridesData) (*OverridesDataResponse, error)

func (UnimplementedDispatcherServer) RefreshTimeout 

func (UnimplementedDispatcherServer) RefreshTimeout(context.Context, *RefreshTimeoutRequest) (*RefreshTimeoutResponse, error)

func (UnimplementedDispatcherServer) Register 

func (UnimplementedDispatcherServer) Register(context.Context, *WorkerRegisterRequest) (*WorkerRegisterResponse, error)

func (UnimplementedDispatcherServer) ReleaseSlot 

func (UnimplementedDispatcherServer) ReleaseSlot(context.Context, *ReleaseSlotRequest) (*ReleaseSlotResponse, error)

func (UnimplementedDispatcherServer) SendGroupKeyActionEvent 

func (UnimplementedDispatcherServer) SendGroupKeyActionEvent(context.Context, *GroupKeyActionEvent) (*ActionEventResponse, error)

func (UnimplementedDispatcherServer) SendStepActionEvent 

func (UnimplementedDispatcherServer) SendStepActionEvent(context.Context, *StepActionEvent) (*ActionEventResponse, error)

func (UnimplementedDispatcherServer) SubscribeToWorkflowEvents 

func (UnimplementedDispatcherServer) SubscribeToWorkflowEvents(*SubscribeToWorkflowEventsRequest, Dispatcher_SubscribeToWorkflowEventsServer) error

func (UnimplementedDispatcherServer) SubscribeToWorkflowRuns 

func (UnimplementedDispatcherServer) SubscribeToWorkflowRuns(Dispatcher_SubscribeToWorkflowRunsServer) error

func (UnimplementedDispatcherServer) Unsubscribe 

func (UnimplementedDispatcherServer) Unsubscribe(context.Context, *WorkerUnsubscribeRequest) (*WorkerUnsubscribeResponse, error)

func (UnimplementedDispatcherServer) UpsertWorkerLabels 

func (UnimplementedDispatcherServer) UpsertWorkerLabels(context.Context, *UpsertWorkerLabelsRequest) (*UpsertWorkerLabelsResponse, error)

type UnsafeDispatcherServer 

type UnsafeDispatcherServer interface {
	// contains filtered or unexported methods
}

UnsafeDispatcherServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to DispatcherServer will result in compilation errors.

type UpsertWorkerLabelsRequest 

type UpsertWorkerLabelsRequest struct {

	// the name of the worker
	WorkerId string `protobuf:"bytes,1,opt,name=workerId,proto3" json:"workerId,omitempty"`
	// (optional) the worker labels
	Labels map[string]*WorkerLabels `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*UpsertWorkerLabelsRequest) Descriptor deprecated 

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

Deprecated: Use UpsertWorkerLabelsRequest.ProtoReflect.Descriptor instead.

func (*UpsertWorkerLabelsRequest) GetLabels 

func (x *UpsertWorkerLabelsRequest) GetLabels() map[string]*WorkerLabels

func (*UpsertWorkerLabelsRequest) GetWorkerId 

func (x *UpsertWorkerLabelsRequest) GetWorkerId() string

func (*UpsertWorkerLabelsRequest) ProtoMessage 

func (*UpsertWorkerLabelsRequest) ProtoMessage()

func (*UpsertWorkerLabelsRequest) ProtoReflect 

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

func (*UpsertWorkerLabelsRequest) Reset 

func (x *UpsertWorkerLabelsRequest) Reset()

func (*UpsertWorkerLabelsRequest) String 

func (x *UpsertWorkerLabelsRequest) String() string

type UpsertWorkerLabelsResponse 

type UpsertWorkerLabelsResponse struct {

	// the tenant id
	TenantId string `protobuf:"bytes,1,opt,name=tenantId,proto3" json:"tenantId,omitempty"`
	// the id of the worker
	WorkerId string `protobuf:"bytes,2,opt,name=workerId,proto3" json:"workerId,omitempty"`
	// contains filtered or unexported fields
}

func (*UpsertWorkerLabelsResponse) Descriptor deprecated 

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

Deprecated: Use UpsertWorkerLabelsResponse.ProtoReflect.Descriptor instead.

func (*UpsertWorkerLabelsResponse) GetTenantId 

func (x *UpsertWorkerLabelsResponse) GetTenantId() string

func (*UpsertWorkerLabelsResponse) GetWorkerId 

func (x *UpsertWorkerLabelsResponse) GetWorkerId() string

func (*UpsertWorkerLabelsResponse) ProtoMessage 

func (*UpsertWorkerLabelsResponse) ProtoMessage()

func (*UpsertWorkerLabelsResponse) ProtoReflect 

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

func (*UpsertWorkerLabelsResponse) Reset 

func (x *UpsertWorkerLabelsResponse) Reset()

func (*UpsertWorkerLabelsResponse) String 

func (x *UpsertWorkerLabelsResponse) String() string

type WorkerLabels 

type WorkerLabels struct {

	// value of the label
	StrValue *string `protobuf:"bytes,1,opt,name=strValue,proto3,oneof" json:"strValue,omitempty"`
	IntValue *int32  `protobuf:"varint,2,opt,name=intValue,proto3,oneof" json:"intValue,omitempty"`
	// contains filtered or unexported fields
}

func (*WorkerLabels) Descriptor deprecated 

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

Deprecated: Use WorkerLabels.ProtoReflect.Descriptor instead.

func (*WorkerLabels) GetIntValue 

func (x *WorkerLabels) GetIntValue() int32

func (*WorkerLabels) GetStrValue 

func (x *WorkerLabels) GetStrValue() string

func (*WorkerLabels) ProtoMessage 

func (*WorkerLabels) ProtoMessage()

func (*WorkerLabels) ProtoReflect 

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

func (*WorkerLabels) Reset 

func (x *WorkerLabels) Reset()

func (*WorkerLabels) String 

func (x *WorkerLabels) String() string

type WorkerListenRequest 

type WorkerListenRequest struct {

	// the id of the worker
	WorkerId string `protobuf:"bytes,1,opt,name=workerId,proto3" json:"workerId,omitempty"`
	// contains filtered or unexported fields
}

func (*WorkerListenRequest) Descriptor deprecated 

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

Deprecated: Use WorkerListenRequest.ProtoReflect.Descriptor instead.

func (*WorkerListenRequest) GetWorkerId 

func (x *WorkerListenRequest) GetWorkerId() string

func (*WorkerListenRequest) ProtoMessage 

func (*WorkerListenRequest) ProtoMessage()

func (*WorkerListenRequest) ProtoReflect 

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

func (*WorkerListenRequest) Reset 

func (x *WorkerListenRequest) Reset()

func (*WorkerListenRequest) String 

func (x *WorkerListenRequest) String() string

type WorkerRegisterRequest 

type WorkerRegisterRequest struct {

	// the name of the worker
	WorkerName string `protobuf:"bytes,1,opt,name=workerName,proto3" json:"workerName,omitempty"`
	// a list of actions that this worker can run
	Actions []string `protobuf:"bytes,2,rep,name=actions,proto3" json:"actions,omitempty"`
	// (optional) the services for this worker
	Services []string `protobuf:"bytes,3,rep,name=services,proto3" json:"services,omitempty"`
	// (optional) the max number of runs this worker can handle
	MaxRuns *int32 `protobuf:"varint,4,opt,name=maxRuns,proto3,oneof" json:"maxRuns,omitempty"`
	// (optional) worker labels (i.e. state or other metadata)
	Labels map[string]*WorkerLabels `` /* 153-byte string literal not displayed */
	// (optional) webhookId is the id of the webhook that the worker is associated with (if any)
	WebhookId *string `protobuf:"bytes,6,opt,name=webhookId,proto3,oneof" json:"webhookId,omitempty"`
	// (optional) information regarding the runtime environment of the worker
	RuntimeInfo *RuntimeInfo `protobuf:"bytes,7,opt,name=runtimeInfo,proto3,oneof" json:"runtimeInfo,omitempty"`
	// contains filtered or unexported fields
}

func (*WorkerRegisterRequest) Descriptor deprecated 

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

Deprecated: Use WorkerRegisterRequest.ProtoReflect.Descriptor instead.

func (*WorkerRegisterRequest) GetActions 

func (x *WorkerRegisterRequest) GetActions() []string

func (*WorkerRegisterRequest) GetLabels 

func (x *WorkerRegisterRequest) GetLabels() map[string]*WorkerLabels

func (*WorkerRegisterRequest) GetMaxRuns 

func (x *WorkerRegisterRequest) GetMaxRuns() int32

func (*WorkerRegisterRequest) GetRuntimeInfo 

func (x *WorkerRegisterRequest) GetRuntimeInfo() *RuntimeInfo

func (*WorkerRegisterRequest) GetServices 

func (x *WorkerRegisterRequest) GetServices() []string

func (*WorkerRegisterRequest) GetWebhookId 

func (x *WorkerRegisterRequest) GetWebhookId() string

func (*WorkerRegisterRequest) GetWorkerName 

func (x *WorkerRegisterRequest) GetWorkerName() string

func (*WorkerRegisterRequest) ProtoMessage 

func (*WorkerRegisterRequest) ProtoMessage()

func (*WorkerRegisterRequest) ProtoReflect 

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

func (*WorkerRegisterRequest) Reset 

func (x *WorkerRegisterRequest) Reset()

func (*WorkerRegisterRequest) String 

func (x *WorkerRegisterRequest) String() string

type WorkerRegisterResponse 

type WorkerRegisterResponse struct {

	// the tenant id
	TenantId string `protobuf:"bytes,1,opt,name=tenantId,proto3" json:"tenantId,omitempty"`
	// the id of the worker
	WorkerId string `protobuf:"bytes,2,opt,name=workerId,proto3" json:"workerId,omitempty"`
	// the name of the worker
	WorkerName string `protobuf:"bytes,3,opt,name=workerName,proto3" json:"workerName,omitempty"`
	// contains filtered or unexported fields
}

func (*WorkerRegisterResponse) Descriptor deprecated 

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

Deprecated: Use WorkerRegisterResponse.ProtoReflect.Descriptor instead.

func (*WorkerRegisterResponse) GetTenantId 

func (x *WorkerRegisterResponse) GetTenantId() string

func (*WorkerRegisterResponse) GetWorkerId 

func (x *WorkerRegisterResponse) GetWorkerId() string

func (*WorkerRegisterResponse) GetWorkerName 

func (x *WorkerRegisterResponse) GetWorkerName() string

func (*WorkerRegisterResponse) ProtoMessage 

func (*WorkerRegisterResponse) ProtoMessage()

func (*WorkerRegisterResponse) ProtoReflect 

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

func (*WorkerRegisterResponse) Reset 

func (x *WorkerRegisterResponse) Reset()

func (*WorkerRegisterResponse) String 

func (x *WorkerRegisterResponse) String() string

type WorkerUnsubscribeRequest 

type WorkerUnsubscribeRequest struct {

	// the id of the worker
	WorkerId string `protobuf:"bytes,1,opt,name=workerId,proto3" json:"workerId,omitempty"`
	// contains filtered or unexported fields
}

func (*WorkerUnsubscribeRequest) Descriptor deprecated 

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

Deprecated: Use WorkerUnsubscribeRequest.ProtoReflect.Descriptor instead.

func (*WorkerUnsubscribeRequest) GetWorkerId 

func (x *WorkerUnsubscribeRequest) GetWorkerId() string

func (*WorkerUnsubscribeRequest) ProtoMessage 

func (*WorkerUnsubscribeRequest) ProtoMessage()

func (*WorkerUnsubscribeRequest) ProtoReflect 

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

func (*WorkerUnsubscribeRequest) Reset 

func (x *WorkerUnsubscribeRequest) Reset()

func (*WorkerUnsubscribeRequest) String 

func (x *WorkerUnsubscribeRequest) String() string

type WorkerUnsubscribeResponse 

type WorkerUnsubscribeResponse struct {

	// the tenant id to unsubscribe from
	TenantId string `protobuf:"bytes,1,opt,name=tenantId,proto3" json:"tenantId,omitempty"`
	// the id of the worker
	WorkerId string `protobuf:"bytes,2,opt,name=workerId,proto3" json:"workerId,omitempty"`
	// contains filtered or unexported fields
}

func (*WorkerUnsubscribeResponse) Descriptor deprecated 

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

Deprecated: Use WorkerUnsubscribeResponse.ProtoReflect.Descriptor instead.

func (*WorkerUnsubscribeResponse) GetTenantId 

func (x *WorkerUnsubscribeResponse) GetTenantId() string

func (*WorkerUnsubscribeResponse) GetWorkerId 

func (x *WorkerUnsubscribeResponse) GetWorkerId() string

func (*WorkerUnsubscribeResponse) ProtoMessage 

func (*WorkerUnsubscribeResponse) ProtoMessage()

func (*WorkerUnsubscribeResponse) ProtoReflect 

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

func (*WorkerUnsubscribeResponse) Reset 

func (x *WorkerUnsubscribeResponse) Reset()

func (*WorkerUnsubscribeResponse) String 

func (x *WorkerUnsubscribeResponse) String() string

type WorkflowEvent 

type WorkflowEvent struct {

	// the id of the workflow run
	WorkflowRunId  string                 `protobuf:"bytes,1,opt,name=workflowRunId,proto3" json:"workflowRunId,omitempty"`
	ResourceType   ResourceType           `protobuf:"varint,2,opt,name=resourceType,proto3,enum=ResourceType" json:"resourceType,omitempty"`
	EventType      ResourceEventType      `protobuf:"varint,3,opt,name=eventType,proto3,enum=ResourceEventType" json:"eventType,omitempty"`
	ResourceId     string                 `protobuf:"bytes,4,opt,name=resourceId,proto3" json:"resourceId,omitempty"`
	EventTimestamp *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=eventTimestamp,proto3" json:"eventTimestamp,omitempty"`
	// the event payload
	EventPayload string `protobuf:"bytes,6,opt,name=eventPayload,proto3" json:"eventPayload,omitempty"`
	// whether this is the last event for the workflow run - server
	// will hang up the connection but clients might want to case
	Hangup bool `protobuf:"varint,7,opt,name=hangup,proto3" json:"hangup,omitempty"`
	// (optional) the max number of retries this step can handle
	StepRetries *int32 `protobuf:"varint,8,opt,name=stepRetries,proto3,oneof" json:"stepRetries,omitempty"`
	// (optional) the retry count of this step
	RetryCount *int32 `protobuf:"varint,9,opt,name=retryCount,proto3,oneof" json:"retryCount,omitempty"`
	// contains filtered or unexported fields
}

func (*WorkflowEvent) Descriptor deprecated 

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

Deprecated: Use WorkflowEvent.ProtoReflect.Descriptor instead.

func (*WorkflowEvent) GetEventPayload 

func (x *WorkflowEvent) GetEventPayload() string

func (*WorkflowEvent) GetEventTimestamp 

func (x *WorkflowEvent) GetEventTimestamp() *timestamppb.Timestamp

func (*WorkflowEvent) GetEventType 

func (x *WorkflowEvent) GetEventType() ResourceEventType

func (*WorkflowEvent) GetHangup 

func (x *WorkflowEvent) GetHangup() bool

func (*WorkflowEvent) GetResourceId 

func (x *WorkflowEvent) GetResourceId() string

func (*WorkflowEvent) GetResourceType 

func (x *WorkflowEvent) GetResourceType() ResourceType

func (*WorkflowEvent) GetRetryCount 

func (x *WorkflowEvent) GetRetryCount() int32

func (*WorkflowEvent) GetStepRetries 

func (x *WorkflowEvent) GetStepRetries() int32

func (*WorkflowEvent) GetWorkflowRunId 

func (x *WorkflowEvent) GetWorkflowRunId() string

func (*WorkflowEvent) ProtoMessage 

func (*WorkflowEvent) ProtoMessage()

func (*WorkflowEvent) ProtoReflect 

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

func (*WorkflowEvent) Reset 

func (x *WorkflowEvent) Reset()

func (*WorkflowEvent) String 

func (x *WorkflowEvent) String() string

type WorkflowRunEvent 

type WorkflowRunEvent struct {

	// the id of the workflow run
	WorkflowRunId  string                 `protobuf:"bytes,1,opt,name=workflowRunId,proto3" json:"workflowRunId,omitempty"`
	EventType      WorkflowRunEventType   `protobuf:"varint,2,opt,name=eventType,proto3,enum=WorkflowRunEventType" json:"eventType,omitempty"`
	EventTimestamp *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=eventTimestamp,proto3" json:"eventTimestamp,omitempty"`
	Results        []*StepRunResult       `protobuf:"bytes,4,rep,name=results,proto3" json:"results,omitempty"`
	// contains filtered or unexported fields
}

func (*WorkflowRunEvent) Descriptor deprecated 

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

Deprecated: Use WorkflowRunEvent.ProtoReflect.Descriptor instead.

func (*WorkflowRunEvent) GetEventTimestamp 

func (x *WorkflowRunEvent) GetEventTimestamp() *timestamppb.Timestamp

func (*WorkflowRunEvent) GetEventType 

func (x *WorkflowRunEvent) GetEventType() WorkflowRunEventType

func (*WorkflowRunEvent) GetResults 

func (x *WorkflowRunEvent) GetResults() []*StepRunResult

func (*WorkflowRunEvent) GetWorkflowRunId 

func (x *WorkflowRunEvent) GetWorkflowRunId() string

func (*WorkflowRunEvent) ProtoMessage 

func (*WorkflowRunEvent) ProtoMessage()

func (*WorkflowRunEvent) ProtoReflect 

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

func (*WorkflowRunEvent) Reset 

func (x *WorkflowRunEvent) Reset()

func (*WorkflowRunEvent) String 

func (x *WorkflowRunEvent) String() string

type WorkflowRunEventType 

type WorkflowRunEventType int32
const (
	WorkflowRunEventType_WORKFLOW_RUN_EVENT_TYPE_FINISHED WorkflowRunEventType = 0
)

func (WorkflowRunEventType) Descriptor 

func (WorkflowRunEventType) Descriptor() protoreflect.EnumDescriptor

func (WorkflowRunEventType) Enum 

func (x WorkflowRunEventType) Enum() *WorkflowRunEventType

func (WorkflowRunEventType) EnumDescriptor deprecated 

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

Deprecated: Use WorkflowRunEventType.Descriptor instead.

func (WorkflowRunEventType) Number 

func (x WorkflowRunEventType) Number() protoreflect.EnumNumber

func (WorkflowRunEventType) String 

func (x WorkflowRunEventType) String() string

func (WorkflowRunEventType) Type 

func (WorkflowRunEventType) Type() protoreflect.EnumType

Source Files

View all Source files

Jump to

Keyboard shortcuts

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