commandv1

package
v1.33.0-20230419173345... Latest Latest
Warning

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

Go to latest
Published: unknown License: MIT Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var File_temporal_api_command_v1_message_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type CancelTimerCommandAttributes

type CancelTimerCommandAttributes struct {

	// The same timer id from the start timer command
	TimerId string `protobuf:"bytes,1,opt,name=timer_id,json=timerId,proto3" json:"timer_id,omitempty"`
	// contains filtered or unexported fields
}

func (*CancelTimerCommandAttributes) Descriptor deprecated

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

Deprecated: Use CancelTimerCommandAttributes.ProtoReflect.Descriptor instead.

func (*CancelTimerCommandAttributes) GetTimerId

func (x *CancelTimerCommandAttributes) GetTimerId() string

func (*CancelTimerCommandAttributes) ProtoMessage

func (*CancelTimerCommandAttributes) ProtoMessage()

func (*CancelTimerCommandAttributes) ProtoReflect

func (*CancelTimerCommandAttributes) Reset

func (x *CancelTimerCommandAttributes) Reset()

func (*CancelTimerCommandAttributes) String

type CancelWorkflowExecutionCommandAttributes

type CancelWorkflowExecutionCommandAttributes struct {
	Details *v1.Payloads `protobuf:"bytes,1,opt,name=details,proto3" json:"details,omitempty"`
	// contains filtered or unexported fields
}

func (*CancelWorkflowExecutionCommandAttributes) Descriptor deprecated

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

Deprecated: Use CancelWorkflowExecutionCommandAttributes.ProtoReflect.Descriptor instead.

func (*CancelWorkflowExecutionCommandAttributes) GetDetails

func (*CancelWorkflowExecutionCommandAttributes) ProtoMessage

func (*CancelWorkflowExecutionCommandAttributes) ProtoReflect

func (*CancelWorkflowExecutionCommandAttributes) Reset

func (*CancelWorkflowExecutionCommandAttributes) String

type Command

type Command struct {
	CommandType v13.CommandType `` /* 134-byte string literal not displayed */
	// Types that are assignable to Attributes:
	//
	//	*Command_ScheduleActivityTaskCommandAttributes
	//	*Command_StartTimerCommandAttributes
	//	*Command_CompleteWorkflowExecutionCommandAttributes
	//	*Command_FailWorkflowExecutionCommandAttributes
	//	*Command_RequestCancelActivityTaskCommandAttributes
	//	*Command_CancelTimerCommandAttributes
	//	*Command_CancelWorkflowExecutionCommandAttributes
	//	*Command_RequestCancelExternalWorkflowExecutionCommandAttributes
	//	*Command_RecordMarkerCommandAttributes
	//	*Command_ContinueAsNewWorkflowExecutionCommandAttributes
	//	*Command_StartChildWorkflowExecutionCommandAttributes
	//	*Command_SignalExternalWorkflowExecutionCommandAttributes
	//	*Command_UpsertWorkflowSearchAttributesCommandAttributes
	//	*Command_ProtocolMessageCommandAttributes
	//	*Command_ModifyWorkflowPropertiesCommandAttributes
	Attributes isCommand_Attributes `protobuf_oneof:"attributes"`
	// contains filtered or unexported fields
}

func (*Command) Descriptor deprecated

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

Deprecated: Use Command.ProtoReflect.Descriptor instead.

func (*Command) GetAttributes

func (m *Command) GetAttributes() isCommand_Attributes

func (*Command) GetCancelTimerCommandAttributes

func (x *Command) GetCancelTimerCommandAttributes() *CancelTimerCommandAttributes

func (*Command) GetCancelWorkflowExecutionCommandAttributes

func (x *Command) GetCancelWorkflowExecutionCommandAttributes() *CancelWorkflowExecutionCommandAttributes

func (*Command) GetCommandType

func (x *Command) GetCommandType() v13.CommandType

func (*Command) GetCompleteWorkflowExecutionCommandAttributes

func (x *Command) GetCompleteWorkflowExecutionCommandAttributes() *CompleteWorkflowExecutionCommandAttributes

func (*Command) GetContinueAsNewWorkflowExecutionCommandAttributes

func (x *Command) GetContinueAsNewWorkflowExecutionCommandAttributes() *ContinueAsNewWorkflowExecutionCommandAttributes

func (*Command) GetFailWorkflowExecutionCommandAttributes

func (x *Command) GetFailWorkflowExecutionCommandAttributes() *FailWorkflowExecutionCommandAttributes

func (*Command) GetModifyWorkflowPropertiesCommandAttributes

func (x *Command) GetModifyWorkflowPropertiesCommandAttributes() *ModifyWorkflowPropertiesCommandAttributes

func (*Command) GetProtocolMessageCommandAttributes

func (x *Command) GetProtocolMessageCommandAttributes() *ProtocolMessageCommandAttributes

func (*Command) GetRecordMarkerCommandAttributes

func (x *Command) GetRecordMarkerCommandAttributes() *RecordMarkerCommandAttributes

func (*Command) GetRequestCancelActivityTaskCommandAttributes

