workflowservice

package

Go to main page

Versions in this module

v4

v4.12.0

Mar 28, 2024

v4.11.1

Feb 28, 2024

v4.11.0

Feb 17, 2024

Changes in this version

+ const WorkflowService_PollNexusTaskQueue_FullMethodName

+ const WorkflowService_RespondNexusTaskCompleted_FullMethodName

+ const WorkflowService_RespondNexusTaskFailed_FullMethodName

type DescribeWorkflowExecutionResponse

+ Callbacks []*v112.CallbackInfo

+ func (x *DescribeWorkflowExecutionResponse) GetCallbacks() []*v112.CallbackInfo

+ type PollNexusTaskQueueRequest struct

+ Identity string

+ Namespace string

+ TaskQueue *v14.TaskQueue

+ WorkerVersionCapabilities *v13.WorkerVersionCapabilities

+ func (*PollNexusTaskQueueRequest) Descriptor() ([]byte, []int)

+ func (*PollNexusTaskQueueRequest) ProtoMessage()

+ func (x *PollNexusTaskQueueRequest) GetIdentity() string

+ func (x *PollNexusTaskQueueRequest) GetNamespace() string

+ func (x *PollNexusTaskQueueRequest) GetTaskQueue() *v14.TaskQueue

+ func (x *PollNexusTaskQueueRequest) GetWorkerVersionCapabilities() *v13.WorkerVersionCapabilities

+ func (x *PollNexusTaskQueueRequest) ProtoReflect() protoreflect.Message

+ func (x *PollNexusTaskQueueRequest) Reset()

+ func (x *PollNexusTaskQueueRequest) String() string

+ type PollNexusTaskQueueResponse struct

+ Request *v117.Request

+ TaskToken []byte

+ func (*PollNexusTaskQueueResponse) Descriptor() ([]byte, []int)

+ func (*PollNexusTaskQueueResponse) ProtoMessage()

+ func (x *PollNexusTaskQueueResponse) GetRequest() *v117.Request

+ func (x *PollNexusTaskQueueResponse) GetTaskToken() []byte

+ func (x *PollNexusTaskQueueResponse) ProtoReflect() protoreflect.Message

+ func (x *PollNexusTaskQueueResponse) Reset()

+ func (x *PollNexusTaskQueueResponse) String() string

type ResetWorkflowExecutionRequest

+ ResetReapplyExcludeTypes []v11.ResetReapplyExcludeType

+ func (x *ResetWorkflowExecutionRequest) GetResetReapplyExcludeTypes() []v11.ResetReapplyExcludeType

+ type RespondNexusTaskCompletedRequest struct

+ Identity string

+ Namespace string

+ Response *v117.Response

+ TaskToken []byte

+ func (*RespondNexusTaskCompletedRequest) Descriptor() ([]byte, []int)

+ func (*RespondNexusTaskCompletedRequest) ProtoMessage()

+ func (x *RespondNexusTaskCompletedRequest) GetIdentity() string

+ func (x *RespondNexusTaskCompletedRequest) GetNamespace() string

+ func (x *RespondNexusTaskCompletedRequest) GetResponse() *v117.Response

+ func (x *RespondNexusTaskCompletedRequest) GetTaskToken() []byte

+ func (x *RespondNexusTaskCompletedRequest) ProtoReflect() protoreflect.Message

+ func (x *RespondNexusTaskCompletedRequest) Reset()

+ func (x *RespondNexusTaskCompletedRequest) String() string

+ type RespondNexusTaskCompletedResponse struct

+ func (*RespondNexusTaskCompletedResponse) Descriptor() ([]byte, []int)

+ func (*RespondNexusTaskCompletedResponse) ProtoMessage()

+ func (x *RespondNexusTaskCompletedResponse) ProtoReflect() protoreflect.Message

+ func (x *RespondNexusTaskCompletedResponse) Reset()

+ func (x *RespondNexusTaskCompletedResponse) String() string

+ type RespondNexusTaskFailedRequest struct

+ Error *v117.HandlerError

+ Identity string

+ Namespace string

+ TaskToken []byte

+ func (*RespondNexusTaskFailedRequest) Descriptor() ([]byte, []int)

+ func (*RespondNexusTaskFailedRequest) ProtoMessage()

+ func (x *RespondNexusTaskFailedRequest) GetError() *v117.HandlerError

+ func (x *RespondNexusTaskFailedRequest) GetIdentity() string

+ func (x *RespondNexusTaskFailedRequest) GetNamespace() string

+ func (x *RespondNexusTaskFailedRequest) GetTaskToken() []byte

+ func (x *RespondNexusTaskFailedRequest) ProtoReflect() protoreflect.Message

+ func (x *RespondNexusTaskFailedRequest) Reset()

+ func (x *RespondNexusTaskFailedRequest) String() string

+ type RespondNexusTaskFailedResponse struct

+ func (*RespondNexusTaskFailedResponse) Descriptor() ([]byte, []int)

+ func (*RespondNexusTaskFailedResponse) ProtoMessage()

+ func (x *RespondNexusTaskFailedResponse) ProtoReflect() protoreflect.Message

+ func (x *RespondNexusTaskFailedResponse) Reset()

+ func (x *RespondNexusTaskFailedResponse) String() string

type StartWorkflowExecutionRequest

+ CompletionCallbacks []*v13.Callback

+ func (x *StartWorkflowExecutionRequest) GetCompletionCallbacks() []*v13.Callback

type UnimplementedWorkflowServiceServer

+ func (UnimplementedWorkflowServiceServer) PollNexusTaskQueue(context.Context, *PollNexusTaskQueueRequest) (*PollNexusTaskQueueResponse, error)

+ func (UnimplementedWorkflowServiceServer) RespondNexusTaskCompleted(context.Context, *RespondNexusTaskCompletedRequest) (*RespondNexusTaskCompletedResponse, error)

+ func (UnimplementedWorkflowServiceServer) RespondNexusTaskFailed(context.Context, *RespondNexusTaskFailedRequest) (*RespondNexusTaskFailedResponse, error)

type WorkflowServiceClient

+ PollNexusTaskQueue func(ctx context.Context, in *PollNexusTaskQueueRequest, opts ...grpc.CallOption) (*PollNexusTaskQueueResponse, error)

+ RespondNexusTaskCompleted func(ctx context.Context, in *RespondNexusTaskCompletedRequest, ...) (*RespondNexusTaskCompletedResponse, error)

+ RespondNexusTaskFailed func(ctx context.Context, in *RespondNexusTaskFailedRequest, ...) (*RespondNexusTaskFailedResponse, error)

type WorkflowServiceServer

+ PollNexusTaskQueue func(context.Context, *PollNexusTaskQueueRequest) (*PollNexusTaskQueueResponse, error)

+ RespondNexusTaskCompleted func(context.Context, *RespondNexusTaskCompletedRequest) (*RespondNexusTaskCompletedResponse, error)

+ RespondNexusTaskFailed func(context.Context, *RespondNexusTaskFailedRequest) (*RespondNexusTaskFailedResponse, error)

v4.10.0

Dec 19, 2023

Changes in this version

type PollWorkflowExecutionUpdateResponse

+ Stage v11.UpdateWorkflowExecutionLifecycleStage

+ UpdateRef *v115.UpdateRef

+ func (x *PollWorkflowExecutionUpdateResponse) GetStage() v11.UpdateWorkflowExecutionLifecycleStage

+ func (x *PollWorkflowExecutionUpdateResponse) GetUpdateRef() *v115.UpdateRef

type StartBatchOperationRequest

+ MaxOperationsPerSecond float32

+ func (x *StartBatchOperationRequest) GetMaxOperationsPerSecond() float32

type UpdateWorkflowExecutionResponse

+ Stage v11.UpdateWorkflowExecutionLifecycleStage

+ func (x *UpdateWorkflowExecutionResponse) GetStage() v11.UpdateWorkflowExecutionLifecycleStage

v4.9.0

Oct 9, 2023

v4.8.0

Sep 10, 2023

v4.7.1

Sep 1, 2023

Changes in this version

type CountWorkflowExecutionsResponse

+ Groups []*CountWorkflowExecutionsResponse_AggregationGroup

+ func (x *CountWorkflowExecutionsResponse) GetGroups() []*CountWorkflowExecutionsResponse_AggregationGroup

+ type CountWorkflowExecutionsResponse_AggregationGroup struct

+ Count int64

+ GroupValues []*v13.Payload

+ func (*CountWorkflowExecutionsResponse_AggregationGroup) Descriptor() ([]byte, []int)

+ func (*CountWorkflowExecutionsResponse_AggregationGroup) ProtoMessage()

+ func (x *CountWorkflowExecutionsResponse_AggregationGroup) GetCount() int64

+ func (x *CountWorkflowExecutionsResponse_AggregationGroup) GetGroupValues() []*v13.Payload

+ func (x *CountWorkflowExecutionsResponse_AggregationGroup) ProtoReflect() protoreflect.Message

+ func (x *CountWorkflowExecutionsResponse_AggregationGroup) Reset()

+ func (x *CountWorkflowExecutionsResponse_AggregationGroup) String() string

type GetSystemInfoResponse_Capabilities

+ CountGroupByExecutionStatus bool

+ func (x *GetSystemInfoResponse_Capabilities) GetCountGroupByExecutionStatus() bool

v4.7.0

Aug 23, 2023

v4.6.1

Aug 2, 2023

v4.6.0

Jul 31, 2023

Changes in this version

+ const WorkflowService_CountWorkflowExecutions_FullMethodName

+ const WorkflowService_CreateSchedule_FullMethodName

+ const WorkflowService_DeleteSchedule_FullMethodName

+ const WorkflowService_DeleteWorkflowExecution_FullMethodName

+ const WorkflowService_DeprecateNamespace_FullMethodName

+ const WorkflowService_DescribeBatchOperation_FullMethodName

+ const WorkflowService_DescribeNamespace_FullMethodName

+ const WorkflowService_DescribeSchedule_FullMethodName

+ const WorkflowService_DescribeTaskQueue_FullMethodName

+ const WorkflowService_DescribeWorkflowExecution_FullMethodName

+ const WorkflowService_GetClusterInfo_FullMethodName

+ const WorkflowService_GetSearchAttributes_FullMethodName

+ const WorkflowService_GetSystemInfo_FullMethodName

+ const WorkflowService_GetWorkerBuildIdCompatibility_FullMethodName

+ const WorkflowService_GetWorkerTaskReachability_FullMethodName

+ const WorkflowService_GetWorkflowExecutionHistoryReverse_FullMethodName

+ const WorkflowService_GetWorkflowExecutionHistory_FullMethodName

+ const WorkflowService_ListArchivedWorkflowExecutions_FullMethodName

+ const WorkflowService_ListBatchOperations_FullMethodName

+ const WorkflowService_ListClosedWorkflowExecutions_FullMethodName

+ const WorkflowService_ListNamespaces_FullMethodName

+ const WorkflowService_ListOpenWorkflowExecutions_FullMethodName

+ const WorkflowService_ListScheduleMatchingTimes_FullMethodName

+ const WorkflowService_ListSchedules_FullMethodName

+ const WorkflowService_ListTaskQueuePartitions_FullMethodName

+ const WorkflowService_ListWorkflowExecutions_FullMethodName

+ const WorkflowService_PatchSchedule_FullMethodName

+ const WorkflowService_PollActivityTaskQueue_FullMethodName

+ const WorkflowService_PollWorkflowExecutionUpdate_FullMethodName

+ const WorkflowService_PollWorkflowTaskQueue_FullMethodName

+ const WorkflowService_QueryWorkflow_FullMethodName

+ const WorkflowService_RecordActivityTaskHeartbeatById_FullMethodName

+ const WorkflowService_RecordActivityTaskHeartbeat_FullMethodName

+ const WorkflowService_RegisterNamespace_FullMethodName

+ const WorkflowService_RequestCancelWorkflowExecution_FullMethodName

+ const WorkflowService_ResetStickyTaskQueue_FullMethodName

+ const WorkflowService_ResetWorkflowExecution_FullMethodName

+ const WorkflowService_RespondActivityTaskCanceledById_FullMethodName

+ const WorkflowService_RespondActivityTaskCanceled_FullMethodName

+ const WorkflowService_RespondActivityTaskCompletedById_FullMethodName

+ const WorkflowService_RespondActivityTaskCompleted_FullMethodName

+ const WorkflowService_RespondActivityTaskFailedById_FullMethodName

+ const WorkflowService_RespondActivityTaskFailed_FullMethodName

+ const WorkflowService_RespondQueryTaskCompleted_FullMethodName

+ const WorkflowService_RespondWorkflowTaskCompleted_FullMethodName

+ const WorkflowService_RespondWorkflowTaskFailed_FullMethodName

+ const WorkflowService_ScanWorkflowExecutions_FullMethodName

+ const WorkflowService_SignalWithStartWorkflowExecution_FullMethodName

+ const WorkflowService_SignalWorkflowExecution_FullMethodName

+ const WorkflowService_StartBatchOperation_FullMethodName

+ const WorkflowService_StartWorkflowExecution_FullMethodName

+ const WorkflowService_StopBatchOperation_FullMethodName

+ const WorkflowService_TerminateWorkflowExecution_FullMethodName

+ const WorkflowService_UpdateNamespace_FullMethodName

+ const WorkflowService_UpdateSchedule_FullMethodName

+ const WorkflowService_UpdateWorkerBuildIdCompatibility_FullMethodName

+ const WorkflowService_UpdateWorkflowExecution_FullMethodName

+ var File_temporal_api_workflowservice_v1_request_response_proto protoreflect.FileDescriptor

+ var File_temporal_api_workflowservice_v1_service_proto protoreflect.FileDescriptor

+ var WorkflowService_ServiceDesc = grpc.ServiceDesc

+ func RegisterWorkflowServiceServer(s grpc.ServiceRegistrar, srv WorkflowServiceServer)

+ type CountWorkflowExecutionsRequest struct

+ Namespace string

+ Query string

+ func (*CountWorkflowExecutionsRequest) Descriptor() ([]byte, []int)

+ func (*CountWorkflowExecutionsRequest) ProtoMessage()

+ func (x *CountWorkflowExecutionsRequest) GetNamespace() string

+ func (x *CountWorkflowExecutionsRequest) GetQuery() string

+ func (x *CountWorkflowExecutionsRequest) ProtoReflect() protoreflect.Message

+ func (x *CountWorkflowExecutionsRequest) Reset()

+ func (x *CountWorkflowExecutionsRequest) String() string

+ type CountWorkflowExecutionsResponse struct

+ Count int64

+ func (*CountWorkflowExecutionsResponse) Descriptor() ([]byte, []int)

+ func (*CountWorkflowExecutionsResponse) ProtoMessage()

+ func (x *CountWorkflowExecutionsResponse) GetCount() int64

+ func (x *CountWorkflowExecutionsResponse) ProtoReflect() protoreflect.Message

+ func (x *CountWorkflowExecutionsResponse) Reset()

+ func (x *CountWorkflowExecutionsResponse) String() string

+ type CreateScheduleRequest struct

+ Identity string

+ InitialPatch *v114.SchedulePatch

+ Memo *v13.Memo

+ Namespace string

+ RequestId string

+ Schedule *v114.Schedule

+ ScheduleId string

+ SearchAttributes *v13.SearchAttributes

+ func (*CreateScheduleRequest) Descriptor() ([]byte, []int)

+ func (*CreateScheduleRequest) ProtoMessage()

+ func (x *CreateScheduleRequest) GetIdentity() string

+ func (x *CreateScheduleRequest) GetInitialPatch() *v114.SchedulePatch

+ func (x *CreateScheduleRequest) GetMemo() *v13.Memo

+ func (x *CreateScheduleRequest) GetNamespace() string

+ func (x *CreateScheduleRequest) GetRequestId() string

+ func (x *CreateScheduleRequest) GetSchedule() *v114.Schedule

+ func (x *CreateScheduleRequest) GetScheduleId() string

+ func (x *CreateScheduleRequest) GetSearchAttributes() *v13.SearchAttributes

+ func (x *CreateScheduleRequest) ProtoReflect() protoreflect.Message

+ func (x *CreateScheduleRequest) Reset()

+ func (x *CreateScheduleRequest) String() string

+ type CreateScheduleResponse struct

+ ConflictToken []byte

+ func (*CreateScheduleResponse) Descriptor() ([]byte, []int)

+ func (*CreateScheduleResponse) ProtoMessage()

+ func (x *CreateScheduleResponse) GetConflictToken() []byte

+ func (x *CreateScheduleResponse) ProtoReflect() protoreflect.Message

+ func (x *CreateScheduleResponse) Reset()

+ func (x *CreateScheduleResponse) String() string

+ type DeleteScheduleRequest struct

+ Identity string

+ Namespace string

+ ScheduleId string

+ func (*DeleteScheduleRequest) Descriptor() ([]byte, []int)

+ func (*DeleteScheduleRequest) ProtoMessage()

+ func (x *DeleteScheduleRequest) GetIdentity() string

+ func (x *DeleteScheduleRequest) GetNamespace() string

+ func (x *DeleteScheduleRequest) GetScheduleId() string

+ func (x *DeleteScheduleRequest) ProtoReflect() protoreflect.Message

+ func (x *DeleteScheduleRequest) Reset()

+ func (x *DeleteScheduleRequest) String() string

+ type DeleteScheduleResponse struct

+ func (*DeleteScheduleResponse) Descriptor() ([]byte, []int)

+ func (*DeleteScheduleResponse) ProtoMessage()

+ func (x *DeleteScheduleResponse) ProtoReflect() protoreflect.Message

+ func (x *DeleteScheduleResponse) Reset()

+ func (x *DeleteScheduleResponse) String() string

+ type DeleteWorkflowExecutionRequest struct

+ Namespace string

+ WorkflowExecution *v13.WorkflowExecution

+ func (*DeleteWorkflowExecutionRequest) Descriptor() ([]byte, []int)

+ func (*DeleteWorkflowExecutionRequest) ProtoMessage()

+ func (x *DeleteWorkflowExecutionRequest) GetNamespace() string

+ func (x *DeleteWorkflowExecutionRequest) GetWorkflowExecution() *v13.WorkflowExecution

+ func (x *DeleteWorkflowExecutionRequest) ProtoReflect() protoreflect.Message

+ func (x *DeleteWorkflowExecutionRequest) Reset()

+ func (x *DeleteWorkflowExecutionRequest) String() string

+ type DeleteWorkflowExecutionResponse struct

+ func (*DeleteWorkflowExecutionResponse) Descriptor() ([]byte, []int)

+ func (*DeleteWorkflowExecutionResponse) ProtoMessage()

+ func (x *DeleteWorkflowExecutionResponse) ProtoReflect() protoreflect.Message

+ func (x *DeleteWorkflowExecutionResponse) Reset()

+ func (x *DeleteWorkflowExecutionResponse) String() string

+ type DeprecateNamespaceRequest struct

+ Namespace string

+ SecurityToken string

+ func (*DeprecateNamespaceRequest) Descriptor() ([]byte, []int)

+ func (*DeprecateNamespaceRequest) ProtoMessage()

+ func (x *DeprecateNamespaceRequest) GetNamespace() string

