command

package
v1.39.0 Latest Latest
Warning

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

 Go to latest Published: Aug 28, 2024 License: MIT Imports: 11 Imported by: 12

Documentation

Overview

Code generated by protoc-gen-go-helpers. DO NOT EDIT.

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

func (this *CancelTimerCommandAttributes) Equal(that interface{}) bool

Equal returns whether two CancelTimerCommandAttributes values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*CancelTimerCommandAttributes) GetTimerId 

func (x *CancelTimerCommandAttributes) GetTimerId() string

func (*CancelTimerCommandAttributes) Marshal 

func (val *CancelTimerCommandAttributes) Marshal() ([]byte, error)

Marshal an object of type CancelTimerCommandAttributes to the protobuf v3 wire format

func (*CancelTimerCommandAttributes) ProtoMessage 

func (*CancelTimerCommandAttributes) ProtoMessage()

func (*CancelTimerCommandAttributes) ProtoReflect added in v1.26.1 

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

func (*CancelTimerCommandAttributes) Reset 

func (x *CancelTimerCommandAttributes) Reset()

func (*CancelTimerCommandAttributes) Size 

func (val *CancelTimerCommandAttributes) Size() int

Size returns the size of the object, in bytes, once serialized

func (*CancelTimerCommandAttributes) String 

func (x *CancelTimerCommandAttributes) String() string

func (*CancelTimerCommandAttributes) Unmarshal 

func (val *CancelTimerCommandAttributes) Unmarshal(buf []byte) error

Unmarshal an object of type CancelTimerCommandAttributes from the protobuf v3 wire format

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

func (this *CancelWorkflowExecutionCommandAttributes) Equal(that interface{}) bool

Equal returns whether two CancelWorkflowExecutionCommandAttributes values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*CancelWorkflowExecutionCommandAttributes) GetDetails 

func (x *CancelWorkflowExecutionCommandAttributes) GetDetails() *v1.Payloads

func (*CancelWorkflowExecutionCommandAttributes) Marshal 

func (val *CancelWorkflowExecutionCommandAttributes) Marshal() ([]byte, error)

Marshal an object of type CancelWorkflowExecutionCommandAttributes to the protobuf v3 wire format

func (*CancelWorkflowExecutionCommandAttributes) ProtoMessage 

func (*CancelWorkflowExecutionCommandAttributes) ProtoMessage()

func (*CancelWorkflowExecutionCommandAttributes) ProtoReflect added in v1.26.1 

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

func (*CancelWorkflowExecutionCommandAttributes) Reset 

func (x *CancelWorkflowExecutionCommandAttributes) Reset()

func (*CancelWorkflowExecutionCommandAttributes) Size 

func (val *CancelWorkflowExecutionCommandAttributes) Size() int

Size returns the size of the object, in bytes, once serialized

func (*CancelWorkflowExecutionCommandAttributes) String 

func (x *CancelWorkflowExecutionCommandAttributes) String() string

func (*CancelWorkflowExecutionCommandAttributes) Unmarshal 

func (val *CancelWorkflowExecutionCommandAttributes) Unmarshal(buf []byte) error

Unmarshal an object of type CancelWorkflowExecutionCommandAttributes from the protobuf v3 wire format

type Command 

type Command struct {
	CommandType v13.CommandType `` /* 134-byte string literal not displayed */
	// Metadata on the command. This is sometimes carried over to the history event if one is
	// created as a result of the command. Most commands won't have this information, and how this
	// information is used is dependent upon the interface that reads it.
	//
	// Current well-known uses:
	//   - start_child_workflow_execution_command_attributes - populates
	//     temporal.api.workflow.v1.WorkflowExecutionInfo.user_metadata where the summary and details
	//     are used by user interfaces to show fixed as-of-start workflow summary and details.
	//   - start_timer_command_attributes - populates temporal.api.history.v1.HistoryEvent for timer
	//     started where the summary is used to identify the timer.
	UserMetadata *v14.UserMetadata `protobuf:"bytes,301,opt,name=user_metadata,json=userMetadata,proto3" json:"user_metadata,omitempty"`
	// The command details. The type must match that in `command_type`.
	//
	// 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
	//	*Command_ScheduleNexusOperationCommandAttributes
	//	*Command_RequestCancelNexusOperationCommandAttributes
	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) Equal 

func (this *Command) Equal(that interface{}) bool

Equal returns whether two Command values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

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 added in v1.12.0 

func (x *Command) GetModifyWorkflowPropertiesCommandAttributes() *ModifyWorkflowPropertiesCommandAttributes

func (*Command) GetProtocolMessageCommandAttributes added in v1.16.0 

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) GetRequestCancelNexusOperationCommandAttributes added in v1.32.1 

func (x *Command) GetRequestCancelNexusOperationCommandAttributes() *RequestCancelNexusOperationCommandAttributes

func (*Command) GetScheduleActivityTaskCommandAttributes 

func (x *Command) GetScheduleActivityTaskCommandAttributes() *ScheduleActivityTaskCommandAttributes

func (*Command) GetScheduleNexusOperationCommandAttributes added in v1.32.1 

func (x *Command) GetScheduleNexusOperationCommandAttributes() *ScheduleNexusOperationCommandAttributes

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) GetUserMetadata added in v1.34.0 

func (x *Command) GetUserMetadata() *v14.UserMetadata

func (*Command) Marshal 

func (val *Command) Marshal() ([]byte, error)

Marshal an object of type Command to the protobuf v3 wire format

func (*Command) ProtoMessage 

func (*Command) ProtoMessage()

func (*Command) ProtoReflect added in v1.26.1 

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

func (*Command) Reset 

func (x *Command) Reset()

func (*Command) Size 

func (val *Command) Size() int

Size returns the size of the object, in bytes, once serialized

func (*Command) String 

func (x *Command) String() string

func (*Command) Unmarshal 

func (val *Command) Unmarshal(buf []byte) error

