contracts

package
v0.19.5 Latest Latest
Warning

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

 Go to latest Published: Apr 10, 2024 License: MIT Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

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",
	}
	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,
	}
)

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 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,
		},
	},
	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,
		},
	},
	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"`
	// 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) GetGetGroupKeyRunId added in v0.8.0 

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) GetStepId 

func (x *AssignedAction) GetStepId() string

func (*AssignedAction) GetStepName added in v0.13.3 

func (x *AssignedAction) GetStepName() string

func (*AssignedAction) GetStepRunId 

func (x *AssignedAction) GetStepRunId() string

func (*AssignedAction) GetTenantId 

func (x *AssignedAction) GetTenantId() string

func (*AssignedAction) GetWorkflowRunId added in v0.8.0 

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)
	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)
}

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
	SendStepActionEvent(context.Context, *StepActionEvent) (*ActionEventResponse, error)
	SendGroupKeyActionEvent(context.Context, *GroupKeyActionEvent) (*ActionEventResponse, error)
	PutOverridesData(context.Context, *OverridesData) (*OverridesDataResponse, error)
	Unsubscribe(context.Context, *WorkerUnsubscribeRequest) (*WorkerUnsubscribeResponse, 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 added in v0.18.1 

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

type Dispatcher_ListenV2Server added in v0.18.1 

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

type Dispatcher_SubscribeToWorkflowEventsClient added in v0.9.0 

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

type Dispatcher_SubscribeToWorkflowEventsServer added in v0.9.0 

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

type GroupKeyActionEvent added in v0.8.0 

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

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

Deprecated: Use GroupKeyActionEvent.ProtoReflect.Descriptor instead.

func (*GroupKeyActionEvent) GetActionId added in v0.8.0 

func (x *GroupKeyActionEvent) GetActionId() string

func (*GroupKeyActionEvent) GetEventPayload added in v0.8.0 

func (x *GroupKeyActionEvent) GetEventPayload() string

func (*GroupKeyActionEvent) GetEventTimestamp added in v0.8.0 

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

func (*GroupKeyActionEvent) GetEventType added in v0.8.0 

func (x *GroupKeyActionEvent) GetEventType() GroupKeyActionEventType

func (*GroupKeyActionEvent) GetGetGroupKeyRunId added in v0.8.0 

func (x *GroupKeyActionEvent) GetGetGroupKeyRunId() string

func (*GroupKeyActionEvent) GetWorkerId added in v0.8.0 

func (x *GroupKeyActionEvent) GetWorkerId() string

func (*GroupKeyActionEvent) GetWorkflowRunId added in v0.8.0 

func (x *GroupKeyActionEvent) GetWorkflowRunId() string

func (*GroupKeyActionEvent) ProtoMessage added in v0.8.0 

func (*GroupKeyActionEvent) ProtoMessage()

func (*GroupKeyActionEvent) ProtoReflect added in v0.8.0 

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

func (*GroupKeyActionEvent) Reset added in v0.8.0 

func (x *GroupKeyActionEvent) Reset()

func (*GroupKeyActionEvent) String added in v0.8.0 

func (x *GroupKeyActionEvent) String() string

type GroupKeyActionEventType added in v0.8.0 

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

func (GroupKeyActionEventType) Descriptor() protoreflect.EnumDescriptor

func (GroupKeyActionEventType) Enum added in v0.8.0 

func (x GroupKeyActionEventType) Enum() *GroupKeyActionEventType

func (GroupKeyActionEventType) EnumDescriptor deprecated added in v0.8.0 

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

Deprecated: Use GroupKeyActionEventType.Descriptor instead.

func (GroupKeyActionEventType) Number added in v0.8.0 

func (x GroupKeyActionEventType) Number() protoreflect.EnumNumber

func (GroupKeyActionEventType) String added in v0.8.0 

func (x GroupKeyActionEventType) String() string

func (GroupKeyActionEventType) Type added in v0.8.0 

func (GroupKeyActionEventType) Type() protoreflect.EnumType

type HeartbeatRequest added in v0.18.1 

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

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

Deprecated: Use HeartbeatRequest.ProtoReflect.Descriptor instead.

func (*HeartbeatRequest) GetHeartbeatAt added in v0.18.1 

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

func (*HeartbeatRequest) GetWorkerId added in v0.18.1 

func (x *HeartbeatRequest) GetWorkerId() string

func (*HeartbeatRequest) ProtoMessage added in v0.18.1 

func (*HeartbeatRequest) ProtoMessage()

func (*HeartbeatRequest) ProtoReflect added in v0.18.1 

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

func (*HeartbeatRequest) Reset added in v0.18.1 

func (x *HeartbeatRequest) Reset()

func (*HeartbeatRequest) String added in v0.18.1 

func (x *HeartbeatRequest) String() string

type HeartbeatResponse added in v0.18.1 

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

func (*HeartbeatResponse) Descriptor deprecated added in v0.18.1 

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

Deprecated: Use HeartbeatResponse.ProtoReflect.Descriptor instead.

func (*HeartbeatResponse) ProtoMessage added in v0.18.1 

func (*HeartbeatResponse) ProtoMessage()

func (*HeartbeatResponse) ProtoReflect added in v0.18.1 

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

func (*HeartbeatResponse) Reset added in v0.18.1 

func (x *HeartbeatResponse) Reset()

func (*HeartbeatResponse) String added in v0.18.1 

func (x *HeartbeatResponse) String() string

type OverridesData added in v0.11.0 

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

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

Deprecated: Use OverridesData.ProtoReflect.Descriptor instead.

func (*OverridesData) GetCallerFilename added in v0.11.0 

func (x *OverridesData) GetCallerFilename() string

func (*OverridesData) GetPath added in v0.11.0 

func (x *OverridesData) GetPath() string

func (*OverridesData) GetStepRunId added in v0.11.0 

func (x *OverridesData) GetStepRunId() string

func (*OverridesData) GetValue added in v0.11.0 

func (x *OverridesData) GetValue() string

func (*OverridesData) ProtoMessage added in v0.11.0 

func (*OverridesData) ProtoMessage()

func (*OverridesData) ProtoReflect added in v0.11.0 

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

func (*OverridesData) Reset added in v0.11.0 

func (x *OverridesData) Reset()

func (*OverridesData) String added in v0.11.0 

func (x *OverridesData) String() string

type OverridesDataResponse added in v0.11.0 

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

func (*OverridesDataResponse) Descriptor deprecated added in v0.11.0 

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

Deprecated: Use OverridesDataResponse.ProtoReflect.Descriptor instead.

func (*OverridesDataResponse) ProtoMessage added in v0.11.0 

func (*OverridesDataResponse) ProtoMessage()

func (*OverridesDataResponse) ProtoReflect added in v0.11.0 

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

func (*OverridesDataResponse) Reset added in v0.11.0 

func (x *OverridesDataResponse) Reset()

func (*OverridesDataResponse) String added in v0.11.0 

func (x *OverridesDataResponse) String() string

type ResourceEventType added in v0.9.0 

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

func (ResourceEventType) Descriptor() protoreflect.EnumDescriptor

func (ResourceEventType) Enum added in v0.9.0 

func (x ResourceEventType) Enum() *ResourceEventType

func (ResourceEventType) EnumDescriptor deprecated added in v0.9.0 

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

Deprecated: Use ResourceEventType.Descriptor instead.

func (ResourceEventType) Number added in v0.9.0 

func (x ResourceEventType) Number() protoreflect.EnumNumber

func (ResourceEventType) String added in v0.9.0 

func (x ResourceEventType) String() string

func (ResourceEventType) Type added in v0.9.0 

func (ResourceEventType) Type() protoreflect.EnumType

type ResourceType added in v0.9.0 

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

func (ResourceType) Descriptor() protoreflect.EnumDescriptor

func (ResourceType) Enum added in v0.9.0 

func (x ResourceType) Enum() *ResourceType

func (ResourceType) EnumDescriptor deprecated added in v0.9.0 

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

Deprecated: Use ResourceType.Descriptor instead.

func (ResourceType) Number added in v0.9.0 

func (x ResourceType) Number() protoreflect.EnumNumber

func (ResourceType) String added in v0.9.0 

func (x ResourceType) String() string

func (ResourceType) Type added in v0.9.0 

func (ResourceType) Type() protoreflect.EnumType

type StepActionEvent added in v0.8.0 

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"`
	// contains filtered or unexported fields
}