+ func (x *DeprecateNamespaceRequest) GetSecurityToken() string

+ func (x *DeprecateNamespaceRequest) ProtoReflect() protoreflect.Message

+ func (x *DeprecateNamespaceRequest) Reset()

+ func (x *DeprecateNamespaceRequest) String() string

+ type DeprecateNamespaceResponse struct

+ func (*DeprecateNamespaceResponse) Descriptor() ([]byte, []int)

+ func (*DeprecateNamespaceResponse) ProtoMessage()

+ func (x *DeprecateNamespaceResponse) ProtoReflect() protoreflect.Message

+ func (x *DeprecateNamespaceResponse) Reset()

+ func (x *DeprecateNamespaceResponse) String() string

+ type DescribeBatchOperationRequest struct

+ JobId string

+ Namespace string

+ func (*DescribeBatchOperationRequest) Descriptor() ([]byte, []int)

+ func (*DescribeBatchOperationRequest) ProtoMessage()

+ func (x *DescribeBatchOperationRequest) GetJobId() string

+ func (x *DescribeBatchOperationRequest) GetNamespace() string

+ func (x *DescribeBatchOperationRequest) ProtoReflect() protoreflect.Message

+ func (x *DescribeBatchOperationRequest) Reset()

+ func (x *DescribeBatchOperationRequest) String() string

+ type DescribeBatchOperationResponse struct

+ CloseTime *timestamppb.Timestamp

+ CompleteOperationCount int64

+ FailureOperationCount int64

+ Identity string

+ JobId string

+ OperationType v11.BatchOperationType

+ Reason string

+ StartTime *timestamppb.Timestamp

+ State v11.BatchOperationState

+ TotalOperationCount int64

+ func (*DescribeBatchOperationResponse) Descriptor() ([]byte, []int)

+ func (*DescribeBatchOperationResponse) ProtoMessage()

+ func (x *DescribeBatchOperationResponse) GetCloseTime() *timestamppb.Timestamp

+ func (x *DescribeBatchOperationResponse) GetCompleteOperationCount() int64

+ func (x *DescribeBatchOperationResponse) GetFailureOperationCount() int64

+ func (x *DescribeBatchOperationResponse) GetIdentity() string

+ func (x *DescribeBatchOperationResponse) GetJobId() string

+ func (x *DescribeBatchOperationResponse) GetOperationType() v11.BatchOperationType

+ func (x *DescribeBatchOperationResponse) GetReason() string

+ func (x *DescribeBatchOperationResponse) GetStartTime() *timestamppb.Timestamp

+ func (x *DescribeBatchOperationResponse) GetState() v11.BatchOperationState

+ func (x *DescribeBatchOperationResponse) GetTotalOperationCount() int64

+ func (x *DescribeBatchOperationResponse) ProtoReflect() protoreflect.Message

+ func (x *DescribeBatchOperationResponse) Reset()

+ func (x *DescribeBatchOperationResponse) String() string

+ type DescribeNamespaceRequest struct

+ Id string

+ Namespace string

+ func (*DescribeNamespaceRequest) Descriptor() ([]byte, []int)

+ func (*DescribeNamespaceRequest) ProtoMessage()

+ func (x *DescribeNamespaceRequest) GetId() string

+ func (x *DescribeNamespaceRequest) GetNamespace() string

+ func (x *DescribeNamespaceRequest) ProtoReflect() protoreflect.Message

+ func (x *DescribeNamespaceRequest) Reset()

+ func (x *DescribeNamespaceRequest) String() string

+ type DescribeNamespaceResponse struct

+ Config *v12.NamespaceConfig

+ FailoverHistory []*v1.FailoverStatus

+ FailoverVersion int64

+ IsGlobalNamespace bool

+ NamespaceInfo *v12.NamespaceInfo

+ ReplicationConfig *v1.NamespaceReplicationConfig

+ func (*DescribeNamespaceResponse) Descriptor() ([]byte, []int)

+ func (*DescribeNamespaceResponse) ProtoMessage()

+ func (x *DescribeNamespaceResponse) GetConfig() *v12.NamespaceConfig

+ func (x *DescribeNamespaceResponse) GetFailoverHistory() []*v1.FailoverStatus

+ func (x *DescribeNamespaceResponse) GetFailoverVersion() int64

+ func (x *DescribeNamespaceResponse) GetIsGlobalNamespace() bool

+ func (x *DescribeNamespaceResponse) GetNamespaceInfo() *v12.NamespaceInfo

+ func (x *DescribeNamespaceResponse) GetReplicationConfig() *v1.NamespaceReplicationConfig

+ func (x *DescribeNamespaceResponse) ProtoReflect() protoreflect.Message

+ func (x *DescribeNamespaceResponse) Reset()

+ func (x *DescribeNamespaceResponse) String() string

+ type DescribeScheduleRequest struct

+ Namespace string

+ ScheduleId string

+ func (*DescribeScheduleRequest) Descriptor() ([]byte, []int)

+ func (*DescribeScheduleRequest) ProtoMessage()

+ func (x *DescribeScheduleRequest) GetNamespace() string

+ func (x *DescribeScheduleRequest) GetScheduleId() string

+ func (x *DescribeScheduleRequest) ProtoReflect() protoreflect.Message

+ func (x *DescribeScheduleRequest) Reset()

+ func (x *DescribeScheduleRequest) String() string

+ type DescribeScheduleResponse struct

+ ConflictToken []byte

+ Info *v114.ScheduleInfo

+ Memo *v13.Memo

+ Schedule *v114.Schedule

+ SearchAttributes *v13.SearchAttributes

+ func (*DescribeScheduleResponse) Descriptor() ([]byte, []int)

+ func (*DescribeScheduleResponse) ProtoMessage()

+ func (x *DescribeScheduleResponse) GetConflictToken() []byte

+ func (x *DescribeScheduleResponse) GetInfo() *v114.ScheduleInfo

+ func (x *DescribeScheduleResponse) GetMemo() *v13.Memo

+ func (x *DescribeScheduleResponse) GetSchedule() *v114.Schedule

+ func (x *DescribeScheduleResponse) GetSearchAttributes() *v13.SearchAttributes

+ func (x *DescribeScheduleResponse) ProtoReflect() protoreflect.Message

+ func (x *DescribeScheduleResponse) Reset()

+ func (x *DescribeScheduleResponse) String() string

+ type DescribeTaskQueueRequest struct

+ IncludeTaskQueueStatus bool

+ Namespace string

+ TaskQueue *v14.TaskQueue

+ TaskQueueType v11.TaskQueueType

+ func (*DescribeTaskQueueRequest) Descriptor() ([]byte, []int)

+ func (*DescribeTaskQueueRequest) ProtoMessage()

+ func (x *DescribeTaskQueueRequest) GetIncludeTaskQueueStatus() bool

+ func (x *DescribeTaskQueueRequest) GetNamespace() string

+ func (x *DescribeTaskQueueRequest) GetTaskQueue() *v14.TaskQueue

+ func (x *DescribeTaskQueueRequest) GetTaskQueueType() v11.TaskQueueType

+ func (x *DescribeTaskQueueRequest) ProtoReflect() protoreflect.Message

+ func (x *DescribeTaskQueueRequest) Reset()

+ func (x *DescribeTaskQueueRequest) String() string

+ type DescribeTaskQueueResponse struct

+ Pollers []*v14.PollerInfo

+ TaskQueueStatus *v14.TaskQueueStatus

+ func (*DescribeTaskQueueResponse) Descriptor() ([]byte, []int)

+ func (*DescribeTaskQueueResponse) ProtoMessage()

+ func (x *DescribeTaskQueueResponse) GetPollers() []*v14.PollerInfo

+ func (x *DescribeTaskQueueResponse) GetTaskQueueStatus() *v14.TaskQueueStatus

+ func (x *DescribeTaskQueueResponse) ProtoReflect() protoreflect.Message

+ func (x *DescribeTaskQueueResponse) Reset()

+ func (x *DescribeTaskQueueResponse) String() string

+ type DescribeWorkflowExecutionRequest struct

+ Execution *v13.WorkflowExecution

+ Namespace string

+ func (*DescribeWorkflowExecutionRequest) Descriptor() ([]byte, []int)

+ func (*DescribeWorkflowExecutionRequest) ProtoMessage()

+ func (x *DescribeWorkflowExecutionRequest) GetExecution() *v13.WorkflowExecution

+ func (x *DescribeWorkflowExecutionRequest) GetNamespace() string

+ func (x *DescribeWorkflowExecutionRequest) ProtoReflect() protoreflect.Message

+ func (x *DescribeWorkflowExecutionRequest) Reset()

+ func (x *DescribeWorkflowExecutionRequest) String() string

+ type DescribeWorkflowExecutionResponse struct

+ ExecutionConfig *v112.WorkflowExecutionConfig

+ PendingActivities []*v112.PendingActivityInfo

+ PendingChildren []*v112.PendingChildExecutionInfo

+ PendingWorkflowTask *v112.PendingWorkflowTaskInfo

+ WorkflowExecutionInfo *v112.WorkflowExecutionInfo

+ func (*DescribeWorkflowExecutionResponse) Descriptor() ([]byte, []int)

+ func (*DescribeWorkflowExecutionResponse) ProtoMessage()

+ func (x *DescribeWorkflowExecutionResponse) GetExecutionConfig() *v112.WorkflowExecutionConfig

+ func (x *DescribeWorkflowExecutionResponse) GetPendingActivities() []*v112.PendingActivityInfo

+ func (x *DescribeWorkflowExecutionResponse) GetPendingChildren() []*v112.PendingChildExecutionInfo

+ func (x *DescribeWorkflowExecutionResponse) GetPendingWorkflowTask() *v112.PendingWorkflowTaskInfo

+ func (x *DescribeWorkflowExecutionResponse) GetWorkflowExecutionInfo() *v112.WorkflowExecutionInfo

+ func (x *DescribeWorkflowExecutionResponse) ProtoReflect() protoreflect.Message

+ func (x *DescribeWorkflowExecutionResponse) Reset()

+ func (x *DescribeWorkflowExecutionResponse) String() string

+ type GetClusterInfoRequest struct

+ func (*GetClusterInfoRequest) Descriptor() ([]byte, []int)

+ func (*GetClusterInfoRequest) ProtoMessage()

+ func (x *GetClusterInfoRequest) ProtoReflect() protoreflect.Message

+ func (x *GetClusterInfoRequest) Reset()

+ func (x *GetClusterInfoRequest) String() string

+ type GetClusterInfoResponse struct

+ ClusterId string

+ ClusterName string

+ HistoryShardCount int32

+ PersistenceStore string

+ ServerVersion string

+ SupportedClients map[string]string

+ VersionInfo *v113.VersionInfo

+ VisibilityStore string

+ func (*GetClusterInfoResponse) Descriptor() ([]byte, []int)

+ func (*GetClusterInfoResponse) ProtoMessage()

+ func (x *GetClusterInfoResponse) GetClusterId() string

+ func (x *GetClusterInfoResponse) GetClusterName() string

+ func (x *GetClusterInfoResponse) GetHistoryShardCount() int32

+ func (x *GetClusterInfoResponse) GetPersistenceStore() string

+ func (x *GetClusterInfoResponse) GetServerVersion() string

+ func (x *GetClusterInfoResponse) GetSupportedClients() map[string]string

+ func (x *GetClusterInfoResponse) GetVersionInfo() *v113.VersionInfo

+ func (x *GetClusterInfoResponse) GetVisibilityStore() string

+ func (x *GetClusterInfoResponse) ProtoReflect() protoreflect.Message

+ func (x *GetClusterInfoResponse) Reset()

+ func (x *GetClusterInfoResponse) String() string

+ type GetSearchAttributesRequest struct

+ func (*GetSearchAttributesRequest) Descriptor() ([]byte, []int)

+ func (*GetSearchAttributesRequest) ProtoMessage()

+ func (x *GetSearchAttributesRequest) ProtoReflect() protoreflect.Message

+ func (x *GetSearchAttributesRequest) Reset()

+ func (x *GetSearchAttributesRequest) String() string

+ type GetSearchAttributesResponse struct

+ Keys map[string]v11.IndexedValueType

+ func (*GetSearchAttributesResponse) Descriptor() ([]byte, []int)

+ func (*GetSearchAttributesResponse) ProtoMessage()

+ func (x *GetSearchAttributesResponse) GetKeys() map[string]v11.IndexedValueType

+ func (x *GetSearchAttributesResponse) ProtoReflect() protoreflect.Message

+ func (x *GetSearchAttributesResponse) Reset()

+ func (x *GetSearchAttributesResponse) String() string

+ type GetSystemInfoRequest struct

+ func (*GetSystemInfoRequest) Descriptor() ([]byte, []int)

+ func (*GetSystemInfoRequest) ProtoMessage()

+ func (x *GetSystemInfoRequest) ProtoReflect() protoreflect.Message

+ func (x *GetSystemInfoRequest) Reset()

+ func (x *GetSystemInfoRequest) String() string

+ type GetSystemInfoResponse struct

+ Capabilities *GetSystemInfoResponse_Capabilities

+ ServerVersion string

+ func (*GetSystemInfoResponse) Descriptor() ([]byte, []int)

+ func (*GetSystemInfoResponse) ProtoMessage()

+ func (x *GetSystemInfoResponse) GetCapabilities() *GetSystemInfoResponse_Capabilities

+ func (x *GetSystemInfoResponse) GetServerVersion() string

+ func (x *GetSystemInfoResponse) ProtoReflect() protoreflect.Message

+ func (x *GetSystemInfoResponse) Reset()

+ func (x *GetSystemInfoResponse) String() string

+ type GetSystemInfoResponse_Capabilities struct

+ ActivityFailureIncludeHeartbeat bool

+ BuildIdBasedVersioning bool

+ EagerWorkflowStart bool

+ EncodedFailureAttributes bool

+ InternalErrorDifferentiation bool

+ SdkMetadata bool

+ SignalAndQueryHeader bool

+ SupportsSchedules bool

+ UpsertMemo bool

+ func (*GetSystemInfoResponse_Capabilities) Descriptor() ([]byte, []int)

+ func (*GetSystemInfoResponse_Capabilities) ProtoMessage()

+ func (x *GetSystemInfoResponse_Capabilities) GetActivityFailureIncludeHeartbeat() bool

+ func (x *GetSystemInfoResponse_Capabilities) GetBuildIdBasedVersioning() bool

+ func (x *GetSystemInfoResponse_Capabilities) GetEagerWorkflowStart() bool

+ func (x *GetSystemInfoResponse_Capabilities) GetEncodedFailureAttributes() bool

+ func (x *GetSystemInfoResponse_Capabilities) GetInternalErrorDifferentiation() bool

+ func (x *GetSystemInfoResponse_Capabilities) GetSdkMetadata() bool

+ func (x *GetSystemInfoResponse_Capabilities) GetSignalAndQueryHeader() bool

+ func (x *GetSystemInfoResponse_Capabilities) GetSupportsSchedules() bool

+ func (x *GetSystemInfoResponse_Capabilities) GetUpsertMemo() bool

+ func (x *GetSystemInfoResponse_Capabilities) ProtoReflect() protoreflect.Message

+ func (x *GetSystemInfoResponse_Capabilities) Reset()

+ func (x *GetSystemInfoResponse_Capabilities) String() string

+ type GetWorkerBuildIdCompatibilityRequest struct

+ MaxSets int32

+ Namespace string

+ TaskQueue string

+ func (*GetWorkerBuildIdCompatibilityRequest) Descriptor() ([]byte, []int)

+ func (*GetWorkerBuildIdCompatibilityRequest) ProtoMessage()

+ func (x *GetWorkerBuildIdCompatibilityRequest) GetMaxSets() int32

+ func (x *GetWorkerBuildIdCompatibilityRequest) GetNamespace() string

+ func (x *GetWorkerBuildIdCompatibilityRequest) GetTaskQueue() string

+ func (x *GetWorkerBuildIdCompatibilityRequest) ProtoReflect() protoreflect.Message

+ func (x *GetWorkerBuildIdCompatibilityRequest) Reset()

+ func (x *GetWorkerBuildIdCompatibilityRequest) String() string

+ type GetWorkerBuildIdCompatibilityResponse struct

+ MajorVersionSets []*v14.CompatibleVersionSet

+ func (*GetWorkerBuildIdCompatibilityResponse) Descriptor() ([]byte, []int)

+ func (*GetWorkerBuildIdCompatibilityResponse) ProtoMessage()

+ func (x *GetWorkerBuildIdCompatibilityResponse) GetMajorVersionSets() []*v14.CompatibleVersionSet

+ func (x *GetWorkerBuildIdCompatibilityResponse) ProtoReflect() protoreflect.Message

+ func (x *GetWorkerBuildIdCompatibilityResponse) Reset()

+ func (x *GetWorkerBuildIdCompatibilityResponse) String() string

+ type GetWorkerTaskReachabilityRequest struct

+ BuildIds []string

+ Namespace string

+ Reachability v11.TaskReachability

+ TaskQueues []string

+ func (*GetWorkerTaskReachabilityRequest) Descriptor() ([]byte, []int)

+ func (*GetWorkerTaskReachabilityRequest) ProtoMessage()

+ func (x *GetWorkerTaskReachabilityRequest) GetBuildIds() []string

+ func (x *GetWorkerTaskReachabilityRequest) GetNamespace() string

+ func (x *GetWorkerTaskReachabilityRequest) GetReachability() v11.TaskReachability

+ func (x *GetWorkerTaskReachabilityRequest) GetTaskQueues() []string

+ func (x *GetWorkerTaskReachabilityRequest) ProtoReflect() protoreflect.Message

+ func (x *GetWorkerTaskReachabilityRequest) Reset()

+ func (x *GetWorkerTaskReachabilityRequest) String() string

+ type GetWorkerTaskReachabilityResponse struct

+ BuildIdReachability []*v14.BuildIdReachability

+ func (*GetWorkerTaskReachabilityResponse) Descriptor() ([]byte, []int)

+ func (*GetWorkerTaskReachabilityResponse) ProtoMessage()

+ func (x *GetWorkerTaskReachabilityResponse) GetBuildIdReachability() []*v14.BuildIdReachability

+ func (x *GetWorkerTaskReachabilityResponse) ProtoReflect() protoreflect.Message

+ func (x *GetWorkerTaskReachabilityResponse) Reset()

+ func (x *GetWorkerTaskReachabilityResponse) String() string

+ type GetWorkflowExecutionHistoryRequest struct

+ Execution *v13.WorkflowExecution

+ HistoryEventFilterType v11.HistoryEventFilterType

+ MaximumPageSize int32

+ Namespace string

+ NextPageToken []byte

+ SkipArchival bool

+ WaitNewEvent bool

+ func (*GetWorkflowExecutionHistoryRequest) Descriptor() ([]byte, []int)

+ func (*GetWorkflowExecutionHistoryRequest) ProtoMessage()

+ func (x *GetWorkflowExecutionHistoryRequest) GetExecution() *v13.WorkflowExecution

+ func (x *GetWorkflowExecutionHistoryRequest) GetHistoryEventFilterType() v11.HistoryEventFilterType

+ func (x *GetWorkflowExecutionHistoryRequest) GetMaximumPageSize() int32