func (x *Command) GetRequestCancelActivityTaskCommandAttributes() *RequestCancelActivityTaskCommandAttributes

func (*Command) GetRequestCancelExternalWorkflowExecutionCommandAttributes

func (x *Command) GetRequestCancelExternalWorkflowExecutionCommandAttributes() *RequestCancelExternalWorkflowExecutionCommandAttributes

func (*Command) GetScheduleActivityTaskCommandAttributes

func (x *Command) GetScheduleActivityTaskCommandAttributes() *ScheduleActivityTaskCommandAttributes

func (*Command) GetSignalExternalWorkflowExecutionCommandAttributes

func (x *Command) GetSignalExternalWorkflowExecutionCommandAttributes() *SignalExternalWorkflowExecutionCommandAttributes

func (*Command) GetStartChildWorkflowExecutionCommandAttributes

func (x *Command) GetStartChildWorkflowExecutionCommandAttributes() *StartChildWorkflowExecutionCommandAttributes

func (*Command) GetStartTimerCommandAttributes

func (x *Command) GetStartTimerCommandAttributes() *StartTimerCommandAttributes

func (*Command) GetUpsertWorkflowSearchAttributesCommandAttributes

func (x *Command) GetUpsertWorkflowSearchAttributesCommandAttributes() *UpsertWorkflowSearchAttributesCommandAttributes

func (*Command) ProtoMessage

func (*Command) ProtoMessage()

func (*Command) ProtoReflect

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

func (*Command) Reset

func (x *Command) Reset()

func (*Command) String

func (x *Command) String() string

type Command_CancelTimerCommandAttributes

type Command_CancelTimerCommandAttributes struct {
	CancelTimerCommandAttributes *CancelTimerCommandAttributes `protobuf:"bytes,7,opt,name=cancel_timer_command_attributes,json=cancelTimerCommandAttributes,proto3,oneof"`
}

type Command_CancelWorkflowExecutionCommandAttributes

type Command_CancelWorkflowExecutionCommandAttributes struct {
	CancelWorkflowExecutionCommandAttributes *CancelWorkflowExecutionCommandAttributes `` /* 131-byte string literal not displayed */
}

type Command_CompleteWorkflowExecutionCommandAttributes

type Command_CompleteWorkflowExecutionCommandAttributes struct {
	CompleteWorkflowExecutionCommandAttributes *CompleteWorkflowExecutionCommandAttributes `` /* 135-byte string literal not displayed */
}

type Command_ContinueAsNewWorkflowExecutionCommandAttributes

type Command_ContinueAsNewWorkflowExecutionCommandAttributes struct {
	ContinueAsNewWorkflowExecutionCommandAttributes *ContinueAsNewWorkflowExecutionCommandAttributes `` /* 148-byte string literal not displayed */
}

type Command_FailWorkflowExecutionCommandAttributes

type Command_FailWorkflowExecutionCommandAttributes struct {
	FailWorkflowExecutionCommandAttributes *FailWorkflowExecutionCommandAttributes `` /* 127-byte string literal not displayed */
}

type Command_ModifyWorkflowPropertiesCommandAttributes

type Command_ModifyWorkflowPropertiesCommandAttributes struct {
	// 16 is available for use - it was used as part of a prototype that never made it into a release
	ModifyWorkflowPropertiesCommandAttributes *ModifyWorkflowPropertiesCommandAttributes `` /* 134-byte string literal not displayed */
}

type Command_ProtocolMessageCommandAttributes

type Command_ProtocolMessageCommandAttributes struct {
	ProtocolMessageCommandAttributes *ProtocolMessageCommandAttributes `protobuf:"bytes,15,opt,name=protocol_message_command_attributes,json=protocolMessageCommandAttributes,proto3,oneof"`
}

type Command_RecordMarkerCommandAttributes

type Command_RecordMarkerCommandAttributes struct {
	RecordMarkerCommandAttributes *RecordMarkerCommandAttributes `protobuf:"bytes,10,opt,name=record_marker_command_attributes,json=recordMarkerCommandAttributes,proto3,oneof"`
}

type Command_RequestCancelActivityTaskCommandAttributes

type Command_RequestCancelActivityTaskCommandAttributes struct {
	RequestCancelActivityTaskCommandAttributes *RequestCancelActivityTaskCommandAttributes `` /* 136-byte string literal not displayed */
}

type Command_RequestCancelExternalWorkflowExecutionCommandAttributes

type Command_RequestCancelExternalWorkflowExecutionCommandAttributes struct {
	RequestCancelExternalWorkflowExecutionCommandAttributes *RequestCancelExternalWorkflowExecutionCommandAttributes `` /* 163-byte string literal not displayed */
}

type Command_ScheduleActivityTaskCommandAttributes

type Command_ScheduleActivityTaskCommandAttributes struct {
	ScheduleActivityTaskCommandAttributes *ScheduleActivityTaskCommandAttributes `protobuf:"bytes,2,opt,name=schedule_activity_task_command_attributes,json=scheduleActivityTaskCommandAttributes,proto3,oneof"`
}