Unmarshal an object of type Command from the protobuf v3 wire format

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 added in v1.12.0 

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 added in v1.16.0 

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_RequestCancelNexusOperationCommandAttributes added in v1.32.1 

type Command_RequestCancelNexusOperationCommandAttributes struct {
	RequestCancelNexusOperationCommandAttributes *RequestCancelNexusOperationCommandAttributes `` /* 141-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_ScheduleNexusOperationCommandAttributes added in v1.32.1 

type Command_ScheduleNexusOperationCommandAttributes struct {
	ScheduleNexusOperationCommandAttributes *ScheduleNexusOperationCommandAttributes `` /* 130-byte string literal not displayed */
}

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 

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

Deprecated: Use CompleteWorkflowExecutionCommandAttributes.ProtoReflect.Descriptor instead.

func (*CompleteWorkflowExecutionCommandAttributes) Equal 

func (this *CompleteWorkflowExecutionCommandAttributes) Equal(that interface{}) bool

Equal returns whether two CompleteWorkflowExecutionCommandAttributes values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*CompleteWorkflowExecutionCommandAttributes) GetResult 

func (x *CompleteWorkflowExecutionCommandAttributes) GetResult() *v1.Payloads

func (*CompleteWorkflowExecutionCommandAttributes) Marshal 

func (val *CompleteWorkflowExecutionCommandAttributes) Marshal() ([]byte, error)

Marshal an object of type CompleteWorkflowExecutionCommandAttributes to the protobuf v3 wire format

func (*CompleteWorkflowExecutionCommandAttributes) ProtoMessage 

func (*CompleteWorkflowExecutionCommandAttributes) ProtoMessage()

func (*CompleteWorkflowExecutionCommandAttributes) ProtoReflect added in v1.26.1 

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

func (*CompleteWorkflowExecutionCommandAttributes) Reset 

func (x *CompleteWorkflowExecutionCommandAttributes) Reset()

func (*CompleteWorkflowExecutionCommandAttributes) Size 

func (val *CompleteWorkflowExecutionCommandAttributes) Size() int

Size returns the size of the object, in bytes, once serialized

func (*CompleteWorkflowExecutionCommandAttributes) String 

func (x *CompleteWorkflowExecutionCommandAttributes) String() string

func (*CompleteWorkflowExecutionCommandAttributes) Unmarshal 

func (val *CompleteWorkflowExecutionCommandAttributes) Unmarshal(buf []byte) error

Unmarshal an object of type CompleteWorkflowExecutionCommandAttributes from the protobuf v3 wire format

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"`
	// If this is set, the new execution inherits the Build ID of the current execution. Otherwise,
	// the assignment rules will be used to independently assign a Build ID to the new execution.
	InheritBuildId bool `protobuf:"varint,15,opt,name=inherit_build_id,json=inheritBuildId,proto3" json:"inherit_build_id,omitempty"`
	// contains filtered or unexported fields
}

func (*ContinueAsNewWorkflowExecutionCommandAttributes) Descriptor deprecated 

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

Deprecated: Use ContinueAsNewWorkflowExecutionCommandAttributes.ProtoReflect.Descriptor instead.

func (*ContinueAsNewWorkflowExecutionCommandAttributes) Equal 

func (this *ContinueAsNewWorkflowExecutionCommandAttributes) Equal(that interface{}) bool

Equal returns whether two ContinueAsNewWorkflowExecutionCommandAttributes values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*ContinueAsNewWorkflowExecutionCommandAttributes) GetBackoffStartInterval added in v0.28.0 

func (x *ContinueAsNewWorkflowExecutionCommandAttributes) GetBackoffStartInterval() *durationpb.Duration

func (*ContinueAsNewWorkflowExecutionCommandAttributes) GetCronSchedule 

func (x *ContinueAsNewWorkflowExecutionCommandAttributes) GetCronSchedule() string

func (*ContinueAsNewWorkflowExecutionCommandAttributes) GetFailure 

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

func (*ContinueAsNewWorkflowExecutionCommandAttributes) GetHeader 

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

func (*ContinueAsNewWorkflowExecutionCommandAttributes) GetInheritBuildId added in v1.32.0 

func (x *ContinueAsNewWorkflowExecutionCommandAttributes) GetInheritBuildId() bool

func (*ContinueAsNewWorkflowExecutionCommandAttributes) GetInitiator 

func (x *ContinueAsNewWorkflowExecutionCommandAttributes) GetInitiator() v13.ContinueAsNewInitiator

func (*ContinueAsNewWorkflowExecutionCommandAttributes) GetInput 

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

func (*ContinueAsNewWorkflowExecutionCommandAttributes) GetLastCompletionResult 

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

func (*ContinueAsNewWorkflowExecutionCommandAttributes) GetMemo 

func (x *ContinueAsNewWorkflowExecutionCommandAttributes) GetMemo() *v1.Memo

func (*ContinueAsNewWorkflowExecutionCommandAttributes) GetRetryPolicy 

func (x *ContinueAsNewWorkflowExecutionCommandAttributes) GetRetryPolicy() *v1.RetryPolicy

func (*ContinueAsNewWorkflowExecutionCommandAttributes) GetSearchAttributes 

func (x *ContinueAsNewWorkflowExecutionCommandAttributes) GetSearchAttributes() *v1.SearchAttributes

func (*ContinueAsNewWorkflowExecutionCommandAttributes) GetTaskQueue 

func (x *ContinueAsNewWorkflowExecutionCommandAttributes) GetTaskQueue() *v11.TaskQueue

func (*ContinueAsNewWorkflowExecutionCommandAttributes) GetWorkflowRunTimeout added in v0.28.0 

func (x *ContinueAsNewWorkflowExecutionCommandAttributes) GetWorkflowRunTimeout() *durationpb.Duration

func (*ContinueAsNewWorkflowExecutionCommandAttributes) GetWorkflowTaskTimeout added in v0.28.0 