+ func (x *GetWorkflowExecutionHistoryRequest) GetNamespace() string

+ func (x *GetWorkflowExecutionHistoryRequest) GetNextPageToken() []byte

+ func (x *GetWorkflowExecutionHistoryRequest) GetSkipArchival() bool

+ func (x *GetWorkflowExecutionHistoryRequest) GetWaitNewEvent() bool

+ func (x *GetWorkflowExecutionHistoryRequest) ProtoReflect() protoreflect.Message

+ func (x *GetWorkflowExecutionHistoryRequest) Reset()

+ func (x *GetWorkflowExecutionHistoryRequest) String() string

+ type GetWorkflowExecutionHistoryResponse struct

+ Archived bool

+ History *v16.History

+ NextPageToken []byte

+ RawHistory []*v13.DataBlob

+ func (*GetWorkflowExecutionHistoryResponse) Descriptor() ([]byte, []int)

+ func (*GetWorkflowExecutionHistoryResponse) ProtoMessage()

+ func (x *GetWorkflowExecutionHistoryResponse) GetArchived() bool

+ func (x *GetWorkflowExecutionHistoryResponse) GetHistory() *v16.History

+ func (x *GetWorkflowExecutionHistoryResponse) GetNextPageToken() []byte

+ func (x *GetWorkflowExecutionHistoryResponse) GetRawHistory() []*v13.DataBlob

+ func (x *GetWorkflowExecutionHistoryResponse) ProtoReflect() protoreflect.Message

+ func (x *GetWorkflowExecutionHistoryResponse) Reset()

+ func (x *GetWorkflowExecutionHistoryResponse) String() string

+ type GetWorkflowExecutionHistoryReverseRequest struct

+ Execution *v13.WorkflowExecution

+ MaximumPageSize int32

+ Namespace string

+ NextPageToken []byte

+ func (*GetWorkflowExecutionHistoryReverseRequest) Descriptor() ([]byte, []int)

+ func (*GetWorkflowExecutionHistoryReverseRequest) ProtoMessage()

+ func (x *GetWorkflowExecutionHistoryReverseRequest) GetExecution() *v13.WorkflowExecution

+ func (x *GetWorkflowExecutionHistoryReverseRequest) GetMaximumPageSize() int32

+ func (x *GetWorkflowExecutionHistoryReverseRequest) GetNamespace() string

+ func (x *GetWorkflowExecutionHistoryReverseRequest) GetNextPageToken() []byte

+ func (x *GetWorkflowExecutionHistoryReverseRequest) ProtoReflect() protoreflect.Message

+ func (x *GetWorkflowExecutionHistoryReverseRequest) Reset()

+ func (x *GetWorkflowExecutionHistoryReverseRequest) String() string

+ type GetWorkflowExecutionHistoryReverseResponse struct

+ History *v16.History

+ NextPageToken []byte

+ func (*GetWorkflowExecutionHistoryReverseResponse) Descriptor() ([]byte, []int)

+ func (*GetWorkflowExecutionHistoryReverseResponse) ProtoMessage()

+ func (x *GetWorkflowExecutionHistoryReverseResponse) GetHistory() *v16.History

+ func (x *GetWorkflowExecutionHistoryReverseResponse) GetNextPageToken() []byte

+ func (x *GetWorkflowExecutionHistoryReverseResponse) ProtoReflect() protoreflect.Message

+ func (x *GetWorkflowExecutionHistoryReverseResponse) Reset()

+ func (x *GetWorkflowExecutionHistoryReverseResponse) String() string

+ type ListArchivedWorkflowExecutionsRequest struct

+ Namespace string

+ NextPageToken []byte

+ PageSize int32

+ Query string

+ func (*ListArchivedWorkflowExecutionsRequest) Descriptor() ([]byte, []int)

+ func (*ListArchivedWorkflowExecutionsRequest) ProtoMessage()

+ func (x *ListArchivedWorkflowExecutionsRequest) GetNamespace() string

+ func (x *ListArchivedWorkflowExecutionsRequest) GetNextPageToken() []byte

+ func (x *ListArchivedWorkflowExecutionsRequest) GetPageSize() int32

+ func (x *ListArchivedWorkflowExecutionsRequest) GetQuery() string

+ func (x *ListArchivedWorkflowExecutionsRequest) ProtoReflect() protoreflect.Message

+ func (x *ListArchivedWorkflowExecutionsRequest) Reset()

+ func (x *ListArchivedWorkflowExecutionsRequest) String() string

+ type ListArchivedWorkflowExecutionsResponse struct

+ Executions []*v112.WorkflowExecutionInfo

+ NextPageToken []byte

+ func (*ListArchivedWorkflowExecutionsResponse) Descriptor() ([]byte, []int)

+ func (*ListArchivedWorkflowExecutionsResponse) ProtoMessage()

+ func (x *ListArchivedWorkflowExecutionsResponse) GetExecutions() []*v112.WorkflowExecutionInfo

+ func (x *ListArchivedWorkflowExecutionsResponse) GetNextPageToken() []byte

+ func (x *ListArchivedWorkflowExecutionsResponse) ProtoReflect() protoreflect.Message

+ func (x *ListArchivedWorkflowExecutionsResponse) Reset()

+ func (x *ListArchivedWorkflowExecutionsResponse) String() string

+ type ListBatchOperationsRequest struct

+ Namespace string

+ NextPageToken []byte

+ PageSize int32

+ func (*ListBatchOperationsRequest) Descriptor() ([]byte, []int)

+ func (*ListBatchOperationsRequest) ProtoMessage()

+ func (x *ListBatchOperationsRequest) GetNamespace() string

+ func (x *ListBatchOperationsRequest) GetNextPageToken() []byte

+ func (x *ListBatchOperationsRequest) GetPageSize() int32

+ func (x *ListBatchOperationsRequest) ProtoReflect() protoreflect.Message

+ func (x *ListBatchOperationsRequest) Reset()

+ func (x *ListBatchOperationsRequest) String() string

+ type ListBatchOperationsResponse struct

+ NextPageToken []byte

+ OperationInfo []*v116.BatchOperationInfo

+ func (*ListBatchOperationsResponse) Descriptor() ([]byte, []int)

+ func (*ListBatchOperationsResponse) ProtoMessage()

+ func (x *ListBatchOperationsResponse) GetNextPageToken() []byte

+ func (x *ListBatchOperationsResponse) GetOperationInfo() []*v116.BatchOperationInfo

+ func (x *ListBatchOperationsResponse) ProtoReflect() protoreflect.Message

+ func (x *ListBatchOperationsResponse) Reset()

+ func (x *ListBatchOperationsResponse) String() string

+ type ListClosedWorkflowExecutionsRequest struct

+ Filters isListClosedWorkflowExecutionsRequest_Filters

+ MaximumPageSize int32

+ Namespace string

+ NextPageToken []byte

+ StartTimeFilter *v111.StartTimeFilter

+ func (*ListClosedWorkflowExecutionsRequest) Descriptor() ([]byte, []int)

+ func (*ListClosedWorkflowExecutionsRequest) ProtoMessage()

+ func (m *ListClosedWorkflowExecutionsRequest) GetFilters() isListClosedWorkflowExecutionsRequest_Filters

+ func (x *ListClosedWorkflowExecutionsRequest) GetExecutionFilter() *v111.WorkflowExecutionFilter

+ func (x *ListClosedWorkflowExecutionsRequest) GetMaximumPageSize() int32

+ func (x *ListClosedWorkflowExecutionsRequest) GetNamespace() string

+ func (x *ListClosedWorkflowExecutionsRequest) GetNextPageToken() []byte

+ func (x *ListClosedWorkflowExecutionsRequest) GetStartTimeFilter() *v111.StartTimeFilter

+ func (x *ListClosedWorkflowExecutionsRequest) GetStatusFilter() *v111.StatusFilter

+ func (x *ListClosedWorkflowExecutionsRequest) GetTypeFilter() *v111.WorkflowTypeFilter

+ func (x *ListClosedWorkflowExecutionsRequest) ProtoReflect() protoreflect.Message

+ func (x *ListClosedWorkflowExecutionsRequest) Reset()

+ func (x *ListClosedWorkflowExecutionsRequest) String() string

+ type ListClosedWorkflowExecutionsRequest_ExecutionFilter struct

+ ExecutionFilter *v111.WorkflowExecutionFilter

+ type ListClosedWorkflowExecutionsRequest_StatusFilter struct

+ StatusFilter *v111.StatusFilter

+ type ListClosedWorkflowExecutionsRequest_TypeFilter struct

+ TypeFilter *v111.WorkflowTypeFilter

+ type ListClosedWorkflowExecutionsResponse struct

+ Executions []*v112.WorkflowExecutionInfo

+ NextPageToken []byte

+ func (*ListClosedWorkflowExecutionsResponse) Descriptor() ([]byte, []int)

+ func (*ListClosedWorkflowExecutionsResponse) ProtoMessage()

+ func (x *ListClosedWorkflowExecutionsResponse) GetExecutions() []*v112.WorkflowExecutionInfo

+ func (x *ListClosedWorkflowExecutionsResponse) GetNextPageToken() []byte

+ func (x *ListClosedWorkflowExecutionsResponse) ProtoReflect() protoreflect.Message

+ func (x *ListClosedWorkflowExecutionsResponse) Reset()

+ func (x *ListClosedWorkflowExecutionsResponse) String() string

+ type ListNamespacesRequest struct

+ NamespaceFilter *v12.NamespaceFilter

+ NextPageToken []byte

+ PageSize int32

+ func (*ListNamespacesRequest) Descriptor() ([]byte, []int)

+ func (*ListNamespacesRequest) ProtoMessage()

+ func (x *ListNamespacesRequest) GetNamespaceFilter() *v12.NamespaceFilter

+ func (x *ListNamespacesRequest) GetNextPageToken() []byte

+ func (x *ListNamespacesRequest) GetPageSize() int32

+ func (x *ListNamespacesRequest) ProtoReflect() protoreflect.Message

+ func (x *ListNamespacesRequest) Reset()

+ func (x *ListNamespacesRequest) String() string

+ type ListNamespacesResponse struct

+ Namespaces []*DescribeNamespaceResponse

+ NextPageToken []byte

+ func (*ListNamespacesResponse) Descriptor() ([]byte, []int)

+ func (*ListNamespacesResponse) ProtoMessage()

+ func (x *ListNamespacesResponse) GetNamespaces() []*DescribeNamespaceResponse

+ func (x *ListNamespacesResponse) GetNextPageToken() []byte

+ func (x *ListNamespacesResponse) ProtoReflect() protoreflect.Message

+ func (x *ListNamespacesResponse) Reset()

+ func (x *ListNamespacesResponse) String() string

+ type ListOpenWorkflowExecutionsRequest struct

+ Filters isListOpenWorkflowExecutionsRequest_Filters

+ MaximumPageSize int32

+ Namespace string

+ NextPageToken []byte

+ StartTimeFilter *v111.StartTimeFilter

+ func (*ListOpenWorkflowExecutionsRequest) Descriptor() ([]byte, []int)

+ func (*ListOpenWorkflowExecutionsRequest) ProtoMessage()

+ func (m *ListOpenWorkflowExecutionsRequest) GetFilters() isListOpenWorkflowExecutionsRequest_Filters

+ func (x *ListOpenWorkflowExecutionsRequest) GetExecutionFilter() *v111.WorkflowExecutionFilter

+ func (x *ListOpenWorkflowExecutionsRequest) GetMaximumPageSize() int32

+ func (x *ListOpenWorkflowExecutionsRequest) GetNamespace() string

+ func (x *ListOpenWorkflowExecutionsRequest) GetNextPageToken() []byte

+ func (x *ListOpenWorkflowExecutionsRequest) GetStartTimeFilter() *v111.StartTimeFilter

+ func (x *ListOpenWorkflowExecutionsRequest) GetTypeFilter() *v111.WorkflowTypeFilter

+ func (x *ListOpenWorkflowExecutionsRequest) ProtoReflect() protoreflect.Message

+ func (x *ListOpenWorkflowExecutionsRequest) Reset()

+ func (x *ListOpenWorkflowExecutionsRequest) String() string

+ type ListOpenWorkflowExecutionsRequest_ExecutionFilter struct

+ ExecutionFilter *v111.WorkflowExecutionFilter

+ type ListOpenWorkflowExecutionsRequest_TypeFilter struct

+ TypeFilter *v111.WorkflowTypeFilter

+ type ListOpenWorkflowExecutionsResponse struct

+ Executions []*v112.WorkflowExecutionInfo

+ NextPageToken []byte

+ func (*ListOpenWorkflowExecutionsResponse) Descriptor() ([]byte, []int)

+ func (*ListOpenWorkflowExecutionsResponse) ProtoMessage()

+ func (x *ListOpenWorkflowExecutionsResponse) GetExecutions() []*v112.WorkflowExecutionInfo

+ func (x *ListOpenWorkflowExecutionsResponse) GetNextPageToken() []byte

+ func (x *ListOpenWorkflowExecutionsResponse) ProtoReflect() protoreflect.Message

+ func (x *ListOpenWorkflowExecutionsResponse) Reset()

+ func (x *ListOpenWorkflowExecutionsResponse) String() string

+ type ListScheduleMatchingTimesRequest struct

+ EndTime *timestamppb.Timestamp

+ Namespace string

+ ScheduleId string

+ StartTime *timestamppb.Timestamp

+ func (*ListScheduleMatchingTimesRequest) Descriptor() ([]byte, []int)

+ func (*ListScheduleMatchingTimesRequest) ProtoMessage()

+ func (x *ListScheduleMatchingTimesRequest) GetEndTime() *timestamppb.Timestamp

+ func (x *ListScheduleMatchingTimesRequest) GetNamespace() string

+ func (x *ListScheduleMatchingTimesRequest) GetScheduleId() string

+ func (x *ListScheduleMatchingTimesRequest) GetStartTime() *timestamppb.Timestamp

+ func (x *ListScheduleMatchingTimesRequest) ProtoReflect() protoreflect.Message

+ func (x *ListScheduleMatchingTimesRequest) Reset()

+ func (x *ListScheduleMatchingTimesRequest) String() string

+ type ListScheduleMatchingTimesResponse struct

+ StartTime []*timestamppb.Timestamp

+ func (*ListScheduleMatchingTimesResponse) Descriptor() ([]byte, []int)

+ func (*ListScheduleMatchingTimesResponse) ProtoMessage()

+ func (x *ListScheduleMatchingTimesResponse) GetStartTime() []*timestamppb.Timestamp

+ func (x *ListScheduleMatchingTimesResponse) ProtoReflect() protoreflect.Message

+ func (x *ListScheduleMatchingTimesResponse) Reset()

+ func (x *ListScheduleMatchingTimesResponse) String() string

+ type ListSchedulesRequest struct

+ MaximumPageSize int32

+ Namespace string

+ NextPageToken []byte

+ func (*ListSchedulesRequest) Descriptor() ([]byte, []int)

+ func (*ListSchedulesRequest) ProtoMessage()

+ func (x *ListSchedulesRequest) GetMaximumPageSize() int32

+ func (x *ListSchedulesRequest) GetNamespace() string

+ func (x *ListSchedulesRequest) GetNextPageToken() []byte

+ func (x *ListSchedulesRequest) ProtoReflect() protoreflect.Message

+ func (x *ListSchedulesRequest) Reset()

+ func (x *ListSchedulesRequest) String() string

+ type ListSchedulesResponse struct

+ NextPageToken []byte

+ Schedules []*v114.ScheduleListEntry

+ func (*ListSchedulesResponse) Descriptor() ([]byte, []int)

+ func (*ListSchedulesResponse) ProtoMessage()

+ func (x *ListSchedulesResponse) GetNextPageToken() []byte

+ func (x *ListSchedulesResponse) GetSchedules() []*v114.ScheduleListEntry

+ func (x *ListSchedulesResponse) ProtoReflect() protoreflect.Message

+ func (x *ListSchedulesResponse) Reset()

+ func (x *ListSchedulesResponse) String() string

+ type ListTaskQueuePartitionsRequest struct

+ Namespace string

+ TaskQueue *v14.TaskQueue

+ func (*ListTaskQueuePartitionsRequest) Descriptor() ([]byte, []int)

+ func (*ListTaskQueuePartitionsRequest) ProtoMessage()

+ func (x *ListTaskQueuePartitionsRequest) GetNamespace() string

+ func (x *ListTaskQueuePartitionsRequest) GetTaskQueue() *v14.TaskQueue

+ func (x *ListTaskQueuePartitionsRequest) ProtoReflect() protoreflect.Message

+ func (x *ListTaskQueuePartitionsRequest) Reset()

+ func (x *ListTaskQueuePartitionsRequest) String() string

+ type ListTaskQueuePartitionsResponse struct

+ ActivityTaskQueuePartitions []*v14.TaskQueuePartitionMetadata

+ WorkflowTaskQueuePartitions []*v14.TaskQueuePartitionMetadata

+ func (*ListTaskQueuePartitionsResponse) Descriptor() ([]byte, []int)

+ func (*ListTaskQueuePartitionsResponse) ProtoMessage()

+ func (x *ListTaskQueuePartitionsResponse) GetActivityTaskQueuePartitions() []*v14.TaskQueuePartitionMetadata

+ func (x *ListTaskQueuePartitionsResponse) GetWorkflowTaskQueuePartitions() []*v14.TaskQueuePartitionMetadata

+ func (x *ListTaskQueuePartitionsResponse) ProtoReflect() protoreflect.Message

+ func (x *ListTaskQueuePartitionsResponse) Reset()

+ func (x *ListTaskQueuePartitionsResponse) String() string

+ type ListWorkflowExecutionsRequest struct

+ Namespace string

+ NextPageToken []byte

+ PageSize int32

+ Query string

+ func (*ListWorkflowExecutionsRequest) Descriptor() ([]byte, []int)

+ func (*ListWorkflowExecutionsRequest) ProtoMessage()

+ func (x *ListWorkflowExecutionsRequest) GetNamespace() string

+ func (x *ListWorkflowExecutionsRequest) GetNextPageToken() []byte

+ func (x *ListWorkflowExecutionsRequest) GetPageSize() int32

+ func (x *ListWorkflowExecutionsRequest) GetQuery() string

+ func (x *ListWorkflowExecutionsRequest) ProtoReflect() protoreflect.Message

+ func (x *ListWorkflowExecutionsRequest) Reset()

+ func (x *ListWorkflowExecutionsRequest) String() string

+ type ListWorkflowExecutionsResponse struct

+ Executions []*v112.WorkflowExecutionInfo

+ NextPageToken []byte

+ func (*ListWorkflowExecutionsResponse) Descriptor() ([]byte, []int)

+ func (*ListWorkflowExecutionsResponse) ProtoMessage()

+ func (x *ListWorkflowExecutionsResponse) GetExecutions() []*v112.WorkflowExecutionInfo

+ func (x *ListWorkflowExecutionsResponse) GetNextPageToken() []byte

+ func (x *ListWorkflowExecutionsResponse) ProtoReflect() protoreflect.Message

+ func (x *ListWorkflowExecutionsResponse) Reset()