type Command_SignalExternalWorkflowExecutionCommandAttributes

type Command_SignalExternalWorkflowExecutionCommandAttributes struct {
	SignalExternalWorkflowExecutionCommandAttributes *SignalExternalWorkflowExecutionCommandAttributes `` /* 149-byte string literal not displayed */
}

type Command_StartChildWorkflowExecutionCommandAttributes

type Command_StartChildWorkflowExecutionCommandAttributes struct {
	StartChildWorkflowExecutionCommandAttributes *StartChildWorkflowExecutionCommandAttributes `` /* 141-byte string literal not displayed */
}

type Command_StartTimerCommandAttributes

type Command_StartTimerCommandAttributes struct {
	StartTimerCommandAttributes *StartTimerCommandAttributes `protobuf:"bytes,3,opt,name=start_timer_command_attributes,json=startTimerCommandAttributes,proto3,oneof"`
}

type Command_UpsertWorkflowSearchAttributesCommandAttributes

type Command_UpsertWorkflowSearchAttributesCommandAttributes struct {
	UpsertWorkflowSearchAttributesCommandAttributes *UpsertWorkflowSearchAttributesCommandAttributes `` /* 147-byte string literal not displayed */
}

type CompleteWorkflowExecutionCommandAttributes

type CompleteWorkflowExecutionCommandAttributes struct {
	Result *v1.Payloads `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"`
	// contains filtered or unexported fields
}

func (*CompleteWorkflowExecutionCommandAttributes) Descriptor deprecated

Deprecated: Use CompleteWorkflowExecutionCommandAttributes.ProtoReflect.Descriptor instead.

func (*CompleteWorkflowExecutionCommandAttributes) GetResult

func (*CompleteWorkflowExecutionCommandAttributes) ProtoMessage

func (*CompleteWorkflowExecutionCommandAttributes) ProtoReflect

func (*CompleteWorkflowExecutionCommandAttributes) Reset

func (*CompleteWorkflowExecutionCommandAttributes) String

type ContinueAsNewWorkflowExecutionCommandAttributes

type ContinueAsNewWorkflowExecutionCommandAttributes struct {
	WorkflowType *v1.WorkflowType `protobuf:"bytes,1,opt,name=workflow_type,json=workflowType,proto3" json:"workflow_type,omitempty"`
	TaskQueue    *v11.TaskQueue   `protobuf:"bytes,2,opt,name=task_queue,json=taskQueue,proto3" json:"task_queue,omitempty"`
	Input        *v1.Payloads     `protobuf:"bytes,3,opt,name=input,proto3" json:"input,omitempty"`
	// Timeout of a single workflow run.
	WorkflowRunTimeout *durationpb.Duration `protobuf:"bytes,4,opt,name=workflow_run_timeout,json=workflowRunTimeout,proto3" json:"workflow_run_timeout,omitempty"`
	// Timeout of a single workflow task.
	WorkflowTaskTimeout *durationpb.Duration `protobuf:"bytes,5,opt,name=workflow_task_timeout,json=workflowTaskTimeout,proto3" json:"workflow_task_timeout,omitempty"`
	// How long the workflow start will be delayed - not really a "backoff" in the traditional sense.
	BackoffStartInterval *durationpb.Duration `protobuf:"bytes,6,opt,name=backoff_start_interval,json=backoffStartInterval,proto3" json:"backoff_start_interval,omitempty"`
	RetryPolicy          *v1.RetryPolicy      `protobuf:"bytes,7,opt,name=retry_policy,json=retryPolicy,proto3" json:"retry_policy,omitempty"`
	// Should be removed
	Initiator v13.ContinueAsNewInitiator `protobuf:"varint,8,opt,name=initiator,proto3,enum=temporal.api.enums.v1.ContinueAsNewInitiator" json:"initiator,omitempty"`
	// Should be removed
	Failure *v12.Failure `protobuf:"bytes,9,opt,name=failure,proto3" json:"failure,omitempty"`
	// Should be removed
	LastCompletionResult *v1.Payloads `protobuf:"bytes,10,opt,name=last_completion_result,json=lastCompletionResult,proto3" json:"last_completion_result,omitempty"`
	// Should be removed. Not necessarily unused but unclear and not exposed by SDKs.
	CronSchedule     string               `protobuf:"bytes,11,opt,name=cron_schedule,json=cronSchedule,proto3" json:"cron_schedule,omitempty"`
	Header           *v1.Header           `protobuf:"bytes,12,opt,name=header,proto3" json:"header,omitempty"`
	Memo             *v1.Memo             `protobuf:"bytes,13,opt,name=memo,proto3" json:"memo,omitempty"`
	SearchAttributes *v1.SearchAttributes `protobuf:"bytes,14,opt,name=search_attributes,json=searchAttributes,proto3" json:"search_attributes,omitempty"`
	// contains filtered or unexported fields
}

func (*ContinueAsNewWorkflowExecutionCommandAttributes) Descriptor deprecated

Deprecated: Use ContinueAsNewWorkflowExecutionCommandAttributes.ProtoReflect.Descriptor instead.