func (x *ContinueAsNewWorkflowExecutionCommandAttributes) GetWorkflowTaskTimeout() *durationpb.Duration

func (*ContinueAsNewWorkflowExecutionCommandAttributes) GetWorkflowType 

func (x *ContinueAsNewWorkflowExecutionCommandAttributes) GetWorkflowType() *v1.WorkflowType

func (*ContinueAsNewWorkflowExecutionCommandAttributes) Marshal 

func (val *ContinueAsNewWorkflowExecutionCommandAttributes) Marshal() ([]byte, error)

Marshal an object of type ContinueAsNewWorkflowExecutionCommandAttributes to the protobuf v3 wire format

func (*ContinueAsNewWorkflowExecutionCommandAttributes) ProtoMessage 

func (*ContinueAsNewWorkflowExecutionCommandAttributes) ProtoMessage()

func (*ContinueAsNewWorkflowExecutionCommandAttributes) ProtoReflect added in v1.26.1 

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

func (*ContinueAsNewWorkflowExecutionCommandAttributes) Reset 

func (x *ContinueAsNewWorkflowExecutionCommandAttributes) Reset()

func (*ContinueAsNewWorkflowExecutionCommandAttributes) Size 

func (val *ContinueAsNewWorkflowExecutionCommandAttributes) Size() int

Size returns the size of the object, in bytes, once serialized

func (*ContinueAsNewWorkflowExecutionCommandAttributes) String 

func (x *ContinueAsNewWorkflowExecutionCommandAttributes) String() string

func (*ContinueAsNewWorkflowExecutionCommandAttributes) Unmarshal 

func (val *ContinueAsNewWorkflowExecutionCommandAttributes) Unmarshal(buf []byte) error

Unmarshal an object of type ContinueAsNewWorkflowExecutionCommandAttributes from the protobuf v3 wire format

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

func (this *FailWorkflowExecutionCommandAttributes) Equal(that interface{}) bool

Equal returns whether two FailWorkflowExecutionCommandAttributes values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*FailWorkflowExecutionCommandAttributes) GetFailure 

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

func (*FailWorkflowExecutionCommandAttributes) Marshal 

func (val *FailWorkflowExecutionCommandAttributes) Marshal() ([]byte, error)

Marshal an object of type FailWorkflowExecutionCommandAttributes to the protobuf v3 wire format

func (*FailWorkflowExecutionCommandAttributes) ProtoMessage 

func (*FailWorkflowExecutionCommandAttributes) ProtoMessage()

func (*FailWorkflowExecutionCommandAttributes) ProtoReflect added in v1.26.1 

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

func (*FailWorkflowExecutionCommandAttributes) Reset 

func (x *FailWorkflowExecutionCommandAttributes) Reset()

func (*FailWorkflowExecutionCommandAttributes) Size 

func (val *FailWorkflowExecutionCommandAttributes) Size() int

Size returns the size of the object, in bytes, once serialized

func (*FailWorkflowExecutionCommandAttributes) String 

func (x *FailWorkflowExecutionCommandAttributes) String() string

func (*FailWorkflowExecutionCommandAttributes) Unmarshal 

func (val *FailWorkflowExecutionCommandAttributes) Unmarshal(buf []byte) error

Unmarshal an object of type FailWorkflowExecutionCommandAttributes from the protobuf v3 wire format

type ModifyWorkflowPropertiesCommandAttributes added in v1.12.0 

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 added in v1.12.0 

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

Deprecated: Use ModifyWorkflowPropertiesCommandAttributes.ProtoReflect.Descriptor instead.

func (*ModifyWorkflowPropertiesCommandAttributes) Equal added in v1.12.0 

func (this *ModifyWorkflowPropertiesCommandAttributes) Equal(that interface{}) bool

Equal returns whether two ModifyWorkflowPropertiesCommandAttributes values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*ModifyWorkflowPropertiesCommandAttributes) GetUpsertedMemo added in v1.12.0 

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

func (*ModifyWorkflowPropertiesCommandAttributes) Marshal added in v1.12.0 

func (val *ModifyWorkflowPropertiesCommandAttributes) Marshal() ([]byte, error)

Marshal an object of type ModifyWorkflowPropertiesCommandAttributes to the protobuf v3 wire format

func (*ModifyWorkflowPropertiesCommandAttributes) ProtoMessage added in v1.12.0 

func (*ModifyWorkflowPropertiesCommandAttributes) ProtoMessage()

func (*ModifyWorkflowPropertiesCommandAttributes) ProtoReflect added in v1.26.1 

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

func (*ModifyWorkflowPropertiesCommandAttributes) Reset added in v1.12.0 

func (x *ModifyWorkflowPropertiesCommandAttributes) Reset()

func (*ModifyWorkflowPropertiesCommandAttributes) Size added in v1.12.0 

func (val *ModifyWorkflowPropertiesCommandAttributes) Size() int

Size returns the size of the object, in bytes, once serialized

func (*ModifyWorkflowPropertiesCommandAttributes) String added in v1.12.0 

func (x *ModifyWorkflowPropertiesCommandAttributes) String() string

func (*ModifyWorkflowPropertiesCommandAttributes) Unmarshal added in v1.12.0 

func (val *ModifyWorkflowPropertiesCommandAttributes) Unmarshal(buf []byte) error

Unmarshal an object of type ModifyWorkflowPropertiesCommandAttributes from the protobuf v3 wire format

type ProtocolMessageCommandAttributes added in v1.16.0 

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 added in v1.16.0 

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

Deprecated: Use ProtocolMessageCommandAttributes.ProtoReflect.Descriptor instead.

func (*ProtocolMessageCommandAttributes) Equal added in v1.16.0 

func (this *ProtocolMessageCommandAttributes) Equal(that interface{}) bool

Equal returns whether two ProtocolMessageCommandAttributes values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*ProtocolMessageCommandAttributes) GetMessageId added in v1.16.0 

func (x *ProtocolMessageCommandAttributes) GetMessageId() string