+ func (x *ListWorkflowExecutionsResponse) String() string

+ type PatchScheduleRequest struct

+ Identity string

+ Namespace string

+ Patch *v114.SchedulePatch

+ RequestId string

+ ScheduleId string

+ func (*PatchScheduleRequest) Descriptor() ([]byte, []int)

+ func (*PatchScheduleRequest) ProtoMessage()

+ func (x *PatchScheduleRequest) GetIdentity() string

+ func (x *PatchScheduleRequest) GetNamespace() string

+ func (x *PatchScheduleRequest) GetPatch() *v114.SchedulePatch

+ func (x *PatchScheduleRequest) GetRequestId() string

+ func (x *PatchScheduleRequest) GetScheduleId() string

+ func (x *PatchScheduleRequest) ProtoReflect() protoreflect.Message

+ func (x *PatchScheduleRequest) Reset()

+ func (x *PatchScheduleRequest) String() string

+ type PatchScheduleResponse struct

+ func (*PatchScheduleResponse) Descriptor() ([]byte, []int)

+ func (*PatchScheduleResponse) ProtoMessage()

+ func (x *PatchScheduleResponse) ProtoReflect() protoreflect.Message

+ func (x *PatchScheduleResponse) Reset()

+ func (x *PatchScheduleResponse) String() string

+ type PollActivityTaskQueueRequest struct

+ Identity string

+ Namespace string

+ TaskQueue *v14.TaskQueue

+ TaskQueueMetadata *v14.TaskQueueMetadata

+ WorkerVersionCapabilities *v13.WorkerVersionCapabilities

+ func (*PollActivityTaskQueueRequest) Descriptor() ([]byte, []int)

+ func (*PollActivityTaskQueueRequest) ProtoMessage()

+ func (x *PollActivityTaskQueueRequest) GetIdentity() string

+ func (x *PollActivityTaskQueueRequest) GetNamespace() string

+ func (x *PollActivityTaskQueueRequest) GetTaskQueue() *v14.TaskQueue

+ func (x *PollActivityTaskQueueRequest) GetTaskQueueMetadata() *v14.TaskQueueMetadata

+ func (x *PollActivityTaskQueueRequest) GetWorkerVersionCapabilities() *v13.WorkerVersionCapabilities

+ func (x *PollActivityTaskQueueRequest) ProtoReflect() protoreflect.Message

+ func (x *PollActivityTaskQueueRequest) Reset()

+ func (x *PollActivityTaskQueueRequest) String() string

+ type PollActivityTaskQueueResponse struct

+ ActivityId string

+ ActivityType *v13.ActivityType

+ Attempt int32

+ CurrentAttemptScheduledTime *timestamppb.Timestamp

+ Header *v13.Header

+ HeartbeatDetails *v13.Payloads

+ HeartbeatTimeout *durationpb.Duration

+ Input *v13.Payloads

+ RetryPolicy *v13.RetryPolicy

+ ScheduleToCloseTimeout *durationpb.Duration

+ ScheduledTime *timestamppb.Timestamp

+ StartToCloseTimeout *durationpb.Duration

+ StartedTime *timestamppb.Timestamp

+ TaskToken []byte

+ WorkflowExecution *v13.WorkflowExecution

+ WorkflowNamespace string

+ WorkflowType *v13.WorkflowType

+ func (*PollActivityTaskQueueResponse) Descriptor() ([]byte, []int)

+ func (*PollActivityTaskQueueResponse) ProtoMessage()

+ func (x *PollActivityTaskQueueResponse) GetActivityId() string

+ func (x *PollActivityTaskQueueResponse) GetActivityType() *v13.ActivityType

+ func (x *PollActivityTaskQueueResponse) GetAttempt() int32

+ func (x *PollActivityTaskQueueResponse) GetCurrentAttemptScheduledTime() *timestamppb.Timestamp

+ func (x *PollActivityTaskQueueResponse) GetHeader() *v13.Header

+ func (x *PollActivityTaskQueueResponse) GetHeartbeatDetails() *v13.Payloads

+ func (x *PollActivityTaskQueueResponse) GetHeartbeatTimeout() *durationpb.Duration

+ func (x *PollActivityTaskQueueResponse) GetInput() *v13.Payloads

+ func (x *PollActivityTaskQueueResponse) GetRetryPolicy() *v13.RetryPolicy

+ func (x *PollActivityTaskQueueResponse) GetScheduleToCloseTimeout() *durationpb.Duration

+ func (x *PollActivityTaskQueueResponse) GetScheduledTime() *timestamppb.Timestamp

+ func (x *PollActivityTaskQueueResponse) GetStartToCloseTimeout() *durationpb.Duration

+ func (x *PollActivityTaskQueueResponse) GetStartedTime() *timestamppb.Timestamp

+ func (x *PollActivityTaskQueueResponse) GetTaskToken() []byte

+ func (x *PollActivityTaskQueueResponse) GetWorkflowExecution() *v13.WorkflowExecution

+ func (x *PollActivityTaskQueueResponse) GetWorkflowNamespace() string

+ func (x *PollActivityTaskQueueResponse) GetWorkflowType() *v13.WorkflowType

+ func (x *PollActivityTaskQueueResponse) ProtoReflect() protoreflect.Message

+ func (x *PollActivityTaskQueueResponse) Reset()

+ func (x *PollActivityTaskQueueResponse) String() string

+ type PollWorkflowExecutionUpdateRequest struct

+ Identity string

+ Namespace string

+ UpdateRef *v115.UpdateRef

+ WaitPolicy *v115.WaitPolicy

+ func (*PollWorkflowExecutionUpdateRequest) Descriptor() ([]byte, []int)

+ func (*PollWorkflowExecutionUpdateRequest) ProtoMessage()

+ func (x *PollWorkflowExecutionUpdateRequest) GetIdentity() string

+ func (x *PollWorkflowExecutionUpdateRequest) GetNamespace() string

+ func (x *PollWorkflowExecutionUpdateRequest) GetUpdateRef() *v115.UpdateRef

+ func (x *PollWorkflowExecutionUpdateRequest) GetWaitPolicy() *v115.WaitPolicy

+ func (x *PollWorkflowExecutionUpdateRequest) ProtoReflect() protoreflect.Message

+ func (x *PollWorkflowExecutionUpdateRequest) Reset()

+ func (x *PollWorkflowExecutionUpdateRequest) String() string

+ type PollWorkflowExecutionUpdateResponse struct

+ Outcome *v115.Outcome

+ func (*PollWorkflowExecutionUpdateResponse) Descriptor() ([]byte, []int)

+ func (*PollWorkflowExecutionUpdateResponse) ProtoMessage()

+ func (x *PollWorkflowExecutionUpdateResponse) GetOutcome() *v115.Outcome

+ func (x *PollWorkflowExecutionUpdateResponse) ProtoReflect() protoreflect.Message

+ func (x *PollWorkflowExecutionUpdateResponse) Reset()

+ func (x *PollWorkflowExecutionUpdateResponse) String() string

+ type PollWorkflowTaskQueueRequest struct

+ BinaryChecksum string

+ Identity string

+ Namespace string

+ TaskQueue *v14.TaskQueue

+ WorkerVersionCapabilities *v13.WorkerVersionCapabilities

+ func (*PollWorkflowTaskQueueRequest) Descriptor() ([]byte, []int)

+ func (*PollWorkflowTaskQueueRequest) ProtoMessage()

+ func (x *PollWorkflowTaskQueueRequest) GetBinaryChecksum() string

+ func (x *PollWorkflowTaskQueueRequest) GetIdentity() string

+ func (x *PollWorkflowTaskQueueRequest) GetNamespace() string

+ func (x *PollWorkflowTaskQueueRequest) GetTaskQueue() *v14.TaskQueue

+ func (x *PollWorkflowTaskQueueRequest) GetWorkerVersionCapabilities() *v13.WorkerVersionCapabilities

+ func (x *PollWorkflowTaskQueueRequest) ProtoReflect() protoreflect.Message

+ func (x *PollWorkflowTaskQueueRequest) Reset()

+ func (x *PollWorkflowTaskQueueRequest) String() string

+ type PollWorkflowTaskQueueResponse struct

+ Attempt int32

+ BacklogCountHint int64

+ History *v16.History

+ Messages []*v18.Message

+ NextPageToken []byte

+ PreviousStartedEventId int64

+ Queries map[string]*v17.WorkflowQuery

+ Query *v17.WorkflowQuery

+ ScheduledTime *timestamppb.Timestamp

+ StartedEventId int64

+ StartedTime *timestamppb.Timestamp

+ TaskToken []byte

+ WorkflowExecution *v13.WorkflowExecution

+ WorkflowExecutionTaskQueue *v14.TaskQueue

+ WorkflowType *v13.WorkflowType

+ func (*PollWorkflowTaskQueueResponse) Descriptor() ([]byte, []int)

+ func (*PollWorkflowTaskQueueResponse) ProtoMessage()

+ func (x *PollWorkflowTaskQueueResponse) GetAttempt() int32

+ func (x *PollWorkflowTaskQueueResponse) GetBacklogCountHint() int64

+ func (x *PollWorkflowTaskQueueResponse) GetHistory() *v16.History

+ func (x *PollWorkflowTaskQueueResponse) GetMessages() []*v18.Message

+ func (x *PollWorkflowTaskQueueResponse) GetNextPageToken() []byte

+ func (x *PollWorkflowTaskQueueResponse) GetPreviousStartedEventId() int64

+ func (x *PollWorkflowTaskQueueResponse) GetQueries() map[string]*v17.WorkflowQuery

+ func (x *PollWorkflowTaskQueueResponse) GetQuery() *v17.WorkflowQuery

+ func (x *PollWorkflowTaskQueueResponse) GetScheduledTime() *timestamppb.Timestamp

+ func (x *PollWorkflowTaskQueueResponse) GetStartedEventId() int64

+ func (x *PollWorkflowTaskQueueResponse) GetStartedTime() *timestamppb.Timestamp

+ func (x *PollWorkflowTaskQueueResponse) GetTaskToken() []byte

+ func (x *PollWorkflowTaskQueueResponse) GetWorkflowExecution() *v13.WorkflowExecution

+ func (x *PollWorkflowTaskQueueResponse) GetWorkflowExecutionTaskQueue() *v14.TaskQueue

+ func (x *PollWorkflowTaskQueueResponse) GetWorkflowType() *v13.WorkflowType

+ func (x *PollWorkflowTaskQueueResponse) ProtoReflect() protoreflect.Message

+ func (x *PollWorkflowTaskQueueResponse) Reset()

+ func (x *PollWorkflowTaskQueueResponse) String() string

+ type QueryWorkflowRequest struct

+ Execution *v13.WorkflowExecution

+ Namespace string

+ Query *v17.WorkflowQuery

+ QueryRejectCondition v11.QueryRejectCondition

+ func (*QueryWorkflowRequest) Descriptor() ([]byte, []int)

+ func (*QueryWorkflowRequest) ProtoMessage()

+ func (x *QueryWorkflowRequest) GetExecution() *v13.WorkflowExecution

+ func (x *QueryWorkflowRequest) GetNamespace() string

+ func (x *QueryWorkflowRequest) GetQuery() *v17.WorkflowQuery

+ func (x *QueryWorkflowRequest) GetQueryRejectCondition() v11.QueryRejectCondition

+ func (x *QueryWorkflowRequest) ProtoReflect() protoreflect.Message

+ func (x *QueryWorkflowRequest) Reset()

+ func (x *QueryWorkflowRequest) String() string

+ type QueryWorkflowResponse struct

+ QueryRejected *v17.QueryRejected

+ QueryResult *v13.Payloads

+ func (*QueryWorkflowResponse) Descriptor() ([]byte, []int)

+ func (*QueryWorkflowResponse) ProtoMessage()

+ func (x *QueryWorkflowResponse) GetQueryRejected() *v17.QueryRejected

+ func (x *QueryWorkflowResponse) GetQueryResult() *v13.Payloads

+ func (x *QueryWorkflowResponse) ProtoReflect() protoreflect.Message

+ func (x *QueryWorkflowResponse) Reset()

+ func (x *QueryWorkflowResponse) String() string

+ type RecordActivityTaskHeartbeatByIdRequest struct

+ ActivityId string

+ Details *v13.Payloads

+ Identity string

+ Namespace string

+ RunId string

+ WorkflowId string

+ func (*RecordActivityTaskHeartbeatByIdRequest) Descriptor() ([]byte, []int)

+ func (*RecordActivityTaskHeartbeatByIdRequest) ProtoMessage()

+ func (x *RecordActivityTaskHeartbeatByIdRequest) GetActivityId() string

+ func (x *RecordActivityTaskHeartbeatByIdRequest) GetDetails() *v13.Payloads

+ func (x *RecordActivityTaskHeartbeatByIdRequest) GetIdentity() string

+ func (x *RecordActivityTaskHeartbeatByIdRequest) GetNamespace() string

+ func (x *RecordActivityTaskHeartbeatByIdRequest) GetRunId() string

+ func (x *RecordActivityTaskHeartbeatByIdRequest) GetWorkflowId() string

+ func (x *RecordActivityTaskHeartbeatByIdRequest) ProtoReflect() protoreflect.Message

+ func (x *RecordActivityTaskHeartbeatByIdRequest) Reset()

+ func (x *RecordActivityTaskHeartbeatByIdRequest) String() string

+ type RecordActivityTaskHeartbeatByIdResponse struct

+ CancelRequested bool

+ func (*RecordActivityTaskHeartbeatByIdResponse) Descriptor() ([]byte, []int)

+ func (*RecordActivityTaskHeartbeatByIdResponse) ProtoMessage()

+ func (x *RecordActivityTaskHeartbeatByIdResponse) GetCancelRequested() bool

+ func (x *RecordActivityTaskHeartbeatByIdResponse) ProtoReflect() protoreflect.Message

+ func (x *RecordActivityTaskHeartbeatByIdResponse) Reset()

+ func (x *RecordActivityTaskHeartbeatByIdResponse) String() string

+ type RecordActivityTaskHeartbeatRequest struct

+ Details *v13.Payloads

+ Identity string

+ Namespace string

+ TaskToken []byte

+ func (*RecordActivityTaskHeartbeatRequest) Descriptor() ([]byte, []int)

+ func (*RecordActivityTaskHeartbeatRequest) ProtoMessage()

+ func (x *RecordActivityTaskHeartbeatRequest) GetDetails() *v13.Payloads

+ func (x *RecordActivityTaskHeartbeatRequest) GetIdentity() string

+ func (x *RecordActivityTaskHeartbeatRequest) GetNamespace() string

+ func (x *RecordActivityTaskHeartbeatRequest) GetTaskToken() []byte

+ func (x *RecordActivityTaskHeartbeatRequest) ProtoReflect() protoreflect.Message

+ func (x *RecordActivityTaskHeartbeatRequest) Reset()

+ func (x *RecordActivityTaskHeartbeatRequest) String() string

+ type RecordActivityTaskHeartbeatResponse struct

+ CancelRequested bool

+ func (*RecordActivityTaskHeartbeatResponse) Descriptor() ([]byte, []int)

+ func (*RecordActivityTaskHeartbeatResponse) ProtoMessage()

+ func (x *RecordActivityTaskHeartbeatResponse) GetCancelRequested() bool

+ func (x *RecordActivityTaskHeartbeatResponse) ProtoReflect() protoreflect.Message

+ func (x *RecordActivityTaskHeartbeatResponse) Reset()

+ func (x *RecordActivityTaskHeartbeatResponse) String() string

+ type RegisterNamespaceRequest struct

+ ActiveClusterName string

+ Clusters []*v1.ClusterReplicationConfig

+ Data map[string]string

+ Description string

+ HistoryArchivalState v11.ArchivalState

+ HistoryArchivalUri string

+ IsGlobalNamespace bool

+ Namespace string

+ OwnerEmail string

+ SecurityToken string

+ VisibilityArchivalState v11.ArchivalState

+ VisibilityArchivalUri string

+ WorkflowExecutionRetentionPeriod *durationpb.Duration

+ func (*RegisterNamespaceRequest) Descriptor() ([]byte, []int)

+ func (*RegisterNamespaceRequest) ProtoMessage()

+ func (x *RegisterNamespaceRequest) GetActiveClusterName() string

+ func (x *RegisterNamespaceRequest) GetClusters() []*v1.ClusterReplicationConfig

+ func (x *RegisterNamespaceRequest) GetData() map[string]string

+ func (x *RegisterNamespaceRequest) GetDescription() string

+ func (x *RegisterNamespaceRequest) GetHistoryArchivalState() v11.ArchivalState

+ func (x *RegisterNamespaceRequest) GetHistoryArchivalUri() string

+ func (x *RegisterNamespaceRequest) GetIsGlobalNamespace() bool

+ func (x *RegisterNamespaceRequest) GetNamespace() string

+ func (x *RegisterNamespaceRequest) GetOwnerEmail() string

+ func (x *RegisterNamespaceRequest) GetSecurityToken() string

+ func (x *RegisterNamespaceRequest) GetVisibilityArchivalState() v11.ArchivalState

+ func (x *RegisterNamespaceRequest) GetVisibilityArchivalUri() string

+ func (x *RegisterNamespaceRequest) GetWorkflowExecutionRetentionPeriod() *durationpb.Duration

+ func (x *RegisterNamespaceRequest) ProtoReflect() protoreflect.Message

+ func (x *RegisterNamespaceRequest) Reset()

+ func (x *RegisterNamespaceRequest) String() string

+ type RegisterNamespaceResponse struct

+ func (*RegisterNamespaceResponse) Descriptor() ([]byte, []int)

+ func (*RegisterNamespaceResponse) ProtoMessage()

+ func (x *RegisterNamespaceResponse) ProtoReflect() protoreflect.Message

+ func (x *RegisterNamespaceResponse) Reset()

+ func (x *RegisterNamespaceResponse) String() string

+ type RequestCancelWorkflowExecutionRequest struct

+ FirstExecutionRunId string

+ Identity string

+ Namespace string

+ Reason string

+ RequestId string

+ WorkflowExecution *v13.WorkflowExecution

+ func (*RequestCancelWorkflowExecutionRequest) Descriptor() ([]byte, []int)

+ func (*RequestCancelWorkflowExecutionRequest) ProtoMessage()

+ func (x *RequestCancelWorkflowExecutionRequest) GetFirstExecutionRunId() string

+ func (x *RequestCancelWorkflowExecutionRequest) GetIdentity() string

+ func (x *RequestCancelWorkflowExecutionRequest) GetNamespace() string

+ func (x *RequestCancelWorkflowExecutionRequest) GetReason() string

+ func (x *RequestCancelWorkflowExecutionRequest) GetRequestId() string

+ func (x *RequestCancelWorkflowExecutionRequest) GetWorkflowExecution() *v13.WorkflowExecution

+ func (x *RequestCancelWorkflowExecutionRequest) ProtoReflect() protoreflect.Message

+ func (x *RequestCancelWorkflowExecutionRequest) Reset()

+ func (x *RequestCancelWorkflowExecutionRequest) String() string

+ type RequestCancelWorkflowExecutionResponse struct

+ func (*RequestCancelWorkflowExecutionResponse) Descriptor() ([]byte, []int)