func (*ContinueAsNewWorkflowExecutionCommandAttributes) GetBackoffStartInterval

func (*ContinueAsNewWorkflowExecutionCommandAttributes) GetCronSchedule

func (*ContinueAsNewWorkflowExecutionCommandAttributes) GetFailure

func (*ContinueAsNewWorkflowExecutionCommandAttributes) GetHeader

func (*ContinueAsNewWorkflowExecutionCommandAttributes) GetInitiator

func (*ContinueAsNewWorkflowExecutionCommandAttributes) GetInput

func (*ContinueAsNewWorkflowExecutionCommandAttributes) GetLastCompletionResult

func (x *ContinueAsNewWorkflowExecutionCommandAttributes) GetLastCompletionResult() *v1.Payloads

func (*ContinueAsNewWorkflowExecutionCommandAttributes) GetMemo

func (*ContinueAsNewWorkflowExecutionCommandAttributes) GetRetryPolicy

func (*ContinueAsNewWorkflowExecutionCommandAttributes) GetSearchAttributes

func (*ContinueAsNewWorkflowExecutionCommandAttributes) GetTaskQueue

func (*ContinueAsNewWorkflowExecutionCommandAttributes) GetWorkflowRunTimeout

func (*ContinueAsNewWorkflowExecutionCommandAttributes) GetWorkflowTaskTimeout

func (*ContinueAsNewWorkflowExecutionCommandAttributes) GetWorkflowType

func (*ContinueAsNewWorkflowExecutionCommandAttributes) ProtoMessage

func (*ContinueAsNewWorkflowExecutionCommandAttributes) ProtoReflect

func (*ContinueAsNewWorkflowExecutionCommandAttributes) Reset

func (*ContinueAsNewWorkflowExecutionCommandAttributes) String

type FailWorkflowExecutionCommandAttributes

type FailWorkflowExecutionCommandAttributes struct {
	Failure *v12.Failure `protobuf:"bytes,1,opt,name=failure,proto3" json:"failure,omitempty"`
	// contains filtered or unexported fields
}

func (*FailWorkflowExecutionCommandAttributes) Descriptor deprecated

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

Deprecated: Use FailWorkflowExecutionCommandAttributes.ProtoReflect.Descriptor instead.

func (*FailWorkflowExecutionCommandAttributes) GetFailure

func (*FailWorkflowExecutionCommandAttributes) ProtoMessage

func (*FailWorkflowExecutionCommandAttributes) ProtoReflect

func (*FailWorkflowExecutionCommandAttributes) Reset

func (*FailWorkflowExecutionCommandAttributes) String

type ModifyWorkflowPropertiesCommandAttributes

type ModifyWorkflowPropertiesCommandAttributes struct {

	// If set, update the workflow memo with the provided values. The values will be merged with
	// the existing memo. If the user wants to delete values, a default/empty Payload should be
	// used as the value for the key being deleted.
	UpsertedMemo *v1.Memo `protobuf:"bytes,1,opt,name=upserted_memo,json=upsertedMemo,proto3" json:"upserted_memo,omitempty"`
	// contains filtered or unexported fields
}

func (*ModifyWorkflowPropertiesCommandAttributes) Descriptor deprecated

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

Deprecated: Use ModifyWorkflowPropertiesCommandAttributes.ProtoReflect.Descriptor instead.

func (*ModifyWorkflowPropertiesCommandAttributes) GetUpsertedMemo

func (x *ModifyWorkflowPropertiesCommandAttributes) GetUpsertedMemo() *v1.Memo

func (*ModifyWorkflowPropertiesCommandAttributes) ProtoMessage

func (*ModifyWorkflowPropertiesCommandAttributes) ProtoReflect

func (*ModifyWorkflowPropertiesCommandAttributes) Reset

func (*ModifyWorkflowPropertiesCommandAttributes) String

type ProtocolMessageCommandAttributes

type ProtocolMessageCommandAttributes struct {

	// The message ID of the message to which this command is a pointer.
	MessageId string `protobuf:"bytes,1,opt,name=message_id,json=messageId,proto3" json:"message_id,omitempty"`
	// contains filtered or unexported fields
}

func (*ProtocolMessageCommandAttributes) Descriptor deprecated

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

Deprecated: Use ProtocolMessageCommandAttributes.ProtoReflect.Descriptor instead.

func (*ProtocolMessageCommandAttributes) GetMessageId

func (x *ProtocolMessageCommandAttributes) GetMessageId() string

func (*ProtocolMessageCommandAttributes) ProtoMessage

func (*ProtocolMessageCommandAttributes) ProtoMessage()

func (*ProtocolMessageCommandAttributes) ProtoReflect

func (*ProtocolMessageCommandAttributes) Reset

func (*ProtocolMessageCommandAttributes) String

type RecordMarkerCommandAttributes