func (*ProtocolMessageCommandAttributes) Marshal added in v1.16.0 

func (val *ProtocolMessageCommandAttributes) Marshal() ([]byte, error)

Marshal an object of type ProtocolMessageCommandAttributes to the protobuf v3 wire format

func (*ProtocolMessageCommandAttributes) ProtoMessage added in v1.16.0 

func (*ProtocolMessageCommandAttributes) ProtoMessage()

func (*ProtocolMessageCommandAttributes) ProtoReflect added in v1.26.1 

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

func (*ProtocolMessageCommandAttributes) Reset added in v1.16.0 

func (x *ProtocolMessageCommandAttributes) Reset()

func (*ProtocolMessageCommandAttributes) Size added in v1.16.0 

func (val *ProtocolMessageCommandAttributes) Size() int

Size returns the size of the object, in bytes, once serialized

func (*ProtocolMessageCommandAttributes) String added in v1.16.0 

func (x *ProtocolMessageCommandAttributes) String() string

func (*ProtocolMessageCommandAttributes) Unmarshal added in v1.16.0 

func (val *ProtocolMessageCommandAttributes) Unmarshal(buf []byte) error

Unmarshal an object of type ProtocolMessageCommandAttributes from the protobuf v3 wire format

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

func (this *RecordMarkerCommandAttributes) Equal(that interface{}) bool

Equal returns whether two RecordMarkerCommandAttributes values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

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

func (val *RecordMarkerCommandAttributes) Marshal() ([]byte, error)

Marshal an object of type RecordMarkerCommandAttributes to the protobuf v3 wire format

func (*RecordMarkerCommandAttributes) ProtoMessage 

func (*RecordMarkerCommandAttributes) ProtoMessage()

func (*RecordMarkerCommandAttributes) ProtoReflect added in v1.26.1 

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

func (*RecordMarkerCommandAttributes) Reset 

func (x *RecordMarkerCommandAttributes) Reset()

func (*RecordMarkerCommandAttributes) Size 

func (val *RecordMarkerCommandAttributes) Size() int

Size returns the size of the object, in bytes, once serialized

func (*RecordMarkerCommandAttributes) String 

func (x *RecordMarkerCommandAttributes) String() string

func (*RecordMarkerCommandAttributes) Unmarshal 

func (val *RecordMarkerCommandAttributes) Unmarshal(buf []byte) error

Unmarshal an object of type RecordMarkerCommandAttributes from the protobuf v3 wire format

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 

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

Deprecated: Use RequestCancelActivityTaskCommandAttributes.ProtoReflect.Descriptor instead.

func (*RequestCancelActivityTaskCommandAttributes) Equal 

func (this *RequestCancelActivityTaskCommandAttributes) Equal(that interface{}) bool

Equal returns whether two RequestCancelActivityTaskCommandAttributes values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*RequestCancelActivityTaskCommandAttributes) GetScheduledEventId 

func (x *RequestCancelActivityTaskCommandAttributes) GetScheduledEventId() int64

func (*RequestCancelActivityTaskCommandAttributes) Marshal 

func (val *RequestCancelActivityTaskCommandAttributes) Marshal() ([]byte, error)

Marshal an object of type RequestCancelActivityTaskCommandAttributes to the protobuf v3 wire format

func (*RequestCancelActivityTaskCommandAttributes) ProtoMessage 

func (*RequestCancelActivityTaskCommandAttributes) ProtoMessage()

func (*RequestCancelActivityTaskCommandAttributes) ProtoReflect added in v1.26.1 

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

func (*RequestCancelActivityTaskCommandAttributes) Reset 

func (x *RequestCancelActivityTaskCommandAttributes) Reset()

func (*RequestCancelActivityTaskCommandAttributes) Size 

func (val *RequestCancelActivityTaskCommandAttributes) Size() int

Size returns the size of the object, in bytes, once serialized

func (*RequestCancelActivityTaskCommandAttributes) String 

func (x *RequestCancelActivityTaskCommandAttributes) String() string

func (*RequestCancelActivityTaskCommandAttributes) Unmarshal 

func (val *RequestCancelActivityTaskCommandAttributes) Unmarshal(buf []byte) error

Unmarshal an object of type RequestCancelActivityTaskCommandAttributes from the protobuf v3 wire format

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 

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

Deprecated: Use RequestCancelExternalWorkflowExecutionCommandAttributes.ProtoReflect.Descriptor instead.

func (*RequestCancelExternalWorkflowExecutionCommandAttributes) Equal 

func (this *RequestCancelExternalWorkflowExecutionCommandAttributes) Equal(that interface{}) bool

Equal returns whether two RequestCancelExternalWorkflowExecutionCommandAttributes values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*RequestCancelExternalWorkflowExecutionCommandAttributes) GetChildWorkflowOnly 

func (x *RequestCancelExternalWorkflowExecutionCommandAttributes) GetChildWorkflowOnly() bool

func (*RequestCancelExternalWorkflowExecutionCommandAttributes) GetControl 

func (x *RequestCancelExternalWorkflowExecutionCommandAttributes) GetControl() string

func (*RequestCancelExternalWorkflowExecutionCommandAttributes) GetNamespace 

func (x *RequestCancelExternalWorkflowExecutionCommandAttributes) GetNamespace() string

func (*RequestCancelExternalWorkflowExecutionCommandAttributes) GetReason added in v1.8.0 

func (x *RequestCancelExternalWorkflowExecutionCommandAttributes) GetReason() string

func (*RequestCancelExternalWorkflowExecutionCommandAttributes) GetRunId 

func (x *RequestCancelExternalWorkflowExecutionCommandAttributes) GetRunId() string

func (*RequestCancelExternalWorkflowExecutionCommandAttributes) GetWorkflowId 

func (x *RequestCancelExternalWorkflowExecutionCommandAttributes) GetWorkflowId() string

func (*RequestCancelExternalWorkflowExecutionCommandAttributes) Marshal 