+ func (*RequestCancelWorkflowExecutionResponse) ProtoMessage()

+ func (x *RequestCancelWorkflowExecutionResponse) ProtoReflect() protoreflect.Message

+ func (x *RequestCancelWorkflowExecutionResponse) Reset()

+ func (x *RequestCancelWorkflowExecutionResponse) String() string

+ type ResetStickyTaskQueueRequest struct

+ Execution *v13.WorkflowExecution

+ Namespace string

+ func (*ResetStickyTaskQueueRequest) Descriptor() ([]byte, []int)

+ func (*ResetStickyTaskQueueRequest) ProtoMessage()

+ func (x *ResetStickyTaskQueueRequest) GetExecution() *v13.WorkflowExecution

+ func (x *ResetStickyTaskQueueRequest) GetNamespace() string

+ func (x *ResetStickyTaskQueueRequest) ProtoReflect() protoreflect.Message

+ func (x *ResetStickyTaskQueueRequest) Reset()

+ func (x *ResetStickyTaskQueueRequest) String() string

+ type ResetStickyTaskQueueResponse struct

+ func (*ResetStickyTaskQueueResponse) Descriptor() ([]byte, []int)

+ func (*ResetStickyTaskQueueResponse) ProtoMessage()

+ func (x *ResetStickyTaskQueueResponse) ProtoReflect() protoreflect.Message

+ func (x *ResetStickyTaskQueueResponse) Reset()

+ func (x *ResetStickyTaskQueueResponse) String() string

+ type ResetWorkflowExecutionRequest struct

+ Namespace string

+ Reason string

+ RequestId string

+ ResetReapplyType v11.ResetReapplyType

+ WorkflowExecution *v13.WorkflowExecution

+ WorkflowTaskFinishEventId int64

+ func (*ResetWorkflowExecutionRequest) Descriptor() ([]byte, []int)

+ func (*ResetWorkflowExecutionRequest) ProtoMessage()

+ func (x *ResetWorkflowExecutionRequest) GetNamespace() string

+ func (x *ResetWorkflowExecutionRequest) GetReason() string

+ func (x *ResetWorkflowExecutionRequest) GetRequestId() string

+ func (x *ResetWorkflowExecutionRequest) GetResetReapplyType() v11.ResetReapplyType

+ func (x *ResetWorkflowExecutionRequest) GetWorkflowExecution() *v13.WorkflowExecution

+ func (x *ResetWorkflowExecutionRequest) GetWorkflowTaskFinishEventId() int64

+ func (x *ResetWorkflowExecutionRequest) ProtoReflect() protoreflect.Message

+ func (x *ResetWorkflowExecutionRequest) Reset()

+ func (x *ResetWorkflowExecutionRequest) String() string

+ type ResetWorkflowExecutionResponse struct

+ RunId string

+ func (*ResetWorkflowExecutionResponse) Descriptor() ([]byte, []int)

+ func (*ResetWorkflowExecutionResponse) ProtoMessage()

+ func (x *ResetWorkflowExecutionResponse) GetRunId() string

+ func (x *ResetWorkflowExecutionResponse) ProtoReflect() protoreflect.Message

+ func (x *ResetWorkflowExecutionResponse) Reset()

+ func (x *ResetWorkflowExecutionResponse) String() string

+ type RespondActivityTaskCanceledByIdRequest struct

+ ActivityId string

+ Details *v13.Payloads

+ Identity string

+ Namespace string

+ RunId string

+ WorkflowId string

+ func (*RespondActivityTaskCanceledByIdRequest) Descriptor() ([]byte, []int)

+ func (*RespondActivityTaskCanceledByIdRequest) ProtoMessage()

+ func (x *RespondActivityTaskCanceledByIdRequest) GetActivityId() string

+ func (x *RespondActivityTaskCanceledByIdRequest) GetDetails() *v13.Payloads

+ func (x *RespondActivityTaskCanceledByIdRequest) GetIdentity() string

+ func (x *RespondActivityTaskCanceledByIdRequest) GetNamespace() string

+ func (x *RespondActivityTaskCanceledByIdRequest) GetRunId() string

+ func (x *RespondActivityTaskCanceledByIdRequest) GetWorkflowId() string

+ func (x *RespondActivityTaskCanceledByIdRequest) ProtoReflect() protoreflect.Message

+ func (x *RespondActivityTaskCanceledByIdRequest) Reset()

+ func (x *RespondActivityTaskCanceledByIdRequest) String() string

+ type RespondActivityTaskCanceledByIdResponse struct

+ func (*RespondActivityTaskCanceledByIdResponse) Descriptor() ([]byte, []int)

+ func (*RespondActivityTaskCanceledByIdResponse) ProtoMessage()

+ func (x *RespondActivityTaskCanceledByIdResponse) ProtoReflect() protoreflect.Message

+ func (x *RespondActivityTaskCanceledByIdResponse) Reset()

+ func (x *RespondActivityTaskCanceledByIdResponse) String() string

+ type RespondActivityTaskCanceledRequest struct

+ Details *v13.Payloads

+ Identity string

+ Namespace string

+ TaskToken []byte

+ WorkerVersion *v13.WorkerVersionStamp

+ func (*RespondActivityTaskCanceledRequest) Descriptor() ([]byte, []int)

+ func (*RespondActivityTaskCanceledRequest) ProtoMessage()

+ func (x *RespondActivityTaskCanceledRequest) GetDetails() *v13.Payloads

+ func (x *RespondActivityTaskCanceledRequest) GetIdentity() string

+ func (x *RespondActivityTaskCanceledRequest) GetNamespace() string

+ func (x *RespondActivityTaskCanceledRequest) GetTaskToken() []byte

+ func (x *RespondActivityTaskCanceledRequest) GetWorkerVersion() *v13.WorkerVersionStamp

+ func (x *RespondActivityTaskCanceledRequest) ProtoReflect() protoreflect.Message

+ func (x *RespondActivityTaskCanceledRequest) Reset()

+ func (x *RespondActivityTaskCanceledRequest) String() string

+ type RespondActivityTaskCanceledResponse struct

+ func (*RespondActivityTaskCanceledResponse) Descriptor() ([]byte, []int)

+ func (*RespondActivityTaskCanceledResponse) ProtoMessage()

+ func (x *RespondActivityTaskCanceledResponse) ProtoReflect() protoreflect.Message

+ func (x *RespondActivityTaskCanceledResponse) Reset()

+ func (x *RespondActivityTaskCanceledResponse) String() string

+ type RespondActivityTaskCompletedByIdRequest struct

+ ActivityId string

+ Identity string

+ Namespace string

+ Result *v13.Payloads

+ RunId string

+ WorkflowId string

+ func (*RespondActivityTaskCompletedByIdRequest) Descriptor() ([]byte, []int)

+ func (*RespondActivityTaskCompletedByIdRequest) ProtoMessage()

+ func (x *RespondActivityTaskCompletedByIdRequest) GetActivityId() string

+ func (x *RespondActivityTaskCompletedByIdRequest) GetIdentity() string

+ func (x *RespondActivityTaskCompletedByIdRequest) GetNamespace() string

+ func (x *RespondActivityTaskCompletedByIdRequest) GetResult() *v13.Payloads

+ func (x *RespondActivityTaskCompletedByIdRequest) GetRunId() string

+ func (x *RespondActivityTaskCompletedByIdRequest) GetWorkflowId() string

+ func (x *RespondActivityTaskCompletedByIdRequest) ProtoReflect() protoreflect.Message

+ func (x *RespondActivityTaskCompletedByIdRequest) Reset()

+ func (x *RespondActivityTaskCompletedByIdRequest) String() string

+ type RespondActivityTaskCompletedByIdResponse struct

+ func (*RespondActivityTaskCompletedByIdResponse) Descriptor() ([]byte, []int)

+ func (*RespondActivityTaskCompletedByIdResponse) ProtoMessage()

+ func (x *RespondActivityTaskCompletedByIdResponse) ProtoReflect() protoreflect.Message

+ func (x *RespondActivityTaskCompletedByIdResponse) Reset()

+ func (x *RespondActivityTaskCompletedByIdResponse) String() string

+ type RespondActivityTaskCompletedRequest struct

+ Identity string

+ Namespace string

+ Result *v13.Payloads

+ TaskToken []byte

+ WorkerVersion *v13.WorkerVersionStamp

+ func (*RespondActivityTaskCompletedRequest) Descriptor() ([]byte, []int)

+ func (*RespondActivityTaskCompletedRequest) ProtoMessage()

+ func (x *RespondActivityTaskCompletedRequest) GetIdentity() string

+ func (x *RespondActivityTaskCompletedRequest) GetNamespace() string

+ func (x *RespondActivityTaskCompletedRequest) GetResult() *v13.Payloads

+ func (x *RespondActivityTaskCompletedRequest) GetTaskToken() []byte

+ func (x *RespondActivityTaskCompletedRequest) GetWorkerVersion() *v13.WorkerVersionStamp

+ func (x *RespondActivityTaskCompletedRequest) ProtoReflect() protoreflect.Message

+ func (x *RespondActivityTaskCompletedRequest) Reset()

+ func (x *RespondActivityTaskCompletedRequest) String() string

+ type RespondActivityTaskCompletedResponse struct

+ func (*RespondActivityTaskCompletedResponse) Descriptor() ([]byte, []int)

+ func (*RespondActivityTaskCompletedResponse) ProtoMessage()

+ func (x *RespondActivityTaskCompletedResponse) ProtoReflect() protoreflect.Message

+ func (x *RespondActivityTaskCompletedResponse) Reset()

+ func (x *RespondActivityTaskCompletedResponse) String() string

+ type RespondActivityTaskFailedByIdRequest struct

+ ActivityId string

+ Failure *v15.Failure

+ Identity string

+ LastHeartbeatDetails *v13.Payloads

+ Namespace string

+ RunId string

+ WorkflowId string

+ func (*RespondActivityTaskFailedByIdRequest) Descriptor() ([]byte, []int)

+ func (*RespondActivityTaskFailedByIdRequest) ProtoMessage()

+ func (x *RespondActivityTaskFailedByIdRequest) GetActivityId() string

+ func (x *RespondActivityTaskFailedByIdRequest) GetFailure() *v15.Failure

+ func (x *RespondActivityTaskFailedByIdRequest) GetIdentity() string

+ func (x *RespondActivityTaskFailedByIdRequest) GetLastHeartbeatDetails() *v13.Payloads

+ func (x *RespondActivityTaskFailedByIdRequest) GetNamespace() string

+ func (x *RespondActivityTaskFailedByIdRequest) GetRunId() string

+ func (x *RespondActivityTaskFailedByIdRequest) GetWorkflowId() string

+ func (x *RespondActivityTaskFailedByIdRequest) ProtoReflect() protoreflect.Message

+ func (x *RespondActivityTaskFailedByIdRequest) Reset()

+ func (x *RespondActivityTaskFailedByIdRequest) String() string

+ type RespondActivityTaskFailedByIdResponse struct

+ Failures []*v15.Failure

+ func (*RespondActivityTaskFailedByIdResponse) Descriptor() ([]byte, []int)

+ func (*RespondActivityTaskFailedByIdResponse) ProtoMessage()

+ func (x *RespondActivityTaskFailedByIdResponse) GetFailures() []*v15.Failure

+ func (x *RespondActivityTaskFailedByIdResponse) ProtoReflect() protoreflect.Message

+ func (x *RespondActivityTaskFailedByIdResponse) Reset()

+ func (x *RespondActivityTaskFailedByIdResponse) String() string

+ type RespondActivityTaskFailedRequest struct

+ Failure *v15.Failure

+ Identity string

+ LastHeartbeatDetails *v13.Payloads

+ Namespace string

+ TaskToken []byte

+ WorkerVersion *v13.WorkerVersionStamp

+ func (*RespondActivityTaskFailedRequest) Descriptor() ([]byte, []int)

+ func (*RespondActivityTaskFailedRequest) ProtoMessage()

+ func (x *RespondActivityTaskFailedRequest) GetFailure() *v15.Failure

+ func (x *RespondActivityTaskFailedRequest) GetIdentity() string

+ func (x *RespondActivityTaskFailedRequest) GetLastHeartbeatDetails() *v13.Payloads

+ func (x *RespondActivityTaskFailedRequest) GetNamespace() string

+ func (x *RespondActivityTaskFailedRequest) GetTaskToken() []byte

+ func (x *RespondActivityTaskFailedRequest) GetWorkerVersion() *v13.WorkerVersionStamp

+ func (x *RespondActivityTaskFailedRequest) ProtoReflect() protoreflect.Message

+ func (x *RespondActivityTaskFailedRequest) Reset()

+ func (x *RespondActivityTaskFailedRequest) String() string

+ type RespondActivityTaskFailedResponse struct

+ Failures []*v15.Failure

+ func (*RespondActivityTaskFailedResponse) Descriptor() ([]byte, []int)

+ func (*RespondActivityTaskFailedResponse) ProtoMessage()

+ func (x *RespondActivityTaskFailedResponse) GetFailures() []*v15.Failure

+ func (x *RespondActivityTaskFailedResponse) ProtoReflect() protoreflect.Message

+ func (x *RespondActivityTaskFailedResponse) Reset()

+ func (x *RespondActivityTaskFailedResponse) String() string

+ type RespondQueryTaskCompletedRequest struct

+ CompletedType v11.QueryResultType

+ ErrorMessage string

+ Namespace string

+ QueryResult *v13.Payloads

+ TaskToken []byte

+ func (*RespondQueryTaskCompletedRequest) Descriptor() ([]byte, []int)

+ func (*RespondQueryTaskCompletedRequest) ProtoMessage()

+ func (x *RespondQueryTaskCompletedRequest) GetCompletedType() v11.QueryResultType

+ func (x *RespondQueryTaskCompletedRequest) GetErrorMessage() string

+ func (x *RespondQueryTaskCompletedRequest) GetNamespace() string

+ func (x *RespondQueryTaskCompletedRequest) GetQueryResult() *v13.Payloads

+ func (x *RespondQueryTaskCompletedRequest) GetTaskToken() []byte

+ func (x *RespondQueryTaskCompletedRequest) ProtoReflect() protoreflect.Message

+ func (x *RespondQueryTaskCompletedRequest) Reset()

+ func (x *RespondQueryTaskCompletedRequest) String() string

+ type RespondQueryTaskCompletedResponse struct

+ func (*RespondQueryTaskCompletedResponse) Descriptor() ([]byte, []int)

+ func (*RespondQueryTaskCompletedResponse) ProtoMessage()

+ func (x *RespondQueryTaskCompletedResponse) ProtoReflect() protoreflect.Message

+ func (x *RespondQueryTaskCompletedResponse) Reset()

+ func (x *RespondQueryTaskCompletedResponse) String() string

+ type RespondWorkflowTaskCompletedRequest struct

+ BinaryChecksum string

+ Commands []*v19.Command

+ ForceCreateNewWorkflowTask bool

+ Identity string

+ Messages []*v18.Message

+ MeteringMetadata *v13.MeteringMetadata

+ Namespace string

+ QueryResults map[string]*v17.WorkflowQueryResult

+ ReturnNewWorkflowTask bool

+ SdkMetadata *v110.WorkflowTaskCompletedMetadata

+ StickyAttributes *v14.StickyExecutionAttributes

+ TaskToken []byte

+ WorkerVersionStamp *v13.WorkerVersionStamp

+ func (*RespondWorkflowTaskCompletedRequest) Descriptor() ([]byte, []int)

+ func (*RespondWorkflowTaskCompletedRequest) ProtoMessage()

+ func (x *RespondWorkflowTaskCompletedRequest) GetBinaryChecksum() string

+ func (x *RespondWorkflowTaskCompletedRequest) GetCommands() []*v19.Command

+ func (x *RespondWorkflowTaskCompletedRequest) GetForceCreateNewWorkflowTask() bool

+ func (x *RespondWorkflowTaskCompletedRequest) GetIdentity() string

+ func (x *RespondWorkflowTaskCompletedRequest) GetMessages() []*v18.Message

+ func (x *RespondWorkflowTaskCompletedRequest) GetMeteringMetadata() *v13.MeteringMetadata

+ func (x *RespondWorkflowTaskCompletedRequest) GetNamespace() string

+ func (x *RespondWorkflowTaskCompletedRequest) GetQueryResults() map[string]*v17.WorkflowQueryResult

+ func (x *RespondWorkflowTaskCompletedRequest) GetReturnNewWorkflowTask() bool

+ func (x *RespondWorkflowTaskCompletedRequest) GetSdkMetadata() *v110.WorkflowTaskCompletedMetadata

+ func (x *RespondWorkflowTaskCompletedRequest) GetStickyAttributes() *v14.StickyExecutionAttributes

+ func (x *RespondWorkflowTaskCompletedRequest) GetTaskToken() []byte

+ func (x *RespondWorkflowTaskCompletedRequest) GetWorkerVersionStamp() *v13.WorkerVersionStamp

+ func (x *RespondWorkflowTaskCompletedRequest) ProtoReflect() protoreflect.Message

+ func (x *RespondWorkflowTaskCompletedRequest) Reset()

+ func (x *RespondWorkflowTaskCompletedRequest) String() string

+ type RespondWorkflowTaskCompletedResponse struct

+ ActivityTasks []*PollActivityTaskQueueResponse

+ ResetHistoryEventId int64

+ WorkflowTask *PollWorkflowTaskQueueResponse

+ func (*RespondWorkflowTaskCompletedResponse) Descriptor() ([]byte, []int)

+ func (*RespondWorkflowTaskCompletedResponse) ProtoMessage()

+ func (x *RespondWorkflowTaskCompletedResponse) GetActivityTasks() []*PollActivityTaskQueueResponse

+ func (x *RespondWorkflowTaskCompletedResponse) GetResetHistoryEventId() int64

+ func (x *RespondWorkflowTaskCompletedResponse) GetWorkflowTask() *PollWorkflowTaskQueueResponse

+ func (x *RespondWorkflowTaskCompletedResponse) ProtoReflect() protoreflect.Message

+ func (x *RespondWorkflowTaskCompletedResponse) Reset()

+ func (x *RespondWorkflowTaskCompletedResponse) String() string

+ type RespondWorkflowTaskFailedRequest struct

+ BinaryChecksum string

+ Cause v11.WorkflowTaskFailedCause

+ Failure *v15.Failure

+ Identity string

+ Messages []*v18.Message

+ Namespace string

+ TaskToken []byte

+ WorkerVersion *v13.WorkerVersionStamp

+ func (*RespondWorkflowTaskFailedRequest) Descriptor() ([]byte, []int)

+ func (*RespondWorkflowTaskFailedRequest) ProtoMessage()

+ func (x *RespondWorkflowTaskFailedRequest) GetBinaryChecksum() string

+ func (x *RespondWorkflowTaskFailedRequest) GetCause() v11.WorkflowTaskFailedCause

+ func (x *RespondWorkflowTaskFailedRequest) GetFailure() *v15.Failure

+ func (x *RespondWorkflowTaskFailedRequest) GetIdentity() string

+ func (x *RespondWorkflowTaskFailedRequest) GetMessages() []*v18.Message