type RecordMarkerCommandAttributes struct {
	MarkerName string                  `protobuf:"bytes,1,opt,name=marker_name,json=markerName,proto3" json:"marker_name,omitempty"`
	Details    map[string]*v1.Payloads `` /* 155-byte string literal not displayed */
	Header     *v1.Header              `protobuf:"bytes,3,opt,name=header,proto3" json:"header,omitempty"`
	Failure    *v12.Failure            `protobuf:"bytes,4,opt,name=failure,proto3" json:"failure,omitempty"`
	// contains filtered or unexported fields
}

func (*RecordMarkerCommandAttributes) Descriptor deprecated

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

Deprecated: Use RecordMarkerCommandAttributes.ProtoReflect.Descriptor instead.

func (*RecordMarkerCommandAttributes) GetDetails

func (x *RecordMarkerCommandAttributes) GetDetails() map[string]*v1.Payloads

func (*RecordMarkerCommandAttributes) GetFailure

func (x *RecordMarkerCommandAttributes) GetFailure() *v12.Failure

func (*RecordMarkerCommandAttributes) GetHeader

func (x *RecordMarkerCommandAttributes) GetHeader() *v1.Header

func (*RecordMarkerCommandAttributes) GetMarkerName

func (x *RecordMarkerCommandAttributes) GetMarkerName() string

func (*RecordMarkerCommandAttributes) ProtoMessage

func (*RecordMarkerCommandAttributes) ProtoMessage()

func (*RecordMarkerCommandAttributes) ProtoReflect

func (*RecordMarkerCommandAttributes) Reset

func (x *RecordMarkerCommandAttributes) Reset()

func (*RecordMarkerCommandAttributes) String

type RequestCancelActivityTaskCommandAttributes

type RequestCancelActivityTaskCommandAttributes struct {

	// The `ACTIVITY_TASK_SCHEDULED` event id for the activity being cancelled.
	ScheduledEventId int64 `protobuf:"varint,1,opt,name=scheduled_event_id,json=scheduledEventId,proto3" json:"scheduled_event_id,omitempty"`
	// contains filtered or unexported fields
}

func (*RequestCancelActivityTaskCommandAttributes) Descriptor deprecated

Deprecated: Use RequestCancelActivityTaskCommandAttributes.ProtoReflect.Descriptor instead.

func (*RequestCancelActivityTaskCommandAttributes) GetScheduledEventId

func (x *RequestCancelActivityTaskCommandAttributes) GetScheduledEventId() int64

func (*RequestCancelActivityTaskCommandAttributes) ProtoMessage

func (*RequestCancelActivityTaskCommandAttributes) ProtoReflect

func (*RequestCancelActivityTaskCommandAttributes) Reset

func (*RequestCancelActivityTaskCommandAttributes) String

type RequestCancelExternalWorkflowExecutionCommandAttributes