func (*StepActionEvent) Descriptor deprecated added in v0.8.0 

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

Deprecated: Use StepActionEvent.ProtoReflect.Descriptor instead.

func (*StepActionEvent) GetActionId added in v0.8.0 

func (x *StepActionEvent) GetActionId() string

func (*StepActionEvent) GetEventPayload added in v0.8.0 

func (x *StepActionEvent) GetEventPayload() string

func (*StepActionEvent) GetEventTimestamp added in v0.8.0 

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

func (*StepActionEvent) GetEventType added in v0.8.0 

func (x *StepActionEvent) GetEventType() StepActionEventType

func (*StepActionEvent) GetJobId added in v0.8.0 

func (x *StepActionEvent) GetJobId() string

func (*StepActionEvent) GetJobRunId added in v0.8.0 

func (x *StepActionEvent) GetJobRunId() string

func (*StepActionEvent) GetStepId added in v0.8.0 

func (x *StepActionEvent) GetStepId() string

func (*StepActionEvent) GetStepRunId added in v0.8.0 

func (x *StepActionEvent) GetStepRunId() string

func (*StepActionEvent) GetWorkerId added in v0.8.0 

func (x *StepActionEvent) GetWorkerId() string

func (*StepActionEvent) ProtoMessage added in v0.8.0 

func (*StepActionEvent) ProtoMessage()

func (*StepActionEvent) ProtoReflect added in v0.8.0 

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

func (*StepActionEvent) Reset added in v0.8.0 