+ func (x *RespondWorkflowTaskFailedRequest) GetNamespace() string

+ func (x *RespondWorkflowTaskFailedRequest) GetTaskToken() []byte

+ func (x *RespondWorkflowTaskFailedRequest) GetWorkerVersion() *v13.WorkerVersionStamp

+ func (x *RespondWorkflowTaskFailedRequest) ProtoReflect() protoreflect.Message

+ func (x *RespondWorkflowTaskFailedRequest) Reset()

+ func (x *RespondWorkflowTaskFailedRequest) String() string

+ type RespondWorkflowTaskFailedResponse struct

+ func (*RespondWorkflowTaskFailedResponse) Descriptor() ([]byte, []int)

+ func (*RespondWorkflowTaskFailedResponse) ProtoMessage()

+ func (x *RespondWorkflowTaskFailedResponse) ProtoReflect() protoreflect.Message

+ func (x *RespondWorkflowTaskFailedResponse) Reset()

+ func (x *RespondWorkflowTaskFailedResponse) String() string

+ type ScanWorkflowExecutionsRequest struct

+ Namespace string

+ NextPageToken []byte

+ PageSize int32

+ Query string

+ func (*ScanWorkflowExecutionsRequest) Descriptor() ([]byte, []int)

+ func (*ScanWorkflowExecutionsRequest) ProtoMessage()

+ func (x *ScanWorkflowExecutionsRequest) GetNamespace() string

+ func (x *ScanWorkflowExecutionsRequest) GetNextPageToken() []byte

+ func (x *ScanWorkflowExecutionsRequest) GetPageSize() int32

+ func (x *ScanWorkflowExecutionsRequest) GetQuery() string

+ func (x *ScanWorkflowExecutionsRequest) ProtoReflect() protoreflect.Message

+ func (x *ScanWorkflowExecutionsRequest) Reset()

+ func (x *ScanWorkflowExecutionsRequest) String() string

+ type ScanWorkflowExecutionsResponse struct

+ Executions []*v112.WorkflowExecutionInfo

+ NextPageToken []byte

+ func (*ScanWorkflowExecutionsResponse) Descriptor() ([]byte, []int)

+ func (*ScanWorkflowExecutionsResponse) ProtoMessage()

+ func (x *ScanWorkflowExecutionsResponse) GetExecutions() []*v112.WorkflowExecutionInfo

+ func (x *ScanWorkflowExecutionsResponse) GetNextPageToken() []byte

+ func (x *ScanWorkflowExecutionsResponse) ProtoReflect() protoreflect.Message

+ func (x *ScanWorkflowExecutionsResponse) Reset()

+ func (x *ScanWorkflowExecutionsResponse) String() string

+ type SignalWithStartWorkflowExecutionRequest struct

+ Control string

+ CronSchedule string

+ Header *v13.Header

+ Identity string

+ Input *v13.Payloads

+ Memo *v13.Memo

+ Namespace string

+ RequestId string

+ RetryPolicy *v13.RetryPolicy

+ SearchAttributes *v13.SearchAttributes

+ SignalInput *v13.Payloads

+ SignalName string

+ SkipGenerateWorkflowTask bool

+ TaskQueue *v14.TaskQueue

+ WorkflowExecutionTimeout *durationpb.Duration

+ WorkflowId string

+ WorkflowIdReusePolicy v11.WorkflowIdReusePolicy

+ WorkflowRunTimeout *durationpb.Duration

+ WorkflowStartDelay *durationpb.Duration

+ WorkflowTaskTimeout *durationpb.Duration

+ WorkflowType *v13.WorkflowType

+ func (*SignalWithStartWorkflowExecutionRequest) Descriptor() ([]byte, []int)

+ func (*SignalWithStartWorkflowExecutionRequest) ProtoMessage()

+ func (x *SignalWithStartWorkflowExecutionRequest) GetControl() string

+ func (x *SignalWithStartWorkflowExecutionRequest) GetCronSchedule() string

+ func (x *SignalWithStartWorkflowExecutionRequest) GetHeader() *v13.Header

+ func (x *SignalWithStartWorkflowExecutionRequest) GetIdentity() string

+ func (x *SignalWithStartWorkflowExecutionRequest) GetInput() *v13.Payloads

+ func (x *SignalWithStartWorkflowExecutionRequest) GetMemo() *v13.Memo

+ func (x *SignalWithStartWorkflowExecutionRequest) GetNamespace() string

+ func (x *SignalWithStartWorkflowExecutionRequest) GetRequestId() string

+ func (x *SignalWithStartWorkflowExecutionRequest) GetRetryPolicy() *v13.RetryPolicy

+ func (x *SignalWithStartWorkflowExecutionRequest) GetSearchAttributes() *v13.SearchAttributes

+ func (x *SignalWithStartWorkflowExecutionRequest) GetSignalInput() *v13.Payloads

+ func (x *SignalWithStartWorkflowExecutionRequest) GetSignalName() string

+ func (x *SignalWithStartWorkflowExecutionRequest) GetSkipGenerateWorkflowTask() bool

+ func (x *SignalWithStartWorkflowExecutionRequest) GetTaskQueue() *v14.TaskQueue

+ func (x *SignalWithStartWorkflowExecutionRequest) GetWorkflowExecutionTimeout() *durationpb.Duration

+ func (x *SignalWithStartWorkflowExecutionRequest) GetWorkflowId() string

+ func (x *SignalWithStartWorkflowExecutionRequest) GetWorkflowIdReusePolicy() v11.WorkflowIdReusePolicy

+ func (x *SignalWithStartWorkflowExecutionRequest) GetWorkflowRunTimeout() *durationpb.Duration

+ func (x *SignalWithStartWorkflowExecutionRequest) GetWorkflowStartDelay() *durationpb.Duration

+ func (x *SignalWithStartWorkflowExecutionRequest) GetWorkflowTaskTimeout() *durationpb.Duration

+ func (x *SignalWithStartWorkflowExecutionRequest) GetWorkflowType() *v13.WorkflowType

+ func (x *SignalWithStartWorkflowExecutionRequest) ProtoReflect() protoreflect.Message

+ func (x *SignalWithStartWorkflowExecutionRequest) Reset()

+ func (x *SignalWithStartWorkflowExecutionRequest) String() string

+ type SignalWithStartWorkflowExecutionResponse struct

+ RunId string

+ func (*SignalWithStartWorkflowExecutionResponse) Descriptor() ([]byte, []int)

+ func (*SignalWithStartWorkflowExecutionResponse) ProtoMessage()

+ func (x *SignalWithStartWorkflowExecutionResponse) GetRunId() string

+ func (x *SignalWithStartWorkflowExecutionResponse) ProtoReflect() protoreflect.Message

+ func (x *SignalWithStartWorkflowExecutionResponse) Reset()

+ func (x *SignalWithStartWorkflowExecutionResponse) String() string

+ type SignalWorkflowExecutionRequest struct

+ Control string

+ Header *v13.Header

+ Identity string

+ Input *v13.Payloads

+ Namespace string

+ RequestId string

+ SignalName string

+ SkipGenerateWorkflowTask bool

+ WorkflowExecution *v13.WorkflowExecution

+ func (*SignalWorkflowExecutionRequest) Descriptor() ([]byte, []int)

+ func (*SignalWorkflowExecutionRequest) ProtoMessage()

+ func (x *SignalWorkflowExecutionRequest) GetControl() string

+ func (x *SignalWorkflowExecutionRequest) GetHeader() *v13.Header

+ func (x *SignalWorkflowExecutionRequest) GetIdentity() string

+ func (x *SignalWorkflowExecutionRequest) GetInput() *v13.Payloads

+ func (x *SignalWorkflowExecutionRequest) GetNamespace() string

+ func (x *SignalWorkflowExecutionRequest) GetRequestId() string

+ func (x *SignalWorkflowExecutionRequest) GetSignalName() string

+ func (x *SignalWorkflowExecutionRequest) GetSkipGenerateWorkflowTask() bool

+ func (x *SignalWorkflowExecutionRequest) GetWorkflowExecution() *v13.WorkflowExecution

+ func (x *SignalWorkflowExecutionRequest) ProtoReflect() protoreflect.Message

+ func (x *SignalWorkflowExecutionRequest) Reset()

+ func (x *SignalWorkflowExecutionRequest) String() string

+ type SignalWorkflowExecutionResponse struct

+ func (*SignalWorkflowExecutionResponse) Descriptor() ([]byte, []int)

+ func (*SignalWorkflowExecutionResponse) ProtoMessage()

+ func (x *SignalWorkflowExecutionResponse) ProtoReflect() protoreflect.Message

+ func (x *SignalWorkflowExecutionResponse) Reset()

+ func (x *SignalWorkflowExecutionResponse) String() string

+ type StartBatchOperationRequest struct

+ Executions []*v13.WorkflowExecution

+ JobId string

+ Namespace string

+ Operation isStartBatchOperationRequest_Operation

+ Reason string

+ VisibilityQuery string

+ func (*StartBatchOperationRequest) Descriptor() ([]byte, []int)

+ func (*StartBatchOperationRequest) ProtoMessage()

+ func (m *StartBatchOperationRequest) GetOperation() isStartBatchOperationRequest_Operation

+ func (x *StartBatchOperationRequest) GetCancellationOperation() *v116.BatchOperationCancellation

+ func (x *StartBatchOperationRequest) GetDeletionOperation() *v116.BatchOperationDeletion

+ func (x *StartBatchOperationRequest) GetExecutions() []*v13.WorkflowExecution

+ func (x *StartBatchOperationRequest) GetJobId() string

+ func (x *StartBatchOperationRequest) GetNamespace() string

+ func (x *StartBatchOperationRequest) GetReason() string

+ func (x *StartBatchOperationRequest) GetResetOperation() *v116.BatchOperationReset

+ func (x *StartBatchOperationRequest) GetSignalOperation() *v116.BatchOperationSignal

+ func (x *StartBatchOperationRequest) GetTerminationOperation() *v116.BatchOperationTermination

+ func (x *StartBatchOperationRequest) GetVisibilityQuery() string

+ func (x *StartBatchOperationRequest) ProtoReflect() protoreflect.Message

+ func (x *StartBatchOperationRequest) Reset()

+ func (x *StartBatchOperationRequest) String() string

+ type StartBatchOperationRequest_CancellationOperation struct

+ CancellationOperation *v116.BatchOperationCancellation

+ type StartBatchOperationRequest_DeletionOperation struct

+ DeletionOperation *v116.BatchOperationDeletion

+ type StartBatchOperationRequest_ResetOperation struct

+ ResetOperation *v116.BatchOperationReset

+ type StartBatchOperationRequest_SignalOperation struct

+ SignalOperation *v116.BatchOperationSignal

+ type StartBatchOperationRequest_TerminationOperation struct

+ TerminationOperation *v116.BatchOperationTermination

+ type StartBatchOperationResponse struct

+ func (*StartBatchOperationResponse) Descriptor() ([]byte, []int)

+ func (*StartBatchOperationResponse) ProtoMessage()

+ func (x *StartBatchOperationResponse) ProtoReflect() protoreflect.Message

+ func (x *StartBatchOperationResponse) Reset()

+ func (x *StartBatchOperationResponse) String() string

+ type StartWorkflowExecutionRequest struct

+ ContinuedFailure *v15.Failure

+ CronSchedule string

+ Header *v13.Header

+ Identity string

+ Input *v13.Payloads

+ LastCompletionResult *v13.Payloads

+ Memo *v13.Memo

+ Namespace string

+ RequestEagerExecution bool

+ RequestId string

+ RetryPolicy *v13.RetryPolicy

+ SearchAttributes *v13.SearchAttributes

+ TaskQueue *v14.TaskQueue

+ WorkflowExecutionTimeout *durationpb.Duration

+ WorkflowId string

+ WorkflowIdReusePolicy v11.WorkflowIdReusePolicy

+ WorkflowRunTimeout *durationpb.Duration

+ WorkflowStartDelay *durationpb.Duration

+ WorkflowTaskTimeout *durationpb.Duration

+ WorkflowType *v13.WorkflowType

+ func (*StartWorkflowExecutionRequest) Descriptor() ([]byte, []int)

+ func (*StartWorkflowExecutionRequest) ProtoMessage()

+ func (x *StartWorkflowExecutionRequest) GetContinuedFailure() *v15.Failure

+ func (x *StartWorkflowExecutionRequest) GetCronSchedule() string

+ func (x *StartWorkflowExecutionRequest) GetHeader() *v13.Header

+ func (x *StartWorkflowExecutionRequest) GetIdentity() string

+ func (x *StartWorkflowExecutionRequest) GetInput() *v13.Payloads

+ func (x *StartWorkflowExecutionRequest) GetLastCompletionResult() *v13.Payloads

+ func (x *StartWorkflowExecutionRequest) GetMemo() *v13.Memo

+ func (x *StartWorkflowExecutionRequest) GetNamespace() string

+ func (x *StartWorkflowExecutionRequest) GetRequestEagerExecution() bool

+ func (x *StartWorkflowExecutionRequest) GetRequestId() string

+ func (x *StartWorkflowExecutionRequest) GetRetryPolicy() *v13.RetryPolicy

+ func (x *StartWorkflowExecutionRequest) GetSearchAttributes() *v13.SearchAttributes

+ func (x *StartWorkflowExecutionRequest) GetTaskQueue() *v14.TaskQueue

+ func (x *StartWorkflowExecutionRequest) GetWorkflowExecutionTimeout() *durationpb.Duration

+ func (x *StartWorkflowExecutionRequest) GetWorkflowId() string

+ func (x *StartWorkflowExecutionRequest) GetWorkflowIdReusePolicy() v11.WorkflowIdReusePolicy

+ func (x *StartWorkflowExecutionRequest) GetWorkflowRunTimeout() *durationpb.Duration

+ func (x *StartWorkflowExecutionRequest) GetWorkflowStartDelay() *durationpb.Duration

+ func (x *StartWorkflowExecutionRequest) GetWorkflowTaskTimeout() *durationpb.Duration

+ func (x *StartWorkflowExecutionRequest) GetWorkflowType() *v13.WorkflowType

+ func (x *StartWorkflowExecutionRequest) ProtoReflect() protoreflect.Message

+ func (x *StartWorkflowExecutionRequest) Reset()

+ func (x *StartWorkflowExecutionRequest) String() string

+ type StartWorkflowExecutionResponse struct

+ EagerWorkflowTask *PollWorkflowTaskQueueResponse

+ RunId string

+ func (*StartWorkflowExecutionResponse) Descriptor() ([]byte, []int)

+ func (*StartWorkflowExecutionResponse) ProtoMessage()

+ func (x *StartWorkflowExecutionResponse) GetEagerWorkflowTask() *PollWorkflowTaskQueueResponse

+ func (x *StartWorkflowExecutionResponse) GetRunId() string

+ func (x *StartWorkflowExecutionResponse) ProtoReflect() protoreflect.Message

+ func (x *StartWorkflowExecutionResponse) Reset()

+ func (x *StartWorkflowExecutionResponse) String() string

+ type StopBatchOperationRequest struct

+ Identity string

+ JobId string

+ Namespace string

+ Reason string

+ func (*StopBatchOperationRequest) Descriptor() ([]byte, []int)

+ func (*StopBatchOperationRequest) ProtoMessage()

+ func (x *StopBatchOperationRequest) GetIdentity() string

+ func (x *StopBatchOperationRequest) GetJobId() string

+ func (x *StopBatchOperationRequest) GetNamespace() string

+ func (x *StopBatchOperationRequest) GetReason() string

+ func (x *StopBatchOperationRequest) ProtoReflect() protoreflect.Message

+ func (x *StopBatchOperationRequest) Reset()

+ func (x *StopBatchOperationRequest) String() string

+ type StopBatchOperationResponse struct

+ func (*StopBatchOperationResponse) Descriptor() ([]byte, []int)

+ func (*StopBatchOperationResponse) ProtoMessage()

+ func (x *StopBatchOperationResponse) ProtoReflect() protoreflect.Message

+ func (x *StopBatchOperationResponse) Reset()

+ func (x *StopBatchOperationResponse) String() string

+ type TerminateWorkflowExecutionRequest struct

+ Details *v13.Payloads

+ FirstExecutionRunId string

+ Identity string

+ Namespace string

+ Reason string

+ WorkflowExecution *v13.WorkflowExecution

+ func (*TerminateWorkflowExecutionRequest) Descriptor() ([]byte, []int)

+ func (*TerminateWorkflowExecutionRequest) ProtoMessage()

+ func (x *TerminateWorkflowExecutionRequest) GetDetails() *v13.Payloads

+ func (x *TerminateWorkflowExecutionRequest) GetFirstExecutionRunId() string

+ func (x *TerminateWorkflowExecutionRequest) GetIdentity() string

+ func (x *TerminateWorkflowExecutionRequest) GetNamespace() string

+ func (x *TerminateWorkflowExecutionRequest) GetReason() string

+ func (x *TerminateWorkflowExecutionRequest) GetWorkflowExecution() *v13.WorkflowExecution

+ func (x *TerminateWorkflowExecutionRequest) ProtoReflect() protoreflect.Message

+ func (x *TerminateWorkflowExecutionRequest) Reset()

+ func (x *TerminateWorkflowExecutionRequest) String() string

+ type TerminateWorkflowExecutionResponse struct

+ func (*TerminateWorkflowExecutionResponse) Descriptor() ([]byte, []int)

+ func (*TerminateWorkflowExecutionResponse) ProtoMessage()

+ func (x *TerminateWorkflowExecutionResponse) ProtoReflect() protoreflect.Message

+ func (x *TerminateWorkflowExecutionResponse) Reset()

+ func (x *TerminateWorkflowExecutionResponse) String() string

+ type UnimplementedWorkflowServiceServer struct

+ func (UnimplementedWorkflowServiceServer) CountWorkflowExecutions(context.Context, *CountWorkflowExecutionsRequest) (*CountWorkflowExecutionsResponse, error)

+ func (UnimplementedWorkflowServiceServer) CreateSchedule(context.Context, *CreateScheduleRequest) (*CreateScheduleResponse, error)

+ func (UnimplementedWorkflowServiceServer) DeleteSchedule(context.Context, *DeleteScheduleRequest) (*DeleteScheduleResponse, error)

+ func (UnimplementedWorkflowServiceServer) DeleteWorkflowExecution(context.Context, *DeleteWorkflowExecutionRequest) (*DeleteWorkflowExecutionResponse, error)

+ func (UnimplementedWorkflowServiceServer) DeprecateNamespace(context.Context, *DeprecateNamespaceRequest) (*DeprecateNamespaceResponse, error)

+ func (UnimplementedWorkflowServiceServer) DescribeBatchOperation(context.Context, *DescribeBatchOperationRequest) (*DescribeBatchOperationResponse, error)

+ func (UnimplementedWorkflowServiceServer) DescribeNamespace(context.Context, *DescribeNamespaceRequest) (*DescribeNamespaceResponse, error)

+ func (UnimplementedWorkflowServiceServer) DescribeSchedule(context.Context, *DescribeScheduleRequest) (*DescribeScheduleResponse, error)

+ func (UnimplementedWorkflowServiceServer) DescribeTaskQueue(context.Context, *DescribeTaskQueueRequest) (*DescribeTaskQueueResponse, error)

+ func (UnimplementedWorkflowServiceServer) DescribeWorkflowExecution(context.Context, *DescribeWorkflowExecutionRequest) (*DescribeWorkflowExecutionResponse, error)

+ func (UnimplementedWorkflowServiceServer) GetClusterInfo(context.Context, *GetClusterInfoRequest) (*GetClusterInfoResponse, error)

+ func (UnimplementedWorkflowServiceServer) GetSearchAttributes(context.Context, *GetSearchAttributesRequest) (*GetSearchAttributesResponse, error)

+ func (UnimplementedWorkflowServiceServer) GetSystemInfo(context.Context, *GetSystemInfoRequest) (*GetSystemInfoResponse, error)

+ func (UnimplementedWorkflowServiceServer) GetWorkerBuildIdCompatibility(context.Context, *GetWorkerBuildIdCompatibilityRequest) (*GetWorkerBuildIdCompatibilityResponse, error)

+ func (UnimplementedWorkflowServiceServer) GetWorkerTaskReachability(context.Context, *GetWorkerTaskReachabilityRequest) (*GetWorkerTaskReachabilityResponse, error)

+ func (UnimplementedWorkflowServiceServer) GetWorkflowExecutionHistory(context.Context, *GetWorkflowExecutionHistoryRequest) (*GetWorkflowExecutionHistoryResponse, error)

+ func (UnimplementedWorkflowServiceServer) GetWorkflowExecutionHistoryReverse(context.Context, *GetWorkflowExecutionHistoryReverseRequest) (*GetWorkflowExecutionHistoryReverseResponse, error)

+ func (UnimplementedWorkflowServiceServer) ListArchivedWorkflowExecutions(context.Context, *ListArchivedWorkflowExecutionsRequest) (*ListArchivedWorkflowExecutionsResponse, error)

+ func (UnimplementedWorkflowServiceServer) ListBatchOperations(context.Context, *ListBatchOperationsRequest) (*ListBatchOperationsResponse, error)

+ func (UnimplementedWorkflowServiceServer) ListClosedWorkflowExecutions(context.Context, *ListClosedWorkflowExecutionsRequest) (*ListClosedWorkflowExecutionsResponse, error)

+ func (UnimplementedWorkflowServiceServer) ListNamespaces(context.Context, *ListNamespacesRequest) (*ListNamespacesResponse, error)

+ func (UnimplementedWorkflowServiceServer) ListOpenWorkflowExecutions(context.Context, *ListOpenWorkflowExecutionsRequest) (*ListOpenWorkflowExecutionsResponse, error)

+ func (UnimplementedWorkflowServiceServer) ListScheduleMatchingTimes(context.Context, *ListScheduleMatchingTimesRequest) (*ListScheduleMatchingTimesResponse, error)

+ func (UnimplementedWorkflowServiceServer) ListSchedules(context.Context, *ListSchedulesRequest) (*ListSchedulesResponse, error)

+ func (UnimplementedWorkflowServiceServer) ListTaskQueuePartitions(context.Context, *ListTaskQueuePartitionsRequest) (*ListTaskQueuePartitionsResponse, error)

+ func (UnimplementedWorkflowServiceServer) ListWorkflowExecutions(context.Context, *ListWorkflowExecutionsRequest) (*ListWorkflowExecutionsResponse, error)

+ func (UnimplementedWorkflowServiceServer) PatchSchedule(context.Context, *PatchScheduleRequest) (*PatchScheduleResponse, error)

+ func (UnimplementedWorkflowServiceServer) PollActivityTaskQueue(context.Context, *PollActivityTaskQueueRequest) (*PollActivityTaskQueueResponse, error)

+ func (UnimplementedWorkflowServiceServer) PollWorkflowExecutionUpdate(context.Context, *PollWorkflowExecutionUpdateRequest) (*PollWorkflowExecutionUpdateResponse, error)

+ func (UnimplementedWorkflowServiceServer) PollWorkflowTaskQueue(context.Context, *PollWorkflowTaskQueueRequest) (*PollWorkflowTaskQueueResponse, error)

+ func (UnimplementedWorkflowServiceServer) QueryWorkflow(context.Context, *QueryWorkflowRequest) (*QueryWorkflowResponse, error)

+ func (UnimplementedWorkflowServiceServer) RecordActivityTaskHeartbeat(context.Context, *RecordActivityTaskHeartbeatRequest) (*RecordActivityTaskHeartbeatResponse, error)

+ func (UnimplementedWorkflowServiceServer) RecordActivityTaskHeartbeatById(context.Context, *RecordActivityTaskHeartbeatByIdRequest) (*RecordActivityTaskHeartbeatByIdResponse, error)

+ func (UnimplementedWorkflowServiceServer) RegisterNamespace(context.Context, *RegisterNamespaceRequest) (*RegisterNamespaceResponse, error)

+ func (UnimplementedWorkflowServiceServer) RequestCancelWorkflowExecution(context.Context, *RequestCancelWorkflowExecutionRequest) (*RequestCancelWorkflowExecutionResponse, error)

+ func (UnimplementedWorkflowServiceServer) ResetStickyTaskQueue(context.Context, *ResetStickyTaskQueueRequest) (*ResetStickyTaskQueueResponse, error)

+ func (UnimplementedWorkflowServiceServer) ResetWorkflowExecution(context.Context, *ResetWorkflowExecutionRequest) (*ResetWorkflowExecutionResponse, error)

+ func (UnimplementedWorkflowServiceServer) RespondActivityTaskCanceled(context.Context, *RespondActivityTaskCanceledRequest) (*RespondActivityTaskCanceledResponse, error)

+ func (UnimplementedWorkflowServiceServer) RespondActivityTaskCanceledById(context.Context, *RespondActivityTaskCanceledByIdRequest) (*RespondActivityTaskCanceledByIdResponse, error)

+ func (UnimplementedWorkflowServiceServer) RespondActivityTaskCompleted(context.Context, *RespondActivityTaskCompletedRequest) (*RespondActivityTaskCompletedResponse, error)

+ func (UnimplementedWorkflowServiceServer) RespondActivityTaskCompletedById(context.Context, *RespondActivityTaskCompletedByIdRequest) (*RespondActivityTaskCompletedByIdResponse, error)

+ func (UnimplementedWorkflowServiceServer) RespondActivityTaskFailed(context.Context, *RespondActivityTaskFailedRequest) (*RespondActivityTaskFailedResponse, error)

+ func (UnimplementedWorkflowServiceServer) RespondActivityTaskFailedById(context.Context, *RespondActivityTaskFailedByIdRequest) (*RespondActivityTaskFailedByIdResponse, error)

+ func (UnimplementedWorkflowServiceServer) RespondQueryTaskCompleted(context.Context, *RespondQueryTaskCompletedRequest) (*RespondQueryTaskCompletedResponse, error)

+ func (UnimplementedWorkflowServiceServer) RespondWorkflowTaskCompleted(context.Context, *RespondWorkflowTaskCompletedRequest) (*RespondWorkflowTaskCompletedResponse, error)

+ func (UnimplementedWorkflowServiceServer) RespondWorkflowTaskFailed(context.Context, *RespondWorkflowTaskFailedRequest) (*RespondWorkflowTaskFailedResponse, error)

+ func (UnimplementedWorkflowServiceServer) ScanWorkflowExecutions(context.Context, *ScanWorkflowExecutionsRequest) (*ScanWorkflowExecutionsResponse, error)

+ func (UnimplementedWorkflowServiceServer) SignalWithStartWorkflowExecution(context.Context, *SignalWithStartWorkflowExecutionRequest) (*SignalWithStartWorkflowExecutionResponse, error)

+ func (UnimplementedWorkflowServiceServer) SignalWorkflowExecution(context.Context, *SignalWorkflowExecutionRequest) (*SignalWorkflowExecutionResponse, error)

+ func (UnimplementedWorkflowServiceServer) StartBatchOperation(context.Context, *StartBatchOperationRequest) (*StartBatchOperationResponse, error)

+ func (UnimplementedWorkflowServiceServer) StartWorkflowExecution(context.Context, *StartWorkflowExecutionRequest) (*StartWorkflowExecutionResponse, error)

+ func (UnimplementedWorkflowServiceServer) StopBatchOperation(context.Context, *StopBatchOperationRequest) (*StopBatchOperationResponse, error)

+ func (UnimplementedWorkflowServiceServer) TerminateWorkflowExecution(context.Context, *TerminateWorkflowExecutionRequest) (*TerminateWorkflowExecutionResponse, error)

+ func (UnimplementedWorkflowServiceServer) UpdateNamespace(context.Context, *UpdateNamespaceRequest) (*UpdateNamespaceResponse, error)

+ func (UnimplementedWorkflowServiceServer) UpdateSchedule(context.Context, *UpdateScheduleRequest) (*UpdateScheduleResponse, error)

+ func (UnimplementedWorkflowServiceServer) UpdateWorkerBuildIdCompatibility(context.Context, *UpdateWorkerBuildIdCompatibilityRequest) (*UpdateWorkerBuildIdCompatibilityResponse, error)

+ func (UnimplementedWorkflowServiceServer) UpdateWorkflowExecution(context.Context, *UpdateWorkflowExecutionRequest) (*UpdateWorkflowExecutionResponse, error)

+ type UnsafeWorkflowServiceServer interface

+ type UpdateNamespaceRequest struct

+ Config *v12.NamespaceConfig

+ DeleteBadBinary string

+ Namespace string

+ PromoteNamespace bool

+ ReplicationConfig *v1.NamespaceReplicationConfig

+ SecurityToken string

+ UpdateInfo *v12.UpdateNamespaceInfo

+ func (*UpdateNamespaceRequest) Descriptor() ([]byte, []int)

+ func (*UpdateNamespaceRequest) ProtoMessage()

+ func (x *UpdateNamespaceRequest) GetConfig() *v12.NamespaceConfig

+ func (x *UpdateNamespaceRequest) GetDeleteBadBinary() string

+ func (x *UpdateNamespaceRequest) GetNamespace() string

+ func (x *UpdateNamespaceRequest) GetPromoteNamespace() bool

+ func (x *UpdateNamespaceRequest) GetReplicationConfig() *v1.NamespaceReplicationConfig

+ func (x *UpdateNamespaceRequest) GetSecurityToken() string

+ func (x *UpdateNamespaceRequest) GetUpdateInfo() *v12.UpdateNamespaceInfo

+ func (x *UpdateNamespaceRequest) ProtoReflect() protoreflect.Message

+ func (x *UpdateNamespaceRequest) Reset()

+ func (x *UpdateNamespaceRequest) String() string

+ type UpdateNamespaceResponse struct

+ Config *v12.NamespaceConfig

+ FailoverVersion int64

+ IsGlobalNamespace bool

+ NamespaceInfo *v12.NamespaceInfo

+ ReplicationConfig *v1.NamespaceReplicationConfig

+ func (*UpdateNamespaceResponse) Descriptor() ([]byte, []int)

+ func (*UpdateNamespaceResponse) ProtoMessage()

+ func (x *UpdateNamespaceResponse) GetConfig() *v12.NamespaceConfig

+ func (x *UpdateNamespaceResponse) GetFailoverVersion() int64

+ func (x *UpdateNamespaceResponse) GetIsGlobalNamespace() bool

+ func (x *UpdateNamespaceResponse) GetNamespaceInfo() *v12.NamespaceInfo

+ func (x *UpdateNamespaceResponse) GetReplicationConfig() *v1.NamespaceReplicationConfig

+ func (x *UpdateNamespaceResponse) ProtoReflect() protoreflect.Message

+ func (x *UpdateNamespaceResponse) Reset()

+ func (x *UpdateNamespaceResponse) String() string

+ type UpdateScheduleRequest struct

+ ConflictToken []byte

+ Identity string

+ Namespace string

+ RequestId string

+ Schedule *v114.Schedule

+ ScheduleId string

+ func (*UpdateScheduleRequest) Descriptor() ([]byte, []int)

+ func (*UpdateScheduleRequest) ProtoMessage()

+ func (x *UpdateScheduleRequest) GetConflictToken() []byte

+ func (x *UpdateScheduleRequest) GetIdentity() string

+ func (x *UpdateScheduleRequest) GetNamespace() string

+ func (x *UpdateScheduleRequest) GetRequestId() string

+ func (x *UpdateScheduleRequest) GetSchedule() *v114.Schedule

+ func (x *UpdateScheduleRequest) GetScheduleId() string

+ func (x *UpdateScheduleRequest) ProtoReflect() protoreflect.Message

+ func (x *UpdateScheduleRequest) Reset()

+ func (x *UpdateScheduleRequest) String() string

+ type UpdateScheduleResponse struct

+ func (*UpdateScheduleResponse) Descriptor() ([]byte, []int)

+ func (*UpdateScheduleResponse) ProtoMessage()

+ func (x *UpdateScheduleResponse) ProtoReflect() protoreflect.Message

+ func (x *UpdateScheduleResponse) Reset()

+ func (x *UpdateScheduleResponse) String() string

+ type UpdateWorkerBuildIdCompatibilityRequest struct

+ Namespace string

+ Operation isUpdateWorkerBuildIdCompatibilityRequest_Operation

+ TaskQueue string

+ func (*UpdateWorkerBuildIdCompatibilityRequest) Descriptor() ([]byte, []int)

+ func (*UpdateWorkerBuildIdCompatibilityRequest) ProtoMessage()

+ func (m *UpdateWorkerBuildIdCompatibilityRequest) GetOperation() isUpdateWorkerBuildIdCompatibilityRequest_Operation

+ func (x *UpdateWorkerBuildIdCompatibilityRequest) GetAddNewBuildIdInNewDefaultSet() string

+ func (x *UpdateWorkerBuildIdCompatibilityRequest) GetAddNewCompatibleBuildId() *UpdateWorkerBuildIdCompatibilityRequest_AddNewCompatibleVersion

+ func (x *UpdateWorkerBuildIdCompatibilityRequest) GetMergeSets() *UpdateWorkerBuildIdCompatibilityRequest_MergeSets

+ func (x *UpdateWorkerBuildIdCompatibilityRequest) GetNamespace() string

+ func (x *UpdateWorkerBuildIdCompatibilityRequest) GetPromoteBuildIdWithinSet() string

+ func (x *UpdateWorkerBuildIdCompatibilityRequest) GetPromoteSetByBuildId() string

+ func (x *UpdateWorkerBuildIdCompatibilityRequest) GetTaskQueue() string

+ func (x *UpdateWorkerBuildIdCompatibilityRequest) ProtoReflect() protoreflect.Message

+ func (x *UpdateWorkerBuildIdCompatibilityRequest) Reset()

+ func (x *UpdateWorkerBuildIdCompatibilityRequest) String() string

+ type UpdateWorkerBuildIdCompatibilityRequest_AddNewBuildIdInNewDefaultSet struct

+ AddNewBuildIdInNewDefaultSet string

+ type UpdateWorkerBuildIdCompatibilityRequest_AddNewCompatibleBuildId struct

+ AddNewCompatibleBuildId *UpdateWorkerBuildIdCompatibilityRequest_AddNewCompatibleVersion

+ type UpdateWorkerBuildIdCompatibilityRequest_AddNewCompatibleVersion struct

+ ExistingCompatibleBuildId string

+ MakeSetDefault bool

+ NewBuildId string

+ func (*UpdateWorkerBuildIdCompatibilityRequest_AddNewCompatibleVersion) Descriptor() ([]byte, []int)

+ func (*UpdateWorkerBuildIdCompatibilityRequest_AddNewCompatibleVersion) ProtoMessage()

+ func (x *UpdateWorkerBuildIdCompatibilityRequest_AddNewCompatibleVersion) GetExistingCompatibleBuildId() string

+ func (x *UpdateWorkerBuildIdCompatibilityRequest_AddNewCompatibleVersion) GetMakeSetDefault() bool

+ func (x *UpdateWorkerBuildIdCompatibilityRequest_AddNewCompatibleVersion) GetNewBuildId() string

+ func (x *UpdateWorkerBuildIdCompatibilityRequest_AddNewCompatibleVersion) ProtoReflect() protoreflect.Message

+ func (x *UpdateWorkerBuildIdCompatibilityRequest_AddNewCompatibleVersion) Reset()

+ func (x *UpdateWorkerBuildIdCompatibilityRequest_AddNewCompatibleVersion) String() string

+ type UpdateWorkerBuildIdCompatibilityRequest_MergeSets struct

+ PrimarySetBuildId string

+ SecondarySetBuildId string

+ func (*UpdateWorkerBuildIdCompatibilityRequest_MergeSets) Descriptor() ([]byte, []int)

+ func (*UpdateWorkerBuildIdCompatibilityRequest_MergeSets) ProtoMessage()

+ func (x *UpdateWorkerBuildIdCompatibilityRequest_MergeSets) GetPrimarySetBuildId() string

+ func (x *UpdateWorkerBuildIdCompatibilityRequest_MergeSets) GetSecondarySetBuildId() string

+ func (x *UpdateWorkerBuildIdCompatibilityRequest_MergeSets) ProtoReflect() protoreflect.Message

+ func (x *UpdateWorkerBuildIdCompatibilityRequest_MergeSets) Reset()

+ func (x *UpdateWorkerBuildIdCompatibilityRequest_MergeSets) String() string

+ type UpdateWorkerBuildIdCompatibilityRequest_MergeSets_ struct

+ MergeSets *UpdateWorkerBuildIdCompatibilityRequest_MergeSets

+ type UpdateWorkerBuildIdCompatibilityRequest_PromoteBuildIdWithinSet struct

+ PromoteBuildIdWithinSet string

+ type UpdateWorkerBuildIdCompatibilityRequest_PromoteSetByBuildId struct

+ PromoteSetByBuildId string

+ type UpdateWorkerBuildIdCompatibilityResponse struct

+ VersionSetId string

+ func (*UpdateWorkerBuildIdCompatibilityResponse) Descriptor() ([]byte, []int)

+ func (*UpdateWorkerBuildIdCompatibilityResponse) ProtoMessage()

+ func (x *UpdateWorkerBuildIdCompatibilityResponse) GetVersionSetId() string

+ func (x *UpdateWorkerBuildIdCompatibilityResponse) ProtoReflect() protoreflect.Message

+ func (x *UpdateWorkerBuildIdCompatibilityResponse) Reset()

+ func (x *UpdateWorkerBuildIdCompatibilityResponse) String() string

+ type UpdateWorkflowExecutionRequest struct

+ FirstExecutionRunId string

+ Namespace string

+ Request *v115.Request

+ WaitPolicy *v115.WaitPolicy

+ WorkflowExecution *v13.WorkflowExecution

+ func (*UpdateWorkflowExecutionRequest) Descriptor() ([]byte, []int)

+ func (*UpdateWorkflowExecutionRequest) ProtoMessage()

+ func (x *UpdateWorkflowExecutionRequest) GetFirstExecutionRunId() string

+ func (x *UpdateWorkflowExecutionRequest) GetNamespace() string

+ func (x *UpdateWorkflowExecutionRequest) GetRequest() *v115.Request

+ func (x *UpdateWorkflowExecutionRequest) GetWaitPolicy() *v115.WaitPolicy

+ func (x *UpdateWorkflowExecutionRequest) GetWorkflowExecution() *v13.WorkflowExecution

+ func (x *UpdateWorkflowExecutionRequest) ProtoReflect() protoreflect.Message

+ func (x *UpdateWorkflowExecutionRequest) Reset()

+ func (x *UpdateWorkflowExecutionRequest) String() string

+ type UpdateWorkflowExecutionResponse struct

+ Outcome *v115.Outcome

+ UpdateRef *v115.UpdateRef

+ func (*UpdateWorkflowExecutionResponse) Descriptor() ([]byte, []int)

+ func (*UpdateWorkflowExecutionResponse) ProtoMessage()

+ func (x *UpdateWorkflowExecutionResponse) GetOutcome() *v115.Outcome

+ func (x *UpdateWorkflowExecutionResponse) GetUpdateRef() *v115.UpdateRef

+ func (x *UpdateWorkflowExecutionResponse) ProtoReflect() protoreflect.Message

+ func (x *UpdateWorkflowExecutionResponse) Reset()

+ func (x *UpdateWorkflowExecutionResponse) String() string

+ type WorkflowServiceClient interface

+ CountWorkflowExecutions func(ctx context.Context, in *CountWorkflowExecutionsRequest, ...) (*CountWorkflowExecutionsResponse, error)

+ CreateSchedule func(ctx context.Context, in *CreateScheduleRequest, opts ...grpc.CallOption) (*CreateScheduleResponse, error)

+ DeleteSchedule func(ctx context.Context, in *DeleteScheduleRequest, opts ...grpc.CallOption) (*DeleteScheduleResponse, error)

+ DeleteWorkflowExecution func(ctx context.Context, in *DeleteWorkflowExecutionRequest, ...) (*DeleteWorkflowExecutionResponse, error)

+ DeprecateNamespace func(ctx context.Context, in *DeprecateNamespaceRequest, opts ...grpc.CallOption) (*DeprecateNamespaceResponse, error)

+ DescribeBatchOperation func(ctx context.Context, in *DescribeBatchOperationRequest, ...) (*DescribeBatchOperationResponse, error)

+ DescribeNamespace func(ctx context.Context, in *DescribeNamespaceRequest, opts ...grpc.CallOption) (*DescribeNamespaceResponse, error)

+ DescribeSchedule func(ctx context.Context, in *DescribeScheduleRequest, opts ...grpc.CallOption) (*DescribeScheduleResponse, error)

+ DescribeTaskQueue func(ctx context.Context, in *DescribeTaskQueueRequest, opts ...grpc.CallOption) (*DescribeTaskQueueResponse, error)

+ DescribeWorkflowExecution func(ctx context.Context, in *DescribeWorkflowExecutionRequest, ...) (*DescribeWorkflowExecutionResponse, error)

+ GetClusterInfo func(ctx context.Context, in *GetClusterInfoRequest, opts ...grpc.CallOption) (*GetClusterInfoResponse, error)

+ GetSearchAttributes func(ctx context.Context, in *GetSearchAttributesRequest, opts ...grpc.CallOption) (*GetSearchAttributesResponse, error)

+ GetSystemInfo func(ctx context.Context, in *GetSystemInfoRequest, opts ...grpc.CallOption) (*GetSystemInfoResponse, error)

+ GetWorkerBuildIdCompatibility func(ctx context.Context, in *GetWorkerBuildIdCompatibilityRequest, ...) (*GetWorkerBuildIdCompatibilityResponse, error)

+ GetWorkerTaskReachability func(ctx context.Context, in *GetWorkerTaskReachabilityRequest, ...) (*GetWorkerTaskReachabilityResponse, error)

+ GetWorkflowExecutionHistory func(ctx context.Context, in *GetWorkflowExecutionHistoryRequest, ...) (*GetWorkflowExecutionHistoryResponse, error)

+ GetWorkflowExecutionHistoryReverse func(ctx context.Context, in *GetWorkflowExecutionHistoryReverseRequest, ...) (*GetWorkflowExecutionHistoryReverseResponse, error)

+ ListArchivedWorkflowExecutions func(ctx context.Context, in *ListArchivedWorkflowExecutionsRequest, ...) (*ListArchivedWorkflowExecutionsResponse, error)

+ ListBatchOperations func(ctx context.Context, in *ListBatchOperationsRequest, opts ...grpc.CallOption) (*ListBatchOperationsResponse, error)

+ ListClosedWorkflowExecutions func(ctx context.Context, in *ListClosedWorkflowExecutionsRequest, ...) (*ListClosedWorkflowExecutionsResponse, error)

+ ListNamespaces func(ctx context.Context, in *ListNamespacesRequest, opts ...grpc.CallOption) (*ListNamespacesResponse, error)

+ ListOpenWorkflowExecutions func(ctx context.Context, in *ListOpenWorkflowExecutionsRequest, ...) (*ListOpenWorkflowExecutionsResponse, error)

+ ListScheduleMatchingTimes func(ctx context.Context, in *ListScheduleMatchingTimesRequest, ...) (*ListScheduleMatchingTimesResponse, error)

+ ListSchedules func(ctx context.Context, in *ListSchedulesRequest, opts ...grpc.CallOption) (*ListSchedulesResponse, error)

+ ListTaskQueuePartitions func(ctx context.Context, in *ListTaskQueuePartitionsRequest, ...) (*ListTaskQueuePartitionsResponse, error)

+ ListWorkflowExecutions func(ctx context.Context, in *ListWorkflowExecutionsRequest, ...) (*ListWorkflowExecutionsResponse, error)

+ PatchSchedule func(ctx context.Context, in *PatchScheduleRequest, opts ...grpc.CallOption) (*PatchScheduleResponse, error)

+ PollActivityTaskQueue func(ctx context.Context, in *PollActivityTaskQueueRequest, opts ...grpc.CallOption) (*PollActivityTaskQueueResponse, error)

+ PollWorkflowExecutionUpdate func(ctx context.Context, in *PollWorkflowExecutionUpdateRequest, ...) (*PollWorkflowExecutionUpdateResponse, error)

+ PollWorkflowTaskQueue func(ctx context.Context, in *PollWorkflowTaskQueueRequest, opts ...grpc.CallOption) (*PollWorkflowTaskQueueResponse, error)

+ QueryWorkflow func(ctx context.Context, in *QueryWorkflowRequest, opts ...grpc.CallOption) (*QueryWorkflowResponse, error)

+ RecordActivityTaskHeartbeat func(ctx context.Context, in *RecordActivityTaskHeartbeatRequest, ...) (*RecordActivityTaskHeartbeatResponse, error)

+ RecordActivityTaskHeartbeatById func(ctx context.Context, in *RecordActivityTaskHeartbeatByIdRequest, ...) (*RecordActivityTaskHeartbeatByIdResponse, error)

+ RegisterNamespace func(ctx context.Context, in *RegisterNamespaceRequest, opts ...grpc.CallOption) (*RegisterNamespaceResponse, error)

+ RequestCancelWorkflowExecution func(ctx context.Context, in *RequestCancelWorkflowExecutionRequest, ...) (*RequestCancelWorkflowExecutionResponse, error)

+ ResetStickyTaskQueue func(ctx context.Context, in *ResetStickyTaskQueueRequest, opts ...grpc.CallOption) (*ResetStickyTaskQueueResponse, error)

+ ResetWorkflowExecution func(ctx context.Context, in *ResetWorkflowExecutionRequest, ...) (*ResetWorkflowExecutionResponse, error)

+ RespondActivityTaskCanceled func(ctx context.Context, in *RespondActivityTaskCanceledRequest, ...) (*RespondActivityTaskCanceledResponse, error)

+ RespondActivityTaskCanceledById func(ctx context.Context, in *RespondActivityTaskCanceledByIdRequest, ...) (*RespondActivityTaskCanceledByIdResponse, error)

+ RespondActivityTaskCompleted func(ctx context.Context, in *RespondActivityTaskCompletedRequest, ...) (*RespondActivityTaskCompletedResponse, error)

+ RespondActivityTaskCompletedById func(ctx context.Context, in *RespondActivityTaskCompletedByIdRequest, ...) (*RespondActivityTaskCompletedByIdResponse, error)

+ RespondActivityTaskFailed func(ctx context.Context, in *RespondActivityTaskFailedRequest, ...) (*RespondActivityTaskFailedResponse, error)

+ RespondActivityTaskFailedById func(ctx context.Context, in *RespondActivityTaskFailedByIdRequest, ...) (*RespondActivityTaskFailedByIdResponse, error)

+ RespondQueryTaskCompleted func(ctx context.Context, in *RespondQueryTaskCompletedRequest, ...) (*RespondQueryTaskCompletedResponse, error)

+ RespondWorkflowTaskCompleted func(ctx context.Context, in *RespondWorkflowTaskCompletedRequest, ...) (*RespondWorkflowTaskCompletedResponse, error)

+ RespondWorkflowTaskFailed func(ctx context.Context, in *RespondWorkflowTaskFailedRequest, ...) (*RespondWorkflowTaskFailedResponse, error)

+ ScanWorkflowExecutions func(ctx context.Context, in *ScanWorkflowExecutionsRequest, ...) (*ScanWorkflowExecutionsResponse, error)

+ SignalWithStartWorkflowExecution func(ctx context.Context, in *SignalWithStartWorkflowExecutionRequest, ...) (*SignalWithStartWorkflowExecutionResponse, error)

+ SignalWorkflowExecution func(ctx context.Context, in *SignalWorkflowExecutionRequest, ...) (*SignalWorkflowExecutionResponse, error)

+ StartBatchOperation func(ctx context.Context, in *StartBatchOperationRequest, opts ...grpc.CallOption) (*StartBatchOperationResponse, error)

+ StartWorkflowExecution func(ctx context.Context, in *StartWorkflowExecutionRequest, ...) (*StartWorkflowExecutionResponse, error)

+ StopBatchOperation func(ctx context.Context, in *StopBatchOperationRequest, opts ...grpc.CallOption) (*StopBatchOperationResponse, error)

+ TerminateWorkflowExecution func(ctx context.Context, in *TerminateWorkflowExecutionRequest, ...) (*TerminateWorkflowExecutionResponse, error)

+ UpdateNamespace func(ctx context.Context, in *UpdateNamespaceRequest, opts ...grpc.CallOption) (*UpdateNamespaceResponse, error)

+ UpdateSchedule func(ctx context.Context, in *UpdateScheduleRequest, opts ...grpc.CallOption) (*UpdateScheduleResponse, error)

+ UpdateWorkerBuildIdCompatibility func(ctx context.Context, in *UpdateWorkerBuildIdCompatibilityRequest, ...) (*UpdateWorkerBuildIdCompatibilityResponse, error)

+ UpdateWorkflowExecution func(ctx context.Context, in *UpdateWorkflowExecutionRequest, ...) (*UpdateWorkflowExecutionResponse, error)

+ func NewWorkflowServiceClient(cc grpc.ClientConnInterface) WorkflowServiceClient

+ type WorkflowServiceServer interface

+ CountWorkflowExecutions func(context.Context, *CountWorkflowExecutionsRequest) (*CountWorkflowExecutionsResponse, error)

+ CreateSchedule func(context.Context, *CreateScheduleRequest) (*CreateScheduleResponse, error)

+ DeleteSchedule func(context.Context, *DeleteScheduleRequest) (*DeleteScheduleResponse, error)

+ DeleteWorkflowExecution func(context.Context, *DeleteWorkflowExecutionRequest) (*DeleteWorkflowExecutionResponse, error)

+ DeprecateNamespace func(context.Context, *DeprecateNamespaceRequest) (*DeprecateNamespaceResponse, error)

+ DescribeBatchOperation func(context.Context, *DescribeBatchOperationRequest) (*DescribeBatchOperationResponse, error)

+ DescribeNamespace func(context.Context, *DescribeNamespaceRequest) (*DescribeNamespaceResponse, error)

+ DescribeSchedule func(context.Context, *DescribeScheduleRequest) (*DescribeScheduleResponse, error)

+ DescribeTaskQueue func(context.Context, *DescribeTaskQueueRequest) (*DescribeTaskQueueResponse, error)

+ DescribeWorkflowExecution func(context.Context, *DescribeWorkflowExecutionRequest) (*DescribeWorkflowExecutionResponse, error)

+ GetClusterInfo func(context.Context, *GetClusterInfoRequest) (*GetClusterInfoResponse, error)

+ GetSearchAttributes func(context.Context, *GetSearchAttributesRequest) (*GetSearchAttributesResponse, error)

+ GetSystemInfo func(context.Context, *GetSystemInfoRequest) (*GetSystemInfoResponse, error)

+ GetWorkerBuildIdCompatibility func(context.Context, *GetWorkerBuildIdCompatibilityRequest) (*GetWorkerBuildIdCompatibilityResponse, error)

+ GetWorkerTaskReachability func(context.Context, *GetWorkerTaskReachabilityRequest) (*GetWorkerTaskReachabilityResponse, error)

+ GetWorkflowExecutionHistory func(context.Context, *GetWorkflowExecutionHistoryRequest) (*GetWorkflowExecutionHistoryResponse, error)

+ GetWorkflowExecutionHistoryReverse func(context.Context, *GetWorkflowExecutionHistoryReverseRequest) (*GetWorkflowExecutionHistoryReverseResponse, error)

+ ListArchivedWorkflowExecutions func(context.Context, *ListArchivedWorkflowExecutionsRequest) (*ListArchivedWorkflowExecutionsResponse, error)

+ ListBatchOperations func(context.Context, *ListBatchOperationsRequest) (*ListBatchOperationsResponse, error)

+ ListClosedWorkflowExecutions func(context.Context, *ListClosedWorkflowExecutionsRequest) (*ListClosedWorkflowExecutionsResponse, error)

+ ListNamespaces func(context.Context, *ListNamespacesRequest) (*ListNamespacesResponse, error)

+ ListOpenWorkflowExecutions func(context.Context, *ListOpenWorkflowExecutionsRequest) (*ListOpenWorkflowExecutionsResponse, error)

+ ListScheduleMatchingTimes func(context.Context, *ListScheduleMatchingTimesRequest) (*ListScheduleMatchingTimesResponse, error)

+ ListSchedules func(context.Context, *ListSchedulesRequest) (*ListSchedulesResponse, error)

+ ListTaskQueuePartitions func(context.Context, *ListTaskQueuePartitionsRequest) (*ListTaskQueuePartitionsResponse, error)

+ ListWorkflowExecutions func(context.Context, *ListWorkflowExecutionsRequest) (*ListWorkflowExecutionsResponse, error)

+ PatchSchedule func(context.Context, *PatchScheduleRequest) (*PatchScheduleResponse, error)

+ PollActivityTaskQueue func(context.Context, *PollActivityTaskQueueRequest) (*PollActivityTaskQueueResponse, error)

+ PollWorkflowExecutionUpdate func(context.Context, *PollWorkflowExecutionUpdateRequest) (*PollWorkflowExecutionUpdateResponse, error)

+ PollWorkflowTaskQueue func(context.Context, *PollWorkflowTaskQueueRequest) (*PollWorkflowTaskQueueResponse, error)

+ QueryWorkflow func(context.Context, *QueryWorkflowRequest) (*QueryWorkflowResponse, error)

+ RecordActivityTaskHeartbeat func(context.Context, *RecordActivityTaskHeartbeatRequest) (*RecordActivityTaskHeartbeatResponse, error)

+ RecordActivityTaskHeartbeatById func(context.Context, *RecordActivityTaskHeartbeatByIdRequest) (*RecordActivityTaskHeartbeatByIdResponse, error)

+ RegisterNamespace func(context.Context, *RegisterNamespaceRequest) (*RegisterNamespaceResponse, error)

+ RequestCancelWorkflowExecution func(context.Context, *RequestCancelWorkflowExecutionRequest) (*RequestCancelWorkflowExecutionResponse, error)

+ ResetStickyTaskQueue func(context.Context, *ResetStickyTaskQueueRequest) (*ResetStickyTaskQueueResponse, error)

+ ResetWorkflowExecution func(context.Context, *ResetWorkflowExecutionRequest) (*ResetWorkflowExecutionResponse, error)

+ RespondActivityTaskCanceled func(context.Context, *RespondActivityTaskCanceledRequest) (*RespondActivityTaskCanceledResponse, error)

+ RespondActivityTaskCanceledById func(context.Context, *RespondActivityTaskCanceledByIdRequest) (*RespondActivityTaskCanceledByIdResponse, error)

+ RespondActivityTaskCompleted func(context.Context, *RespondActivityTaskCompletedRequest) (*RespondActivityTaskCompletedResponse, error)

+ RespondActivityTaskCompletedById func(context.Context, *RespondActivityTaskCompletedByIdRequest) (*RespondActivityTaskCompletedByIdResponse, error)

+ RespondActivityTaskFailed func(context.Context, *RespondActivityTaskFailedRequest) (*RespondActivityTaskFailedResponse, error)

+ RespondActivityTaskFailedById func(context.Context, *RespondActivityTaskFailedByIdRequest) (*RespondActivityTaskFailedByIdResponse, error)

+ RespondQueryTaskCompleted func(context.Context, *RespondQueryTaskCompletedRequest) (*RespondQueryTaskCompletedResponse, error)

+ RespondWorkflowTaskCompleted func(context.Context, *RespondWorkflowTaskCompletedRequest) (*RespondWorkflowTaskCompletedResponse, error)

+ RespondWorkflowTaskFailed func(context.Context, *RespondWorkflowTaskFailedRequest) (*RespondWorkflowTaskFailedResponse, error)

+ ScanWorkflowExecutions func(context.Context, *ScanWorkflowExecutionsRequest) (*ScanWorkflowExecutionsResponse, error)

+ SignalWithStartWorkflowExecution func(context.Context, *SignalWithStartWorkflowExecutionRequest) (*SignalWithStartWorkflowExecutionResponse, error)

+ SignalWorkflowExecution func(context.Context, *SignalWorkflowExecutionRequest) (*SignalWorkflowExecutionResponse, error)

+ StartBatchOperation func(context.Context, *StartBatchOperationRequest) (*StartBatchOperationResponse, error)

+ StartWorkflowExecution func(context.Context, *StartWorkflowExecutionRequest) (*StartWorkflowExecutionResponse, error)

+ StopBatchOperation func(context.Context, *StopBatchOperationRequest) (*StopBatchOperationResponse, error)

+ TerminateWorkflowExecution func(context.Context, *TerminateWorkflowExecutionRequest) (*TerminateWorkflowExecutionResponse, error)

+ UpdateNamespace func(context.Context, *UpdateNamespaceRequest) (*UpdateNamespaceResponse, error)

+ UpdateSchedule func(context.Context, *UpdateScheduleRequest) (*UpdateScheduleResponse, error)

+ UpdateWorkerBuildIdCompatibility func(context.Context, *UpdateWorkerBuildIdCompatibilityRequest) (*UpdateWorkerBuildIdCompatibilityResponse, error)

+ UpdateWorkflowExecution func(context.Context, *UpdateWorkflowExecutionRequest) (*UpdateWorkflowExecutionResponse, error)

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