type RequestCancelExternalWorkflowExecutionCommandAttributes struct {
	Namespace  string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	WorkflowId string `protobuf:"bytes,2,opt,name=workflow_id,json=workflowId,proto3" json:"workflow_id,omitempty"`
	RunId      string `protobuf:"bytes,3,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	// Deprecated.
	Control string `protobuf:"bytes,4,opt,name=control,proto3" json:"control,omitempty"`
	// Set this to true if the workflow being cancelled is a child of the workflow originating this
	// command. The request will be rejected if it is set to true and the target workflow is *not*
	// a child of the requesting workflow.
	ChildWorkflowOnly bool `protobuf:"varint,5,opt,name=child_workflow_only,json=childWorkflowOnly,proto3" json:"child_workflow_only,omitempty"`
	// Reason for requesting the cancellation
	Reason string `protobuf:"bytes,6,opt,name=reason,proto3" json:"reason,omitempty"`
	// contains filtered or unexported fields
}

func (*RequestCancelExternalWorkflowExecutionCommandAttributes) Descriptor deprecated

Deprecated: Use RequestCancelExternalWorkflowExecutionCommandAttributes.ProtoReflect.Descriptor instead.

func (*RequestCancelExternalWorkflowExecutionCommandAttributes) GetChildWorkflowOnly

func (*RequestCancelExternalWorkflowExecutionCommandAttributes) GetControl

func (*RequestCancelExternalWorkflowExecutionCommandAttributes) GetNamespace

func (*RequestCancelExternalWorkflowExecutionCommandAttributes) GetReason

func (*RequestCancelExternalWorkflowExecutionCommandAttributes) GetRunId

func (*RequestCancelExternalWorkflowExecutionCommandAttributes) GetWorkflowId

func (*RequestCancelExternalWorkflowExecutionCommandAttributes) ProtoMessage

func (*RequestCancelExternalWorkflowExecutionCommandAttributes) ProtoReflect

func (*RequestCancelExternalWorkflowExecutionCommandAttributes) Reset

func (*RequestCancelExternalWorkflowExecutionCommandAttributes) String

type ScheduleActivityTaskCommandAttributes

type ScheduleActivityTaskCommandAttributes struct {
	ActivityId   string           `protobuf:"bytes,1,opt,name=activity_id,json=activityId,proto3" json:"activity_id,omitempty"`
	ActivityType *v1.ActivityType `protobuf:"bytes,2,opt,name=activity_type,json=activityType,proto3" json:"activity_type,omitempty"`
	TaskQueue    *v11.TaskQueue   `protobuf:"bytes,4,opt,name=task_queue,json=taskQueue,proto3" json:"task_queue,omitempty"`
	Header       *v1.Header       `protobuf:"bytes,5,opt,name=header,proto3" json:"header,omitempty"`
	Input        *v1.Payloads     `protobuf:"bytes,6,opt,name=input,proto3" json:"input,omitempty"`
	// Indicates how long the caller is willing to wait for activity completion. The "schedule" time
	// is when the activity is initially scheduled, not when the most recent retry is scheduled.
	// Limits how long retries will be attempted. Either this or `start_to_close_timeout` must be
	// specified. When not specified, defaults to the workflow execution timeout.
	//
	// (-- api-linter: core::0140::prepositions=disabled
	//
	//	aip.dev/not-precedent: "to" is used to indicate interval. --)
	ScheduleToCloseTimeout *durationpb.Duration `` /* 131-byte string literal not displayed */
	// Limits the time an activity task can stay in a task queue before a worker picks it up. The
	// "schedule" time is when the most recent retry is scheduled. This timeout should usually not
	// be set: it's useful in specific scenarios like worker-specific task queues. This timeout is
	// always non retryable, as all a retry would achieve is to put it back into the same queue.
	// Defaults to `schedule_to_close_timeout` or workflow execution timeout if that is not
	// specified. More info:
	// https://docs.temporal.io/docs/content/what-is-a-schedule-to-start-timeout/
	//
	// (-- api-linter: core::0140::prepositions=disabled
	//
	//	aip.dev/not-precedent: "to" is used to indicate interval. --)
	ScheduleToStartTimeout *durationpb.Duration `` /* 131-byte string literal not displayed */
	// Maximum time an activity is allowed to execute after being picked up by a worker. This
	// timeout is always retryable. Either this or `schedule_to_close_timeout` must be specified.
	//
	// (-- api-linter: core::0140::prepositions=disabled
	//
	//	aip.dev/not-precedent: "to" is used to indicate interval. --)
	StartToCloseTimeout *durationpb.Duration `protobuf:"bytes,9,opt,name=start_to_close_timeout,json=startToCloseTimeout,proto3" json:"start_to_close_timeout,omitempty"`
	// Maximum permitted time between successful worker heartbeats.
	HeartbeatTimeout *durationpb.Duration `protobuf:"bytes,10,opt,name=heartbeat_timeout,json=heartbeatTimeout,proto3" json:"heartbeat_timeout,omitempty"`
	// Activities are provided by a default retry policy which is controlled through the service's
	// dynamic configuration. Retries will be attempted until `schedule_to_close_timeout` has
	// elapsed. To disable retries set retry_policy.maximum_attempts to 1.
	RetryPolicy *v1.RetryPolicy `protobuf:"bytes,11,opt,name=retry_policy,json=retryPolicy,proto3" json:"retry_policy,omitempty"`
	// Request to start the activity directly bypassing matching service and worker polling
	// The slot for executing the activity should be reserved when setting this field to true.
	RequestEagerExecution bool `` /* 128-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ScheduleActivityTaskCommandAttributes) Descriptor deprecated

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

Deprecated: Use ScheduleActivityTaskCommandAttributes.ProtoReflect.Descriptor instead.

func (*ScheduleActivityTaskCommandAttributes) GetActivityId

func (x *ScheduleActivityTaskCommandAttributes) GetActivityId() string

func (*ScheduleActivityTaskCommandAttributes) GetActivityType

func (*ScheduleActivityTaskCommandAttributes) GetHeader

func (*ScheduleActivityTaskCommandAttributes) GetHeartbeatTimeout

func (x *ScheduleActivityTaskCommandAttributes) GetHeartbeatTimeout() *durationpb.Duration

func (*ScheduleActivityTaskCommandAttributes) GetInput

func (*ScheduleActivityTaskCommandAttributes) GetRequestEagerExecution

func (x *ScheduleActivityTaskCommandAttributes) GetRequestEagerExecution() bool

func (*ScheduleActivityTaskCommandAttributes) GetRetryPolicy

func (*ScheduleActivityTaskCommandAttributes) GetScheduleToCloseTimeout

func (x *ScheduleActivityTaskCommandAttributes) GetScheduleToCloseTimeout() *durationpb.Duration

func (*ScheduleActivityTaskCommandAttributes) GetScheduleToStartTimeout

func (x *ScheduleActivityTaskCommandAttributes) GetScheduleToStartTimeout() *durationpb.Duration

func (*ScheduleActivityTaskCommandAttributes) GetStartToCloseTimeout

func (x *ScheduleActivityTaskCommandAttributes) GetStartToCloseTimeout() *durationpb.Duration

func (*ScheduleActivityTaskCommandAttributes) GetTaskQueue

func (*ScheduleActivityTaskCommandAttributes) ProtoMessage

func (*ScheduleActivityTaskCommandAttributes) ProtoMessage()

func (*ScheduleActivityTaskCommandAttributes) ProtoReflect

func (*ScheduleActivityTaskCommandAttributes) Reset

func (*ScheduleActivityTaskCommandAttributes) String

type SignalExternalWorkflowExecutionCommandAttributes

type SignalExternalWorkflowExecutionCommandAttributes struct {
	Namespace string                `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Execution *v1.WorkflowExecution `protobuf:"bytes,2,opt,name=execution,proto3" json:"execution,omitempty"`
	// The workflow author-defined name of the signal to send to the workflow.
	SignalName string `protobuf:"bytes,3,opt,name=signal_name,json=signalName,proto3" json:"signal_name,omitempty"`
	// Serialized value(s) to provide with the signal.
	Input *v1.Payloads `protobuf:"bytes,4,opt,name=input,proto3" json:"input,omitempty"`
	// Deprecated
	Control string `protobuf:"bytes,5,opt,name=control,proto3" json:"control,omitempty"`
	// Set this to true if the workflow being cancelled is a child of the workflow originating this
	// command. The request will be rejected if it is set to true and the target workflow is *not*
	// a child of the requesting workflow.
	ChildWorkflowOnly bool `protobuf:"varint,6,opt,name=child_workflow_only,json=childWorkflowOnly,proto3" json:"child_workflow_only,omitempty"`
	// Headers that are passed by the workflow that is sending a signal to the external
	// workflow that is receiving this signal.
	Header *v1.Header `protobuf:"bytes,7,opt,name=header,proto3" json:"header,omitempty"`
	// contains filtered or unexported fields
}