func (val *RequestCancelExternalWorkflowExecutionCommandAttributes) Marshal() ([]byte, error)

Marshal an object of type RequestCancelExternalWorkflowExecutionCommandAttributes to the protobuf v3 wire format

func (*RequestCancelExternalWorkflowExecutionCommandAttributes) ProtoMessage 

func (*RequestCancelExternalWorkflowExecutionCommandAttributes) ProtoMessage()

func (*RequestCancelExternalWorkflowExecutionCommandAttributes) ProtoReflect added in v1.26.1 

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

func (*RequestCancelExternalWorkflowExecutionCommandAttributes) Reset 

func (x *RequestCancelExternalWorkflowExecutionCommandAttributes) Reset()

func (*RequestCancelExternalWorkflowExecutionCommandAttributes) Size 

func (val *RequestCancelExternalWorkflowExecutionCommandAttributes) Size() int

Size returns the size of the object, in bytes, once serialized

func (*RequestCancelExternalWorkflowExecutionCommandAttributes) String 

func (x *RequestCancelExternalWorkflowExecutionCommandAttributes) String() string

func (*RequestCancelExternalWorkflowExecutionCommandAttributes) Unmarshal 

func (val *RequestCancelExternalWorkflowExecutionCommandAttributes) Unmarshal(buf []byte) error

Unmarshal an object of type RequestCancelExternalWorkflowExecutionCommandAttributes from the protobuf v3 wire format

type RequestCancelNexusOperationCommandAttributes added in v1.32.1 

type RequestCancelNexusOperationCommandAttributes struct {

	// The `NEXUS_OPERATION_SCHEDULED` event ID (a unique identifier) for the operation to be canceled.
	// The operation may ignore cancellation and end up with any completion state.
	ScheduledEventId int64 `protobuf:"varint,1,opt,name=scheduled_event_id,json=scheduledEventId,proto3" json:"scheduled_event_id,omitempty"`
	// contains filtered or unexported fields
}

func (*RequestCancelNexusOperationCommandAttributes) Descriptor deprecated added in v1.32.1 

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

Deprecated: Use RequestCancelNexusOperationCommandAttributes.ProtoReflect.Descriptor instead.

func (*RequestCancelNexusOperationCommandAttributes) Equal added in v1.32.1 

func (this *RequestCancelNexusOperationCommandAttributes) Equal(that interface{}) bool

Equal returns whether two RequestCancelNexusOperationCommandAttributes values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*RequestCancelNexusOperationCommandAttributes) GetScheduledEventId added in v1.32.1 

func (x *RequestCancelNexusOperationCommandAttributes) GetScheduledEventId() int64

func (*RequestCancelNexusOperationCommandAttributes) Marshal added in v1.32.1 

func (val *RequestCancelNexusOperationCommandAttributes) Marshal() ([]byte, error)

Marshal an object of type RequestCancelNexusOperationCommandAttributes to the protobuf v3 wire format

func (*RequestCancelNexusOperationCommandAttributes) ProtoMessage added in v1.32.1 

func (*RequestCancelNexusOperationCommandAttributes) ProtoMessage()

func (*RequestCancelNexusOperationCommandAttributes) ProtoReflect added in v1.32.1 

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

func (*RequestCancelNexusOperationCommandAttributes) Reset added in v1.32.1 

func (x *RequestCancelNexusOperationCommandAttributes) Reset()

func (*RequestCancelNexusOperationCommandAttributes) Size added in v1.32.1 

func (val *RequestCancelNexusOperationCommandAttributes) Size() int

Size returns the size of the object, in bytes, once serialized

func (*RequestCancelNexusOperationCommandAttributes) String added in v1.32.1 

func (x *RequestCancelNexusOperationCommandAttributes) String() string

func (*RequestCancelNexusOperationCommandAttributes) Unmarshal added in v1.32.1 

func (val *RequestCancelNexusOperationCommandAttributes) Unmarshal(buf []byte) error

Unmarshal an object of type RequestCancelNexusOperationCommandAttributes from the protobuf v3 wire format

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 */
	// If this is set, the activity would be assigned to the Build ID of the workflow. Otherwise,
	// Assignment rules of the activity's Task Queue will be used to determine the Build ID.
	UseWorkflowBuildId bool `protobuf:"varint,13,opt,name=use_workflow_build_id,json=useWorkflowBuildId,proto3" json:"use_workflow_build_id,omitempty"`
	// contains filtered or unexported fields
}

func (*ScheduleActivityTaskCommandAttributes) Descriptor deprecated 

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

Deprecated: Use ScheduleActivityTaskCommandAttributes.ProtoReflect.Descriptor instead.

func (*ScheduleActivityTaskCommandAttributes) Equal 

func (this *ScheduleActivityTaskCommandAttributes) Equal(that interface{}) bool

Equal returns whether two ScheduleActivityTaskCommandAttributes values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*ScheduleActivityTaskCommandAttributes) GetActivityId 

func (x *ScheduleActivityTaskCommandAttributes) GetActivityId() string

func (*ScheduleActivityTaskCommandAttributes) GetActivityType 

func (x *ScheduleActivityTaskCommandAttributes) GetActivityType() *v1.ActivityType

func (*ScheduleActivityTaskCommandAttributes) GetHeader 

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

func (*ScheduleActivityTaskCommandAttributes) GetHeartbeatTimeout added in v0.28.0 

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

func (*ScheduleActivityTaskCommandAttributes) GetInput 

func (x *ScheduleActivityTaskCommandAttributes) GetInput() *v1.Payloads

func (*ScheduleActivityTaskCommandAttributes) GetRequestEagerExecution added in v1.8.0 

func (x *ScheduleActivityTaskCommandAttributes) GetRequestEagerExecution() bool

func (*ScheduleActivityTaskCommandAttributes) GetRetryPolicy 

func (x *ScheduleActivityTaskCommandAttributes) GetRetryPolicy() *v1.RetryPolicy

func (*ScheduleActivityTaskCommandAttributes) GetScheduleToCloseTimeout added in v0.28.0 

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

func (*ScheduleActivityTaskCommandAttributes) GetScheduleToStartTimeout added in v0.28.0 

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

func (*ScheduleActivityTaskCommandAttributes) GetStartToCloseTimeout added in v0.28.0 

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

func (*ScheduleActivityTaskCommandAttributes) GetTaskQueue 

func (x *ScheduleActivityTaskCommandAttributes) GetTaskQueue() *v11.TaskQueue

func (*ScheduleActivityTaskCommandAttributes) GetUseWorkflowBuildId added in v1.32.0 

func (x *ScheduleActivityTaskCommandAttributes) GetUseWorkflowBuildId() bool

func (*ScheduleActivityTaskCommandAttributes) Marshal 

func (val *ScheduleActivityTaskCommandAttributes) Marshal() ([]byte, error)

Marshal an object of type ScheduleActivityTaskCommandAttributes to the protobuf v3 wire format

func (*ScheduleActivityTaskCommandAttributes) ProtoMessage 

func (*ScheduleActivityTaskCommandAttributes) ProtoMessage()

func (*ScheduleActivityTaskCommandAttributes) ProtoReflect added in v1.26.1 

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

func (*ScheduleActivityTaskCommandAttributes) Reset 

func (x *ScheduleActivityTaskCommandAttributes) Reset()

func (*ScheduleActivityTaskCommandAttributes) Size 

func (val *ScheduleActivityTaskCommandAttributes) Size() int

Size returns the size of the object, in bytes, once serialized

func (*ScheduleActivityTaskCommandAttributes) String 

func (x *ScheduleActivityTaskCommandAttributes) String() string

func (*ScheduleActivityTaskCommandAttributes) Unmarshal 

func (val *ScheduleActivityTaskCommandAttributes) Unmarshal(buf []byte) error

Unmarshal an object of type ScheduleActivityTaskCommandAttributes from the protobuf v3 wire format

type ScheduleNexusOperationCommandAttributes added in v1.32.1 

type ScheduleNexusOperationCommandAttributes struct {

	// Endpoint name, must exist in the endpoint registry or this command will fail.
	Endpoint string `protobuf:"bytes,1,opt,name=endpoint,proto3" json:"endpoint,omitempty"`
	// Service name.
	Service string `protobuf:"bytes,2,opt,name=service,proto3" json:"service,omitempty"`
	// Operation name.
	Operation string `protobuf:"bytes,3,opt,name=operation,proto3" json:"operation,omitempty"`
	// Input for the operation. The server converts this into Nexus request content and the appropriate content headers
	// internally when sending the StartOperation request. On the handler side, if it is also backed by Temporal, the
	// content is transformed back to the original Payload sent in this command.
	Input *v1.Payload `protobuf:"bytes,4,opt,name=input,proto3" json:"input,omitempty"`
	// Schedule-to-close timeout for this operation.
	// Indicates how long the caller is willing to wait for operation completion.
	// Calls are retried internally by the server.
	// (-- 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 */
	// Header to attach to the Nexus request.
	// Users are responsible for encrypting sensitive data in this header as it is stored in workflow history and
	// transmitted to external services as-is.
	// This is useful for propagating tracing information.
	// Note these headers are not the same as Temporal headers on internal activities and child workflows, these are
	// transmitted to Nexus operations that may be external and are not traditional payloads.
	NexusHeader map[string]string `` /* 182-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ScheduleNexusOperationCommandAttributes) Descriptor deprecated added in v1.32.1 

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

Deprecated: Use ScheduleNexusOperationCommandAttributes.ProtoReflect.Descriptor instead.

func (*ScheduleNexusOperationCommandAttributes) Equal added in v1.32.1 

func (this *ScheduleNexusOperationCommandAttributes) Equal(that interface{}) bool

Equal returns whether two ScheduleNexusOperationCommandAttributes values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*ScheduleNexusOperationCommandAttributes) GetEndpoint added in v1.33.0 

func (x *ScheduleNexusOperationCommandAttributes) GetEndpoint() string

func (*ScheduleNexusOperationCommandAttributes) GetInput added in v1.32.1 

func (x *ScheduleNexusOperationCommandAttributes) GetInput() *v1.Payload

func (*ScheduleNexusOperationCommandAttributes) GetNexusHeader added in v1.32.1 

func (x *ScheduleNexusOperationCommandAttributes) GetNexusHeader() map[string]string

func (*ScheduleNexusOperationCommandAttributes) GetOperation added in v1.32.1 

func (x *ScheduleNexusOperationCommandAttributes) GetOperation() string

func (*ScheduleNexusOperationCommandAttributes) GetScheduleToCloseTimeout added in v1.32.1 

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

func (*ScheduleNexusOperationCommandAttributes) GetService added in v1.32.1 

func (x *ScheduleNexusOperationCommandAttributes) GetService() string

func (*ScheduleNexusOperationCommandAttributes) Marshal added in v1.32.1 

func (val *ScheduleNexusOperationCommandAttributes) Marshal() ([]byte, error)

Marshal an object of type ScheduleNexusOperationCommandAttributes to the protobuf v3 wire format

func (*ScheduleNexusOperationCommandAttributes) ProtoMessage added in v1.32.1 

func (*ScheduleNexusOperationCommandAttributes) ProtoMessage()

func (*ScheduleNexusOperationCommandAttributes) ProtoReflect added in v1.32.1 

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

func (*ScheduleNexusOperationCommandAttributes) Reset added in v1.32.1 

func (x *ScheduleNexusOperationCommandAttributes) Reset()

func (*ScheduleNexusOperationCommandAttributes) Size added in v1.32.1 

func (val *ScheduleNexusOperationCommandAttributes) Size() int

Size returns the size of the object, in bytes, once serialized

func (*ScheduleNexusOperationCommandAttributes) String added in v1.32.1 

func (x *ScheduleNexusOperationCommandAttributes) String() string

func (*ScheduleNexusOperationCommandAttributes) Unmarshal added in v1.32.1 

func (val *ScheduleNexusOperationCommandAttributes) Unmarshal(buf []byte) error

Unmarshal an object of type ScheduleNexusOperationCommandAttributes from the protobuf v3 wire format

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 

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

Deprecated: Use SignalExternalWorkflowExecutionCommandAttributes.ProtoReflect.Descriptor instead.

func (*SignalExternalWorkflowExecutionCommandAttributes) Equal 

func (this *SignalExternalWorkflowExecutionCommandAttributes) Equal(that interface{}) bool

Equal returns whether two SignalExternalWorkflowExecutionCommandAttributes values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*SignalExternalWorkflowExecutionCommandAttributes) GetChildWorkflowOnly 

func (x *SignalExternalWorkflowExecutionCommandAttributes) GetChildWorkflowOnly() bool

func (*SignalExternalWorkflowExecutionCommandAttributes) GetControl 

func (x *SignalExternalWorkflowExecutionCommandAttributes) GetControl() string

func (*SignalExternalWorkflowExecutionCommandAttributes) GetExecution 

func (x *SignalExternalWorkflowExecutionCommandAttributes) GetExecution() *v1.WorkflowExecution

func (*SignalExternalWorkflowExecutionCommandAttributes) GetHeader added in v1.6.0 

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

func (*SignalExternalWorkflowExecutionCommandAttributes) GetInput 

func (x *SignalExternalWorkflowExecutionCommandAttributes) GetInput() *v1.Payloads

func (*SignalExternalWorkflowExecutionCommandAttributes) GetNamespace 

func (x *SignalExternalWorkflowExecutionCommandAttributes) GetNamespace() string

func (*SignalExternalWorkflowExecutionCommandAttributes) GetSignalName 

func (x *SignalExternalWorkflowExecutionCommandAttributes) GetSignalName() string

func (*SignalExternalWorkflowExecutionCommandAttributes) Marshal 

func (val *SignalExternalWorkflowExecutionCommandAttributes) Marshal() ([]byte, error)

Marshal an object of type SignalExternalWorkflowExecutionCommandAttributes to the protobuf v3 wire format

func (*SignalExternalWorkflowExecutionCommandAttributes) ProtoMessage 

func (*SignalExternalWorkflowExecutionCommandAttributes) ProtoMessage()

func (*SignalExternalWorkflowExecutionCommandAttributes) ProtoReflect added in v1.26.1 

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

func (*SignalExternalWorkflowExecutionCommandAttributes) Reset 

func (x *SignalExternalWorkflowExecutionCommandAttributes) Reset()

func (*SignalExternalWorkflowExecutionCommandAttributes) Size 

func (val *SignalExternalWorkflowExecutionCommandAttributes) Size() int

Size returns the size of the object, in bytes, once serialized

func (*SignalExternalWorkflowExecutionCommandAttributes) String 

func (x *SignalExternalWorkflowExecutionCommandAttributes) String() string

func (*SignalExternalWorkflowExecutionCommandAttributes) Unmarshal 

func (val *SignalExternalWorkflowExecutionCommandAttributes) Unmarshal(buf []byte) error

Unmarshal an object of type SignalExternalWorkflowExecutionCommandAttributes from the protobuf v3 wire format

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"`
	// If this is set, the child workflow inherits the Build ID of the parent. Otherwise, the assignment
	// rules of the child's Task Queue will be used to independently assign a Build ID to it.
	InheritBuildId bool `protobuf:"varint,17,opt,name=inherit_build_id,json=inheritBuildId,proto3" json:"inherit_build_id,omitempty"`
	// contains filtered or unexported fields
}

func (*StartChildWorkflowExecutionCommandAttributes) Descriptor deprecated 

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

Deprecated: Use StartChildWorkflowExecutionCommandAttributes.ProtoReflect.Descriptor instead.

func (*StartChildWorkflowExecutionCommandAttributes) Equal 

func (this *StartChildWorkflowExecutionCommandAttributes) Equal(that interface{}) bool

Equal returns whether two StartChildWorkflowExecutionCommandAttributes values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*StartChildWorkflowExecutionCommandAttributes) GetControl 

func (x *StartChildWorkflowExecutionCommandAttributes) GetControl() string

func (*StartChildWorkflowExecutionCommandAttributes) GetCronSchedule 

func (x *StartChildWorkflowExecutionCommandAttributes) GetCronSchedule() string

func (*StartChildWorkflowExecutionCommandAttributes) GetHeader 

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

func (*StartChildWorkflowExecutionCommandAttributes) GetInheritBuildId added in v1.32.0 

func (x *StartChildWorkflowExecutionCommandAttributes) GetInheritBuildId() bool

func (*StartChildWorkflowExecutionCommandAttributes) GetInput 

func (x *StartChildWorkflowExecutionCommandAttributes) GetInput() *v1.Payloads

func (*StartChildWorkflowExecutionCommandAttributes) GetMemo 

func (x *StartChildWorkflowExecutionCommandAttributes) GetMemo() *v1.Memo

func (*StartChildWorkflowExecutionCommandAttributes) GetNamespace 

func (x *StartChildWorkflowExecutionCommandAttributes) GetNamespace() string

func (*StartChildWorkflowExecutionCommandAttributes) GetParentClosePolicy 

func (x *StartChildWorkflowExecutionCommandAttributes) GetParentClosePolicy() v13.ParentClosePolicy

func (*StartChildWorkflowExecutionCommandAttributes) GetRetryPolicy 

func (x *StartChildWorkflowExecutionCommandAttributes) GetRetryPolicy() *v1.RetryPolicy

func (*StartChildWorkflowExecutionCommandAttributes) GetSearchAttributes 

func (x *StartChildWorkflowExecutionCommandAttributes) GetSearchAttributes() *v1.SearchAttributes

func (*StartChildWorkflowExecutionCommandAttributes) GetTaskQueue 

func (x *StartChildWorkflowExecutionCommandAttributes) GetTaskQueue() *v11.TaskQueue

func (*StartChildWorkflowExecutionCommandAttributes) GetWorkflowExecutionTimeout added in v0.28.0 

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

func (*StartChildWorkflowExecutionCommandAttributes) GetWorkflowId 

func (x *StartChildWorkflowExecutionCommandAttributes) GetWorkflowId() string

func (*StartChildWorkflowExecutionCommandAttributes) GetWorkflowIdReusePolicy 

func (x *StartChildWorkflowExecutionCommandAttributes) GetWorkflowIdReusePolicy() v13.WorkflowIdReusePolicy

func (*StartChildWorkflowExecutionCommandAttributes) GetWorkflowRunTimeout added in v0.28.0 

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

func (*StartChildWorkflowExecutionCommandAttributes) GetWorkflowTaskTimeout added in v0.28.0 

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

func (*StartChildWorkflowExecutionCommandAttributes) GetWorkflowType 

func (x *StartChildWorkflowExecutionCommandAttributes) GetWorkflowType() *v1.WorkflowType

func (*StartChildWorkflowExecutionCommandAttributes) Marshal 

func (val *StartChildWorkflowExecutionCommandAttributes) Marshal() ([]byte, error)

Marshal an object of type StartChildWorkflowExecutionCommandAttributes to the protobuf v3 wire format

func (*StartChildWorkflowExecutionCommandAttributes) ProtoMessage 

func (*StartChildWorkflowExecutionCommandAttributes) ProtoMessage()

func (*StartChildWorkflowExecutionCommandAttributes) ProtoReflect added in v1.26.1 

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

func (*StartChildWorkflowExecutionCommandAttributes) Reset 

func (x *StartChildWorkflowExecutionCommandAttributes) Reset()

func (*StartChildWorkflowExecutionCommandAttributes) Size 

func (val *StartChildWorkflowExecutionCommandAttributes) Size() int

Size returns the size of the object, in bytes, once serialized

func (*StartChildWorkflowExecutionCommandAttributes) String 

func (x *StartChildWorkflowExecutionCommandAttributes) String() string

func (*StartChildWorkflowExecutionCommandAttributes) Unmarshal 

func (val *StartChildWorkflowExecutionCommandAttributes) Unmarshal(buf []byte) error

Unmarshal an object of type StartChildWorkflowExecutionCommandAttributes from the protobuf v3 wire format

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

func (this *StartTimerCommandAttributes) Equal(that interface{}) bool

Equal returns whether two StartTimerCommandAttributes values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*StartTimerCommandAttributes) GetStartToFireTimeout added in v0.28.0 

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

func (*StartTimerCommandAttributes) GetTimerId 

func (x *StartTimerCommandAttributes) GetTimerId() string

func (*StartTimerCommandAttributes) Marshal 

func (val *StartTimerCommandAttributes) Marshal() ([]byte, error)

Marshal an object of type StartTimerCommandAttributes to the protobuf v3 wire format

func (*StartTimerCommandAttributes) ProtoMessage 

func (*StartTimerCommandAttributes) ProtoMessage()

func (*StartTimerCommandAttributes) ProtoReflect added in v1.26.1 

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

func (*StartTimerCommandAttributes) Reset 

func (x *StartTimerCommandAttributes) Reset()

func (*StartTimerCommandAttributes) Size 

func (val *StartTimerCommandAttributes) Size() int

Size returns the size of the object, in bytes, once serialized

func (*StartTimerCommandAttributes) String 

func (x *StartTimerCommandAttributes) String() string

func (*StartTimerCommandAttributes) Unmarshal 

func (val *StartTimerCommandAttributes) Unmarshal(buf []byte) error

Unmarshal an object of type StartTimerCommandAttributes from the protobuf v3 wire format

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 

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

Deprecated: Use UpsertWorkflowSearchAttributesCommandAttributes.ProtoReflect.Descriptor instead.

func (*UpsertWorkflowSearchAttributesCommandAttributes) Equal 

func (this *UpsertWorkflowSearchAttributesCommandAttributes) Equal(that interface{}) bool

Equal returns whether two UpsertWorkflowSearchAttributesCommandAttributes values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*UpsertWorkflowSearchAttributesCommandAttributes) GetSearchAttributes 

func (x *UpsertWorkflowSearchAttributesCommandAttributes) GetSearchAttributes() *v1.SearchAttributes

func (*UpsertWorkflowSearchAttributesCommandAttributes) Marshal 

func (val *UpsertWorkflowSearchAttributesCommandAttributes) Marshal() ([]byte, error)

Marshal an object of type UpsertWorkflowSearchAttributesCommandAttributes to the protobuf v3 wire format

func (*UpsertWorkflowSearchAttributesCommandAttributes) ProtoMessage 

func (*UpsertWorkflowSearchAttributesCommandAttributes) ProtoMessage()

func (*UpsertWorkflowSearchAttributesCommandAttributes) ProtoReflect added in v1.26.1 

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

func (*UpsertWorkflowSearchAttributesCommandAttributes) Reset 

func (x *UpsertWorkflowSearchAttributesCommandAttributes) Reset()

func (*UpsertWorkflowSearchAttributesCommandAttributes) Size 

func (val *UpsertWorkflowSearchAttributesCommandAttributes) Size() int

Size returns the size of the object, in bytes, once serialized

func (*UpsertWorkflowSearchAttributesCommandAttributes) String 

func (x *UpsertWorkflowSearchAttributesCommandAttributes) String() string

func (*UpsertWorkflowSearchAttributesCommandAttributes) Unmarshal 

func (val *UpsertWorkflowSearchAttributesCommandAttributes) Unmarshal(buf []byte) error

Unmarshal an object of type UpsertWorkflowSearchAttributesCommandAttributes from the protobuf v3 wire format

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.