func (x *StepActionEvent) Reset()

func (*StepActionEvent) String added in v0.8.0 

func (x *StepActionEvent) String() string

type StepActionEventType added in v0.8.0 

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
)

func (StepActionEventType) Descriptor added in v0.8.0 

func (StepActionEventType) Descriptor() protoreflect.EnumDescriptor

func (StepActionEventType) Enum added in v0.8.0 

func (x StepActionEventType) Enum() *StepActionEventType

func (StepActionEventType) EnumDescriptor deprecated added in v0.8.0 

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

Deprecated: Use StepActionEventType.Descriptor instead.

func (StepActionEventType) Number added in v0.8.0 

func (x StepActionEventType) Number() protoreflect.EnumNumber

func (StepActionEventType) String added in v0.8.0 

func (x StepActionEventType) String() string

func (StepActionEventType) Type added in v0.8.0 

func (StepActionEventType) Type() protoreflect.EnumType

type SubscribeToWorkflowEventsRequest added in v0.9.0 

type SubscribeToWorkflowEventsRequest 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 (*SubscribeToWorkflowEventsRequest) Descriptor deprecated added in v0.9.0 

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

Deprecated: Use SubscribeToWorkflowEventsRequest.ProtoReflect.Descriptor instead.

func (*SubscribeToWorkflowEventsRequest) GetWorkflowRunId added in v0.9.0 

func (x *SubscribeToWorkflowEventsRequest) GetWorkflowRunId() string

func (*SubscribeToWorkflowEventsRequest) ProtoMessage added in v0.9.0 

func (*SubscribeToWorkflowEventsRequest) ProtoMessage()

func (*SubscribeToWorkflowEventsRequest) ProtoReflect added in v0.9.0 

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

func (*SubscribeToWorkflowEventsRequest) Reset added in v0.9.0 

func (x *SubscribeToWorkflowEventsRequest) Reset()

func (*SubscribeToWorkflowEventsRequest) String added in v0.9.0 

func (x *SubscribeToWorkflowEventsRequest) String() string

type UnimplementedDispatcherServer 

type UnimplementedDispatcherServer struct {
}

UnimplementedDispatcherServer must be embedded to have forward compatible implementations.

func (UnimplementedDispatcherServer) Heartbeat added in v0.18.1 

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

func (UnimplementedDispatcherServer) Listen 

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

func (UnimplementedDispatcherServer) ListenV2 added in v0.18.1 

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

func (UnimplementedDispatcherServer) PutOverridesData added in v0.11.0 

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

func (UnimplementedDispatcherServer) Register 

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

func (UnimplementedDispatcherServer) SendGroupKeyActionEvent added in v0.8.0 

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

func (UnimplementedDispatcherServer) SendStepActionEvent added in v0.8.0 

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

func (UnimplementedDispatcherServer) SubscribeToWorkflowEvents added in v0.9.0 

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

func (UnimplementedDispatcherServer) Unsubscribe 

func (UnimplementedDispatcherServer) Unsubscribe(context.Context, *WorkerUnsubscribeRequest) (*WorkerUnsubscribeResponse, 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 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"`
	// 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) GetMaxRuns added in v0.12.0 

func (x *WorkerRegisterRequest) GetMaxRuns() int32

func (*WorkerRegisterRequest) GetServices 

func (x *WorkerRegisterRequest) GetServices() []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 added in v0.9.0 

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

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

Deprecated: Use WorkflowEvent.ProtoReflect.Descriptor instead.

func (*WorkflowEvent) GetEventPayload added in v0.9.0 

func (x *WorkflowEvent) GetEventPayload() string

func (*WorkflowEvent) GetEventTimestamp added in v0.9.0 

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

func (*WorkflowEvent) GetEventType added in v0.9.0 

func (x *WorkflowEvent) GetEventType() ResourceEventType

func (*WorkflowEvent) GetHangup added in v0.10.2 

func (x *WorkflowEvent) GetHangup() bool

func (*WorkflowEvent) GetResourceId added in v0.9.0 

func (x *WorkflowEvent) GetResourceId() string

func (*WorkflowEvent) GetResourceType added in v0.9.0 

func (x *WorkflowEvent) GetResourceType() ResourceType

func (*WorkflowEvent) GetRetryCount added in v0.18.0 

func (x *WorkflowEvent) GetRetryCount() int32

func (*WorkflowEvent) GetStepRetries added in v0.18.0 

func (x *WorkflowEvent) GetStepRetries() int32

func (*WorkflowEvent) GetWorkflowRunId added in v0.9.0 

func (x *WorkflowEvent) GetWorkflowRunId() string

func (*WorkflowEvent) ProtoMessage added in v0.9.0 

func (*WorkflowEvent) ProtoMessage()

func (*WorkflowEvent) ProtoReflect added in v0.9.0 

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

func (*WorkflowEvent) Reset added in v0.9.0 

func (x *WorkflowEvent) Reset()

func (*WorkflowEvent) String added in v0.9.0 

func (x *WorkflowEvent) String() string

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.