func (*SignalExternalWorkflowExecutionCommandAttributes) Descriptor deprecated

Deprecated: Use SignalExternalWorkflowExecutionCommandAttributes.ProtoReflect.Descriptor instead.

func (*SignalExternalWorkflowExecutionCommandAttributes) GetChildWorkflowOnly

func (x *SignalExternalWorkflowExecutionCommandAttributes) GetChildWorkflowOnly() bool

func (*SignalExternalWorkflowExecutionCommandAttributes) GetControl

func (*SignalExternalWorkflowExecutionCommandAttributes) GetExecution

func (*SignalExternalWorkflowExecutionCommandAttributes) GetHeader

func (*SignalExternalWorkflowExecutionCommandAttributes) GetInput

func (*SignalExternalWorkflowExecutionCommandAttributes) GetNamespace

func (*SignalExternalWorkflowExecutionCommandAttributes) GetSignalName

func (*SignalExternalWorkflowExecutionCommandAttributes) ProtoMessage

func (*SignalExternalWorkflowExecutionCommandAttributes) ProtoReflect

func (*SignalExternalWorkflowExecutionCommandAttributes) Reset

func (*SignalExternalWorkflowExecutionCommandAttributes) String

type StartChildWorkflowExecutionCommandAttributes

type StartChildWorkflowExecutionCommandAttributes struct {
	Namespace    string           `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	WorkflowId   string           `protobuf:"bytes,2,opt,name=workflow_id,json=workflowId,proto3" json:"workflow_id,omitempty"`
	WorkflowType *v1.WorkflowType `protobuf:"bytes,3,opt,name=workflow_type,json=workflowType,proto3" json:"workflow_type,omitempty"`
	TaskQueue    *v11.TaskQueue   `protobuf:"bytes,4,opt,name=task_queue,json=taskQueue,proto3" json:"task_queue,omitempty"`
	Input        *v1.Payloads     `protobuf:"bytes,5,opt,name=input,proto3" json:"input,omitempty"`
	// Total workflow execution timeout including retries and continue as new.
	WorkflowExecutionTimeout *durationpb.Duration `` /* 135-byte string literal not displayed */
	// Timeout of a single workflow run.
	WorkflowRunTimeout *durationpb.Duration `protobuf:"bytes,7,opt,name=workflow_run_timeout,json=workflowRunTimeout,proto3" json:"workflow_run_timeout,omitempty"`
	// Timeout of a single workflow task.
	WorkflowTaskTimeout *durationpb.Duration `protobuf:"bytes,8,opt,name=workflow_task_timeout,json=workflowTaskTimeout,proto3" json:"workflow_task_timeout,omitempty"`
	// Default: PARENT_CLOSE_POLICY_TERMINATE.
	ParentClosePolicy v13.ParentClosePolicy `` /* 160-byte string literal not displayed */
	Control           string                `protobuf:"bytes,10,opt,name=control,proto3" json:"control,omitempty"`
	// Default: WORKFLOW_ID_REUSE_POLICY_ALLOW_DUPLICATE.
	WorkflowIdReusePolicy v13.WorkflowIdReusePolicy `` /* 179-byte string literal not displayed */
	RetryPolicy           *v1.RetryPolicy           `protobuf:"bytes,12,opt,name=retry_policy,json=retryPolicy,proto3" json:"retry_policy,omitempty"`
	// Establish a cron schedule for the child workflow.
	CronSchedule     string               `protobuf:"bytes,13,opt,name=cron_schedule,json=cronSchedule,proto3" json:"cron_schedule,omitempty"`
	Header           *v1.Header           `protobuf:"bytes,14,opt,name=header,proto3" json:"header,omitempty"`
	Memo             *v1.Memo             `protobuf:"bytes,15,opt,name=memo,proto3" json:"memo,omitempty"`
	SearchAttributes *v1.SearchAttributes `protobuf:"bytes,16,opt,name=search_attributes,json=searchAttributes,proto3" json:"search_attributes,omitempty"`
	// contains filtered or unexported fields
}

func (*StartChildWorkflowExecutionCommandAttributes) Descriptor deprecated

Deprecated: Use StartChildWorkflowExecutionCommandAttributes.ProtoReflect.Descriptor instead.

func (*StartChildWorkflowExecutionCommandAttributes) GetControl

func (*StartChildWorkflowExecutionCommandAttributes) GetCronSchedule

func (*StartChildWorkflowExecutionCommandAttributes) GetHeader

func (*StartChildWorkflowExecutionCommandAttributes) GetInput

func (*StartChildWorkflowExecutionCommandAttributes) GetMemo

func (*StartChildWorkflowExecutionCommandAttributes) GetNamespace

func (*StartChildWorkflowExecutionCommandAttributes) GetParentClosePolicy

func (*StartChildWorkflowExecutionCommandAttributes) GetRetryPolicy

func (*StartChildWorkflowExecutionCommandAttributes) GetSearchAttributes

func (*StartChildWorkflowExecutionCommandAttributes) GetTaskQueue

func (*StartChildWorkflowExecutionCommandAttributes) GetWorkflowExecutionTimeout

func (x *StartChildWorkflowExecutionCommandAttributes) GetWorkflowExecutionTimeout() *durationpb.Duration

func (*StartChildWorkflowExecutionCommandAttributes) GetWorkflowId

func (*StartChildWorkflowExecutionCommandAttributes) GetWorkflowIdReusePolicy

func (*StartChildWorkflowExecutionCommandAttributes) GetWorkflowRunTimeout

func (*StartChildWorkflowExecutionCommandAttributes) GetWorkflowTaskTimeout

func (*StartChildWorkflowExecutionCommandAttributes) GetWorkflowType

func (*StartChildWorkflowExecutionCommandAttributes) ProtoMessage

func (*StartChildWorkflowExecutionCommandAttributes) ProtoReflect

func (*StartChildWorkflowExecutionCommandAttributes) Reset

func (*StartChildWorkflowExecutionCommandAttributes) String

type StartTimerCommandAttributes

type StartTimerCommandAttributes struct {

	// An id for the timer, currently live timers must have different ids. Typically autogenerated
	// by the SDK.
	TimerId string `protobuf:"bytes,1,opt,name=timer_id,json=timerId,proto3" json:"timer_id,omitempty"`
	// How long until the timer fires, producing a `TIMER_FIRED` event.
	//
	// (-- api-linter: core::0140::prepositions=disabled
	//
	//	aip.dev/not-precedent: "to" is used to indicate interval. --)
	StartToFireTimeout *durationpb.Duration `protobuf:"bytes,2,opt,name=start_to_fire_timeout,json=startToFireTimeout,proto3" json:"start_to_fire_timeout,omitempty"`
	// contains filtered or unexported fields
}

func (*StartTimerCommandAttributes) Descriptor deprecated

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

Deprecated: Use StartTimerCommandAttributes.ProtoReflect.Descriptor instead.

func (*StartTimerCommandAttributes) GetStartToFireTimeout

func (x *StartTimerCommandAttributes) GetStartToFireTimeout() *durationpb.Duration

func (*StartTimerCommandAttributes) GetTimerId

func (x *StartTimerCommandAttributes) GetTimerId() string

func (*StartTimerCommandAttributes) ProtoMessage

func (*StartTimerCommandAttributes) ProtoMessage()

func (*StartTimerCommandAttributes) ProtoReflect

func (*StartTimerCommandAttributes) Reset

func (x *StartTimerCommandAttributes) Reset()

func (*StartTimerCommandAttributes) String

func (x *StartTimerCommandAttributes) String() string

type UpsertWorkflowSearchAttributesCommandAttributes

type UpsertWorkflowSearchAttributesCommandAttributes struct {
	SearchAttributes *v1.SearchAttributes `protobuf:"bytes,1,opt,name=search_attributes,json=searchAttributes,proto3" json:"search_attributes,omitempty"`
	// contains filtered or unexported fields
}

func (*UpsertWorkflowSearchAttributesCommandAttributes) Descriptor deprecated

Deprecated: Use UpsertWorkflowSearchAttributesCommandAttributes.ProtoReflect.Descriptor instead.

func (*UpsertWorkflowSearchAttributesCommandAttributes) GetSearchAttributes

func (*UpsertWorkflowSearchAttributesCommandAttributes) ProtoMessage

func (*UpsertWorkflowSearchAttributesCommandAttributes) ProtoReflect

func (*UpsertWorkflowSearchAttributesCommandAttributes) Reset

func (*UpsertWorkflowSearchAttributesCommandAttributes) String

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL