historyservice

Sep 25, 2024

retracted

Changes in this version

+ const HistoryService_SyncWorkflowState_FullMethodName

+ const HistoryService_UpdateActivityOptions_FullMethodName

type GetMutableStateResponse

+ TransitionHistory []*v19.VersionedTransition

+ func (x *GetMutableStateResponse) GetTransitionHistory() []*v19.VersionedTransition

type HistoryServiceClient

+ SyncWorkflowState func(ctx context.Context, in *SyncWorkflowStateRequest, opts ...grpc.CallOption) (*SyncWorkflowStateResponse, error)

+ UpdateActivityOptions func(ctx context.Context, in *UpdateActivityOptionsRequest, opts ...grpc.CallOption) (*UpdateActivityOptionsResponse, error)

type HistoryServiceServer

+ SyncWorkflowState func(context.Context, *SyncWorkflowStateRequest) (*SyncWorkflowStateResponse, error)

+ UpdateActivityOptions func(context.Context, *UpdateActivityOptionsRequest) (*UpdateActivityOptionsResponse, error)

+ type SyncWorkflowStateRequest struct

+ Execution *v14.WorkflowExecution

+ NamespaceId string

+ TargetClusterId int32

+ VersionHistories *v16.VersionHistories

+ VersionedTransition *v19.VersionedTransition

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

+ func (*SyncWorkflowStateRequest) ProtoMessage()

+ func (this *SyncWorkflowStateRequest) Equal(that interface{}) bool

+ func (val *SyncWorkflowStateRequest) Marshal() ([]byte, error)

+ func (val *SyncWorkflowStateRequest) Size() int

+ func (val *SyncWorkflowStateRequest) Unmarshal(buf []byte) error

+ func (x *SyncWorkflowStateRequest) GetExecution() *v14.WorkflowExecution

+ func (x *SyncWorkflowStateRequest) GetNamespaceId() string

+ func (x *SyncWorkflowStateRequest) GetTargetClusterId() int32

+ func (x *SyncWorkflowStateRequest) GetVersionHistories() *v16.VersionHistories

+ func (x *SyncWorkflowStateRequest) GetVersionedTransition() *v19.VersionedTransition

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

+ func (x *SyncWorkflowStateRequest) Reset()

+ func (x *SyncWorkflowStateRequest) String() string

+ type SyncWorkflowStateResponse struct

+ Attributes isSyncWorkflowStateResponse_Attributes

+ EventBatches []*v14.DataBlob

+ NewRunInfo *v116.NewRunInfo

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

+ func (*SyncWorkflowStateResponse) ProtoMessage()

+ func (m *SyncWorkflowStateResponse) GetAttributes() isSyncWorkflowStateResponse_Attributes

+ func (this *SyncWorkflowStateResponse) Equal(that interface{}) bool

+ func (val *SyncWorkflowStateResponse) Marshal() ([]byte, error)

+ func (val *SyncWorkflowStateResponse) Size() int

+ func (val *SyncWorkflowStateResponse) Unmarshal(buf []byte) error

+ func (x *SyncWorkflowStateResponse) GetEventBatches() []*v14.DataBlob

+ func (x *SyncWorkflowStateResponse) GetMutation() *v116.SyncWorkflowStateMutationAttributes

+ func (x *SyncWorkflowStateResponse) GetNewRunInfo() *v116.NewRunInfo

+ func (x *SyncWorkflowStateResponse) GetSnapshot() *v116.SyncWorkflowStateSnapshotAttributes

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

+ func (x *SyncWorkflowStateResponse) Reset()

+ func (x *SyncWorkflowStateResponse) String() string

+ type SyncWorkflowStateResponse_Mutation struct

+ Mutation *v116.SyncWorkflowStateMutationAttributes

+ type SyncWorkflowStateResponse_Snapshot struct

+ Snapshot *v116.SyncWorkflowStateSnapshotAttributes

type UnimplementedHistoryServiceServer

+ func (UnimplementedHistoryServiceServer) SyncWorkflowState(context.Context, *SyncWorkflowStateRequest) (*SyncWorkflowStateResponse, error)

+ func (UnimplementedHistoryServiceServer) UpdateActivityOptions(context.Context, *UpdateActivityOptionsRequest) (*UpdateActivityOptionsResponse, error)

+ type UpdateActivityOptionsRequest struct

+ NamespaceId string

+ UpdateRequest *v1.UpdateActivityOptionsByIdRequest

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

+ func (*UpdateActivityOptionsRequest) ProtoMessage()

+ func (this *UpdateActivityOptionsRequest) Equal(that interface{}) bool

+ func (val *UpdateActivityOptionsRequest) Marshal() ([]byte, error)

+ func (val *UpdateActivityOptionsRequest) Size() int

+ func (val *UpdateActivityOptionsRequest) Unmarshal(buf []byte) error

+ func (x *UpdateActivityOptionsRequest) GetNamespaceId() string

+ func (x *UpdateActivityOptionsRequest) GetUpdateRequest() *v1.UpdateActivityOptionsByIdRequest

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

+ func (x *UpdateActivityOptionsRequest) Reset()

+ func (x *UpdateActivityOptionsRequest) String() string

+ type UpdateActivityOptionsResponse struct

+ ActivityOptions *v121.ActivityOptions

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

+ func (*UpdateActivityOptionsResponse) ProtoMessage()

+ func (this *UpdateActivityOptionsResponse) Equal(that interface{}) bool

+ func (val *UpdateActivityOptionsResponse) Marshal() ([]byte, error)

+ func (val *UpdateActivityOptionsResponse) Size() int

+ func (val *UpdateActivityOptionsResponse) Unmarshal(buf []byte) error

+ func (x *UpdateActivityOptionsResponse) GetActivityOptions() *v121.ActivityOptions

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

+ func (x *UpdateActivityOptionsResponse) Reset()

+ func (x *UpdateActivityOptionsResponse) String() string

Sep 6, 2024

Changes in this version

+ const HistoryService_DeepHealthCheck_FullMethodName

+ const HistoryService_InvokeStateMachineMethod_FullMethodName

type ActivitySyncInfo

+ LastStartedBuildId string

+ LastStartedRedirectCounter int64

+ func (x *ActivitySyncInfo) GetLastStartedBuildId() string

+ func (x *ActivitySyncInfo) GetLastStartedRedirectCounter() int64

+ type DeepHealthCheckRequest struct

+ HostAddress string

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

+ func (*DeepHealthCheckRequest) ProtoMessage()

+ func (this *DeepHealthCheckRequest) Equal(that interface{}) bool

+ func (val *DeepHealthCheckRequest) Marshal() ([]byte, error)

+ func (val *DeepHealthCheckRequest) Size() int

+ func (val *DeepHealthCheckRequest) Unmarshal(buf []byte) error

+ func (x *DeepHealthCheckRequest) GetHostAddress() string

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

+ func (x *DeepHealthCheckRequest) Reset()

+ func (x *DeepHealthCheckRequest) String() string

+ type DeepHealthCheckResponse struct

+ State v18.HealthState

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

+ func (*DeepHealthCheckResponse) ProtoMessage()

+ func (this *DeepHealthCheckResponse) Equal(that interface{}) bool

+ func (val *DeepHealthCheckResponse) Marshal() ([]byte, error)

+ func (val *DeepHealthCheckResponse) Size() int

+ func (val *DeepHealthCheckResponse) Unmarshal(buf []byte) error

+ func (x *DeepHealthCheckResponse) GetState() v18.HealthState

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

+ func (x *DeepHealthCheckResponse) Reset()

+ func (x *DeepHealthCheckResponse) String() string

type HistoryServiceClient

+ DeepHealthCheck func(ctx context.Context, in *DeepHealthCheckRequest, opts ...grpc.CallOption) (*DeepHealthCheckResponse, error)

+ InvokeStateMachineMethod func(ctx context.Context, in *InvokeStateMachineMethodRequest, ...) (*InvokeStateMachineMethodResponse, error)

type HistoryServiceServer

+ DeepHealthCheck func(context.Context, *DeepHealthCheckRequest) (*DeepHealthCheckResponse, error)

+ InvokeStateMachineMethod func(context.Context, *InvokeStateMachineMethodRequest) (*InvokeStateMachineMethodResponse, error)

+ type InvokeStateMachineMethodRequest struct

+ Input []byte

+ MethodName string

+ NamespaceId string

+ Ref *v114.StateMachineRef

+ RunId string

+ WorkflowId string

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

+ func (*InvokeStateMachineMethodRequest) ProtoMessage()

+ func (this *InvokeStateMachineMethodRequest) Equal(that interface{}) bool

+ func (val *InvokeStateMachineMethodRequest) Marshal() ([]byte, error)

+ func (val *InvokeStateMachineMethodRequest) Size() int

+ func (val *InvokeStateMachineMethodRequest) Unmarshal(buf []byte) error

+ func (x *InvokeStateMachineMethodRequest) GetInput() []byte

+ func (x *InvokeStateMachineMethodRequest) GetMethodName() string

+ func (x *InvokeStateMachineMethodRequest) GetNamespaceId() string

+ func (x *InvokeStateMachineMethodRequest) GetRef() *v114.StateMachineRef

+ func (x *InvokeStateMachineMethodRequest) GetRunId() string

+ func (x *InvokeStateMachineMethodRequest) GetWorkflowId() string

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

+ func (x *InvokeStateMachineMethodRequest) Reset()

+ func (x *InvokeStateMachineMethodRequest) String() string

+ type InvokeStateMachineMethodResponse struct

+ Output []byte

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

+ func (*InvokeStateMachineMethodResponse) ProtoMessage()

+ func (this *InvokeStateMachineMethodResponse) Equal(that interface{}) bool

+ func (val *InvokeStateMachineMethodResponse) Marshal() ([]byte, error)

+ func (val *InvokeStateMachineMethodResponse) Size() int

+ func (val *InvokeStateMachineMethodResponse) Unmarshal(buf []byte) error

+ func (x *InvokeStateMachineMethodResponse) GetOutput() []byte

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

+ func (x *InvokeStateMachineMethodResponse) Reset()

+ func (x *InvokeStateMachineMethodResponse) String() string

type RecordActivityTaskStartedRequest

+ BuildIdRedirectInfo *v19.BuildIdRedirectInfo

+ func (x *RecordActivityTaskStartedRequest) GetBuildIdRedirectInfo() *v19.BuildIdRedirectInfo

type RecordWorkflowTaskStartedRequest

+ BuildIdRedirectInfo *v19.BuildIdRedirectInfo

+ func (x *RecordWorkflowTaskStartedRequest) GetBuildIdRedirectInfo() *v19.BuildIdRedirectInfo

type SyncActivityRequest

+ LastStartedBuildId string

+ LastStartedRedirectCounter int64

+ func (x *SyncActivityRequest) GetLastStartedBuildId() string

+ func (x *SyncActivityRequest) GetLastStartedRedirectCounter() int64

type UnimplementedHistoryServiceServer

+ func (UnimplementedHistoryServiceServer) DeepHealthCheck(context.Context, *DeepHealthCheckRequest) (*DeepHealthCheckResponse, error)

+ func (UnimplementedHistoryServiceServer) InvokeStateMachineMethod(context.Context, *InvokeStateMachineMethodRequest) (*InvokeStateMachineMethodResponse, error)

May 31, 2024

Changes in this version

+ const HistoryService_CompleteNexusOperation_FullMethodName

+ const HistoryService_ExecuteMultiOperation_FullMethodName

+ const HistoryService_GetWorkflowExecutionRawHistory_FullMethodName

+ const HistoryService_ListTasks_FullMethodName

+ type ActivitySyncInfo struct

+ Attempt int32

+ Details *v14.Payloads

+ LastFailure *v13.Failure

+ LastHeartbeatTime *timestamppb.Timestamp

+ LastWorkerIdentity string

+ ScheduledEventId int64

+ ScheduledTime *timestamppb.Timestamp

+ StartedEventId int64

+ StartedTime *timestamppb.Timestamp

+ Version int64

+ VersionHistory *v16.VersionHistory

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

+ func (*ActivitySyncInfo) ProtoMessage()

+ func (this *ActivitySyncInfo) Equal(that interface{}) bool

+ func (val *ActivitySyncInfo) Marshal() ([]byte, error)

+ func (val *ActivitySyncInfo) Size() int

+ func (val *ActivitySyncInfo) Unmarshal(buf []byte) error

+ func (x *ActivitySyncInfo) GetAttempt() int32

+ func (x *ActivitySyncInfo) GetDetails() *v14.Payloads

+ func (x *ActivitySyncInfo) GetLastFailure() *v13.Failure

+ func (x *ActivitySyncInfo) GetLastHeartbeatTime() *timestamppb.Timestamp

+ func (x *ActivitySyncInfo) GetLastWorkerIdentity() string

+ func (x *ActivitySyncInfo) GetScheduledEventId() int64

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

+ func (x *ActivitySyncInfo) GetStartedEventId() int64

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

+ func (x *ActivitySyncInfo) GetVersion() int64

+ func (x *ActivitySyncInfo) GetVersionHistory() *v16.VersionHistory

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

+ func (x *ActivitySyncInfo) Reset()

+ func (x *ActivitySyncInfo) String() string

+ type CompleteNexusOperationRequest struct

+ Completion *v118.NexusOperationCompletion

+ Outcome isCompleteNexusOperationRequest_Outcome

+ State string

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

+ func (*CompleteNexusOperationRequest) ProtoMessage()

+ func (m *CompleteNexusOperationRequest) GetOutcome() isCompleteNexusOperationRequest_Outcome

+ func (this *CompleteNexusOperationRequest) Equal(that interface{}) bool

+ func (val *CompleteNexusOperationRequest) Marshal() ([]byte, error)

+ func (val *CompleteNexusOperationRequest) Size() int

+ func (val *CompleteNexusOperationRequest) Unmarshal(buf []byte) error

+ func (x *CompleteNexusOperationRequest) GetCompletion() *v118.NexusOperationCompletion

+ func (x *CompleteNexusOperationRequest) GetFailure() *v119.Failure

+ func (x *CompleteNexusOperationRequest) GetState() string

+ func (x *CompleteNexusOperationRequest) GetSuccess() *v14.Payload

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

+ func (x *CompleteNexusOperationRequest) Reset()

+ func (x *CompleteNexusOperationRequest) String() string

+ type CompleteNexusOperationRequest_Failure struct

+ Failure *v119.Failure

+ type CompleteNexusOperationRequest_Success struct

+ Success *v14.Payload

+ type CompleteNexusOperationResponse struct

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

+ func (*CompleteNexusOperationResponse) ProtoMessage()

+ func (this *CompleteNexusOperationResponse) Equal(that interface{}) bool

+ func (val *CompleteNexusOperationResponse) Marshal() ([]byte, error)

+ func (val *CompleteNexusOperationResponse) Size() int

+ func (val *CompleteNexusOperationResponse) Unmarshal(buf []byte) error

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

+ func (x *CompleteNexusOperationResponse) Reset()

+ func (x *CompleteNexusOperationResponse) String() string

type DescribeWorkflowExecutionResponse

+ Callbacks []*v112.CallbackInfo

+ PendingNexusOperations []*v112.PendingNexusOperationInfo

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

+ func (x *DescribeWorkflowExecutionResponse) GetPendingNexusOperations() []*v112.PendingNexusOperationInfo

+ type ExecuteMultiOperationRequest struct

+ NamespaceId string

+ Operations []*ExecuteMultiOperationRequest_Operation

+ WorkflowId string

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

+ func (*ExecuteMultiOperationRequest) ProtoMessage()

+ func (this *ExecuteMultiOperationRequest) Equal(that interface{}) bool

+ func (val *ExecuteMultiOperationRequest) Marshal() ([]byte, error)

+ func (val *ExecuteMultiOperationRequest) Size() int

+ func (val *ExecuteMultiOperationRequest) Unmarshal(buf []byte) error

+ func (x *ExecuteMultiOperationRequest) GetNamespaceId() string

+ func (x *ExecuteMultiOperationRequest) GetOperations() []*ExecuteMultiOperationRequest_Operation

+ func (x *ExecuteMultiOperationRequest) GetWorkflowId() string

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

+ func (x *ExecuteMultiOperationRequest) Reset()

+ func (x *ExecuteMultiOperationRequest) String() string

+ type ExecuteMultiOperationRequest_Operation struct

+ Operation isExecuteMultiOperationRequest_Operation_Operation

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

+ func (*ExecuteMultiOperationRequest_Operation) ProtoMessage()

+ func (m *ExecuteMultiOperationRequest_Operation) GetOperation() isExecuteMultiOperationRequest_Operation_Operation

+ func (x *ExecuteMultiOperationRequest_Operation) GetStartWorkflow() *StartWorkflowExecutionRequest

+ func (x *ExecuteMultiOperationRequest_Operation) GetUpdateWorkflow() *UpdateWorkflowExecutionRequest

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

+ func (x *ExecuteMultiOperationRequest_Operation) Reset()

+ func (x *ExecuteMultiOperationRequest_Operation) String() string

+ type ExecuteMultiOperationRequest_Operation_StartWorkflow struct

+ StartWorkflow *StartWorkflowExecutionRequest

+ type ExecuteMultiOperationRequest_Operation_UpdateWorkflow struct

+ UpdateWorkflow *UpdateWorkflowExecutionRequest

+ type ExecuteMultiOperationResponse struct

+ Responses []*ExecuteMultiOperationResponse_Response

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

+ func (*ExecuteMultiOperationResponse) ProtoMessage()

+ func (this *ExecuteMultiOperationResponse) Equal(that interface{}) bool

+ func (val *ExecuteMultiOperationResponse) Marshal() ([]byte, error)

+ func (val *ExecuteMultiOperationResponse) Size() int

+ func (val *ExecuteMultiOperationResponse) Unmarshal(buf []byte) error

+ func (x *ExecuteMultiOperationResponse) GetResponses() []*ExecuteMultiOperationResponse_Response

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

+ func (x *ExecuteMultiOperationResponse) Reset()

+ func (x *ExecuteMultiOperationResponse) String() string

+ type ExecuteMultiOperationResponse_Response struct

+ Response isExecuteMultiOperationResponse_Response_Response

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

+ func (*ExecuteMultiOperationResponse_Response) ProtoMessage()

+ func (m *ExecuteMultiOperationResponse_Response) GetResponse() isExecuteMultiOperationResponse_Response_Response

+ func (x *ExecuteMultiOperationResponse_Response) GetStartWorkflow() *StartWorkflowExecutionResponse

+ func (x *ExecuteMultiOperationResponse_Response) GetUpdateWorkflow() *UpdateWorkflowExecutionResponse

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

+ func (x *ExecuteMultiOperationResponse_Response) Reset()

+ func (x *ExecuteMultiOperationResponse_Response) String() string

+ type ExecuteMultiOperationResponse_Response_StartWorkflow struct

+ StartWorkflow *StartWorkflowExecutionResponse

+ type ExecuteMultiOperationResponse_Response_UpdateWorkflow struct

+ UpdateWorkflow *UpdateWorkflowExecutionResponse

type GetMutableStateResponse

+ AssignedBuildId string

+ InheritedBuildId string

+ MostRecentWorkerVersionStamp *v14.WorkerVersionStamp

+ func (x *GetMutableStateResponse) GetAssignedBuildId() string

+ func (x *GetMutableStateResponse) GetInheritedBuildId() string

+ func (x *GetMutableStateResponse) GetMostRecentWorkerVersionStamp() *v14.WorkerVersionStamp

+ type GetWorkflowExecutionRawHistoryRequest struct

+ NamespaceId string

+ Request *v116.GetWorkflowExecutionRawHistoryRequest

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

+ func (*GetWorkflowExecutionRawHistoryRequest) ProtoMessage()

+ func (this *GetWorkflowExecutionRawHistoryRequest) Equal(that interface{}) bool

+ func (val *GetWorkflowExecutionRawHistoryRequest) Marshal() ([]byte, error)

+ func (val *GetWorkflowExecutionRawHistoryRequest) Size() int

+ func (val *GetWorkflowExecutionRawHistoryRequest) Unmarshal(buf []byte) error

+ func (x *GetWorkflowExecutionRawHistoryRequest) GetNamespaceId() string

+ func (x *GetWorkflowExecutionRawHistoryRequest) GetRequest() *v116.GetWorkflowExecutionRawHistoryRequest

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

+ func (x *GetWorkflowExecutionRawHistoryRequest) Reset()

+ func (x *GetWorkflowExecutionRawHistoryRequest) String() string

+ type GetWorkflowExecutionRawHistoryResponse struct

+ Response *v116.GetWorkflowExecutionRawHistoryResponse

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

+ func (*GetWorkflowExecutionRawHistoryResponse) ProtoMessage()

+ func (this *GetWorkflowExecutionRawHistoryResponse) Equal(that interface{}) bool

+ func (val *GetWorkflowExecutionRawHistoryResponse) Marshal() ([]byte, error)

+ func (val *GetWorkflowExecutionRawHistoryResponse) Size() int

+ func (val *GetWorkflowExecutionRawHistoryResponse) Unmarshal(buf []byte) error

+ func (x *GetWorkflowExecutionRawHistoryResponse) GetResponse() *v116.GetWorkflowExecutionRawHistoryResponse

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

+ func (x *GetWorkflowExecutionRawHistoryResponse) Reset()

+ func (x *GetWorkflowExecutionRawHistoryResponse) String() string

type HistoryServiceClient

+ CompleteNexusOperation func(ctx context.Context, in *CompleteNexusOperationRequest, ...) (*CompleteNexusOperationResponse, error)

+ ExecuteMultiOperation func(ctx context.Context, in *ExecuteMultiOperationRequest, opts ...grpc.CallOption) (*ExecuteMultiOperationResponse, error)

+ GetWorkflowExecutionRawHistory func(ctx context.Context, in *GetWorkflowExecutionRawHistoryRequest, ...) (*GetWorkflowExecutionRawHistoryResponse, error)

+ ListTasks func(ctx context.Context, in *ListTasksRequest, opts ...grpc.CallOption) (*ListTasksResponse, error)

type HistoryServiceServer

+ CompleteNexusOperation func(context.Context, *CompleteNexusOperationRequest) (*CompleteNexusOperationResponse, error)

+ ExecuteMultiOperation func(context.Context, *ExecuteMultiOperationRequest) (*ExecuteMultiOperationResponse, error)

+ GetWorkflowExecutionRawHistory func(context.Context, *GetWorkflowExecutionRawHistoryRequest) (*GetWorkflowExecutionRawHistoryResponse, error)

+ ListTasks func(context.Context, *ListTasksRequest) (*ListTasksResponse, error)

+ type ListTasksRequest struct

+ Request *v116.ListHistoryTasksRequest

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

+ func (*ListTasksRequest) ProtoMessage()

+ func (this *ListTasksRequest) Equal(that interface{}) bool

+ func (val *ListTasksRequest) Marshal() ([]byte, error)

+ func (val *ListTasksRequest) Size() int

+ func (val *ListTasksRequest) Unmarshal(buf []byte) error

+ func (x *ListTasksRequest) GetRequest() *v116.ListHistoryTasksRequest

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

+ func (x *ListTasksRequest) Reset()

+ func (x *ListTasksRequest) String() string

+ type ListTasksResponse struct

+ Response *v116.ListHistoryTasksResponse

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

+ func (*ListTasksResponse) ProtoMessage()

+ func (this *ListTasksResponse) Equal(that interface{}) bool

+ func (val *ListTasksResponse) Marshal() ([]byte, error)

+ func (val *ListTasksResponse) Size() int

+ func (val *ListTasksResponse) Unmarshal(buf []byte) error

+ func (x *ListTasksResponse) GetResponse() *v116.ListHistoryTasksResponse

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

+ func (x *ListTasksResponse) Reset()

+ func (x *ListTasksResponse) String() string

type ReplicateEventsV2Request

+ NewRunId string

+ func (x *ReplicateEventsV2Request) GetNewRunId() string

type SignalWithStartWorkflowExecutionResponse

+ Started bool

+ func (x *SignalWithStartWorkflowExecutionResponse) GetStarted() bool

type StartWorkflowExecutionRequest

+ InheritedBuildId string

+ RootExecutionInfo *v11.RootExecutionInfo

+ func (x *StartWorkflowExecutionRequest) GetInheritedBuildId() string

+ func (x *StartWorkflowExecutionRequest) GetRootExecutionInfo() *v11.RootExecutionInfo

type StartWorkflowExecutionResponse

+ Started bool

+ func (x *StartWorkflowExecutionResponse) GetStarted() bool

+ type SyncActivitiesRequest struct

+ ActivitiesInfo []*ActivitySyncInfo

+ NamespaceId string

+ RunId string

+ WorkflowId string

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

+ func (*SyncActivitiesRequest) ProtoMessage()

+ func (this *SyncActivitiesRequest) Equal(that interface{}) bool

+ func (val *SyncActivitiesRequest) Marshal() ([]byte, error)

+ func (val *SyncActivitiesRequest) Size() int

+ func (val *SyncActivitiesRequest) Unmarshal(buf []byte) error

+ func (x *SyncActivitiesRequest) GetActivitiesInfo() []*ActivitySyncInfo

+ func (x *SyncActivitiesRequest) GetNamespaceId() string

+ func (x *SyncActivitiesRequest) GetRunId() string

+ func (x *SyncActivitiesRequest) GetWorkflowId() string

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

+ func (x *SyncActivitiesRequest) Reset()

+ func (x *SyncActivitiesRequest) String() string

type UnimplementedHistoryServiceServer

+ func (UnimplementedHistoryServiceServer) CompleteNexusOperation(context.Context, *CompleteNexusOperationRequest) (*CompleteNexusOperationResponse, error)

+ func (UnimplementedHistoryServiceServer) ExecuteMultiOperation(context.Context, *ExecuteMultiOperationRequest) (*ExecuteMultiOperationResponse, error)

+ func (UnimplementedHistoryServiceServer) GetWorkflowExecutionRawHistory(context.Context, *GetWorkflowExecutionRawHistoryRequest) (*GetWorkflowExecutionRawHistoryResponse, error)

+ func (UnimplementedHistoryServiceServer) ListTasks(context.Context, *ListTasksRequest) (*ListTasksResponse, error)

Mar 22, 2024

Changes in this version

+ const HistoryService_AddTasks_FullMethodName

+ const HistoryService_CloseShard_FullMethodName

+ const HistoryService_DeleteDLQTasks_FullMethodName

+ const HistoryService_DeleteWorkflowExecution_FullMethodName

+ const HistoryService_DeleteWorkflowVisibilityRecord_FullMethodName

+ const HistoryService_DescribeHistoryHost_FullMethodName

+ const HistoryService_DescribeMutableState_FullMethodName

+ const HistoryService_DescribeWorkflowExecution_FullMethodName

+ const HistoryService_ForceDeleteWorkflowExecution_FullMethodName

+ const HistoryService_GenerateLastHistoryReplicationTasks_FullMethodName

+ const HistoryService_GetDLQMessages_FullMethodName

+ const HistoryService_GetDLQReplicationMessages_FullMethodName

+ const HistoryService_GetDLQTasks_FullMethodName

+ const HistoryService_GetMutableState_FullMethodName

+ const HistoryService_GetReplicationMessages_FullMethodName

+ const HistoryService_GetReplicationStatus_FullMethodName

+ const HistoryService_GetShard_FullMethodName

+ const HistoryService_GetWorkflowExecutionHistoryReverse_FullMethodName

+ const HistoryService_GetWorkflowExecutionHistory_FullMethodName

+ const HistoryService_GetWorkflowExecutionRawHistoryV2_FullMethodName

+ const HistoryService_ImportWorkflowExecution_FullMethodName

+ const HistoryService_IsActivityTaskValid_FullMethodName

+ const HistoryService_IsWorkflowTaskValid_FullMethodName

+ const HistoryService_ListQueues_FullMethodName

+ const HistoryService_MergeDLQMessages_FullMethodName

+ const HistoryService_PollMutableState_FullMethodName

+ const HistoryService_PollWorkflowExecutionUpdate_FullMethodName

+ const HistoryService_PurgeDLQMessages_FullMethodName

+ const HistoryService_QueryWorkflow_FullMethodName

+ const HistoryService_ReapplyEvents_FullMethodName

+ const HistoryService_RebuildMutableState_FullMethodName

+ const HistoryService_RecordActivityTaskHeartbeat_FullMethodName

+ const HistoryService_RecordActivityTaskStarted_FullMethodName

+ const HistoryService_RecordChildExecutionCompleted_FullMethodName

+ const HistoryService_RecordWorkflowTaskStarted_FullMethodName

+ const HistoryService_RefreshWorkflowTasks_FullMethodName

+ const HistoryService_RemoveSignalMutableState_FullMethodName

+ const HistoryService_RemoveTask_FullMethodName

+ const HistoryService_ReplicateEventsV2_FullMethodName

+ const HistoryService_ReplicateWorkflowState_FullMethodName

+ const HistoryService_RequestCancelWorkflowExecution_FullMethodName

+ const HistoryService_ResetStickyTaskQueue_FullMethodName

+ const HistoryService_ResetWorkflowExecution_FullMethodName

+ const HistoryService_RespondActivityTaskCanceled_FullMethodName

+ const HistoryService_RespondActivityTaskCompleted_FullMethodName

+ const HistoryService_RespondActivityTaskFailed_FullMethodName

+ const HistoryService_RespondWorkflowTaskCompleted_FullMethodName

+ const HistoryService_RespondWorkflowTaskFailed_FullMethodName

+ const HistoryService_ScheduleWorkflowTask_FullMethodName

+ const HistoryService_SignalWithStartWorkflowExecution_FullMethodName

+ const HistoryService_SignalWorkflowExecution_FullMethodName

+ const HistoryService_StartWorkflowExecution_FullMethodName

+ const HistoryService_StreamWorkflowReplicationMessages_FullMethodName

+ const HistoryService_SyncActivity_FullMethodName

+ const HistoryService_SyncShardStatus_FullMethodName

+ const HistoryService_TerminateWorkflowExecution_FullMethodName

+ const HistoryService_UpdateWorkflowExecution_FullMethodName

+ const HistoryService_VerifyChildExecutionCompletionRecorded_FullMethodName

+ const HistoryService_VerifyFirstWorkflowTaskScheduled_FullMethodName

+ var File_temporal_server_api_historyservice_v1_request_response_proto protoreflect.FileDescriptor

+ var File_temporal_server_api_historyservice_v1_service_proto protoreflect.FileDescriptor

+ var HistoryService_ServiceDesc = grpc.ServiceDesc

+ type AddTasksRequest struct

+ ShardId int32

+ Tasks []*AddTasksRequest_Task

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

+ func (*AddTasksRequest) ProtoMessage()

+ func (this *AddTasksRequest) Equal(that interface{}) bool

+ func (val *AddTasksRequest) Marshal() ([]byte, error)

+ func (val *AddTasksRequest) Size() int

+ func (val *AddTasksRequest) Unmarshal(buf []byte) error

+ func (x *AddTasksRequest) GetShardId() int32

+ func (x *AddTasksRequest) GetTasks() []*AddTasksRequest_Task

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

+ func (x *AddTasksRequest) Reset()

+ func (x *AddTasksRequest) String() string

+ type AddTasksRequest_Task struct

+ Blob *v14.DataBlob

+ CategoryId int32

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

+ func (*AddTasksRequest_Task) ProtoMessage()

+ func (x *AddTasksRequest_Task) GetBlob() *v14.DataBlob

+ func (x *AddTasksRequest_Task) GetCategoryId() int32

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

+ func (x *AddTasksRequest_Task) Reset()

+ func (x *AddTasksRequest_Task) String() string

+ type AddTasksResponse struct

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

+ func (*AddTasksResponse) ProtoMessage()

+ func (this *AddTasksResponse) Equal(that interface{}) bool

+ func (val *AddTasksResponse) Marshal() ([]byte, error)

+ func (val *AddTasksResponse) Size() int

+ func (val *AddTasksResponse) Unmarshal(buf []byte) error

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

+ func (x *AddTasksResponse) Reset()

+ func (x *AddTasksResponse) String() string

type CloseShardRequest

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

type CloseShardResponse

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

+ type DeleteDLQTasksRequest struct

+ DlqKey *v117.HistoryDLQKey

+ InclusiveMaxTaskMetadata *v117.HistoryDLQTaskMetadata

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

+ func (*DeleteDLQTasksRequest) ProtoMessage()

+ func (this *DeleteDLQTasksRequest) Equal(that interface{}) bool

+ func (val *DeleteDLQTasksRequest) Marshal() ([]byte, error)

+ func (val *DeleteDLQTasksRequest) Size() int

+ func (val *DeleteDLQTasksRequest) Unmarshal(buf []byte) error

+ func (x *DeleteDLQTasksRequest) GetDlqKey() *v117.HistoryDLQKey

+ func (x *DeleteDLQTasksRequest) GetInclusiveMaxTaskMetadata() *v117.HistoryDLQTaskMetadata

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

+ func (x *DeleteDLQTasksRequest) Reset()

+ func (x *DeleteDLQTasksRequest) String() string

+ type DeleteDLQTasksResponse struct

+ MessagesDeleted int64

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

+ func (*DeleteDLQTasksResponse) ProtoMessage()

+ func (this *DeleteDLQTasksResponse) Equal(that interface{}) bool

+ func (val *DeleteDLQTasksResponse) Marshal() ([]byte, error)

+ func (val *DeleteDLQTasksResponse) Size() int

+ func (val *DeleteDLQTasksResponse) Unmarshal(buf []byte) error

+ func (x *DeleteDLQTasksResponse) GetMessagesDeleted() int64

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

+ func (x *DeleteDLQTasksResponse) Reset()

+ func (x *DeleteDLQTasksResponse) String() string

type DeleteWorkflowExecutionRequest

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

type DeleteWorkflowExecutionResponse

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

type DeleteWorkflowVisibilityRecordRequest

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

type DeleteWorkflowVisibilityRecordResponse

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

type DescribeHistoryHostRequest

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

type DescribeHistoryHostResponse

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

type DescribeMutableStateRequest

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

type DescribeMutableStateResponse

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

type DescribeWorkflowExecutionRequest

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

type DescribeWorkflowExecutionResponse

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

+ type ForceDeleteWorkflowExecutionRequest struct

+ NamespaceId string

+ Request *v116.DeleteWorkflowExecutionRequest

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

+ func (*ForceDeleteWorkflowExecutionRequest) ProtoMessage()

+ func (this *ForceDeleteWorkflowExecutionRequest) Equal(that interface{}) bool

+ func (val *ForceDeleteWorkflowExecutionRequest) Marshal() ([]byte, error)

+ func (val *ForceDeleteWorkflowExecutionRequest) Size() int

+ func (val *ForceDeleteWorkflowExecutionRequest) Unmarshal(buf []byte) error

+ func (x *ForceDeleteWorkflowExecutionRequest) GetNamespaceId() string

+ func (x *ForceDeleteWorkflowExecutionRequest) GetRequest() *v116.DeleteWorkflowExecutionRequest

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

+ func (x *ForceDeleteWorkflowExecutionRequest) Reset()

+ func (x *ForceDeleteWorkflowExecutionRequest) String() string

+ type ForceDeleteWorkflowExecutionResponse struct

+ Response *v116.DeleteWorkflowExecutionResponse

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

+ func (*ForceDeleteWorkflowExecutionResponse) ProtoMessage()

+ func (this *ForceDeleteWorkflowExecutionResponse) Equal(that interface{}) bool

+ func (val *ForceDeleteWorkflowExecutionResponse) Marshal() ([]byte, error)

+ func (val *ForceDeleteWorkflowExecutionResponse) Size() int

+ func (val *ForceDeleteWorkflowExecutionResponse) Unmarshal(buf []byte) error

+ func (x *ForceDeleteWorkflowExecutionResponse) GetResponse() *v116.DeleteWorkflowExecutionResponse

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

+ func (x *ForceDeleteWorkflowExecutionResponse) Reset()

+ func (x *ForceDeleteWorkflowExecutionResponse) String() string

type GenerateLastHistoryReplicationTasksRequest

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

type GenerateLastHistoryReplicationTasksResponse

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

type GetDLQMessagesRequest

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

type GetDLQMessagesResponse

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

type GetDLQReplicationMessagesRequest

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

type GetDLQReplicationMessagesResponse

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

+ type GetDLQTasksRequest struct

+ DlqKey *v117.HistoryDLQKey

+ NextPageToken []byte

+ PageSize int32

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

+ func (*GetDLQTasksRequest) ProtoMessage()

+ func (this *GetDLQTasksRequest) Equal(that interface{}) bool

+ func (val *GetDLQTasksRequest) Marshal() ([]byte, error)

+ func (val *GetDLQTasksRequest) Size() int

+ func (val *GetDLQTasksRequest) Unmarshal(buf []byte) error

+ func (x *GetDLQTasksRequest) GetDlqKey() *v117.HistoryDLQKey

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

+ func (x *GetDLQTasksRequest) GetPageSize() int32

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

+ func (x *GetDLQTasksRequest) Reset()

+ func (x *GetDLQTasksRequest) String() string

+ type GetDLQTasksResponse struct

+ DlqTasks []*v117.HistoryDLQTask

+ NextPageToken []byte

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

+ func (*GetDLQTasksResponse) ProtoMessage()

+ func (this *GetDLQTasksResponse) Equal(that interface{}) bool

+ func (val *GetDLQTasksResponse) Marshal() ([]byte, error)

+ func (val *GetDLQTasksResponse) Size() int

+ func (val *GetDLQTasksResponse) Unmarshal(buf []byte) error

+ func (x *GetDLQTasksResponse) GetDlqTasks() []*v117.HistoryDLQTask

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

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

+ func (x *GetDLQTasksResponse) Reset()

+ func (x *GetDLQTasksResponse) String() string

type GetMutableStateRequest

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

type GetMutableStateResponse

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

type GetReplicationMessagesRequest

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

type GetReplicationMessagesResponse

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

type GetReplicationStatusRequest

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

type GetReplicationStatusResponse

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

type GetShardRequest

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

type GetShardResponse

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

+ type GetWorkflowExecutionHistoryRequest struct

+ NamespaceId string

+ Request *v1.GetWorkflowExecutionHistoryRequest

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

+ func (*GetWorkflowExecutionHistoryRequest) ProtoMessage()

+ func (this *GetWorkflowExecutionHistoryRequest) Equal(that interface{}) bool

+ func (val *GetWorkflowExecutionHistoryRequest) Marshal() ([]byte, error)

+ func (val *GetWorkflowExecutionHistoryRequest) Size() int

+ func (val *GetWorkflowExecutionHistoryRequest) Unmarshal(buf []byte) error

+ func (x *GetWorkflowExecutionHistoryRequest) GetNamespaceId() string

+ func (x *GetWorkflowExecutionHistoryRequest) GetRequest() *v1.GetWorkflowExecutionHistoryRequest

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

+ func (x *GetWorkflowExecutionHistoryRequest) Reset()

+ func (x *GetWorkflowExecutionHistoryRequest) String() string

+ type GetWorkflowExecutionHistoryResponse struct

+ Response *v1.GetWorkflowExecutionHistoryResponse

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

+ func (*GetWorkflowExecutionHistoryResponse) ProtoMessage()

+ func (this *GetWorkflowExecutionHistoryResponse) Equal(that interface{}) bool

+ func (val *GetWorkflowExecutionHistoryResponse) Marshal() ([]byte, error)

+ func (val *GetWorkflowExecutionHistoryResponse) Size() int

+ func (val *GetWorkflowExecutionHistoryResponse) Unmarshal(buf []byte) error

+ func (x *GetWorkflowExecutionHistoryResponse) GetResponse() *v1.GetWorkflowExecutionHistoryResponse

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

+ func (x *GetWorkflowExecutionHistoryResponse) Reset()

+ func (x *GetWorkflowExecutionHistoryResponse) String() string

+ type GetWorkflowExecutionHistoryReverseRequest struct

+ NamespaceId string

+ Request *v1.GetWorkflowExecutionHistoryReverseRequest

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

+ func (*GetWorkflowExecutionHistoryReverseRequest) ProtoMessage()

+ func (this *GetWorkflowExecutionHistoryReverseRequest) Equal(that interface{}) bool

+ func (val *GetWorkflowExecutionHistoryReverseRequest) Marshal() ([]byte, error)

+ func (val *GetWorkflowExecutionHistoryReverseRequest) Size() int

+ func (val *GetWorkflowExecutionHistoryReverseRequest) Unmarshal(buf []byte) error

+ func (x *GetWorkflowExecutionHistoryReverseRequest) GetNamespaceId() string

+ func (x *GetWorkflowExecutionHistoryReverseRequest) GetRequest() *v1.GetWorkflowExecutionHistoryReverseRequest

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

+ func (x *GetWorkflowExecutionHistoryReverseRequest) Reset()

+ func (x *GetWorkflowExecutionHistoryReverseRequest) String() string

+ type GetWorkflowExecutionHistoryReverseResponse struct

+ Response *v1.GetWorkflowExecutionHistoryReverseResponse

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

+ func (*GetWorkflowExecutionHistoryReverseResponse) ProtoMessage()

+ func (this *GetWorkflowExecutionHistoryReverseResponse) Equal(that interface{}) bool

+ func (val *GetWorkflowExecutionHistoryReverseResponse) Marshal() ([]byte, error)

+ func (val *GetWorkflowExecutionHistoryReverseResponse) Size() int

+ func (val *GetWorkflowExecutionHistoryReverseResponse) Unmarshal(buf []byte) error

+ func (x *GetWorkflowExecutionHistoryReverseResponse) GetResponse() *v1.GetWorkflowExecutionHistoryReverseResponse

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

+ func (x *GetWorkflowExecutionHistoryReverseResponse) Reset()

+ func (x *GetWorkflowExecutionHistoryReverseResponse) String() string

+ type GetWorkflowExecutionRawHistoryV2Request struct

+ NamespaceId string

+ Request *v116.GetWorkflowExecutionRawHistoryV2Request

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

+ func (*GetWorkflowExecutionRawHistoryV2Request) ProtoMessage()

+ func (this *GetWorkflowExecutionRawHistoryV2Request) Equal(that interface{}) bool

+ func (val *GetWorkflowExecutionRawHistoryV2Request) Marshal() ([]byte, error)

+ func (val *GetWorkflowExecutionRawHistoryV2Request) Size() int

+ func (val *GetWorkflowExecutionRawHistoryV2Request) Unmarshal(buf []byte) error

+ func (x *GetWorkflowExecutionRawHistoryV2Request) GetNamespaceId() string

+ func (x *GetWorkflowExecutionRawHistoryV2Request) GetRequest() *v116.GetWorkflowExecutionRawHistoryV2Request

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

+ func (x *GetWorkflowExecutionRawHistoryV2Request) Reset()

+ func (x *GetWorkflowExecutionRawHistoryV2Request) String() string

+ type GetWorkflowExecutionRawHistoryV2Response struct

+ Response *v116.GetWorkflowExecutionRawHistoryV2Response

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

+ func (*GetWorkflowExecutionRawHistoryV2Response) ProtoMessage()

+ func (this *GetWorkflowExecutionRawHistoryV2Response) Equal(that interface{}) bool

+ func (val *GetWorkflowExecutionRawHistoryV2Response) Marshal() ([]byte, error)

+ func (val *GetWorkflowExecutionRawHistoryV2Response) Size() int

+ func (val *GetWorkflowExecutionRawHistoryV2Response) Unmarshal(buf []byte) error

+ func (x *GetWorkflowExecutionRawHistoryV2Response) GetResponse() *v116.GetWorkflowExecutionRawHistoryV2Response

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

+ func (x *GetWorkflowExecutionRawHistoryV2Response) Reset()

+ func (x *GetWorkflowExecutionRawHistoryV2Response) String() string

type HandoverNamespaceInfo

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

type HistoryServiceClient

+ AddTasks func(ctx context.Context, in *AddTasksRequest, opts ...grpc.CallOption) (*AddTasksResponse, error)

+ DeleteDLQTasks func(ctx context.Context, in *DeleteDLQTasksRequest, opts ...grpc.CallOption) (*DeleteDLQTasksResponse, error)

+ ForceDeleteWorkflowExecution func(ctx context.Context, in *ForceDeleteWorkflowExecutionRequest, ...) (*ForceDeleteWorkflowExecutionResponse, error)

+ GetDLQTasks func(ctx context.Context, in *GetDLQTasksRequest, opts ...grpc.CallOption) (*GetDLQTasksResponse, error)

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

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

+ GetWorkflowExecutionRawHistoryV2 func(ctx context.Context, in *GetWorkflowExecutionRawHistoryV2Request, ...) (*GetWorkflowExecutionRawHistoryV2Response, error)

+ ImportWorkflowExecution func(ctx context.Context, in *ImportWorkflowExecutionRequest, ...) (*ImportWorkflowExecutionResponse, error)

+ ListQueues func(ctx context.Context, in *ListQueuesRequest, opts ...grpc.CallOption) (*ListQueuesResponse, error)

type HistoryServiceServer

+ AddTasks func(context.Context, *AddTasksRequest) (*AddTasksResponse, error)

+ DeleteDLQTasks func(context.Context, *DeleteDLQTasksRequest) (*DeleteDLQTasksResponse, error)

+ ForceDeleteWorkflowExecution func(context.Context, *ForceDeleteWorkflowExecutionRequest) (*ForceDeleteWorkflowExecutionResponse, error)

+ GetDLQTasks func(context.Context, *GetDLQTasksRequest) (*GetDLQTasksResponse, error)

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

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

+ GetWorkflowExecutionRawHistoryV2 func(context.Context, *GetWorkflowExecutionRawHistoryV2Request) (*GetWorkflowExecutionRawHistoryV2Response, error)

+ ImportWorkflowExecution func(context.Context, *ImportWorkflowExecutionRequest) (*ImportWorkflowExecutionResponse, error)

+ ListQueues func(context.Context, *ListQueuesRequest) (*ListQueuesResponse, error)

+ type ImportWorkflowExecutionRequest struct

+ Execution *v14.WorkflowExecution

+ HistoryBatches []*v14.DataBlob

+ NamespaceId string

+ Token []byte

+ VersionHistory *v16.VersionHistory

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

+ func (*ImportWorkflowExecutionRequest) ProtoMessage()

+ func (this *ImportWorkflowExecutionRequest) Equal(that interface{}) bool

+ func (val *ImportWorkflowExecutionRequest) Marshal() ([]byte, error)

+ func (val *ImportWorkflowExecutionRequest) Size() int

+ func (val *ImportWorkflowExecutionRequest) Unmarshal(buf []byte) error

+ func (x *ImportWorkflowExecutionRequest) GetExecution() *v14.WorkflowExecution

+ func (x *ImportWorkflowExecutionRequest) GetHistoryBatches() []*v14.DataBlob

+ func (x *ImportWorkflowExecutionRequest) GetNamespaceId() string

+ func (x *ImportWorkflowExecutionRequest) GetToken() []byte

+ func (x *ImportWorkflowExecutionRequest) GetVersionHistory() *v16.VersionHistory

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

+ func (x *ImportWorkflowExecutionRequest) Reset()

+ func (x *ImportWorkflowExecutionRequest) String() string

+ type ImportWorkflowExecutionResponse struct

+ EventsApplied bool

+ Token []byte

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

+ func (*ImportWorkflowExecutionResponse) ProtoMessage()

+ func (this *ImportWorkflowExecutionResponse) Equal(that interface{}) bool

+ func (val *ImportWorkflowExecutionResponse) Marshal() ([]byte, error)

+ func (val *ImportWorkflowExecutionResponse) Size() int

+ func (val *ImportWorkflowExecutionResponse) Unmarshal(buf []byte) error

+ func (x *ImportWorkflowExecutionResponse) GetEventsApplied() bool

+ func (x *ImportWorkflowExecutionResponse) GetToken() []byte

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

+ func (x *ImportWorkflowExecutionResponse) Reset()

+ func (x *ImportWorkflowExecutionResponse) String() string

type IsActivityTaskValidRequest

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

type IsActivityTaskValidResponse

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

type IsWorkflowTaskValidRequest

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

type IsWorkflowTaskValidResponse

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

+ type ListQueuesRequest struct

+ NextPageToken []byte

+ PageSize int32

+ QueueType int32

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

+ func (*ListQueuesRequest) ProtoMessage()

+ func (this *ListQueuesRequest) Equal(that interface{}) bool

+ func (val *ListQueuesRequest) Marshal() ([]byte, error)

+ func (val *ListQueuesRequest) Size() int

+ func (val *ListQueuesRequest) Unmarshal(buf []byte) error

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

+ func (x *ListQueuesRequest) GetPageSize() int32

+ func (x *ListQueuesRequest) GetQueueType() int32

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

+ func (x *ListQueuesRequest) Reset()

+ func (x *ListQueuesRequest) String() string

+ type ListQueuesResponse struct

+ NextPageToken []byte

+ Queues []*ListQueuesResponse_QueueInfo

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

+ func (*ListQueuesResponse) ProtoMessage()

+ func (this *ListQueuesResponse) Equal(that interface{}) bool

+ func (val *ListQueuesResponse) Marshal() ([]byte, error)

+ func (val *ListQueuesResponse) Size() int

+ func (val *ListQueuesResponse) Unmarshal(buf []byte) error

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

+ func (x *ListQueuesResponse) GetQueues() []*ListQueuesResponse_QueueInfo

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

+ func (x *ListQueuesResponse) Reset()

+ func (x *ListQueuesResponse) String() string

+ type ListQueuesResponse_QueueInfo struct

+ MessageCount int64

+ QueueName string

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

+ func (*ListQueuesResponse_QueueInfo) ProtoMessage()

+ func (x *ListQueuesResponse_QueueInfo) GetMessageCount() int64

+ func (x *ListQueuesResponse_QueueInfo) GetQueueName() string

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

+ func (x *ListQueuesResponse_QueueInfo) Reset()

+ func (x *ListQueuesResponse_QueueInfo) String() string

type MergeDLQMessagesRequest

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

type MergeDLQMessagesResponse

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

type PollMutableStateRequest

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

type PollMutableStateResponse

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

type PollWorkflowExecutionUpdateRequest

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

type PollWorkflowExecutionUpdateResponse

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

type PurgeDLQMessagesRequest

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

type PurgeDLQMessagesResponse

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

type QueryWorkflowRequest

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

type QueryWorkflowResponse

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

type ReapplyEventsRequest

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

type ReapplyEventsResponse

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

type RebuildMutableStateRequest

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

type RebuildMutableStateResponse

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

type RecordActivityTaskHeartbeatRequest

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

type RecordActivityTaskHeartbeatResponse

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

type RecordActivityTaskStartedRequest

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

type RecordActivityTaskStartedResponse

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

type RecordChildExecutionCompletedRequest

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

type RecordChildExecutionCompletedResponse

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

type RecordWorkflowTaskStartedRequest

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

type RecordWorkflowTaskStartedResponse

+ History *v111.History

+ NextPageToken []byte

+ func (x *RecordWorkflowTaskStartedResponse) GetHistory() *v111.History

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

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

type RefreshWorkflowTasksRequest

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

type RefreshWorkflowTasksResponse

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

type RemoveSignalMutableStateRequest

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

type RemoveSignalMutableStateResponse

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

type RemoveTaskRequest

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

type RemoveTaskResponse

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

type ReplicateEventsV2Request

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

type ReplicateEventsV2Response

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

type ReplicateWorkflowStateRequest

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

type ReplicateWorkflowStateResponse

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

type RequestCancelWorkflowExecutionRequest

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

type RequestCancelWorkflowExecutionResponse

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

type ResetStickyTaskQueueRequest

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

type ResetStickyTaskQueueResponse

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

type ResetWorkflowExecutionRequest

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

type ResetWorkflowExecutionResponse

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

type RespondActivityTaskCanceledRequest

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

type RespondActivityTaskCanceledResponse

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

type RespondActivityTaskCompletedRequest

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

type RespondActivityTaskCompletedResponse

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

type RespondActivityTaskFailedRequest

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

type RespondActivityTaskFailedResponse

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

type RespondWorkflowTaskCompletedRequest

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

type RespondWorkflowTaskCompletedResponse

+ NewWorkflowTask *v1.PollWorkflowTaskQueueResponse

+ func (x *RespondWorkflowTaskCompletedResponse) GetNewWorkflowTask() *v1.PollWorkflowTaskQueueResponse

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

type RespondWorkflowTaskFailedRequest

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

type RespondWorkflowTaskFailedResponse

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

type ScheduleWorkflowTaskRequest

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

type ScheduleWorkflowTaskResponse

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

type ShardReplicationStatus

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

type ShardReplicationStatusPerCluster

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

type SignalWithStartWorkflowExecutionRequest

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

type SignalWithStartWorkflowExecutionResponse

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

type SignalWorkflowExecutionRequest

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

type SignalWorkflowExecutionResponse

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

type StartWorkflowExecutionRequest

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

type StartWorkflowExecutionResponse

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

type StreamWorkflowReplicationMessagesRequest

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

type StreamWorkflowReplicationMessagesResponse

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

type SyncActivityRequest

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

type SyncActivityResponse

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

type SyncShardStatusRequest

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

type SyncShardStatusResponse

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

type TerminateWorkflowExecutionRequest

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

type TerminateWorkflowExecutionResponse

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

type UnimplementedHistoryServiceServer

+ func (UnimplementedHistoryServiceServer) AddTasks(context.Context, *AddTasksRequest) (*AddTasksResponse, error)

+ func (UnimplementedHistoryServiceServer) DeleteDLQTasks(context.Context, *DeleteDLQTasksRequest) (*DeleteDLQTasksResponse, error)

+ func (UnimplementedHistoryServiceServer) ForceDeleteWorkflowExecution(context.Context, *ForceDeleteWorkflowExecutionRequest) (*ForceDeleteWorkflowExecutionResponse, error)

+ func (UnimplementedHistoryServiceServer) GetDLQTasks(context.Context, *GetDLQTasksRequest) (*GetDLQTasksResponse, error)

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

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

+ func (UnimplementedHistoryServiceServer) GetWorkflowExecutionRawHistoryV2(context.Context, *GetWorkflowExecutionRawHistoryV2Request) (*GetWorkflowExecutionRawHistoryV2Response, error)

+ func (UnimplementedHistoryServiceServer) ImportWorkflowExecution(context.Context, *ImportWorkflowExecutionRequest) (*ImportWorkflowExecutionResponse, error)

+ func (UnimplementedHistoryServiceServer) ListQueues(context.Context, *ListQueuesRequest) (*ListQueuesResponse, error)

+ type UnsafeHistoryServiceServer interface

type UpdateWorkflowExecutionRequest

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

type UpdateWorkflowExecutionResponse

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

type VerifyChildExecutionCompletionRecordedRequest

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

type VerifyChildExecutionCompletionRecordedResponse

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

type VerifyFirstWorkflowTaskScheduledRequest

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

type VerifyFirstWorkflowTaskScheduledResponse

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

Feb 29, 2024 GO-2024-2689

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Feb 22, 2024 GO-2024-2689

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Feb 22, 2024 GO-2024-2689

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Feb 2, 2024 GO-2024-2689

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Jan 12, 2024 GO-2024-2689

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Dec 7, 2023 GO-2024-2689

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Changes in this version

type GetMutableStateRequest

+ VersionHistoryItem *v16.VersionHistoryItem

+ func (m *GetMutableStateRequest) GetVersionHistoryItem() *v16.VersionHistoryItem

type PollMutableStateRequest

+ VersionHistoryItem *v16.VersionHistoryItem

+ func (m *PollMutableStateRequest) GetVersionHistoryItem() *v16.VersionHistoryItem

Nov 30, 2023 GO-2024-2689

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Nov 28, 2023 GO-2024-2689

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Nov 22, 2023 GO-2024-2689

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Nov 13, 2023 GO-2024-2689

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Nov 3, 2023 GO-2024-2689

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Nov 1, 2023 GO-2024-2689

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Oct 31, 2023 GO-2024-2689

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Oct 13, 2023 GO-2024-2689

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Changes in this version

type GenerateLastHistoryReplicationTasksResponse

+ HistoryLength int64

+ func (m *GenerateLastHistoryReplicationTasksResponse) GetHistoryLength() int64

Oct 6, 2023 GO-2024-2689

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Nov 1, 2023 GO-2024-2689

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Sep 5, 2023 GO-2024-2689

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Changes in this version

type HistoryServiceClient

+ IsActivityTaskValid func(ctx context.Context, in *IsActivityTaskValidRequest, opts ...grpc.CallOption) (*IsActivityTaskValidResponse, error)

+ IsWorkflowTaskValid func(ctx context.Context, in *IsWorkflowTaskValidRequest, opts ...grpc.CallOption) (*IsWorkflowTaskValidResponse, error)

type HistoryServiceServer

+ IsActivityTaskValid func(context.Context, *IsActivityTaskValidRequest) (*IsActivityTaskValidResponse, error)

+ IsWorkflowTaskValid func(context.Context, *IsWorkflowTaskValidRequest) (*IsWorkflowTaskValidResponse, error)

+ type IsActivityTaskValidRequest struct

+ Clock *v15.VectorClock

+ Execution *v14.WorkflowExecution

+ NamespaceId string

+ ScheduledEventId int64

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

+ func (*IsActivityTaskValidRequest) ProtoMessage()

+ func (m *IsActivityTaskValidRequest) GetClock() *v15.VectorClock

+ func (m *IsActivityTaskValidRequest) GetExecution() *v14.WorkflowExecution

+ func (m *IsActivityTaskValidRequest) GetNamespaceId() string

+ func (m *IsActivityTaskValidRequest) GetScheduledEventId() int64

+ func (m *IsActivityTaskValidRequest) Marshal() (dAtA []byte, err error)

+ func (m *IsActivityTaskValidRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *IsActivityTaskValidRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *IsActivityTaskValidRequest) Reset()

+ func (m *IsActivityTaskValidRequest) Size() (n int)

+ func (m *IsActivityTaskValidRequest) Unmarshal(dAtA []byte) error

+ func (m *IsActivityTaskValidRequest) XXX_DiscardUnknown()

+ func (m *IsActivityTaskValidRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *IsActivityTaskValidRequest) XXX_Merge(src proto.Message)

+ func (m *IsActivityTaskValidRequest) XXX_Size() int

+ func (m *IsActivityTaskValidRequest) XXX_Unmarshal(b []byte) error

+ func (this *IsActivityTaskValidRequest) Equal(that interface{}) bool

+ func (this *IsActivityTaskValidRequest) GoString() string

+ func (this *IsActivityTaskValidRequest) String() string

+ type IsActivityTaskValidResponse struct

+ IsValid bool

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

+ func (*IsActivityTaskValidResponse) ProtoMessage()

+ func (m *IsActivityTaskValidResponse) GetIsValid() bool

+ func (m *IsActivityTaskValidResponse) Marshal() (dAtA []byte, err error)

+ func (m *IsActivityTaskValidResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *IsActivityTaskValidResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *IsActivityTaskValidResponse) Reset()

+ func (m *IsActivityTaskValidResponse) Size() (n int)

+ func (m *IsActivityTaskValidResponse) Unmarshal(dAtA []byte) error

+ func (m *IsActivityTaskValidResponse) XXX_DiscardUnknown()

+ func (m *IsActivityTaskValidResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *IsActivityTaskValidResponse) XXX_Merge(src proto.Message)

+ func (m *IsActivityTaskValidResponse) XXX_Size() int

+ func (m *IsActivityTaskValidResponse) XXX_Unmarshal(b []byte) error

+ func (this *IsActivityTaskValidResponse) Equal(that interface{}) bool

+ func (this *IsActivityTaskValidResponse) GoString() string

+ func (this *IsActivityTaskValidResponse) String() string

+ type IsWorkflowTaskValidRequest struct

+ Clock *v15.VectorClock

+ Execution *v14.WorkflowExecution

+ NamespaceId string

+ ScheduledEventId int64

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

+ func (*IsWorkflowTaskValidRequest) ProtoMessage()

+ func (m *IsWorkflowTaskValidRequest) GetClock() *v15.VectorClock

+ func (m *IsWorkflowTaskValidRequest) GetExecution() *v14.WorkflowExecution

+ func (m *IsWorkflowTaskValidRequest) GetNamespaceId() string

+ func (m *IsWorkflowTaskValidRequest) GetScheduledEventId() int64

+ func (m *IsWorkflowTaskValidRequest) Marshal() (dAtA []byte, err error)

+ func (m *IsWorkflowTaskValidRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *IsWorkflowTaskValidRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *IsWorkflowTaskValidRequest) Reset()

+ func (m *IsWorkflowTaskValidRequest) Size() (n int)

+ func (m *IsWorkflowTaskValidRequest) Unmarshal(dAtA []byte) error

+ func (m *IsWorkflowTaskValidRequest) XXX_DiscardUnknown()

+ func (m *IsWorkflowTaskValidRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *IsWorkflowTaskValidRequest) XXX_Merge(src proto.Message)

+ func (m *IsWorkflowTaskValidRequest) XXX_Size() int

+ func (m *IsWorkflowTaskValidRequest) XXX_Unmarshal(b []byte) error

+ func (this *IsWorkflowTaskValidRequest) Equal(that interface{}) bool

+ func (this *IsWorkflowTaskValidRequest) GoString() string

+ func (this *IsWorkflowTaskValidRequest) String() string

+ type IsWorkflowTaskValidResponse struct

+ IsValid bool

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

+ func (*IsWorkflowTaskValidResponse) ProtoMessage()

+ func (m *IsWorkflowTaskValidResponse) GetIsValid() bool

+ func (m *IsWorkflowTaskValidResponse) Marshal() (dAtA []byte, err error)

+ func (m *IsWorkflowTaskValidResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *IsWorkflowTaskValidResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *IsWorkflowTaskValidResponse) Reset()

+ func (m *IsWorkflowTaskValidResponse) Size() (n int)

+ func (m *IsWorkflowTaskValidResponse) Unmarshal(dAtA []byte) error

+ func (m *IsWorkflowTaskValidResponse) XXX_DiscardUnknown()

+ func (m *IsWorkflowTaskValidResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *IsWorkflowTaskValidResponse) XXX_Merge(src proto.Message)

+ func (m *IsWorkflowTaskValidResponse) XXX_Size() int

+ func (m *IsWorkflowTaskValidResponse) XXX_Unmarshal(b []byte) error

+ func (this *IsWorkflowTaskValidResponse) Equal(that interface{}) bool

+ func (this *IsWorkflowTaskValidResponse) GoString() string

+ func (this *IsWorkflowTaskValidResponse) String() string

type RecordActivityTaskStartedResponse

+ Version int64

+ func (m *RecordActivityTaskStartedResponse) GetVersion() int64

type RecordChildExecutionCompletedRequest

+ ChildExecution *v14.WorkflowExecution

+ ParentExecution *v14.WorkflowExecution

+ func (m *RecordChildExecutionCompletedRequest) GetChildExecution() *v14.WorkflowExecution

+ func (m *RecordChildExecutionCompletedRequest) GetParentExecution() *v14.WorkflowExecution

type RecordWorkflowTaskStartedResponse

+ Version int64

+ func (m *RecordWorkflowTaskStartedResponse) GetVersion() int64

type UnimplementedHistoryServiceServer

+ func (*UnimplementedHistoryServiceServer) IsActivityTaskValid(ctx context.Context, req *IsActivityTaskValidRequest) (*IsActivityTaskValidResponse, error)

+ func (*UnimplementedHistoryServiceServer) IsWorkflowTaskValid(ctx context.Context, req *IsWorkflowTaskValidRequest) (*IsWorkflowTaskValidResponse, error)

Aug 28, 2023 GO-2024-2689

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Aug 21, 2023 GO-2024-2689

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Aug 14, 2023 GO-2024-2689

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Aug 14, 2023 GO-2024-2689

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Aug 14, 2023 GO-2024-2689

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Aug 8, 2023 GO-2024-2689

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Jul 28, 2023 GO-2024-2689

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Jul 24, 2023 GO-2024-2689

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Jul 14, 2023 GO-2024-2689

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Jul 1, 2023 GO-2024-2689

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Jun 23, 2023 GO-2024-2689

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Changes in this version

type GenerateLastHistoryReplicationTasksResponse

+ StateTransitionCount int64

+ func (m *GenerateLastHistoryReplicationTasksResponse) GetStateTransitionCount() int64

type GetDLQMessagesResponse

+ ReplicationTasksInfo []*v115.ReplicationTaskInfo

+ func (m *GetDLQMessagesResponse) GetReplicationTasksInfo() []*v115.ReplicationTaskInfo

type GetMutableStateResponse

+ WorkerVersionStamp *v14.WorkerVersionStamp

+ func (m *GetMutableStateResponse) GetWorkerVersionStamp() *v14.WorkerVersionStamp

type HistoryServiceClient

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

+ StreamWorkflowReplicationMessages func(ctx context.Context, opts ...grpc.CallOption) (HistoryService_StreamWorkflowReplicationMessagesClient, error)

type HistoryServiceServer

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

+ StreamWorkflowReplicationMessages func(HistoryService_StreamWorkflowReplicationMessagesServer) error

+ type HistoryService_StreamWorkflowReplicationMessagesClient interface

+ Recv func() (*StreamWorkflowReplicationMessagesResponse, error)

+ Send func(*StreamWorkflowReplicationMessagesRequest) error

+ type HistoryService_StreamWorkflowReplicationMessagesServer interface

+ Recv func() (*StreamWorkflowReplicationMessagesRequest, error)

+ Send func(*StreamWorkflowReplicationMessagesResponse) error

+ type PollWorkflowExecutionUpdateRequest struct

+ NamespaceId string

+ Request *v1.PollWorkflowExecutionUpdateRequest

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

+ func (*PollWorkflowExecutionUpdateRequest) ProtoMessage()

+ func (m *PollWorkflowExecutionUpdateRequest) GetNamespaceId() string

+ func (m *PollWorkflowExecutionUpdateRequest) GetRequest() *v1.PollWorkflowExecutionUpdateRequest

+ func (m *PollWorkflowExecutionUpdateRequest) Marshal() (dAtA []byte, err error)

+ func (m *PollWorkflowExecutionUpdateRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *PollWorkflowExecutionUpdateRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *PollWorkflowExecutionUpdateRequest) Reset()

+ func (m *PollWorkflowExecutionUpdateRequest) Size() (n int)

+ func (m *PollWorkflowExecutionUpdateRequest) Unmarshal(dAtA []byte) error

+ func (m *PollWorkflowExecutionUpdateRequest) XXX_DiscardUnknown()

+ func (m *PollWorkflowExecutionUpdateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *PollWorkflowExecutionUpdateRequest) XXX_Merge(src proto.Message)

+ func (m *PollWorkflowExecutionUpdateRequest) XXX_Size() int

+ func (m *PollWorkflowExecutionUpdateRequest) XXX_Unmarshal(b []byte) error

+ func (this *PollWorkflowExecutionUpdateRequest) Equal(that interface{}) bool

+ func (this *PollWorkflowExecutionUpdateRequest) GoString() string

+ func (this *PollWorkflowExecutionUpdateRequest) String() string

+ type PollWorkflowExecutionUpdateResponse struct

+ Response *v1.PollWorkflowExecutionUpdateResponse

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

+ func (*PollWorkflowExecutionUpdateResponse) ProtoMessage()

+ func (m *PollWorkflowExecutionUpdateResponse) GetResponse() *v1.PollWorkflowExecutionUpdateResponse

+ func (m *PollWorkflowExecutionUpdateResponse) Marshal() (dAtA []byte, err error)

+ func (m *PollWorkflowExecutionUpdateResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *PollWorkflowExecutionUpdateResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *PollWorkflowExecutionUpdateResponse) Reset()

+ func (m *PollWorkflowExecutionUpdateResponse) Size() (n int)

+ func (m *PollWorkflowExecutionUpdateResponse) Unmarshal(dAtA []byte) error

+ func (m *PollWorkflowExecutionUpdateResponse) XXX_DiscardUnknown()

+ func (m *PollWorkflowExecutionUpdateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *PollWorkflowExecutionUpdateResponse) XXX_Merge(src proto.Message)

+ func (m *PollWorkflowExecutionUpdateResponse) XXX_Size() int

+ func (m *PollWorkflowExecutionUpdateResponse) XXX_Unmarshal(b []byte) error

+ func (this *PollWorkflowExecutionUpdateResponse) Equal(that interface{}) bool

+ func (this *PollWorkflowExecutionUpdateResponse) GoString() string

+ func (this *PollWorkflowExecutionUpdateResponse) String() string

type ReplicateEventsV2Request

+ BaseExecutionInfo *v11.BaseExecutionInfo

+ func (m *ReplicateEventsV2Request) GetBaseExecutionInfo() *v11.BaseExecutionInfo

type StartWorkflowExecutionRequest

+ SourceVersionStamp *v14.WorkerVersionStamp

+ func (m *StartWorkflowExecutionRequest) GetSourceVersionStamp() *v14.WorkerVersionStamp

+ type StreamWorkflowReplicationMessagesRequest struct

+ Attributes isStreamWorkflowReplicationMessagesRequest_Attributes

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

+ func (*StreamWorkflowReplicationMessagesRequest) ProtoMessage()

+ func (*StreamWorkflowReplicationMessagesRequest) XXX_OneofWrappers() []interface{}

+ func (m *StreamWorkflowReplicationMessagesRequest) GetAttributes() isStreamWorkflowReplicationMessagesRequest_Attributes

+ func (m *StreamWorkflowReplicationMessagesRequest) GetSyncReplicationState() *v115.SyncReplicationState

+ func (m *StreamWorkflowReplicationMessagesRequest) Marshal() (dAtA []byte, err error)

+ func (m *StreamWorkflowReplicationMessagesRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *StreamWorkflowReplicationMessagesRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *StreamWorkflowReplicationMessagesRequest) Reset()

+ func (m *StreamWorkflowReplicationMessagesRequest) Size() (n int)

+ func (m *StreamWorkflowReplicationMessagesRequest) Unmarshal(dAtA []byte) error

+ func (m *StreamWorkflowReplicationMessagesRequest) XXX_DiscardUnknown()

+ func (m *StreamWorkflowReplicationMessagesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *StreamWorkflowReplicationMessagesRequest) XXX_Merge(src proto.Message)

+ func (m *StreamWorkflowReplicationMessagesRequest) XXX_Size() int

+ func (m *StreamWorkflowReplicationMessagesRequest) XXX_Unmarshal(b []byte) error

+ func (this *StreamWorkflowReplicationMessagesRequest) Equal(that interface{}) bool

+ func (this *StreamWorkflowReplicationMessagesRequest) GoString() string

+ func (this *StreamWorkflowReplicationMessagesRequest) String() string

+ type StreamWorkflowReplicationMessagesRequest_SyncReplicationState struct

+ SyncReplicationState *v115.SyncReplicationState

+ func (m *StreamWorkflowReplicationMessagesRequest_SyncReplicationState) MarshalTo(dAtA []byte) (int, error)

+ func (m *StreamWorkflowReplicationMessagesRequest_SyncReplicationState) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *StreamWorkflowReplicationMessagesRequest_SyncReplicationState) Size() (n int)

+ func (this *StreamWorkflowReplicationMessagesRequest_SyncReplicationState) Equal(that interface{}) bool

+ func (this *StreamWorkflowReplicationMessagesRequest_SyncReplicationState) GoString() string

+ func (this *StreamWorkflowReplicationMessagesRequest_SyncReplicationState) String() string

+ type StreamWorkflowReplicationMessagesResponse struct

+ Attributes isStreamWorkflowReplicationMessagesResponse_Attributes

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

+ func (*StreamWorkflowReplicationMessagesResponse) ProtoMessage()

+ func (*StreamWorkflowReplicationMessagesResponse) XXX_OneofWrappers() []interface{}

+ func (m *StreamWorkflowReplicationMessagesResponse) GetAttributes() isStreamWorkflowReplicationMessagesResponse_Attributes

+ func (m *StreamWorkflowReplicationMessagesResponse) GetMessages() *v115.WorkflowReplicationMessages

+ func (m *StreamWorkflowReplicationMessagesResponse) Marshal() (dAtA []byte, err error)

+ func (m *StreamWorkflowReplicationMessagesResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *StreamWorkflowReplicationMessagesResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *StreamWorkflowReplicationMessagesResponse) Reset()

+ func (m *StreamWorkflowReplicationMessagesResponse) Size() (n int)

+ func (m *StreamWorkflowReplicationMessagesResponse) Unmarshal(dAtA []byte) error

+ func (m *StreamWorkflowReplicationMessagesResponse) XXX_DiscardUnknown()

+ func (m *StreamWorkflowReplicationMessagesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *StreamWorkflowReplicationMessagesResponse) XXX_Merge(src proto.Message)

+ func (m *StreamWorkflowReplicationMessagesResponse) XXX_Size() int

+ func (m *StreamWorkflowReplicationMessagesResponse) XXX_Unmarshal(b []byte) error

+ func (this *StreamWorkflowReplicationMessagesResponse) Equal(that interface{}) bool

+ func (this *StreamWorkflowReplicationMessagesResponse) GoString() string

+ func (this *StreamWorkflowReplicationMessagesResponse) String() string

+ type StreamWorkflowReplicationMessagesResponse_Messages struct

+ Messages *v115.WorkflowReplicationMessages

+ func (m *StreamWorkflowReplicationMessagesResponse_Messages) MarshalTo(dAtA []byte) (int, error)

+ func (m *StreamWorkflowReplicationMessagesResponse_Messages) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *StreamWorkflowReplicationMessagesResponse_Messages) Size() (n int)

+ func (this *StreamWorkflowReplicationMessagesResponse_Messages) Equal(that interface{}) bool

+ func (this *StreamWorkflowReplicationMessagesResponse_Messages) GoString() string

+ func (this *StreamWorkflowReplicationMessagesResponse_Messages) String() string

type SyncActivityRequest

+ BaseExecutionInfo *v11.BaseExecutionInfo

+ func (m *SyncActivityRequest) GetBaseExecutionInfo() *v11.BaseExecutionInfo

type UnimplementedHistoryServiceServer

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

+ func (*UnimplementedHistoryServiceServer) StreamWorkflowReplicationMessages(srv HistoryService_StreamWorkflowReplicationMessagesServer) error

Jul 13, 2023 GO-2024-2689

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

May 15, 2023 GO-2024-2689

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Apr 17, 2023 GO-2024-2689

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Mar 29, 2023 GO-2024-2689

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Changes in this version

type ScheduleWorkflowTaskRequest

+ ChildClock *v15.VectorClock

+ ParentClock *v15.VectorClock

+ func (m *ScheduleWorkflowTaskRequest) GetChildClock() *v15.VectorClock

+ func (m *ScheduleWorkflowTaskRequest) GetParentClock() *v15.VectorClock

Feb 17, 2023 GO-2024-2689

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Changes in this version

type HistoryServiceClient

+ ReplicateWorkflowState func(ctx context.Context, in *ReplicateWorkflowStateRequest, ...) (*ReplicateWorkflowStateResponse, error)

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

type HistoryServiceServer

+ ReplicateWorkflowState func(context.Context, *ReplicateWorkflowStateRequest) (*ReplicateWorkflowStateResponse, error)

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

type RecordWorkflowTaskStartedResponse

+ Messages []*v110.Message

+ func (m *RecordWorkflowTaskStartedResponse) GetMessages() []*v110.Message

type ReplicateWorkflowStateRequest

+ NamespaceId string

+ func (m *ReplicateWorkflowStateRequest) GetNamespaceId() string

+ type ReplicateWorkflowStateResponse struct

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

+ func (*ReplicateWorkflowStateResponse) ProtoMessage()

+ func (m *ReplicateWorkflowStateResponse) Marshal() (dAtA []byte, err error)

+ func (m *ReplicateWorkflowStateResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *ReplicateWorkflowStateResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ReplicateWorkflowStateResponse) Reset()

+ func (m *ReplicateWorkflowStateResponse) Size() (n int)

+ func (m *ReplicateWorkflowStateResponse) Unmarshal(dAtA []byte) error

+ func (m *ReplicateWorkflowStateResponse) XXX_DiscardUnknown()

+ func (m *ReplicateWorkflowStateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ReplicateWorkflowStateResponse) XXX_Merge(src proto.Message)

+ func (m *ReplicateWorkflowStateResponse) XXX_Size() int

+ func (m *ReplicateWorkflowStateResponse) XXX_Unmarshal(b []byte) error

+ func (this *ReplicateWorkflowStateResponse) Equal(that interface{}) bool

+ func (this *ReplicateWorkflowStateResponse) GoString() string

+ func (this *ReplicateWorkflowStateResponse) String() string

type RespondWorkflowTaskCompletedResponse

+ ResetHistoryEventId int64

+ func (m *RespondWorkflowTaskCompletedResponse) GetResetHistoryEventId() int64

type StartWorkflowExecutionResponse

+ EagerWorkflowTask *v1.PollWorkflowTaskQueueResponse

+ func (m *StartWorkflowExecutionResponse) GetEagerWorkflowTask() *v1.PollWorkflowTaskQueueResponse

type UnimplementedHistoryServiceServer

+ func (*UnimplementedHistoryServiceServer) ReplicateWorkflowState(ctx context.Context, req *ReplicateWorkflowStateRequest) (*ReplicateWorkflowStateResponse, error)

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

+ type UpdateWorkflowExecutionRequest struct

+ NamespaceId string

+ Request *v1.UpdateWorkflowExecutionRequest

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

+ func (*UpdateWorkflowExecutionRequest) ProtoMessage()

+ func (m *UpdateWorkflowExecutionRequest) GetNamespaceId() string

+ func (m *UpdateWorkflowExecutionRequest) GetRequest() *v1.UpdateWorkflowExecutionRequest

+ func (m *UpdateWorkflowExecutionRequest) Marshal() (dAtA []byte, err error)

+ func (m *UpdateWorkflowExecutionRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *UpdateWorkflowExecutionRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *UpdateWorkflowExecutionRequest) Reset()

+ func (m *UpdateWorkflowExecutionRequest) Size() (n int)

+ func (m *UpdateWorkflowExecutionRequest) Unmarshal(dAtA []byte) error

+ func (m *UpdateWorkflowExecutionRequest) XXX_DiscardUnknown()

+ func (m *UpdateWorkflowExecutionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *UpdateWorkflowExecutionRequest) XXX_Merge(src proto.Message)

+ func (m *UpdateWorkflowExecutionRequest) XXX_Size() int

+ func (m *UpdateWorkflowExecutionRequest) XXX_Unmarshal(b []byte) error

+ func (this *UpdateWorkflowExecutionRequest) Equal(that interface{}) bool

+ func (this *UpdateWorkflowExecutionRequest) GoString() string

+ func (this *UpdateWorkflowExecutionRequest) String() string

+ type UpdateWorkflowExecutionResponse struct

+ Response *v1.UpdateWorkflowExecutionResponse

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

+ func (*UpdateWorkflowExecutionResponse) ProtoMessage()

+ func (m *UpdateWorkflowExecutionResponse) GetResponse() *v1.UpdateWorkflowExecutionResponse

+ func (m *UpdateWorkflowExecutionResponse) Marshal() (dAtA []byte, err error)

+ func (m *UpdateWorkflowExecutionResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *UpdateWorkflowExecutionResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *UpdateWorkflowExecutionResponse) Reset()

+ func (m *UpdateWorkflowExecutionResponse) Size() (n int)

+ func (m *UpdateWorkflowExecutionResponse) Unmarshal(dAtA []byte) error

+ func (m *UpdateWorkflowExecutionResponse) XXX_DiscardUnknown()

+ func (m *UpdateWorkflowExecutionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *UpdateWorkflowExecutionResponse) XXX_Merge(src proto.Message)

+ func (m *UpdateWorkflowExecutionResponse) XXX_Size() int

+ func (m *UpdateWorkflowExecutionResponse) XXX_Unmarshal(b []byte) error

+ func (this *UpdateWorkflowExecutionResponse) Equal(that interface{}) bool

+ func (this *UpdateWorkflowExecutionResponse) GoString() string

+ func (this *UpdateWorkflowExecutionResponse) String() string

Jan 13, 2023 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Dec 1, 2022 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Nov 15, 2022 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Oct 31, 2022 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Oct 20, 2022 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Oct 18, 2022 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Oct 10, 2022 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Sep 16, 2022 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Sep 14, 2022 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Aug 30, 2022 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Aug 16, 2022 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Aug 17, 2022 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Changes in this version

type DeleteWorkflowExecutionRequest

+ ClosedWorkflowOnly bool

+ WorkflowVersion int64

+ func (m *DeleteWorkflowExecutionRequest) GetClosedWorkflowOnly() bool

+ func (m *DeleteWorkflowExecutionRequest) GetWorkflowVersion() int64

type HistoryServiceClient

+ UpdateWorkflow func(ctx context.Context, in *UpdateWorkflowRequest, opts ...grpc.CallOption) (*UpdateWorkflowResponse, error)

type HistoryServiceServer

+ UpdateWorkflow func(context.Context, *UpdateWorkflowRequest) (*UpdateWorkflowResponse, error)

type RecordWorkflowTaskStartedResponse

+ TransientWorkflowTask *v18.TransientWorkflowTaskInfo

+ func (m *RecordWorkflowTaskStartedResponse) GetTransientWorkflowTask() *v18.TransientWorkflowTaskInfo

type UnimplementedHistoryServiceServer

+ func (*UnimplementedHistoryServiceServer) UpdateWorkflow(ctx context.Context, req *UpdateWorkflowRequest) (*UpdateWorkflowResponse, error)

+ type UpdateWorkflowRequest struct

+ NamespaceId string

+ Request *v1.UpdateWorkflowRequest

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

+ func (*UpdateWorkflowRequest) ProtoMessage()

+ func (m *UpdateWorkflowRequest) GetNamespaceId() string

+ func (m *UpdateWorkflowRequest) GetRequest() *v1.UpdateWorkflowRequest

+ func (m *UpdateWorkflowRequest) Marshal() (dAtA []byte, err error)

+ func (m *UpdateWorkflowRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *UpdateWorkflowRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *UpdateWorkflowRequest) Reset()

+ func (m *UpdateWorkflowRequest) Size() (n int)

+ func (m *UpdateWorkflowRequest) Unmarshal(dAtA []byte) error

+ func (m *UpdateWorkflowRequest) XXX_DiscardUnknown()

+ func (m *UpdateWorkflowRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *UpdateWorkflowRequest) XXX_Merge(src proto.Message)

+ func (m *UpdateWorkflowRequest) XXX_Size() int

+ func (m *UpdateWorkflowRequest) XXX_Unmarshal(b []byte) error

+ func (this *UpdateWorkflowRequest) Equal(that interface{}) bool

+ func (this *UpdateWorkflowRequest) GoString() string

+ func (this *UpdateWorkflowRequest) String() string

+ type UpdateWorkflowResponse struct

+ Response *v1.UpdateWorkflowResponse

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

+ func (*UpdateWorkflowResponse) ProtoMessage()

+ func (m *UpdateWorkflowResponse) GetResponse() *v1.UpdateWorkflowResponse

+ func (m *UpdateWorkflowResponse) Marshal() (dAtA []byte, err error)

+ func (m *UpdateWorkflowResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *UpdateWorkflowResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *UpdateWorkflowResponse) Reset()

+ func (m *UpdateWorkflowResponse) Size() (n int)

+ func (m *UpdateWorkflowResponse) Unmarshal(dAtA []byte) error

+ func (m *UpdateWorkflowResponse) XXX_DiscardUnknown()

+ func (m *UpdateWorkflowResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *UpdateWorkflowResponse) XXX_Merge(src proto.Message)

+ func (m *UpdateWorkflowResponse) XXX_Size() int

+ func (m *UpdateWorkflowResponse) XXX_Unmarshal(b []byte) error

+ func (this *UpdateWorkflowResponse) Equal(that interface{}) bool

+ func (this *UpdateWorkflowResponse) GoString() string

+ func (this *UpdateWorkflowResponse) String() string

Aug 2, 2022 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Changes in this version

type ShardReplicationStatus

+ MaxReplicationTaskVisibilityTime *time.Time

+ func (m *ShardReplicationStatus) GetMaxReplicationTaskVisibilityTime() *time.Time

Jul 11, 2022 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Jun 17, 2022 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Changes in this version

+ type DeleteWorkflowVisibilityRecordRequest struct

+ Execution *v14.WorkflowExecution

+ NamespaceId string

+ WorkflowCloseTime *time.Time

+ WorkflowStartTime *time.Time

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

+ func (*DeleteWorkflowVisibilityRecordRequest) ProtoMessage()

+ func (m *DeleteWorkflowVisibilityRecordRequest) GetExecution() *v14.WorkflowExecution

+ func (m *DeleteWorkflowVisibilityRecordRequest) GetNamespaceId() string

+ func (m *DeleteWorkflowVisibilityRecordRequest) GetWorkflowCloseTime() *time.Time

+ func (m *DeleteWorkflowVisibilityRecordRequest) GetWorkflowStartTime() *time.Time

+ func (m *DeleteWorkflowVisibilityRecordRequest) Marshal() (dAtA []byte, err error)

+ func (m *DeleteWorkflowVisibilityRecordRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *DeleteWorkflowVisibilityRecordRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *DeleteWorkflowVisibilityRecordRequest) Reset()

+ func (m *DeleteWorkflowVisibilityRecordRequest) Size() (n int)

+ func (m *DeleteWorkflowVisibilityRecordRequest) Unmarshal(dAtA []byte) error

+ func (m *DeleteWorkflowVisibilityRecordRequest) XXX_DiscardUnknown()

+ func (m *DeleteWorkflowVisibilityRecordRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *DeleteWorkflowVisibilityRecordRequest) XXX_Merge(src proto.Message)

+ func (m *DeleteWorkflowVisibilityRecordRequest) XXX_Size() int

+ func (m *DeleteWorkflowVisibilityRecordRequest) XXX_Unmarshal(b []byte) error

+ func (this *DeleteWorkflowVisibilityRecordRequest) Equal(that interface{}) bool

+ func (this *DeleteWorkflowVisibilityRecordRequest) GoString() string

+ func (this *DeleteWorkflowVisibilityRecordRequest) String() string

+ type DeleteWorkflowVisibilityRecordResponse struct

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

+ func (*DeleteWorkflowVisibilityRecordResponse) ProtoMessage()

+ func (m *DeleteWorkflowVisibilityRecordResponse) Marshal() (dAtA []byte, err error)

+ func (m *DeleteWorkflowVisibilityRecordResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *DeleteWorkflowVisibilityRecordResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *DeleteWorkflowVisibilityRecordResponse) Reset()

+ func (m *DeleteWorkflowVisibilityRecordResponse) Size() (n int)

+ func (m *DeleteWorkflowVisibilityRecordResponse) Unmarshal(dAtA []byte) error

+ func (m *DeleteWorkflowVisibilityRecordResponse) XXX_DiscardUnknown()

+ func (m *DeleteWorkflowVisibilityRecordResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *DeleteWorkflowVisibilityRecordResponse) XXX_Merge(src proto.Message)

+ func (m *DeleteWorkflowVisibilityRecordResponse) XXX_Size() int

+ func (m *DeleteWorkflowVisibilityRecordResponse) XXX_Unmarshal(b []byte) error

+ func (this *DeleteWorkflowVisibilityRecordResponse) Equal(that interface{}) bool

+ func (this *DeleteWorkflowVisibilityRecordResponse) GoString() string

+ func (this *DeleteWorkflowVisibilityRecordResponse) String() string

type GetMutableStateResponse

+ FirstExecutionRunId string

+ func (m *GetMutableStateResponse) GetFirstExecutionRunId() string

type HistoryServiceClient

+ DeleteWorkflowVisibilityRecord func(ctx context.Context, in *DeleteWorkflowVisibilityRecordRequest, ...) (*DeleteWorkflowVisibilityRecordResponse, error)

+ VerifyChildExecutionCompletionRecorded func(ctx context.Context, in *VerifyChildExecutionCompletionRecordedRequest, ...) (*VerifyChildExecutionCompletionRecordedResponse, error)

+ VerifyFirstWorkflowTaskScheduled func(ctx context.Context, in *VerifyFirstWorkflowTaskScheduledRequest, ...) (*VerifyFirstWorkflowTaskScheduledResponse, error)

type HistoryServiceServer

+ DeleteWorkflowVisibilityRecord func(context.Context, *DeleteWorkflowVisibilityRecordRequest) (*DeleteWorkflowVisibilityRecordResponse, error)

+ VerifyChildExecutionCompletionRecorded func(context.Context, *VerifyChildExecutionCompletionRecordedRequest) (*VerifyChildExecutionCompletionRecordedResponse, error)

+ VerifyFirstWorkflowTaskScheduled func(context.Context, *VerifyFirstWorkflowTaskScheduledRequest) (*VerifyFirstWorkflowTaskScheduledResponse, error)

type PollMutableStateResponse

+ FirstExecutionRunId string

+ func (m *PollMutableStateResponse) GetFirstExecutionRunId() string

type RecordActivityTaskStartedRequest

+ Clock *v15.VectorClock

+ ScheduledEventId int64

+ func (m *RecordActivityTaskStartedRequest) GetClock() *v15.VectorClock

+ func (m *RecordActivityTaskStartedRequest) GetScheduledEventId() int64

type RecordActivityTaskStartedResponse

+ Clock *v15.VectorClock

+ func (m *RecordActivityTaskStartedResponse) GetClock() *v15.VectorClock

type RecordChildExecutionCompletedRequest

+ Clock *v15.VectorClock

+ ParentInitiatedId int64

+ ParentInitiatedVersion int64

+ func (m *RecordChildExecutionCompletedRequest) GetClock() *v15.VectorClock

+ func (m *RecordChildExecutionCompletedRequest) GetParentInitiatedId() int64

+ func (m *RecordChildExecutionCompletedRequest) GetParentInitiatedVersion() int64

type RecordWorkflowTaskStartedRequest

+ Clock *v15.VectorClock

+ ScheduledEventId int64

+ func (m *RecordWorkflowTaskStartedRequest) GetClock() *v15.VectorClock

+ func (m *RecordWorkflowTaskStartedRequest) GetScheduledEventId() int64

type RecordWorkflowTaskStartedResponse

+ Clock *v15.VectorClock

+ func (m *RecordWorkflowTaskStartedResponse) GetClock() *v15.VectorClock

+ type ReplicateWorkflowStateRequest struct

+ RemoteCluster string

+ WorkflowState *v112.WorkflowMutableState

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

+ func (*ReplicateWorkflowStateRequest) ProtoMessage()

+ func (m *ReplicateWorkflowStateRequest) GetRemoteCluster() string

+ func (m *ReplicateWorkflowStateRequest) GetWorkflowState() *v112.WorkflowMutableState

+ func (m *ReplicateWorkflowStateRequest) Marshal() (dAtA []byte, err error)

+ func (m *ReplicateWorkflowStateRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *ReplicateWorkflowStateRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ReplicateWorkflowStateRequest) Reset()

+ func (m *ReplicateWorkflowStateRequest) Size() (n int)

+ func (m *ReplicateWorkflowStateRequest) Unmarshal(dAtA []byte) error

+ func (m *ReplicateWorkflowStateRequest) XXX_DiscardUnknown()

+ func (m *ReplicateWorkflowStateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ReplicateWorkflowStateRequest) XXX_Merge(src proto.Message)

+ func (m *ReplicateWorkflowStateRequest) XXX_Size() int

+ func (m *ReplicateWorkflowStateRequest) XXX_Unmarshal(b []byte) error

+ func (this *ReplicateWorkflowStateRequest) Equal(that interface{}) bool

+ func (this *ReplicateWorkflowStateRequest) GoString() string

+ func (this *ReplicateWorkflowStateRequest) String() string

type ScheduleWorkflowTaskRequest

+ Clock *v15.VectorClock

+ func (m *ScheduleWorkflowTaskRequest) GetClock() *v15.VectorClock

type StartWorkflowExecutionResponse

+ Clock *v15.VectorClock

+ func (m *StartWorkflowExecutionResponse) GetClock() *v15.VectorClock

type SyncActivityRequest

+ ScheduledEventId int64

+ StartedEventId int64

+ func (m *SyncActivityRequest) GetScheduledEventId() int64

+ func (m *SyncActivityRequest) GetStartedEventId() int64

type UnimplementedHistoryServiceServer

+ func (*UnimplementedHistoryServiceServer) DeleteWorkflowVisibilityRecord(ctx context.Context, req *DeleteWorkflowVisibilityRecordRequest) (*DeleteWorkflowVisibilityRecordResponse, error)

+ func (*UnimplementedHistoryServiceServer) VerifyChildExecutionCompletionRecorded(ctx context.Context, req *VerifyChildExecutionCompletionRecordedRequest) (*VerifyChildExecutionCompletionRecordedResponse, error)

+ func (*UnimplementedHistoryServiceServer) VerifyFirstWorkflowTaskScheduled(ctx context.Context, req *VerifyFirstWorkflowTaskScheduledRequest) (*VerifyFirstWorkflowTaskScheduledResponse, error)

+ type VerifyChildExecutionCompletionRecordedRequest struct

+ ChildExecution *v14.WorkflowExecution

+ Clock *v15.VectorClock

+ NamespaceId string

+ ParentExecution *v14.WorkflowExecution

+ ParentInitiatedId int64

+ ParentInitiatedVersion int64

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

+ func (*VerifyChildExecutionCompletionRecordedRequest) ProtoMessage()

+ func (m *VerifyChildExecutionCompletionRecordedRequest) GetChildExecution() *v14.WorkflowExecution

+ func (m *VerifyChildExecutionCompletionRecordedRequest) GetClock() *v15.VectorClock

+ func (m *VerifyChildExecutionCompletionRecordedRequest) GetNamespaceId() string

+ func (m *VerifyChildExecutionCompletionRecordedRequest) GetParentExecution() *v14.WorkflowExecution

+ func (m *VerifyChildExecutionCompletionRecordedRequest) GetParentInitiatedId() int64

+ func (m *VerifyChildExecutionCompletionRecordedRequest) GetParentInitiatedVersion() int64

+ func (m *VerifyChildExecutionCompletionRecordedRequest) Marshal() (dAtA []byte, err error)

+ func (m *VerifyChildExecutionCompletionRecordedRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *VerifyChildExecutionCompletionRecordedRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *VerifyChildExecutionCompletionRecordedRequest) Reset()

+ func (m *VerifyChildExecutionCompletionRecordedRequest) Size() (n int)

+ func (m *VerifyChildExecutionCompletionRecordedRequest) Unmarshal(dAtA []byte) error

+ func (m *VerifyChildExecutionCompletionRecordedRequest) XXX_DiscardUnknown()

+ func (m *VerifyChildExecutionCompletionRecordedRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *VerifyChildExecutionCompletionRecordedRequest) XXX_Merge(src proto.Message)

+ func (m *VerifyChildExecutionCompletionRecordedRequest) XXX_Size() int

+ func (m *VerifyChildExecutionCompletionRecordedRequest) XXX_Unmarshal(b []byte) error

+ func (this *VerifyChildExecutionCompletionRecordedRequest) Equal(that interface{}) bool

+ func (this *VerifyChildExecutionCompletionRecordedRequest) GoString() string

+ func (this *VerifyChildExecutionCompletionRecordedRequest) String() string

+ type VerifyChildExecutionCompletionRecordedResponse struct

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

+ func (*VerifyChildExecutionCompletionRecordedResponse) ProtoMessage()

+ func (m *VerifyChildExecutionCompletionRecordedResponse) Marshal() (dAtA []byte, err error)

+ func (m *VerifyChildExecutionCompletionRecordedResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *VerifyChildExecutionCompletionRecordedResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *VerifyChildExecutionCompletionRecordedResponse) Reset()

+ func (m *VerifyChildExecutionCompletionRecordedResponse) Size() (n int)

+ func (m *VerifyChildExecutionCompletionRecordedResponse) Unmarshal(dAtA []byte) error

+ func (m *VerifyChildExecutionCompletionRecordedResponse) XXX_DiscardUnknown()

+ func (m *VerifyChildExecutionCompletionRecordedResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *VerifyChildExecutionCompletionRecordedResponse) XXX_Merge(src proto.Message)

+ func (m *VerifyChildExecutionCompletionRecordedResponse) XXX_Size() int

+ func (m *VerifyChildExecutionCompletionRecordedResponse) XXX_Unmarshal(b []byte) error

+ func (this *VerifyChildExecutionCompletionRecordedResponse) Equal(that interface{}) bool

+ func (this *VerifyChildExecutionCompletionRecordedResponse) GoString() string

+ func (this *VerifyChildExecutionCompletionRecordedResponse) String() string

+ type VerifyFirstWorkflowTaskScheduledRequest struct

+ Clock *v15.VectorClock

+ NamespaceId string

+ WorkflowExecution *v14.WorkflowExecution

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

+ func (*VerifyFirstWorkflowTaskScheduledRequest) ProtoMessage()

+ func (m *VerifyFirstWorkflowTaskScheduledRequest) GetClock() *v15.VectorClock

+ func (m *VerifyFirstWorkflowTaskScheduledRequest) GetNamespaceId() string

+ func (m *VerifyFirstWorkflowTaskScheduledRequest) GetWorkflowExecution() *v14.WorkflowExecution

+ func (m *VerifyFirstWorkflowTaskScheduledRequest) Marshal() (dAtA []byte, err error)

+ func (m *VerifyFirstWorkflowTaskScheduledRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *VerifyFirstWorkflowTaskScheduledRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *VerifyFirstWorkflowTaskScheduledRequest) Reset()

+ func (m *VerifyFirstWorkflowTaskScheduledRequest) Size() (n int)

+ func (m *VerifyFirstWorkflowTaskScheduledRequest) Unmarshal(dAtA []byte) error

+ func (m *VerifyFirstWorkflowTaskScheduledRequest) XXX_DiscardUnknown()

+ func (m *VerifyFirstWorkflowTaskScheduledRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *VerifyFirstWorkflowTaskScheduledRequest) XXX_Merge(src proto.Message)

+ func (m *VerifyFirstWorkflowTaskScheduledRequest) XXX_Size() int

+ func (m *VerifyFirstWorkflowTaskScheduledRequest) XXX_Unmarshal(b []byte) error

+ func (this *VerifyFirstWorkflowTaskScheduledRequest) Equal(that interface{}) bool

+ func (this *VerifyFirstWorkflowTaskScheduledRequest) GoString() string

+ func (this *VerifyFirstWorkflowTaskScheduledRequest) String() string

+ type VerifyFirstWorkflowTaskScheduledResponse struct

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

+ func (*VerifyFirstWorkflowTaskScheduledResponse) ProtoMessage()

+ func (m *VerifyFirstWorkflowTaskScheduledResponse) Marshal() (dAtA []byte, err error)

+ func (m *VerifyFirstWorkflowTaskScheduledResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *VerifyFirstWorkflowTaskScheduledResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *VerifyFirstWorkflowTaskScheduledResponse) Reset()

+ func (m *VerifyFirstWorkflowTaskScheduledResponse) Size() (n int)

+ func (m *VerifyFirstWorkflowTaskScheduledResponse) Unmarshal(dAtA []byte) error

+ func (m *VerifyFirstWorkflowTaskScheduledResponse) XXX_DiscardUnknown()

+ func (m *VerifyFirstWorkflowTaskScheduledResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *VerifyFirstWorkflowTaskScheduledResponse) XXX_Merge(src proto.Message)

+ func (m *VerifyFirstWorkflowTaskScheduledResponse) XXX_Size() int

+ func (m *VerifyFirstWorkflowTaskScheduledResponse) XXX_Unmarshal(b []byte) error

+ func (this *VerifyFirstWorkflowTaskScheduledResponse) Equal(that interface{}) bool

+ func (this *VerifyFirstWorkflowTaskScheduledResponse) GoString() string

+ func (this *VerifyFirstWorkflowTaskScheduledResponse) String() string

Jul 11, 2022 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

May 5, 2022 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Apr 19, 2022 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Apr 11, 2022 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Changes in this version

type HistoryServiceClient

+ RebuildMutableState func(ctx context.Context, in *RebuildMutableStateRequest, opts ...grpc.CallOption) (*RebuildMutableStateResponse, error)

type HistoryServiceServer

+ RebuildMutableState func(context.Context, *RebuildMutableStateRequest) (*RebuildMutableStateResponse, error)

+ type RebuildMutableStateRequest struct

+ Execution *v14.WorkflowExecution

+ NamespaceId string

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

+ func (*RebuildMutableStateRequest) ProtoMessage()

+ func (m *RebuildMutableStateRequest) GetExecution() *v14.WorkflowExecution

+ func (m *RebuildMutableStateRequest) GetNamespaceId() string

+ func (m *RebuildMutableStateRequest) Marshal() (dAtA []byte, err error)

+ func (m *RebuildMutableStateRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *RebuildMutableStateRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *RebuildMutableStateRequest) Reset()

+ func (m *RebuildMutableStateRequest) Size() (n int)

+ func (m *RebuildMutableStateRequest) Unmarshal(dAtA []byte) error

+ func (m *RebuildMutableStateRequest) XXX_DiscardUnknown()

+ func (m *RebuildMutableStateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *RebuildMutableStateRequest) XXX_Merge(src proto.Message)

+ func (m *RebuildMutableStateRequest) XXX_Size() int

+ func (m *RebuildMutableStateRequest) XXX_Unmarshal(b []byte) error

+ func (this *RebuildMutableStateRequest) Equal(that interface{}) bool

+ func (this *RebuildMutableStateRequest) GoString() string

+ func (this *RebuildMutableStateRequest) String() string

+ type RebuildMutableStateResponse struct

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

+ func (*RebuildMutableStateResponse) ProtoMessage()

+ func (m *RebuildMutableStateResponse) Marshal() (dAtA []byte, err error)

+ func (m *RebuildMutableStateResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *RebuildMutableStateResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *RebuildMutableStateResponse) Reset()

+ func (m *RebuildMutableStateResponse) Size() (n int)

+ func (m *RebuildMutableStateResponse) Unmarshal(dAtA []byte) error

+ func (m *RebuildMutableStateResponse) XXX_DiscardUnknown()

+ func (m *RebuildMutableStateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *RebuildMutableStateResponse) XXX_Merge(src proto.Message)

+ func (m *RebuildMutableStateResponse) XXX_Size() int

+ func (m *RebuildMutableStateResponse) XXX_Unmarshal(b []byte) error

+ func (this *RebuildMutableStateResponse) Equal(that interface{}) bool

+ func (this *RebuildMutableStateResponse) GoString() string

+ func (this *RebuildMutableStateResponse) String() string

type RespondWorkflowTaskCompletedResponse

+ ActivityTasks []*v1.PollActivityTaskQueueResponse

+ func (m *RespondWorkflowTaskCompletedResponse) GetActivityTasks() []*v1.PollActivityTaskQueueResponse

type UnimplementedHistoryServiceServer

+ func (*UnimplementedHistoryServiceServer) RebuildMutableState(ctx context.Context, req *RebuildMutableStateRequest) (*RebuildMutableStateResponse, error)

Mar 4, 2022 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Mar 1, 2022 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Feb 9, 2022 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Changes in this version

+ type DeleteWorkflowExecutionRequest struct

+ NamespaceId string

+ WorkflowExecution *v14.WorkflowExecution

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

+ func (*DeleteWorkflowExecutionRequest) ProtoMessage()

+ func (m *DeleteWorkflowExecutionRequest) GetNamespaceId() string

+ func (m *DeleteWorkflowExecutionRequest) GetWorkflowExecution() *v14.WorkflowExecution

+ func (m *DeleteWorkflowExecutionRequest) Marshal() (dAtA []byte, err error)

+ func (m *DeleteWorkflowExecutionRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *DeleteWorkflowExecutionRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *DeleteWorkflowExecutionRequest) Reset()

+ func (m *DeleteWorkflowExecutionRequest) Size() (n int)

+ func (m *DeleteWorkflowExecutionRequest) Unmarshal(dAtA []byte) error

+ func (m *DeleteWorkflowExecutionRequest) XXX_DiscardUnknown()

+ func (m *DeleteWorkflowExecutionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *DeleteWorkflowExecutionRequest) XXX_Merge(src proto.Message)

+ func (m *DeleteWorkflowExecutionRequest) XXX_Size() int

+ func (m *DeleteWorkflowExecutionRequest) XXX_Unmarshal(b []byte) error

+ func (this *DeleteWorkflowExecutionRequest) Equal(that interface{}) bool

+ func (this *DeleteWorkflowExecutionRequest) GoString() string

+ func (this *DeleteWorkflowExecutionRequest) String() string

+ type DeleteWorkflowExecutionResponse struct

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

+ func (*DeleteWorkflowExecutionResponse) ProtoMessage()

+ func (m *DeleteWorkflowExecutionResponse) Marshal() (dAtA []byte, err error)

+ func (m *DeleteWorkflowExecutionResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *DeleteWorkflowExecutionResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *DeleteWorkflowExecutionResponse) Reset()

+ func (m *DeleteWorkflowExecutionResponse) Size() (n int)

+ func (m *DeleteWorkflowExecutionResponse) Unmarshal(dAtA []byte) error

+ func (m *DeleteWorkflowExecutionResponse) XXX_DiscardUnknown()

+ func (m *DeleteWorkflowExecutionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *DeleteWorkflowExecutionResponse) XXX_Merge(src proto.Message)

+ func (m *DeleteWorkflowExecutionResponse) XXX_Size() int

+ func (m *DeleteWorkflowExecutionResponse) XXX_Unmarshal(b []byte) error

+ func (this *DeleteWorkflowExecutionResponse) Equal(that interface{}) bool

+ func (this *DeleteWorkflowExecutionResponse) GoString() string

+ func (this *DeleteWorkflowExecutionResponse) String() string

type DescribeWorkflowExecutionResponse

+ PendingWorkflowTask *v110.PendingWorkflowTaskInfo

+ func (m *DescribeWorkflowExecutionResponse) GetPendingWorkflowTask() *v110.PendingWorkflowTaskInfo

type HistoryServiceClient

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

type HistoryServiceServer

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

type TerminateWorkflowExecutionRequest

+ ChildWorkflowOnly bool

+ ExternalWorkflowExecution *v14.WorkflowExecution

+ func (m *TerminateWorkflowExecutionRequest) GetChildWorkflowOnly() bool

+ func (m *TerminateWorkflowExecutionRequest) GetExternalWorkflowExecution() *v14.WorkflowExecution

type UnimplementedHistoryServiceServer

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

Mar 4, 2022 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Feb 11, 2022 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Jan 21, 2022 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Jan 18, 2022 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Jan 10, 2022 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Dec 20, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Dec 13, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Changes in this version

+ type GenerateLastHistoryReplicationTasksRequest struct

+ Execution *v14.WorkflowExecution

+ NamespaceId string

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

+ func (*GenerateLastHistoryReplicationTasksRequest) ProtoMessage()

+ func (m *GenerateLastHistoryReplicationTasksRequest) GetExecution() *v14.WorkflowExecution

+ func (m *GenerateLastHistoryReplicationTasksRequest) GetNamespaceId() string

+ func (m *GenerateLastHistoryReplicationTasksRequest) Marshal() (dAtA []byte, err error)

+ func (m *GenerateLastHistoryReplicationTasksRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *GenerateLastHistoryReplicationTasksRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *GenerateLastHistoryReplicationTasksRequest) Reset()

+ func (m *GenerateLastHistoryReplicationTasksRequest) Size() (n int)

+ func (m *GenerateLastHistoryReplicationTasksRequest) Unmarshal(dAtA []byte) error

+ func (m *GenerateLastHistoryReplicationTasksRequest) XXX_DiscardUnknown()

+ func (m *GenerateLastHistoryReplicationTasksRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *GenerateLastHistoryReplicationTasksRequest) XXX_Merge(src proto.Message)

+ func (m *GenerateLastHistoryReplicationTasksRequest) XXX_Size() int

+ func (m *GenerateLastHistoryReplicationTasksRequest) XXX_Unmarshal(b []byte) error

+ func (this *GenerateLastHistoryReplicationTasksRequest) Equal(that interface{}) bool

+ func (this *GenerateLastHistoryReplicationTasksRequest) GoString() string

+ func (this *GenerateLastHistoryReplicationTasksRequest) String() string

+ type GenerateLastHistoryReplicationTasksResponse struct

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

+ func (*GenerateLastHistoryReplicationTasksResponse) ProtoMessage()

+ func (m *GenerateLastHistoryReplicationTasksResponse) Marshal() (dAtA []byte, err error)

+ func (m *GenerateLastHistoryReplicationTasksResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *GenerateLastHistoryReplicationTasksResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *GenerateLastHistoryReplicationTasksResponse) Reset()

+ func (m *GenerateLastHistoryReplicationTasksResponse) Size() (n int)

+ func (m *GenerateLastHistoryReplicationTasksResponse) Unmarshal(dAtA []byte) error

+ func (m *GenerateLastHistoryReplicationTasksResponse) XXX_DiscardUnknown()

+ func (m *GenerateLastHistoryReplicationTasksResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *GenerateLastHistoryReplicationTasksResponse) XXX_Merge(src proto.Message)

+ func (m *GenerateLastHistoryReplicationTasksResponse) XXX_Size() int

+ func (m *GenerateLastHistoryReplicationTasksResponse) XXX_Unmarshal(b []byte) error

+ func (this *GenerateLastHistoryReplicationTasksResponse) Equal(that interface{}) bool

+ func (this *GenerateLastHistoryReplicationTasksResponse) GoString() string

+ func (this *GenerateLastHistoryReplicationTasksResponse) String() string

+ type GetReplicationStatusRequest struct

+ RemoteClusters []string

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

+ func (*GetReplicationStatusRequest) ProtoMessage()

+ func (m *GetReplicationStatusRequest) GetRemoteClusters() []string

+ func (m *GetReplicationStatusRequest) Marshal() (dAtA []byte, err error)

+ func (m *GetReplicationStatusRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *GetReplicationStatusRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *GetReplicationStatusRequest) Reset()

+ func (m *GetReplicationStatusRequest) Size() (n int)

+ func (m *GetReplicationStatusRequest) Unmarshal(dAtA []byte) error

+ func (m *GetReplicationStatusRequest) XXX_DiscardUnknown()

+ func (m *GetReplicationStatusRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *GetReplicationStatusRequest) XXX_Merge(src proto.Message)

+ func (m *GetReplicationStatusRequest) XXX_Size() int

+ func (m *GetReplicationStatusRequest) XXX_Unmarshal(b []byte) error

+ func (this *GetReplicationStatusRequest) Equal(that interface{}) bool

+ func (this *GetReplicationStatusRequest) GoString() string

+ func (this *GetReplicationStatusRequest) String() string

+ type GetReplicationStatusResponse struct

+ Shards []*ShardReplicationStatus

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

+ func (*GetReplicationStatusResponse) ProtoMessage()

+ func (m *GetReplicationStatusResponse) GetShards() []*ShardReplicationStatus

+ func (m *GetReplicationStatusResponse) Marshal() (dAtA []byte, err error)

+ func (m *GetReplicationStatusResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *GetReplicationStatusResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *GetReplicationStatusResponse) Reset()

+ func (m *GetReplicationStatusResponse) Size() (n int)

+ func (m *GetReplicationStatusResponse) Unmarshal(dAtA []byte) error

+ func (m *GetReplicationStatusResponse) XXX_DiscardUnknown()

+ func (m *GetReplicationStatusResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *GetReplicationStatusResponse) XXX_Merge(src proto.Message)

+ func (m *GetReplicationStatusResponse) XXX_Size() int

+ func (m *GetReplicationStatusResponse) XXX_Unmarshal(b []byte) error

+ func (this *GetReplicationStatusResponse) Equal(that interface{}) bool

+ func (this *GetReplicationStatusResponse) GoString() string

+ func (this *GetReplicationStatusResponse) String() string

+ type GetShardRequest struct

+ ShardId int32

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

+ func (*GetShardRequest) ProtoMessage()

+ func (m *GetShardRequest) GetShardId() int32

+ func (m *GetShardRequest) Marshal() (dAtA []byte, err error)

+ func (m *GetShardRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *GetShardRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *GetShardRequest) Reset()

+ func (m *GetShardRequest) Size() (n int)

+ func (m *GetShardRequest) Unmarshal(dAtA []byte) error

+ func (m *GetShardRequest) XXX_DiscardUnknown()

+ func (m *GetShardRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *GetShardRequest) XXX_Merge(src proto.Message)

+ func (m *GetShardRequest) XXX_Size() int

+ func (m *GetShardRequest) XXX_Unmarshal(b []byte) error

+ func (this *GetShardRequest) Equal(that interface{}) bool

+ func (this *GetShardRequest) GoString() string

+ func (this *GetShardRequest) String() string

+ type GetShardResponse struct

+ ShardInfo *v111.ShardInfo

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

+ func (*GetShardResponse) ProtoMessage()

+ func (m *GetShardResponse) GetShardInfo() *v111.ShardInfo

+ func (m *GetShardResponse) Marshal() (dAtA []byte, err error)

+ func (m *GetShardResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *GetShardResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *GetShardResponse) Reset()

+ func (m *GetShardResponse) Size() (n int)

+ func (m *GetShardResponse) Unmarshal(dAtA []byte) error

+ func (m *GetShardResponse) XXX_DiscardUnknown()

+ func (m *GetShardResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *GetShardResponse) XXX_Merge(src proto.Message)

+ func (m *GetShardResponse) XXX_Size() int

+ func (m *GetShardResponse) XXX_Unmarshal(b []byte) error

+ func (this *GetShardResponse) Equal(that interface{}) bool

+ func (this *GetShardResponse) GoString() string

+ func (this *GetShardResponse) String() string

+ type HandoverNamespaceInfo struct

+ HandoverReplicationTaskId int64

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

+ func (*HandoverNamespaceInfo) ProtoMessage()

+ func (m *HandoverNamespaceInfo) GetHandoverReplicationTaskId() int64

+ func (m *HandoverNamespaceInfo) Marshal() (dAtA []byte, err error)

+ func (m *HandoverNamespaceInfo) MarshalTo(dAtA []byte) (int, error)

+ func (m *HandoverNamespaceInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *HandoverNamespaceInfo) Reset()

+ func (m *HandoverNamespaceInfo) Size() (n int)

+ func (m *HandoverNamespaceInfo) Unmarshal(dAtA []byte) error

+ func (m *HandoverNamespaceInfo) XXX_DiscardUnknown()

+ func (m *HandoverNamespaceInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *HandoverNamespaceInfo) XXX_Merge(src proto.Message)

+ func (m *HandoverNamespaceInfo) XXX_Size() int

+ func (m *HandoverNamespaceInfo) XXX_Unmarshal(b []byte) error

+ func (this *HandoverNamespaceInfo) Equal(that interface{}) bool

+ func (this *HandoverNamespaceInfo) GoString() string

+ func (this *HandoverNamespaceInfo) String() string

type HistoryServiceClient

+ GenerateLastHistoryReplicationTasks func(ctx context.Context, in *GenerateLastHistoryReplicationTasksRequest, ...) (*GenerateLastHistoryReplicationTasksResponse, error)

+ GetReplicationStatus func(ctx context.Context, in *GetReplicationStatusRequest, opts ...grpc.CallOption) (*GetReplicationStatusResponse, error)

+ GetShard func(ctx context.Context, in *GetShardRequest, opts ...grpc.CallOption) (*GetShardResponse, error)

type HistoryServiceServer

+ GenerateLastHistoryReplicationTasks func(context.Context, *GenerateLastHistoryReplicationTasksRequest) (*GenerateLastHistoryReplicationTasksResponse, error)

+ GetReplicationStatus func(context.Context, *GetReplicationStatusRequest) (*GetReplicationStatusResponse, error)

+ GetShard func(context.Context, *GetShardRequest) (*GetShardResponse, error)

+ type ShardReplicationStatus struct

+ HandoverNamespaces map[string]*HandoverNamespaceInfo

+ MaxReplicationTaskId int64

+ RemoteClusters map[string]*ShardReplicationStatusPerCluster

+ ShardId int32

+ ShardLocalTime *time.Time

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

+ func (*ShardReplicationStatus) ProtoMessage()

+ func (m *ShardReplicationStatus) GetHandoverNamespaces() map[string]*HandoverNamespaceInfo

+ func (m *ShardReplicationStatus) GetMaxReplicationTaskId() int64

+ func (m *ShardReplicationStatus) GetRemoteClusters() map[string]*ShardReplicationStatusPerCluster

+ func (m *ShardReplicationStatus) GetShardId() int32

+ func (m *ShardReplicationStatus) GetShardLocalTime() *time.Time

+ func (m *ShardReplicationStatus) Marshal() (dAtA []byte, err error)

+ func (m *ShardReplicationStatus) MarshalTo(dAtA []byte) (int, error)

+ func (m *ShardReplicationStatus) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ShardReplicationStatus) Reset()

+ func (m *ShardReplicationStatus) Size() (n int)

+ func (m *ShardReplicationStatus) Unmarshal(dAtA []byte) error

+ func (m *ShardReplicationStatus) XXX_DiscardUnknown()

+ func (m *ShardReplicationStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ShardReplicationStatus) XXX_Merge(src proto.Message)

+ func (m *ShardReplicationStatus) XXX_Size() int

+ func (m *ShardReplicationStatus) XXX_Unmarshal(b []byte) error

+ func (this *ShardReplicationStatus) Equal(that interface{}) bool

+ func (this *ShardReplicationStatus) GoString() string

+ func (this *ShardReplicationStatus) String() string

+ type ShardReplicationStatusPerCluster struct

+ AckedTaskId int64

+ AckedTaskVisibilityTime *time.Time

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

+ func (*ShardReplicationStatusPerCluster) ProtoMessage()

+ func (m *ShardReplicationStatusPerCluster) GetAckedTaskId() int64

+ func (m *ShardReplicationStatusPerCluster) GetAckedTaskVisibilityTime() *time.Time

+ func (m *ShardReplicationStatusPerCluster) Marshal() (dAtA []byte, err error)

+ func (m *ShardReplicationStatusPerCluster) MarshalTo(dAtA []byte) (int, error)

+ func (m *ShardReplicationStatusPerCluster) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ShardReplicationStatusPerCluster) Reset()

+ func (m *ShardReplicationStatusPerCluster) Size() (n int)

+ func (m *ShardReplicationStatusPerCluster) Unmarshal(dAtA []byte) error

+ func (m *ShardReplicationStatusPerCluster) XXX_DiscardUnknown()

+ func (m *ShardReplicationStatusPerCluster) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ShardReplicationStatusPerCluster) XXX_Merge(src proto.Message)

+ func (m *ShardReplicationStatusPerCluster) XXX_Size() int

+ func (m *ShardReplicationStatusPerCluster) XXX_Unmarshal(b []byte) error

+ func (this *ShardReplicationStatusPerCluster) Equal(that interface{}) bool

+ func (this *ShardReplicationStatusPerCluster) GoString() string

+ func (this *ShardReplicationStatusPerCluster) String() string

type UnimplementedHistoryServiceServer

+ func (*UnimplementedHistoryServiceServer) GenerateLastHistoryReplicationTasks(ctx context.Context, req *GenerateLastHistoryReplicationTasksRequest) (*GenerateLastHistoryReplicationTasksResponse, error)

+ func (*UnimplementedHistoryServiceServer) GetReplicationStatus(ctx context.Context, req *GetReplicationStatusRequest) (*GetReplicationStatusResponse, error)

+ func (*UnimplementedHistoryServiceServer) GetShard(ctx context.Context, req *GetShardRequest) (*GetShardResponse, error)

Feb 10, 2022 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Jan 12, 2022 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Dec 20, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Nov 4, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Oct 20, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Oct 29, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Oct 7, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Oct 4, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Sep 16, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Aug 31, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Aug 18, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Aug 6, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Jul 22, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Jul 20, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Jul 18, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Jun 24, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Jun 23, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Jun 18, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Jun 8, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Jun 7, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Jun 2, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Jun 23, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

May 7, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

May 5, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Apr 27, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Changes in this version

type GetMutableStateResponse

+ LastFirstEventTxnId int64

+ func (m *GetMutableStateResponse) GetLastFirstEventTxnId() int64

type PollMutableStateResponse

+ LastFirstEventTxnId int64

+ func (m *PollMutableStateResponse) GetLastFirstEventTxnId() int64

Apr 15, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Mar 29, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Mar 23, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Apr 15, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Apr 7, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Mar 23, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Feb 16, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Apr 15, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Apr 7, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Mar 23, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Feb 13, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Jan 30, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Jan 26, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Jan 25, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Jan 22, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Apr 7, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Mar 23, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Feb 18, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Feb 13, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Jan 26, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Jan 25, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Jan 22, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Dec 30, 2020 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Dec 22, 2020 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Feb 18, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Jan 25, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Dec 30, 2020 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Dec 10, 2020 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Dec 9, 2020 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Feb 18, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Nov 20, 2020 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Nov 16, 2020 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Nov 11, 2020 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Feb 18, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Nov 20, 2020 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Oct 27, 2020 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Feb 18, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Oct 20, 2020 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Oct 14, 2020 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Feb 18, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Sep 30, 2020 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Sep 28, 2020 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Sep 22, 2020 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Changes in this version

type DescribeMutableStateResponse

+ BranchId string

+ TreeId string

+ func (m *DescribeMutableStateResponse) GetBranchId() string

+ func (m *DescribeMutableStateResponse) GetTreeId() string

Sep 17, 2020 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Jul 31, 2020 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Changes in this version

type DescribeHistoryHostRequest

+ NamespaceId string

+ ShardId int32

+ WorkflowExecution *v14.WorkflowExecution

+ func (m *DescribeHistoryHostRequest) GetNamespaceId() string

+ func (m *DescribeHistoryHostRequest) GetShardId() int32

+ func (m *DescribeHistoryHostRequest) GetWorkflowExecution() *v14.WorkflowExecution

type DescribeHistoryHostResponse

+ ShardsNumber int32

+ func (m *DescribeHistoryHostResponse) GetShardsNumber() int32

type DescribeMutableStateResponse

+ CacheMutableState string

+ DatabaseMutableState string

+ func (m *DescribeMutableStateResponse) GetCacheMutableState() string

+ func (m *DescribeMutableStateResponse) GetDatabaseMutableState() string

type GetReplicationMessagesResponse

+ ShardMessages map[int32]*v16.ReplicationMessages

+ func (m *GetReplicationMessagesResponse) GetShardMessages() map[int32]*v16.ReplicationMessages

type RecordActivityTaskStartedResponse

+ CurrentAttemptScheduledTime *time.Time

+ StartedTime *time.Time

+ func (m *RecordActivityTaskStartedResponse) GetCurrentAttemptScheduledTime() *time.Time

+ func (m *RecordActivityTaskStartedResponse) GetStartedTime() *time.Time

type RecordWorkflowTaskStartedResponse

+ ScheduledTime *time.Time

+ StartedTime *time.Time

+ func (m *RecordWorkflowTaskStartedResponse) GetScheduledTime() *time.Time

+ func (m *RecordWorkflowTaskStartedResponse) GetStartedTime() *time.Time

type RemoveTaskRequest

+ VisibilityTime *time.Time

+ func (m *RemoveTaskRequest) GetVisibilityTime() *time.Time

type StartWorkflowExecutionRequest

+ FirstWorkflowTaskBackoff *time.Duration

+ WorkflowExecutionExpirationTime *time.Time

+ func (m *StartWorkflowExecutionRequest) GetFirstWorkflowTaskBackoff() *time.Duration

+ func (m *StartWorkflowExecutionRequest) GetWorkflowExecutionExpirationTime() *time.Time

type SyncShardStatusRequest

+ StatusTime *time.Time

+ func (m *SyncShardStatusRequest) GetStatusTime() *time.Time

Jul 15, 2020 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Changes in this version

+ var ErrIntOverflowRequestResponse = fmt.Errorf("proto: integer overflow")

+ var ErrInvalidLengthRequestResponse = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrUnexpectedEndOfGroupRequestResponse = fmt.Errorf("proto: unexpected end of group")

+ func RegisterHistoryServiceServer(s *grpc.Server, srv HistoryServiceServer)

+ type CloseShardRequest struct

+ ShardId int32

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

+ func (*CloseShardRequest) ProtoMessage()

+ func (m *CloseShardRequest) GetShardId() int32

+ func (m *CloseShardRequest) Marshal() (dAtA []byte, err error)

+ func (m *CloseShardRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *CloseShardRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *CloseShardRequest) Reset()

+ func (m *CloseShardRequest) Size() (n int)

+ func (m *CloseShardRequest) Unmarshal(dAtA []byte) error

+ func (m *CloseShardRequest) XXX_DiscardUnknown()

+ func (m *CloseShardRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *CloseShardRequest) XXX_Merge(src proto.Message)

+ func (m *CloseShardRequest) XXX_Size() int

+ func (m *CloseShardRequest) XXX_Unmarshal(b []byte) error

+ func (this *CloseShardRequest) Equal(that interface{}) bool

+ func (this *CloseShardRequest) GoString() string

+ func (this *CloseShardRequest) String() string

+ type CloseShardResponse struct

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

+ func (*CloseShardResponse) ProtoMessage()

+ func (m *CloseShardResponse) Marshal() (dAtA []byte, err error)

+ func (m *CloseShardResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *CloseShardResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *CloseShardResponse) Reset()

+ func (m *CloseShardResponse) Size() (n int)

+ func (m *CloseShardResponse) Unmarshal(dAtA []byte) error

+ func (m *CloseShardResponse) XXX_DiscardUnknown()

+ func (m *CloseShardResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *CloseShardResponse) XXX_Merge(src proto.Message)

+ func (m *CloseShardResponse) XXX_Size() int

+ func (m *CloseShardResponse) XXX_Unmarshal(b []byte) error

+ func (this *CloseShardResponse) Equal(that interface{}) bool

+ func (this *CloseShardResponse) GoString() string

+ func (this *CloseShardResponse) String() string

+ type DescribeHistoryHostRequest struct

+ ExecutionForHost *v14.WorkflowExecution

+ HostAddress string

+ ShardIdForHost int32

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

+ func (*DescribeHistoryHostRequest) ProtoMessage()

+ func (m *DescribeHistoryHostRequest) GetExecutionForHost() *v14.WorkflowExecution

+ func (m *DescribeHistoryHostRequest) GetHostAddress() string

+ func (m *DescribeHistoryHostRequest) GetShardIdForHost() int32

+ func (m *DescribeHistoryHostRequest) Marshal() (dAtA []byte, err error)

+ func (m *DescribeHistoryHostRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *DescribeHistoryHostRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *DescribeHistoryHostRequest) Reset()

+ func (m *DescribeHistoryHostRequest) Size() (n int)

+ func (m *DescribeHistoryHostRequest) Unmarshal(dAtA []byte) error

+ func (m *DescribeHistoryHostRequest) XXX_DiscardUnknown()

+ func (m *DescribeHistoryHostRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *DescribeHistoryHostRequest) XXX_Merge(src proto.Message)

+ func (m *DescribeHistoryHostRequest) XXX_Size() int

+ func (m *DescribeHistoryHostRequest) XXX_Unmarshal(b []byte) error

+ func (this *DescribeHistoryHostRequest) Equal(that interface{}) bool

+ func (this *DescribeHistoryHostRequest) GoString() string

+ func (this *DescribeHistoryHostRequest) String() string

+ type DescribeHistoryHostResponse struct

+ Address string

+ NamespaceCache *v112.NamespaceCacheInfo

+ NumberOfShards int32

+ ShardControllerStatus string

+ ShardIds []int32

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

+ func (*DescribeHistoryHostResponse) ProtoMessage()

+ func (m *DescribeHistoryHostResponse) GetAddress() string

+ func (m *DescribeHistoryHostResponse) GetNamespaceCache() *v112.NamespaceCacheInfo

+ func (m *DescribeHistoryHostResponse) GetNumberOfShards() int32

+ func (m *DescribeHistoryHostResponse) GetShardControllerStatus() string

+ func (m *DescribeHistoryHostResponse) GetShardIds() []int32

+ func (m *DescribeHistoryHostResponse) Marshal() (dAtA []byte, err error)

+ func (m *DescribeHistoryHostResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *DescribeHistoryHostResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *DescribeHistoryHostResponse) Reset()

+ func (m *DescribeHistoryHostResponse) Size() (n int)

+ func (m *DescribeHistoryHostResponse) Unmarshal(dAtA []byte) error

+ func (m *DescribeHistoryHostResponse) XXX_DiscardUnknown()

+ func (m *DescribeHistoryHostResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *DescribeHistoryHostResponse) XXX_Merge(src proto.Message)

+ func (m *DescribeHistoryHostResponse) XXX_Size() int

+ func (m *DescribeHistoryHostResponse) XXX_Unmarshal(b []byte) error

+ func (this *DescribeHistoryHostResponse) Equal(that interface{}) bool

+ func (this *DescribeHistoryHostResponse) GoString() string

+ func (this *DescribeHistoryHostResponse) String() string

+ type DescribeMutableStateRequest struct

+ Execution *v14.WorkflowExecution

+ NamespaceId string

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

+ func (*DescribeMutableStateRequest) ProtoMessage()

+ func (m *DescribeMutableStateRequest) GetExecution() *v14.WorkflowExecution

+ func (m *DescribeMutableStateRequest) GetNamespaceId() string

+ func (m *DescribeMutableStateRequest) Marshal() (dAtA []byte, err error)

+ func (m *DescribeMutableStateRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *DescribeMutableStateRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *DescribeMutableStateRequest) Reset()

+ func (m *DescribeMutableStateRequest) Size() (n int)

+ func (m *DescribeMutableStateRequest) Unmarshal(dAtA []byte) error

+ func (m *DescribeMutableStateRequest) XXX_DiscardUnknown()

+ func (m *DescribeMutableStateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *DescribeMutableStateRequest) XXX_Merge(src proto.Message)

+ func (m *DescribeMutableStateRequest) XXX_Size() int

+ func (m *DescribeMutableStateRequest) XXX_Unmarshal(b []byte) error

+ func (this *DescribeMutableStateRequest) Equal(that interface{}) bool

+ func (this *DescribeMutableStateRequest) GoString() string

+ func (this *DescribeMutableStateRequest) String() string

+ type DescribeMutableStateResponse struct

+ MutableStateInCache string

+ MutableStateInDatabase string

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

+ func (*DescribeMutableStateResponse) ProtoMessage()

+ func (m *DescribeMutableStateResponse) GetMutableStateInCache() string

+ func (m *DescribeMutableStateResponse) GetMutableStateInDatabase() string

+ func (m *DescribeMutableStateResponse) Marshal() (dAtA []byte, err error)

+ func (m *DescribeMutableStateResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *DescribeMutableStateResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *DescribeMutableStateResponse) Reset()

+ func (m *DescribeMutableStateResponse) Size() (n int)

+ func (m *DescribeMutableStateResponse) Unmarshal(dAtA []byte) error

+ func (m *DescribeMutableStateResponse) XXX_DiscardUnknown()

+ func (m *DescribeMutableStateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *DescribeMutableStateResponse) XXX_Merge(src proto.Message)

+ func (m *DescribeMutableStateResponse) XXX_Size() int

+ func (m *DescribeMutableStateResponse) XXX_Unmarshal(b []byte) error

+ func (this *DescribeMutableStateResponse) Equal(that interface{}) bool

+ func (this *DescribeMutableStateResponse) GoString() string

+ func (this *DescribeMutableStateResponse) String() string

+ type DescribeWorkflowExecutionRequest struct

+ NamespaceId string

+ Request *v1.DescribeWorkflowExecutionRequest

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

+ func (*DescribeWorkflowExecutionRequest) ProtoMessage()

+ func (m *DescribeWorkflowExecutionRequest) GetNamespaceId() string

+ func (m *DescribeWorkflowExecutionRequest) GetRequest() *v1.DescribeWorkflowExecutionRequest

+ func (m *DescribeWorkflowExecutionRequest) Marshal() (dAtA []byte, err error)

+ func (m *DescribeWorkflowExecutionRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *DescribeWorkflowExecutionRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *DescribeWorkflowExecutionRequest) Reset()

+ func (m *DescribeWorkflowExecutionRequest) Size() (n int)

+ func (m *DescribeWorkflowExecutionRequest) Unmarshal(dAtA []byte) error

+ func (m *DescribeWorkflowExecutionRequest) XXX_DiscardUnknown()

+ func (m *DescribeWorkflowExecutionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *DescribeWorkflowExecutionRequest) XXX_Merge(src proto.Message)

+ func (m *DescribeWorkflowExecutionRequest) XXX_Size() int

+ func (m *DescribeWorkflowExecutionRequest) XXX_Unmarshal(b []byte) error

+ func (this *DescribeWorkflowExecutionRequest) Equal(that interface{}) bool

+ func (this *DescribeWorkflowExecutionRequest) GoString() string

+ func (this *DescribeWorkflowExecutionRequest) String() string

+ type DescribeWorkflowExecutionResponse struct

+ ExecutionConfig *v111.WorkflowExecutionConfig

+ PendingActivities []*v111.PendingActivityInfo

+ PendingChildren []*v111.PendingChildExecutionInfo

+ WorkflowExecutionInfo *v111.WorkflowExecutionInfo

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

+ func (*DescribeWorkflowExecutionResponse) ProtoMessage()

+ func (m *DescribeWorkflowExecutionResponse) GetExecutionConfig() *v111.WorkflowExecutionConfig

+ func (m *DescribeWorkflowExecutionResponse) GetPendingActivities() []*v111.PendingActivityInfo

+ func (m *DescribeWorkflowExecutionResponse) GetPendingChildren() []*v111.PendingChildExecutionInfo

+ func (m *DescribeWorkflowExecutionResponse) GetWorkflowExecutionInfo() *v111.WorkflowExecutionInfo

+ func (m *DescribeWorkflowExecutionResponse) Marshal() (dAtA []byte, err error)

+ func (m *DescribeWorkflowExecutionResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *DescribeWorkflowExecutionResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *DescribeWorkflowExecutionResponse) Reset()

+ func (m *DescribeWorkflowExecutionResponse) Size() (n int)

+ func (m *DescribeWorkflowExecutionResponse) Unmarshal(dAtA []byte) error

+ func (m *DescribeWorkflowExecutionResponse) XXX_DiscardUnknown()

+ func (m *DescribeWorkflowExecutionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *DescribeWorkflowExecutionResponse) XXX_Merge(src proto.Message)

+ func (m *DescribeWorkflowExecutionResponse) XXX_Size() int

+ func (m *DescribeWorkflowExecutionResponse) XXX_Unmarshal(b []byte) error

+ func (this *DescribeWorkflowExecutionResponse) Equal(that interface{}) bool

+ func (this *DescribeWorkflowExecutionResponse) GoString() string

+ func (this *DescribeWorkflowExecutionResponse) String() string

+ type GetDLQMessagesRequest struct

+ InclusiveEndMessageId int64

+ MaximumPageSize int32

+ NextPageToken []byte

+ ShardId int32

+ SourceCluster string

+ Type v17.DeadLetterQueueType

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

+ func (*GetDLQMessagesRequest) ProtoMessage()

+ func (m *GetDLQMessagesRequest) GetInclusiveEndMessageId() int64

+ func (m *GetDLQMessagesRequest) GetMaximumPageSize() int32

+ func (m *GetDLQMessagesRequest) GetNextPageToken() []byte

+ func (m *GetDLQMessagesRequest) GetShardId() int32

+ func (m *GetDLQMessagesRequest) GetSourceCluster() string

+ func (m *GetDLQMessagesRequest) GetType() v17.DeadLetterQueueType

+ func (m *GetDLQMessagesRequest) Marshal() (dAtA []byte, err error)

+ func (m *GetDLQMessagesRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *GetDLQMessagesRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *GetDLQMessagesRequest) Reset()

+ func (m *GetDLQMessagesRequest) Size() (n int)

+ func (m *GetDLQMessagesRequest) Unmarshal(dAtA []byte) error

+ func (m *GetDLQMessagesRequest) XXX_DiscardUnknown()

+ func (m *GetDLQMessagesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *GetDLQMessagesRequest) XXX_Merge(src proto.Message)

+ func (m *GetDLQMessagesRequest) XXX_Size() int

+ func (m *GetDLQMessagesRequest) XXX_Unmarshal(b []byte) error

+ func (this *GetDLQMessagesRequest) Equal(that interface{}) bool

+ func (this *GetDLQMessagesRequest) GoString() string

+ func (this *GetDLQMessagesRequest) String() string

+ type GetDLQMessagesResponse struct

+ NextPageToken []byte

+ ReplicationTasks []*v16.ReplicationTask

+ Type v17.DeadLetterQueueType

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

+ func (*GetDLQMessagesResponse) ProtoMessage()

+ func (m *GetDLQMessagesResponse) GetNextPageToken() []byte

+ func (m *GetDLQMessagesResponse) GetReplicationTasks() []*v16.ReplicationTask

+ func (m *GetDLQMessagesResponse) GetType() v17.DeadLetterQueueType

+ func (m *GetDLQMessagesResponse) Marshal() (dAtA []byte, err error)

+ func (m *GetDLQMessagesResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *GetDLQMessagesResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *GetDLQMessagesResponse) Reset()

+ func (m *GetDLQMessagesResponse) Size() (n int)

+ func (m *GetDLQMessagesResponse) Unmarshal(dAtA []byte) error

+ func (m *GetDLQMessagesResponse) XXX_DiscardUnknown()

+ func (m *GetDLQMessagesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *GetDLQMessagesResponse) XXX_Merge(src proto.Message)

+ func (m *GetDLQMessagesResponse) XXX_Size() int

+ func (m *GetDLQMessagesResponse) XXX_Unmarshal(b []byte) error

+ func (this *GetDLQMessagesResponse) Equal(that interface{}) bool

+ func (this *GetDLQMessagesResponse) GoString() string

+ func (this *GetDLQMessagesResponse) String() string

+ type GetDLQReplicationMessagesRequest struct

+ TaskInfos []*v16.ReplicationTaskInfo

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

+ func (*GetDLQReplicationMessagesRequest) ProtoMessage()

+ func (m *GetDLQReplicationMessagesRequest) GetTaskInfos() []*v16.ReplicationTaskInfo

+ func (m *GetDLQReplicationMessagesRequest) Marshal() (dAtA []byte, err error)

+ func (m *GetDLQReplicationMessagesRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *GetDLQReplicationMessagesRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *GetDLQReplicationMessagesRequest) Reset()

+ func (m *GetDLQReplicationMessagesRequest) Size() (n int)

+ func (m *GetDLQReplicationMessagesRequest) Unmarshal(dAtA []byte) error

+ func (m *GetDLQReplicationMessagesRequest) XXX_DiscardUnknown()

+ func (m *GetDLQReplicationMessagesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *GetDLQReplicationMessagesRequest) XXX_Merge(src proto.Message)

+ func (m *GetDLQReplicationMessagesRequest) XXX_Size() int

+ func (m *GetDLQReplicationMessagesRequest) XXX_Unmarshal(b []byte) error

+ func (this *GetDLQReplicationMessagesRequest) Equal(that interface{}) bool

+ func (this *GetDLQReplicationMessagesRequest) GoString() string

+ func (this *GetDLQReplicationMessagesRequest) String() string

+ type GetDLQReplicationMessagesResponse struct

+ ReplicationTasks []*v16.ReplicationTask

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

+ func (*GetDLQReplicationMessagesResponse) ProtoMessage()

+ func (m *GetDLQReplicationMessagesResponse) GetReplicationTasks() []*v16.ReplicationTask

+ func (m *GetDLQReplicationMessagesResponse) Marshal() (dAtA []byte, err error)

+ func (m *GetDLQReplicationMessagesResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *GetDLQReplicationMessagesResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *GetDLQReplicationMessagesResponse) Reset()

+ func (m *GetDLQReplicationMessagesResponse) Size() (n int)

+ func (m *GetDLQReplicationMessagesResponse) Unmarshal(dAtA []byte) error

+ func (m *GetDLQReplicationMessagesResponse) XXX_DiscardUnknown()

+ func (m *GetDLQReplicationMessagesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *GetDLQReplicationMessagesResponse) XXX_Merge(src proto.Message)

+ func (m *GetDLQReplicationMessagesResponse) XXX_Size() int

+ func (m *GetDLQReplicationMessagesResponse) XXX_Unmarshal(b []byte) error

+ func (this *GetDLQReplicationMessagesResponse) Equal(that interface{}) bool

+ func (this *GetDLQReplicationMessagesResponse) GoString() string

+ func (this *GetDLQReplicationMessagesResponse) String() string

+ type GetMutableStateRequest struct

+ CurrentBranchToken []byte

+ Execution *v14.WorkflowExecution

+ ExpectedNextEventId int64

+ NamespaceId string

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

+ func (*GetMutableStateRequest) ProtoMessage()

+ func (m *GetMutableStateRequest) GetCurrentBranchToken() []byte

+ func (m *GetMutableStateRequest) GetExecution() *v14.WorkflowExecution

+ func (m *GetMutableStateRequest) GetExpectedNextEventId() int64

+ func (m *GetMutableStateRequest) GetNamespaceId() string

+ func (m *GetMutableStateRequest) Marshal() (dAtA []byte, err error)

+ func (m *GetMutableStateRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *GetMutableStateRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *GetMutableStateRequest) Reset()

+ func (m *GetMutableStateRequest) Size() (n int)

+ func (m *GetMutableStateRequest) Unmarshal(dAtA []byte) error

+ func (m *GetMutableStateRequest) XXX_DiscardUnknown()

+ func (m *GetMutableStateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *GetMutableStateRequest) XXX_Merge(src proto.Message)

+ func (m *GetMutableStateRequest) XXX_Size() int

+ func (m *GetMutableStateRequest) XXX_Unmarshal(b []byte) error

+ func (this *GetMutableStateRequest) Equal(that interface{}) bool

+ func (this *GetMutableStateRequest) GoString() string

+ func (this *GetMutableStateRequest) String() string

+ type GetMutableStateResponse struct

+ ClientFeatureVersion string

+ ClientImpl string

+ ClientLibraryVersion string

+ CurrentBranchToken []byte

+ EventStoreVersion int32

+ Execution *v14.WorkflowExecution

+ IsStickyTaskQueueEnabled bool

+ LastFirstEventId int64

+ NextEventId int64

+ PreviousStartedEventId int64

+ ReplicationInfo map[string]*v16.ReplicationInfo

+ StickyTaskQueue *v15.TaskQueue

+ StickyTaskQueueScheduleToStartTimeout int32

+ TaskQueue *v15.TaskQueue

+ VersionHistories *v18.VersionHistories

+ WorkflowState v17.WorkflowExecutionState

+ WorkflowStatus v12.WorkflowExecutionStatus

+ WorkflowType *v14.WorkflowType

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

+ func (*GetMutableStateResponse) ProtoMessage()

+ func (m *GetMutableStateResponse) GetClientFeatureVersion() string

+ func (m *GetMutableStateResponse) GetClientImpl() string

+ func (m *GetMutableStateResponse) GetClientLibraryVersion() string

+ func (m *GetMutableStateResponse) GetCurrentBranchToken() []byte

+ func (m *GetMutableStateResponse) GetEventStoreVersion() int32

+ func (m *GetMutableStateResponse) GetExecution() *v14.WorkflowExecution

+ func (m *GetMutableStateResponse) GetIsStickyTaskQueueEnabled() bool

+ func (m *GetMutableStateResponse) GetLastFirstEventId() int64

+ func (m *GetMutableStateResponse) GetNextEventId() int64

+ func (m *GetMutableStateResponse) GetPreviousStartedEventId() int64

+ func (m *GetMutableStateResponse) GetReplicationInfo() map[string]*v16.ReplicationInfo

+ func (m *GetMutableStateResponse) GetStickyTaskQueue() *v15.TaskQueue

+ func (m *GetMutableStateResponse) GetStickyTaskQueueScheduleToStartTimeout() int32

+ func (m *GetMutableStateResponse) GetTaskQueue() *v15.TaskQueue

+ func (m *GetMutableStateResponse) GetVersionHistories() *v18.VersionHistories

+ func (m *GetMutableStateResponse) GetWorkflowState() v17.WorkflowExecutionState

+ func (m *GetMutableStateResponse) GetWorkflowStatus() v12.WorkflowExecutionStatus

+ func (m *GetMutableStateResponse) GetWorkflowType() *v14.WorkflowType

+ func (m *GetMutableStateResponse) Marshal() (dAtA []byte, err error)

+ func (m *GetMutableStateResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *GetMutableStateResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *GetMutableStateResponse) Reset()

+ func (m *GetMutableStateResponse) Size() (n int)

+ func (m *GetMutableStateResponse) Unmarshal(dAtA []byte) error

+ func (m *GetMutableStateResponse) XXX_DiscardUnknown()

+ func (m *GetMutableStateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *GetMutableStateResponse) XXX_Merge(src proto.Message)

+ func (m *GetMutableStateResponse) XXX_Size() int

+ func (m *GetMutableStateResponse) XXX_Unmarshal(b []byte) error

+ func (this *GetMutableStateResponse) Equal(that interface{}) bool

+ func (this *GetMutableStateResponse) GoString() string

+ func (this *GetMutableStateResponse) String() string

+ type GetReplicationMessagesRequest struct

+ ClusterName string

+ Tokens []*v16.ReplicationToken

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

+ func (*GetReplicationMessagesRequest) ProtoMessage()

+ func (m *GetReplicationMessagesRequest) GetClusterName() string

+ func (m *GetReplicationMessagesRequest) GetTokens() []*v16.ReplicationToken

+ func (m *GetReplicationMessagesRequest) Marshal() (dAtA []byte, err error)

+ func (m *GetReplicationMessagesRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *GetReplicationMessagesRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *GetReplicationMessagesRequest) Reset()

+ func (m *GetReplicationMessagesRequest) Size() (n int)

+ func (m *GetReplicationMessagesRequest) Unmarshal(dAtA []byte) error

+ func (m *GetReplicationMessagesRequest) XXX_DiscardUnknown()

+ func (m *GetReplicationMessagesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *GetReplicationMessagesRequest) XXX_Merge(src proto.Message)

+ func (m *GetReplicationMessagesRequest) XXX_Size() int

+ func (m *GetReplicationMessagesRequest) XXX_Unmarshal(b []byte) error

+ func (this *GetReplicationMessagesRequest) Equal(that interface{}) bool

+ func (this *GetReplicationMessagesRequest) GoString() string

+ func (this *GetReplicationMessagesRequest) String() string

+ type GetReplicationMessagesResponse struct

+ MessagesByShard map[int32]*v16.ReplicationMessages

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

+ func (*GetReplicationMessagesResponse) ProtoMessage()

+ func (m *GetReplicationMessagesResponse) GetMessagesByShard() map[int32]*v16.ReplicationMessages

+ func (m *GetReplicationMessagesResponse) Marshal() (dAtA []byte, err error)

+ func (m *GetReplicationMessagesResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *GetReplicationMessagesResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *GetReplicationMessagesResponse) Reset()

+ func (m *GetReplicationMessagesResponse) Size() (n int)

+ func (m *GetReplicationMessagesResponse) Unmarshal(dAtA []byte) error

+ func (m *GetReplicationMessagesResponse) XXX_DiscardUnknown()

+ func (m *GetReplicationMessagesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *GetReplicationMessagesResponse) XXX_Merge(src proto.Message)

+ func (m *GetReplicationMessagesResponse) XXX_Size() int

+ func (m *GetReplicationMessagesResponse) XXX_Unmarshal(b []byte) error

+ func (this *GetReplicationMessagesResponse) Equal(that interface{}) bool

+ func (this *GetReplicationMessagesResponse) GoString() string

+ func (this *GetReplicationMessagesResponse) String() string

+ type HistoryServiceClient interface

+ CloseShard func(ctx context.Context, in *CloseShardRequest, opts ...grpc.CallOption) (*CloseShardResponse, error)

+ DescribeHistoryHost func(ctx context.Context, in *DescribeHistoryHostRequest, opts ...grpc.CallOption) (*DescribeHistoryHostResponse, error)

+ DescribeMutableState func(ctx context.Context, in *DescribeMutableStateRequest, opts ...grpc.CallOption) (*DescribeMutableStateResponse, error)

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

+ GetDLQMessages func(ctx context.Context, in *GetDLQMessagesRequest, opts ...grpc.CallOption) (*GetDLQMessagesResponse, error)

+ GetDLQReplicationMessages func(ctx context.Context, in *GetDLQReplicationMessagesRequest, ...) (*GetDLQReplicationMessagesResponse, error)

+ GetMutableState func(ctx context.Context, in *GetMutableStateRequest, opts ...grpc.CallOption) (*GetMutableStateResponse, error)

+ GetReplicationMessages func(ctx context.Context, in *GetReplicationMessagesRequest, ...) (*GetReplicationMessagesResponse, error)

+ MergeDLQMessages func(ctx context.Context, in *MergeDLQMessagesRequest, opts ...grpc.CallOption) (*MergeDLQMessagesResponse, error)

+ PollMutableState func(ctx context.Context, in *PollMutableStateRequest, opts ...grpc.CallOption) (*PollMutableStateResponse, error)

+ PurgeDLQMessages func(ctx context.Context, in *PurgeDLQMessagesRequest, opts ...grpc.CallOption) (*PurgeDLQMessagesResponse, error)

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

+ ReapplyEvents func(ctx context.Context, in *ReapplyEventsRequest, opts ...grpc.CallOption) (*ReapplyEventsResponse, error)

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

+ RecordActivityTaskStarted func(ctx context.Context, in *RecordActivityTaskStartedRequest, ...) (*RecordActivityTaskStartedResponse, error)

+ RecordChildExecutionCompleted func(ctx context.Context, in *RecordChildExecutionCompletedRequest, ...) (*RecordChildExecutionCompletedResponse, error)

+ RecordWorkflowTaskStarted func(ctx context.Context, in *RecordWorkflowTaskStartedRequest, ...) (*RecordWorkflowTaskStartedResponse, error)

+ RefreshWorkflowTasks func(ctx context.Context, in *RefreshWorkflowTasksRequest, opts ...grpc.CallOption) (*RefreshWorkflowTasksResponse, error)

+ RemoveSignalMutableState func(ctx context.Context, in *RemoveSignalMutableStateRequest, ...) (*RemoveSignalMutableStateResponse, error)

+ RemoveTask func(ctx context.Context, in *RemoveTaskRequest, opts ...grpc.CallOption) (*RemoveTaskResponse, error)

+ ReplicateEvents func(ctx context.Context, in *ReplicateEventsRequest, opts ...grpc.CallOption) (*ReplicateEventsResponse, error)

+ ReplicateEventsV2 func(ctx context.Context, in *ReplicateEventsV2Request, opts ...grpc.CallOption) (*ReplicateEventsV2Response, error)

+ ReplicateRawEvents func(ctx context.Context, in *ReplicateRawEventsRequest, opts ...grpc.CallOption) (*ReplicateRawEventsResponse, 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)

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

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

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

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

+ ScheduleWorkflowTask func(ctx context.Context, in *ScheduleWorkflowTaskRequest, opts ...grpc.CallOption) (*ScheduleWorkflowTaskResponse, error)

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

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

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

+ SyncActivity func(ctx context.Context, in *SyncActivityRequest, opts ...grpc.CallOption) (*SyncActivityResponse, error)

+ SyncShardStatus func(ctx context.Context, in *SyncShardStatusRequest, opts ...grpc.CallOption) (*SyncShardStatusResponse, error)

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

+ func NewHistoryServiceClient(cc *grpc.ClientConn) HistoryServiceClient

+ type HistoryServiceServer interface

+ CloseShard func(context.Context, *CloseShardRequest) (*CloseShardResponse, error)

+ DescribeHistoryHost func(context.Context, *DescribeHistoryHostRequest) (*DescribeHistoryHostResponse, error)

+ DescribeMutableState func(context.Context, *DescribeMutableStateRequest) (*DescribeMutableStateResponse, error)

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

+ GetDLQMessages func(context.Context, *GetDLQMessagesRequest) (*GetDLQMessagesResponse, error)

+ GetDLQReplicationMessages func(context.Context, *GetDLQReplicationMessagesRequest) (*GetDLQReplicationMessagesResponse, error)

+ GetMutableState func(context.Context, *GetMutableStateRequest) (*GetMutableStateResponse, error)

+ GetReplicationMessages func(context.Context, *GetReplicationMessagesRequest) (*GetReplicationMessagesResponse, error)

+ MergeDLQMessages func(context.Context, *MergeDLQMessagesRequest) (*MergeDLQMessagesResponse, error)

+ PollMutableState func(context.Context, *PollMutableStateRequest) (*PollMutableStateResponse, error)

+ PurgeDLQMessages func(context.Context, *PurgeDLQMessagesRequest) (*PurgeDLQMessagesResponse, error)

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

+ ReapplyEvents func(context.Context, *ReapplyEventsRequest) (*ReapplyEventsResponse, error)

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

+ RecordActivityTaskStarted func(context.Context, *RecordActivityTaskStartedRequest) (*RecordActivityTaskStartedResponse, error)

+ RecordChildExecutionCompleted func(context.Context, *RecordChildExecutionCompletedRequest) (*RecordChildExecutionCompletedResponse, error)

+ RecordWorkflowTaskStarted func(context.Context, *RecordWorkflowTaskStartedRequest) (*RecordWorkflowTaskStartedResponse, error)

+ RefreshWorkflowTasks func(context.Context, *RefreshWorkflowTasksRequest) (*RefreshWorkflowTasksResponse, error)

+ RemoveSignalMutableState func(context.Context, *RemoveSignalMutableStateRequest) (*RemoveSignalMutableStateResponse, error)

+ RemoveTask func(context.Context, *RemoveTaskRequest) (*RemoveTaskResponse, error)

+ ReplicateEvents func(context.Context, *ReplicateEventsRequest) (*ReplicateEventsResponse, error)

+ ReplicateEventsV2 func(context.Context, *ReplicateEventsV2Request) (*ReplicateEventsV2Response, error)

+ ReplicateRawEvents func(context.Context, *ReplicateRawEventsRequest) (*ReplicateRawEventsResponse, 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)

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

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

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

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

+ ScheduleWorkflowTask func(context.Context, *ScheduleWorkflowTaskRequest) (*ScheduleWorkflowTaskResponse, error)

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

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

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

+ SyncActivity func(context.Context, *SyncActivityRequest) (*SyncActivityResponse, error)

+ SyncShardStatus func(context.Context, *SyncShardStatusRequest) (*SyncShardStatusResponse, error)

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

+ type MergeDLQMessagesRequest struct

+ InclusiveEndMessageId int64

+ MaximumPageSize int32

+ NextPageToken []byte

+ ShardId int32

+ SourceCluster string

+ Type v17.DeadLetterQueueType

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

+ func (*MergeDLQMessagesRequest) ProtoMessage()

+ func (m *MergeDLQMessagesRequest) GetInclusiveEndMessageId() int64

+ func (m *MergeDLQMessagesRequest) GetMaximumPageSize() int32

+ func (m *MergeDLQMessagesRequest) GetNextPageToken() []byte

+ func (m *MergeDLQMessagesRequest) GetShardId() int32

+ func (m *MergeDLQMessagesRequest) GetSourceCluster() string

+ func (m *MergeDLQMessagesRequest) GetType() v17.DeadLetterQueueType

+ func (m *MergeDLQMessagesRequest) Marshal() (dAtA []byte, err error)

+ func (m *MergeDLQMessagesRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *MergeDLQMessagesRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *MergeDLQMessagesRequest) Reset()

+ func (m *MergeDLQMessagesRequest) Size() (n int)

+ func (m *MergeDLQMessagesRequest) Unmarshal(dAtA []byte) error

+ func (m *MergeDLQMessagesRequest) XXX_DiscardUnknown()

+ func (m *MergeDLQMessagesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *MergeDLQMessagesRequest) XXX_Merge(src proto.Message)

+ func (m *MergeDLQMessagesRequest) XXX_Size() int

+ func (m *MergeDLQMessagesRequest) XXX_Unmarshal(b []byte) error

+ func (this *MergeDLQMessagesRequest) Equal(that interface{}) bool

+ func (this *MergeDLQMessagesRequest) GoString() string

+ func (this *MergeDLQMessagesRequest) String() string

+ type MergeDLQMessagesResponse struct

+ NextPageToken []byte

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

+ func (*MergeDLQMessagesResponse) ProtoMessage()

+ func (m *MergeDLQMessagesResponse) GetNextPageToken() []byte

+ func (m *MergeDLQMessagesResponse) Marshal() (dAtA []byte, err error)

+ func (m *MergeDLQMessagesResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *MergeDLQMessagesResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *MergeDLQMessagesResponse) Reset()

+ func (m *MergeDLQMessagesResponse) Size() (n int)

+ func (m *MergeDLQMessagesResponse) Unmarshal(dAtA []byte) error

+ func (m *MergeDLQMessagesResponse) XXX_DiscardUnknown()

+ func (m *MergeDLQMessagesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *MergeDLQMessagesResponse) XXX_Merge(src proto.Message)

+ func (m *MergeDLQMessagesResponse) XXX_Size() int

+ func (m *MergeDLQMessagesResponse) XXX_Unmarshal(b []byte) error

+ func (this *MergeDLQMessagesResponse) Equal(that interface{}) bool

+ func (this *MergeDLQMessagesResponse) GoString() string

+ func (this *MergeDLQMessagesResponse) String() string

+ type PollMutableStateRequest struct

+ CurrentBranchToken []byte

+ Execution *v14.WorkflowExecution

+ ExpectedNextEventId int64

+ NamespaceId string

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

+ func (*PollMutableStateRequest) ProtoMessage()

+ func (m *PollMutableStateRequest) GetCurrentBranchToken() []byte

+ func (m *PollMutableStateRequest) GetExecution() *v14.WorkflowExecution

+ func (m *PollMutableStateRequest) GetExpectedNextEventId() int64

+ func (m *PollMutableStateRequest) GetNamespaceId() string

+ func (m *PollMutableStateRequest) Marshal() (dAtA []byte, err error)

+ func (m *PollMutableStateRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *PollMutableStateRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *PollMutableStateRequest) Reset()

+ func (m *PollMutableStateRequest) Size() (n int)

+ func (m *PollMutableStateRequest) Unmarshal(dAtA []byte) error

+ func (m *PollMutableStateRequest) XXX_DiscardUnknown()

+ func (m *PollMutableStateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *PollMutableStateRequest) XXX_Merge(src proto.Message)

+ func (m *PollMutableStateRequest) XXX_Size() int

+ func (m *PollMutableStateRequest) XXX_Unmarshal(b []byte) error

+ func (this *PollMutableStateRequest) Equal(that interface{}) bool

+ func (this *PollMutableStateRequest) GoString() string

+ func (this *PollMutableStateRequest) String() string

+ type PollMutableStateResponse struct

+ ClientFeatureVersion string

+ ClientImpl string

+ ClientLibraryVersion string

+ CurrentBranchToken []byte

+ Execution *v14.WorkflowExecution

+ LastFirstEventId int64

+ NextEventId int64

+ PreviousStartedEventId int64

+ ReplicationInfo map[string]*v16.ReplicationInfo

+ StickyTaskQueue *v15.TaskQueue

+ StickyTaskQueueScheduleToStartTimeout int32

+ TaskQueue *v15.TaskQueue

+ VersionHistories *v18.VersionHistories

+ WorkflowState v17.WorkflowExecutionState

+ WorkflowStatus v12.WorkflowExecutionStatus

+ WorkflowType *v14.WorkflowType

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

+ func (*PollMutableStateResponse) ProtoMessage()

+ func (m *PollMutableStateResponse) GetClientFeatureVersion() string

+ func (m *PollMutableStateResponse) GetClientImpl() string

+ func (m *PollMutableStateResponse) GetClientLibraryVersion() string

+ func (m *PollMutableStateResponse) GetCurrentBranchToken() []byte

+ func (m *PollMutableStateResponse) GetExecution() *v14.WorkflowExecution

+ func (m *PollMutableStateResponse) GetLastFirstEventId() int64

+ func (m *PollMutableStateResponse) GetNextEventId() int64

+ func (m *PollMutableStateResponse) GetPreviousStartedEventId() int64

+ func (m *PollMutableStateResponse) GetReplicationInfo() map[string]*v16.ReplicationInfo

+ func (m *PollMutableStateResponse) GetStickyTaskQueue() *v15.TaskQueue

+ func (m *PollMutableStateResponse) GetStickyTaskQueueScheduleToStartTimeout() int32

+ func (m *PollMutableStateResponse) GetTaskQueue() *v15.TaskQueue

+ func (m *PollMutableStateResponse) GetVersionHistories() *v18.VersionHistories

+ func (m *PollMutableStateResponse) GetWorkflowState() v17.WorkflowExecutionState

+ func (m *PollMutableStateResponse) GetWorkflowStatus() v12.WorkflowExecutionStatus

+ func (m *PollMutableStateResponse) GetWorkflowType() *v14.WorkflowType

+ func (m *PollMutableStateResponse) Marshal() (dAtA []byte, err error)

+ func (m *PollMutableStateResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *PollMutableStateResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *PollMutableStateResponse) Reset()

+ func (m *PollMutableStateResponse) Size() (n int)

+ func (m *PollMutableStateResponse) Unmarshal(dAtA []byte) error

+ func (m *PollMutableStateResponse) XXX_DiscardUnknown()

+ func (m *PollMutableStateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *PollMutableStateResponse) XXX_Merge(src proto.Message)

+ func (m *PollMutableStateResponse) XXX_Size() int

+ func (m *PollMutableStateResponse) XXX_Unmarshal(b []byte) error

+ func (this *PollMutableStateResponse) Equal(that interface{}) bool

+ func (this *PollMutableStateResponse) GoString() string

+ func (this *PollMutableStateResponse) String() string

+ type PurgeDLQMessagesRequest struct

+ InclusiveEndMessageId int64

+ ShardId int32

+ SourceCluster string

+ Type v17.DeadLetterQueueType

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

+ func (*PurgeDLQMessagesRequest) ProtoMessage()

+ func (m *PurgeDLQMessagesRequest) GetInclusiveEndMessageId() int64

+ func (m *PurgeDLQMessagesRequest) GetShardId() int32

+ func (m *PurgeDLQMessagesRequest) GetSourceCluster() string

+ func (m *PurgeDLQMessagesRequest) GetType() v17.DeadLetterQueueType

+ func (m *PurgeDLQMessagesRequest) Marshal() (dAtA []byte, err error)

+ func (m *PurgeDLQMessagesRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *PurgeDLQMessagesRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *PurgeDLQMessagesRequest) Reset()

+ func (m *PurgeDLQMessagesRequest) Size() (n int)

+ func (m *PurgeDLQMessagesRequest) Unmarshal(dAtA []byte) error

+ func (m *PurgeDLQMessagesRequest) XXX_DiscardUnknown()

+ func (m *PurgeDLQMessagesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *PurgeDLQMessagesRequest) XXX_Merge(src proto.Message)

+ func (m *PurgeDLQMessagesRequest) XXX_Size() int

+ func (m *PurgeDLQMessagesRequest) XXX_Unmarshal(b []byte) error

+ func (this *PurgeDLQMessagesRequest) Equal(that interface{}) bool

+ func (this *PurgeDLQMessagesRequest) GoString() string

+ func (this *PurgeDLQMessagesRequest) String() string

+ type PurgeDLQMessagesResponse struct

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

+ func (*PurgeDLQMessagesResponse) ProtoMessage()

+ func (m *PurgeDLQMessagesResponse) Marshal() (dAtA []byte, err error)

+ func (m *PurgeDLQMessagesResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *PurgeDLQMessagesResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *PurgeDLQMessagesResponse) Reset()

+ func (m *PurgeDLQMessagesResponse) Size() (n int)

+ func (m *PurgeDLQMessagesResponse) Unmarshal(dAtA []byte) error

+ func (m *PurgeDLQMessagesResponse) XXX_DiscardUnknown()

+ func (m *PurgeDLQMessagesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *PurgeDLQMessagesResponse) XXX_Merge(src proto.Message)

+ func (m *PurgeDLQMessagesResponse) XXX_Size() int

+ func (m *PurgeDLQMessagesResponse) XXX_Unmarshal(b []byte) error

+ func (this *PurgeDLQMessagesResponse) Equal(that interface{}) bool

+ func (this *PurgeDLQMessagesResponse) GoString() string

+ func (this *PurgeDLQMessagesResponse) String() string

+ type QueryWorkflowRequest struct

+ NamespaceId string

+ Request *v1.QueryWorkflowRequest

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

+ func (*QueryWorkflowRequest) ProtoMessage()

+ func (m *QueryWorkflowRequest) GetNamespaceId() string

+ func (m *QueryWorkflowRequest) GetRequest() *v1.QueryWorkflowRequest

+ func (m *QueryWorkflowRequest) Marshal() (dAtA []byte, err error)

+ func (m *QueryWorkflowRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *QueryWorkflowRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *QueryWorkflowRequest) Reset()

+ func (m *QueryWorkflowRequest) Size() (n int)

+ func (m *QueryWorkflowRequest) Unmarshal(dAtA []byte) error

+ func (m *QueryWorkflowRequest) XXX_DiscardUnknown()

+ func (m *QueryWorkflowRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *QueryWorkflowRequest) XXX_Merge(src proto.Message)

+ func (m *QueryWorkflowRequest) XXX_Size() int

+ func (m *QueryWorkflowRequest) XXX_Unmarshal(b []byte) error

+ func (this *QueryWorkflowRequest) Equal(that interface{}) bool

+ func (this *QueryWorkflowRequest) GoString() string

+ func (this *QueryWorkflowRequest) String() string

+ type QueryWorkflowResponse struct

+ Response *v1.QueryWorkflowResponse

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

+ func (*QueryWorkflowResponse) ProtoMessage()

+ func (m *QueryWorkflowResponse) GetResponse() *v1.QueryWorkflowResponse

+ func (m *QueryWorkflowResponse) Marshal() (dAtA []byte, err error)

+ func (m *QueryWorkflowResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *QueryWorkflowResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *QueryWorkflowResponse) Reset()

+ func (m *QueryWorkflowResponse) Size() (n int)

+ func (m *QueryWorkflowResponse) Unmarshal(dAtA []byte) error

+ func (m *QueryWorkflowResponse) XXX_DiscardUnknown()

+ func (m *QueryWorkflowResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *QueryWorkflowResponse) XXX_Merge(src proto.Message)

+ func (m *QueryWorkflowResponse) XXX_Size() int

+ func (m *QueryWorkflowResponse) XXX_Unmarshal(b []byte) error

+ func (this *QueryWorkflowResponse) Equal(that interface{}) bool

+ func (this *QueryWorkflowResponse) GoString() string

+ func (this *QueryWorkflowResponse) String() string

+ type ReapplyEventsRequest struct

+ NamespaceId string

+ Request *v113.ReapplyEventsRequest

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

+ func (*ReapplyEventsRequest) ProtoMessage()

+ func (m *ReapplyEventsRequest) GetNamespaceId() string

+ func (m *ReapplyEventsRequest) GetRequest() *v113.ReapplyEventsRequest

+ func (m *ReapplyEventsRequest) Marshal() (dAtA []byte, err error)

+ func (m *ReapplyEventsRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *ReapplyEventsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ReapplyEventsRequest) Reset()

+ func (m *ReapplyEventsRequest) Size() (n int)

+ func (m *ReapplyEventsRequest) Unmarshal(dAtA []byte) error

+ func (m *ReapplyEventsRequest) XXX_DiscardUnknown()

+ func (m *ReapplyEventsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ReapplyEventsRequest) XXX_Merge(src proto.Message)

+ func (m *ReapplyEventsRequest) XXX_Size() int

+ func (m *ReapplyEventsRequest) XXX_Unmarshal(b []byte) error

+ func (this *ReapplyEventsRequest) Equal(that interface{}) bool

+ func (this *ReapplyEventsRequest) GoString() string

+ func (this *ReapplyEventsRequest) String() string

+ type ReapplyEventsResponse struct

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

+ func (*ReapplyEventsResponse) ProtoMessage()

+ func (m *ReapplyEventsResponse) Marshal() (dAtA []byte, err error)

+ func (m *ReapplyEventsResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *ReapplyEventsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ReapplyEventsResponse) Reset()

+ func (m *ReapplyEventsResponse) Size() (n int)

+ func (m *ReapplyEventsResponse) Unmarshal(dAtA []byte) error

+ func (m *ReapplyEventsResponse) XXX_DiscardUnknown()

+ func (m *ReapplyEventsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ReapplyEventsResponse) XXX_Merge(src proto.Message)

+ func (m *ReapplyEventsResponse) XXX_Size() int

+ func (m *ReapplyEventsResponse) XXX_Unmarshal(b []byte) error

+ func (this *ReapplyEventsResponse) Equal(that interface{}) bool

+ func (this *ReapplyEventsResponse) GoString() string

+ func (this *ReapplyEventsResponse) String() string

+ type RecordActivityTaskHeartbeatRequest struct

+ HeartbeatRequest *v1.RecordActivityTaskHeartbeatRequest

+ NamespaceId string

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

+ func (*RecordActivityTaskHeartbeatRequest) ProtoMessage()

+ func (m *RecordActivityTaskHeartbeatRequest) GetHeartbeatRequest() *v1.RecordActivityTaskHeartbeatRequest

+ func (m *RecordActivityTaskHeartbeatRequest) GetNamespaceId() string

+ func (m *RecordActivityTaskHeartbeatRequest) Marshal() (dAtA []byte, err error)

+ func (m *RecordActivityTaskHeartbeatRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *RecordActivityTaskHeartbeatRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *RecordActivityTaskHeartbeatRequest) Reset()

+ func (m *RecordActivityTaskHeartbeatRequest) Size() (n int)

+ func (m *RecordActivityTaskHeartbeatRequest) Unmarshal(dAtA []byte) error

+ func (m *RecordActivityTaskHeartbeatRequest) XXX_DiscardUnknown()

+ func (m *RecordActivityTaskHeartbeatRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *RecordActivityTaskHeartbeatRequest) XXX_Merge(src proto.Message)

+ func (m *RecordActivityTaskHeartbeatRequest) XXX_Size() int

+ func (m *RecordActivityTaskHeartbeatRequest) XXX_Unmarshal(b []byte) error

+ func (this *RecordActivityTaskHeartbeatRequest) Equal(that interface{}) bool

+ func (this *RecordActivityTaskHeartbeatRequest) GoString() string

+ func (this *RecordActivityTaskHeartbeatRequest) String() string

+ type RecordActivityTaskHeartbeatResponse struct

+ CancelRequested bool

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

+ func (*RecordActivityTaskHeartbeatResponse) ProtoMessage()

+ func (m *RecordActivityTaskHeartbeatResponse) GetCancelRequested() bool

+ func (m *RecordActivityTaskHeartbeatResponse) Marshal() (dAtA []byte, err error)

+ func (m *RecordActivityTaskHeartbeatResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *RecordActivityTaskHeartbeatResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *RecordActivityTaskHeartbeatResponse) Reset()

+ func (m *RecordActivityTaskHeartbeatResponse) Size() (n int)

+ func (m *RecordActivityTaskHeartbeatResponse) Unmarshal(dAtA []byte) error

+ func (m *RecordActivityTaskHeartbeatResponse) XXX_DiscardUnknown()

+ func (m *RecordActivityTaskHeartbeatResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *RecordActivityTaskHeartbeatResponse) XXX_Merge(src proto.Message)

+ func (m *RecordActivityTaskHeartbeatResponse) XXX_Size() int

+ func (m *RecordActivityTaskHeartbeatResponse) XXX_Unmarshal(b []byte) error

+ func (this *RecordActivityTaskHeartbeatResponse) Equal(that interface{}) bool

+ func (this *RecordActivityTaskHeartbeatResponse) GoString() string

+ func (this *RecordActivityTaskHeartbeatResponse) String() string

+ type RecordActivityTaskStartedRequest struct

+ NamespaceId string

+ PollRequest *v1.PollActivityTaskQueueRequest

+ RequestId string

+ ScheduleId int64

+ TaskId int64

+ WorkflowExecution *v14.WorkflowExecution

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

+ func (*RecordActivityTaskStartedRequest) ProtoMessage()

+ func (m *RecordActivityTaskStartedRequest) GetNamespaceId() string

+ func (m *RecordActivityTaskStartedRequest) GetPollRequest() *v1.PollActivityTaskQueueRequest

+ func (m *RecordActivityTaskStartedRequest) GetRequestId() string

+ func (m *RecordActivityTaskStartedRequest) GetScheduleId() int64

+ func (m *RecordActivityTaskStartedRequest) GetTaskId() int64

+ func (m *RecordActivityTaskStartedRequest) GetWorkflowExecution() *v14.WorkflowExecution

+ func (m *RecordActivityTaskStartedRequest) Marshal() (dAtA []byte, err error)

+ func (m *RecordActivityTaskStartedRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *RecordActivityTaskStartedRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *RecordActivityTaskStartedRequest) Reset()

+ func (m *RecordActivityTaskStartedRequest) Size() (n int)

+ func (m *RecordActivityTaskStartedRequest) Unmarshal(dAtA []byte) error

+ func (m *RecordActivityTaskStartedRequest) XXX_DiscardUnknown()

+ func (m *RecordActivityTaskStartedRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *RecordActivityTaskStartedRequest) XXX_Merge(src proto.Message)

+ func (m *RecordActivityTaskStartedRequest) XXX_Size() int

+ func (m *RecordActivityTaskStartedRequest) XXX_Unmarshal(b []byte) error

+ func (this *RecordActivityTaskStartedRequest) Equal(that interface{}) bool

+ func (this *RecordActivityTaskStartedRequest) GoString() string

+ func (this *RecordActivityTaskStartedRequest) String() string

+ type RecordActivityTaskStartedResponse struct

+ Attempt int64

+ HeartbeatDetails *v14.Payloads

+ ScheduledEvent *v110.HistoryEvent

+ ScheduledTimestampOfThisAttempt int64

+ StartedTimestamp int64

+ WorkflowNamespace string

+ WorkflowType *v14.WorkflowType

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

+ func (*RecordActivityTaskStartedResponse) ProtoMessage()

+ func (m *RecordActivityTaskStartedResponse) GetAttempt() int64

+ func (m *RecordActivityTaskStartedResponse) GetHeartbeatDetails() *v14.Payloads

+ func (m *RecordActivityTaskStartedResponse) GetScheduledEvent() *v110.HistoryEvent

+ func (m *RecordActivityTaskStartedResponse) GetScheduledTimestampOfThisAttempt() int64

+ func (m *RecordActivityTaskStartedResponse) GetStartedTimestamp() int64

+ func (m *RecordActivityTaskStartedResponse) GetWorkflowNamespace() string

+ func (m *RecordActivityTaskStartedResponse) GetWorkflowType() *v14.WorkflowType

+ func (m *RecordActivityTaskStartedResponse) Marshal() (dAtA []byte, err error)

+ func (m *RecordActivityTaskStartedResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *RecordActivityTaskStartedResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *RecordActivityTaskStartedResponse) Reset()

+ func (m *RecordActivityTaskStartedResponse) Size() (n int)

+ func (m *RecordActivityTaskStartedResponse) Unmarshal(dAtA []byte) error

+ func (m *RecordActivityTaskStartedResponse) XXX_DiscardUnknown()

+ func (m *RecordActivityTaskStartedResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *RecordActivityTaskStartedResponse) XXX_Merge(src proto.Message)

+ func (m *RecordActivityTaskStartedResponse) XXX_Size() int

+ func (m *RecordActivityTaskStartedResponse) XXX_Unmarshal(b []byte) error

+ func (this *RecordActivityTaskStartedResponse) Equal(that interface{}) bool

+ func (this *RecordActivityTaskStartedResponse) GoString() string

+ func (this *RecordActivityTaskStartedResponse) String() string

+ type RecordChildExecutionCompletedRequest struct

+ CompletedExecution *v14.WorkflowExecution

+ CompletionEvent *v110.HistoryEvent

+ InitiatedId int64

+ NamespaceId string

+ WorkflowExecution *v14.WorkflowExecution

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

+ func (*RecordChildExecutionCompletedRequest) ProtoMessage()

+ func (m *RecordChildExecutionCompletedRequest) GetCompletedExecution() *v14.WorkflowExecution

+ func (m *RecordChildExecutionCompletedRequest) GetCompletionEvent() *v110.HistoryEvent

+ func (m *RecordChildExecutionCompletedRequest) GetInitiatedId() int64

+ func (m *RecordChildExecutionCompletedRequest) GetNamespaceId() string

+ func (m *RecordChildExecutionCompletedRequest) GetWorkflowExecution() *v14.WorkflowExecution

+ func (m *RecordChildExecutionCompletedRequest) Marshal() (dAtA []byte, err error)

+ func (m *RecordChildExecutionCompletedRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *RecordChildExecutionCompletedRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *RecordChildExecutionCompletedRequest) Reset()

+ func (m *RecordChildExecutionCompletedRequest) Size() (n int)

+ func (m *RecordChildExecutionCompletedRequest) Unmarshal(dAtA []byte) error

+ func (m *RecordChildExecutionCompletedRequest) XXX_DiscardUnknown()

+ func (m *RecordChildExecutionCompletedRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *RecordChildExecutionCompletedRequest) XXX_Merge(src proto.Message)

+ func (m *RecordChildExecutionCompletedRequest) XXX_Size() int

+ func (m *RecordChildExecutionCompletedRequest) XXX_Unmarshal(b []byte) error

+ func (this *RecordChildExecutionCompletedRequest) Equal(that interface{}) bool

+ func (this *RecordChildExecutionCompletedRequest) GoString() string

+ func (this *RecordChildExecutionCompletedRequest) String() string

+ type RecordChildExecutionCompletedResponse struct

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

+ func (*RecordChildExecutionCompletedResponse) ProtoMessage()

+ func (m *RecordChildExecutionCompletedResponse) Marshal() (dAtA []byte, err error)

+ func (m *RecordChildExecutionCompletedResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *RecordChildExecutionCompletedResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *RecordChildExecutionCompletedResponse) Reset()

+ func (m *RecordChildExecutionCompletedResponse) Size() (n int)

+ func (m *RecordChildExecutionCompletedResponse) Unmarshal(dAtA []byte) error

+ func (m *RecordChildExecutionCompletedResponse) XXX_DiscardUnknown()

+ func (m *RecordChildExecutionCompletedResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *RecordChildExecutionCompletedResponse) XXX_Merge(src proto.Message)

+ func (m *RecordChildExecutionCompletedResponse) XXX_Size() int

+ func (m *RecordChildExecutionCompletedResponse) XXX_Unmarshal(b []byte) error

+ func (this *RecordChildExecutionCompletedResponse) Equal(that interface{}) bool

+ func (this *RecordChildExecutionCompletedResponse) GoString() string

+ func (this *RecordChildExecutionCompletedResponse) String() string

+ type RecordWorkflowTaskStartedRequest struct

+ NamespaceId string

+ PollRequest *v1.PollWorkflowTaskQueueRequest

+ RequestId string

+ ScheduleId int64

+ TaskId int64

+ WorkflowExecution *v14.WorkflowExecution

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

+ func (*RecordWorkflowTaskStartedRequest) ProtoMessage()

+ func (m *RecordWorkflowTaskStartedRequest) GetNamespaceId() string

+ func (m *RecordWorkflowTaskStartedRequest) GetPollRequest() *v1.PollWorkflowTaskQueueRequest

+ func (m *RecordWorkflowTaskStartedRequest) GetRequestId() string

+ func (m *RecordWorkflowTaskStartedRequest) GetScheduleId() int64

+ func (m *RecordWorkflowTaskStartedRequest) GetTaskId() int64

+ func (m *RecordWorkflowTaskStartedRequest) GetWorkflowExecution() *v14.WorkflowExecution

+ func (m *RecordWorkflowTaskStartedRequest) Marshal() (dAtA []byte, err error)

+ func (m *RecordWorkflowTaskStartedRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *RecordWorkflowTaskStartedRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *RecordWorkflowTaskStartedRequest) Reset()

+ func (m *RecordWorkflowTaskStartedRequest) Size() (n int)

+ func (m *RecordWorkflowTaskStartedRequest) Unmarshal(dAtA []byte) error

+ func (m *RecordWorkflowTaskStartedRequest) XXX_DiscardUnknown()

+ func (m *RecordWorkflowTaskStartedRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *RecordWorkflowTaskStartedRequest) XXX_Merge(src proto.Message)

+ func (m *RecordWorkflowTaskStartedRequest) XXX_Size() int

+ func (m *RecordWorkflowTaskStartedRequest) XXX_Unmarshal(b []byte) error

+ func (this *RecordWorkflowTaskStartedRequest) Equal(that interface{}) bool

+ func (this *RecordWorkflowTaskStartedRequest) GoString() string

+ func (this *RecordWorkflowTaskStartedRequest) String() string

+ type RecordWorkflowTaskStartedResponse struct

+ Attempt int64

+ BranchToken []byte

+ EventStoreVersion int32

+ NextEventId int64

+ PreviousStartedEventId int64

+ Queries map[string]*v19.WorkflowQuery

+ ScheduledEventId int64

+ ScheduledTimestamp int64

+ StartedEventId int64

+ StartedTimestamp int64

+ StickyExecutionEnabled bool

+ WorkflowExecutionTaskQueue *v15.TaskQueue

+ WorkflowTaskInfo *v18.TransientWorkflowTaskInfo

+ WorkflowType *v14.WorkflowType

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

+ func (*RecordWorkflowTaskStartedResponse) ProtoMessage()

+ func (m *RecordWorkflowTaskStartedResponse) GetAttempt() int64

+ func (m *RecordWorkflowTaskStartedResponse) GetBranchToken() []byte

+ func (m *RecordWorkflowTaskStartedResponse) GetEventStoreVersion() int32

+ func (m *RecordWorkflowTaskStartedResponse) GetNextEventId() int64

+ func (m *RecordWorkflowTaskStartedResponse) GetPreviousStartedEventId() int64

+ func (m *RecordWorkflowTaskStartedResponse) GetQueries() map[string]*v19.WorkflowQuery

+ func (m *RecordWorkflowTaskStartedResponse) GetScheduledEventId() int64

+ func (m *RecordWorkflowTaskStartedResponse) GetScheduledTimestamp() int64

+ func (m *RecordWorkflowTaskStartedResponse) GetStartedEventId() int64

+ func (m *RecordWorkflowTaskStartedResponse) GetStartedTimestamp() int64

+ func (m *RecordWorkflowTaskStartedResponse) GetStickyExecutionEnabled() bool

+ func (m *RecordWorkflowTaskStartedResponse) GetWorkflowExecutionTaskQueue() *v15.TaskQueue

+ func (m *RecordWorkflowTaskStartedResponse) GetWorkflowTaskInfo() *v18.TransientWorkflowTaskInfo

+ func (m *RecordWorkflowTaskStartedResponse) GetWorkflowType() *v14.WorkflowType

+ func (m *RecordWorkflowTaskStartedResponse) Marshal() (dAtA []byte, err error)

+ func (m *RecordWorkflowTaskStartedResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *RecordWorkflowTaskStartedResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *RecordWorkflowTaskStartedResponse) Reset()

+ func (m *RecordWorkflowTaskStartedResponse) Size() (n int)

+ func (m *RecordWorkflowTaskStartedResponse) Unmarshal(dAtA []byte) error

+ func (m *RecordWorkflowTaskStartedResponse) XXX_DiscardUnknown()

+ func (m *RecordWorkflowTaskStartedResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *RecordWorkflowTaskStartedResponse) XXX_Merge(src proto.Message)

+ func (m *RecordWorkflowTaskStartedResponse) XXX_Size() int

+ func (m *RecordWorkflowTaskStartedResponse) XXX_Unmarshal(b []byte) error

+ func (this *RecordWorkflowTaskStartedResponse) Equal(that interface{}) bool

+ func (this *RecordWorkflowTaskStartedResponse) GoString() string

+ func (this *RecordWorkflowTaskStartedResponse) String() string

+ type RefreshWorkflowTasksRequest struct

+ NamespaceId string

+ Request *v113.RefreshWorkflowTasksRequest

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

+ func (*RefreshWorkflowTasksRequest) ProtoMessage()

+ func (m *RefreshWorkflowTasksRequest) GetNamespaceId() string

+ func (m *RefreshWorkflowTasksRequest) GetRequest() *v113.RefreshWorkflowTasksRequest

+ func (m *RefreshWorkflowTasksRequest) Marshal() (dAtA []byte, err error)

+ func (m *RefreshWorkflowTasksRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *RefreshWorkflowTasksRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *RefreshWorkflowTasksRequest) Reset()

+ func (m *RefreshWorkflowTasksRequest) Size() (n int)

+ func (m *RefreshWorkflowTasksRequest) Unmarshal(dAtA []byte) error

+ func (m *RefreshWorkflowTasksRequest) XXX_DiscardUnknown()

+ func (m *RefreshWorkflowTasksRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *RefreshWorkflowTasksRequest) XXX_Merge(src proto.Message)

+ func (m *RefreshWorkflowTasksRequest) XXX_Size() int

+ func (m *RefreshWorkflowTasksRequest) XXX_Unmarshal(b []byte) error

+ func (this *RefreshWorkflowTasksRequest) Equal(that interface{}) bool

+ func (this *RefreshWorkflowTasksRequest) GoString() string

+ func (this *RefreshWorkflowTasksRequest) String() string

+ type RefreshWorkflowTasksResponse struct

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

+ func (*RefreshWorkflowTasksResponse) ProtoMessage()

+ func (m *RefreshWorkflowTasksResponse) Marshal() (dAtA []byte, err error)

+ func (m *RefreshWorkflowTasksResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *RefreshWorkflowTasksResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *RefreshWorkflowTasksResponse) Reset()

+ func (m *RefreshWorkflowTasksResponse) Size() (n int)

+ func (m *RefreshWorkflowTasksResponse) Unmarshal(dAtA []byte) error

+ func (m *RefreshWorkflowTasksResponse) XXX_DiscardUnknown()

+ func (m *RefreshWorkflowTasksResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *RefreshWorkflowTasksResponse) XXX_Merge(src proto.Message)

+ func (m *RefreshWorkflowTasksResponse) XXX_Size() int

+ func (m *RefreshWorkflowTasksResponse) XXX_Unmarshal(b []byte) error

+ func (this *RefreshWorkflowTasksResponse) Equal(that interface{}) bool

+ func (this *RefreshWorkflowTasksResponse) GoString() string

+ func (this *RefreshWorkflowTasksResponse) String() string

+ type RemoveSignalMutableStateRequest struct

+ NamespaceId string

+ RequestId string

+ WorkflowExecution *v14.WorkflowExecution

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

+ func (*RemoveSignalMutableStateRequest) ProtoMessage()

+ func (m *RemoveSignalMutableStateRequest) GetNamespaceId() string

+ func (m *RemoveSignalMutableStateRequest) GetRequestId() string

+ func (m *RemoveSignalMutableStateRequest) GetWorkflowExecution() *v14.WorkflowExecution

+ func (m *RemoveSignalMutableStateRequest) Marshal() (dAtA []byte, err error)

+ func (m *RemoveSignalMutableStateRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *RemoveSignalMutableStateRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *RemoveSignalMutableStateRequest) Reset()

+ func (m *RemoveSignalMutableStateRequest) Size() (n int)

+ func (m *RemoveSignalMutableStateRequest) Unmarshal(dAtA []byte) error

+ func (m *RemoveSignalMutableStateRequest) XXX_DiscardUnknown()

+ func (m *RemoveSignalMutableStateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *RemoveSignalMutableStateRequest) XXX_Merge(src proto.Message)

+ func (m *RemoveSignalMutableStateRequest) XXX_Size() int

+ func (m *RemoveSignalMutableStateRequest) XXX_Unmarshal(b []byte) error

+ func (this *RemoveSignalMutableStateRequest) Equal(that interface{}) bool

+ func (this *RemoveSignalMutableStateRequest) GoString() string

+ func (this *RemoveSignalMutableStateRequest) String() string

+ type RemoveSignalMutableStateResponse struct

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

+ func (*RemoveSignalMutableStateResponse) ProtoMessage()

+ func (m *RemoveSignalMutableStateResponse) Marshal() (dAtA []byte, err error)

+ func (m *RemoveSignalMutableStateResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *RemoveSignalMutableStateResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *RemoveSignalMutableStateResponse) Reset()

+ func (m *RemoveSignalMutableStateResponse) Size() (n int)

+ func (m *RemoveSignalMutableStateResponse) Unmarshal(dAtA []byte) error

+ func (m *RemoveSignalMutableStateResponse) XXX_DiscardUnknown()

+ func (m *RemoveSignalMutableStateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *RemoveSignalMutableStateResponse) XXX_Merge(src proto.Message)

+ func (m *RemoveSignalMutableStateResponse) XXX_Size() int

+ func (m *RemoveSignalMutableStateResponse) XXX_Unmarshal(b []byte) error

+ func (this *RemoveSignalMutableStateResponse) Equal(that interface{}) bool

+ func (this *RemoveSignalMutableStateResponse) GoString() string

+ func (this *RemoveSignalMutableStateResponse) String() string

+ type RemoveTaskRequest struct

+ Category v17.TaskCategory

+ ShardId int32

+ TaskId int64

+ VisibilityTimestamp int64

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

+ func (*RemoveTaskRequest) ProtoMessage()

+ func (m *RemoveTaskRequest) GetCategory() v17.TaskCategory

+ func (m *RemoveTaskRequest) GetShardId() int32

+ func (m *RemoveTaskRequest) GetTaskId() int64

+ func (m *RemoveTaskRequest) GetVisibilityTimestamp() int64

+ func (m *RemoveTaskRequest) Marshal() (dAtA []byte, err error)

+ func (m *RemoveTaskRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *RemoveTaskRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *RemoveTaskRequest) Reset()

+ func (m *RemoveTaskRequest) Size() (n int)

+ func (m *RemoveTaskRequest) Unmarshal(dAtA []byte) error

+ func (m *RemoveTaskRequest) XXX_DiscardUnknown()

+ func (m *RemoveTaskRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *RemoveTaskRequest) XXX_Merge(src proto.Message)

+ func (m *RemoveTaskRequest) XXX_Size() int

+ func (m *RemoveTaskRequest) XXX_Unmarshal(b []byte) error

+ func (this *RemoveTaskRequest) Equal(that interface{}) bool

+ func (this *RemoveTaskRequest) GoString() string

+ func (this *RemoveTaskRequest) String() string

+ type RemoveTaskResponse struct

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

+ func (*RemoveTaskResponse) ProtoMessage()

+ func (m *RemoveTaskResponse) Marshal() (dAtA []byte, err error)

+ func (m *RemoveTaskResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *RemoveTaskResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *RemoveTaskResponse) Reset()

+ func (m *RemoveTaskResponse) Size() (n int)

+ func (m *RemoveTaskResponse) Unmarshal(dAtA []byte) error

+ func (m *RemoveTaskResponse) XXX_DiscardUnknown()

+ func (m *RemoveTaskResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *RemoveTaskResponse) XXX_Merge(src proto.Message)

+ func (m *RemoveTaskResponse) XXX_Size() int

+ func (m *RemoveTaskResponse) XXX_Unmarshal(b []byte) error

+ func (this *RemoveTaskResponse) Equal(that interface{}) bool

+ func (this *RemoveTaskResponse) GoString() string

+ func (this *RemoveTaskResponse) String() string

+ type ReplicateEventsRequest struct

+ EventStoreVersion int32

+ FirstEventId int64

+ ForceBufferEvents bool

+ History *v110.History

+ NamespaceId string

+ NewRunEventStoreVersion int32

+ NewRunHistory *v110.History

+ NewRunNdc bool

+ NextEventId int64

+ ReplicationInfo map[string]*v16.ReplicationInfo

+ ResetWorkflow bool

+ SourceCluster string

+ Version int64

+ WorkflowExecution *v14.WorkflowExecution

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

+ func (*ReplicateEventsRequest) ProtoMessage()

+ func (m *ReplicateEventsRequest) GetEventStoreVersion() int32

+ func (m *ReplicateEventsRequest) GetFirstEventId() int64

+ func (m *ReplicateEventsRequest) GetForceBufferEvents() bool

+ func (m *ReplicateEventsRequest) GetHistory() *v110.History

+ func (m *ReplicateEventsRequest) GetNamespaceId() string

+ func (m *ReplicateEventsRequest) GetNewRunEventStoreVersion() int32

+ func (m *ReplicateEventsRequest) GetNewRunHistory() *v110.History

+ func (m *ReplicateEventsRequest) GetNewRunNdc() bool

+ func (m *ReplicateEventsRequest) GetNextEventId() int64

+ func (m *ReplicateEventsRequest) GetReplicationInfo() map[string]*v16.ReplicationInfo

+ func (m *ReplicateEventsRequest) GetResetWorkflow() bool

+ func (m *ReplicateEventsRequest) GetSourceCluster() string

+ func (m *ReplicateEventsRequest) GetVersion() int64

+ func (m *ReplicateEventsRequest) GetWorkflowExecution() *v14.WorkflowExecution

+ func (m *ReplicateEventsRequest) Marshal() (dAtA []byte, err error)

+ func (m *ReplicateEventsRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *ReplicateEventsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ReplicateEventsRequest) Reset()

+ func (m *ReplicateEventsRequest) Size() (n int)

+ func (m *ReplicateEventsRequest) Unmarshal(dAtA []byte) error

+ func (m *ReplicateEventsRequest) XXX_DiscardUnknown()

+ func (m *ReplicateEventsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ReplicateEventsRequest) XXX_Merge(src proto.Message)

+ func (m *ReplicateEventsRequest) XXX_Size() int

+ func (m *ReplicateEventsRequest) XXX_Unmarshal(b []byte) error

+ func (this *ReplicateEventsRequest) Equal(that interface{}) bool

+ func (this *ReplicateEventsRequest) GoString() string

+ func (this *ReplicateEventsRequest) String() string

+ type ReplicateEventsResponse struct

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

+ func (*ReplicateEventsResponse) ProtoMessage()

+ func (m *ReplicateEventsResponse) Marshal() (dAtA []byte, err error)

+ func (m *ReplicateEventsResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *ReplicateEventsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ReplicateEventsResponse) Reset()

+ func (m *ReplicateEventsResponse) Size() (n int)

+ func (m *ReplicateEventsResponse) Unmarshal(dAtA []byte) error

+ func (m *ReplicateEventsResponse) XXX_DiscardUnknown()

+ func (m *ReplicateEventsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ReplicateEventsResponse) XXX_Merge(src proto.Message)

+ func (m *ReplicateEventsResponse) XXX_Size() int

+ func (m *ReplicateEventsResponse) XXX_Unmarshal(b []byte) error

+ func (this *ReplicateEventsResponse) Equal(that interface{}) bool

+ func (this *ReplicateEventsResponse) GoString() string

+ func (this *ReplicateEventsResponse) String() string

+ type ReplicateEventsV2Request struct

+ Events *v14.DataBlob

+ NamespaceId string

+ NewRunEvents *v14.DataBlob

+ VersionHistoryItems []*v18.VersionHistoryItem

+ WorkflowExecution *v14.WorkflowExecution

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

+ func (*ReplicateEventsV2Request) ProtoMessage()

+ func (m *ReplicateEventsV2Request) GetEvents() *v14.DataBlob

+ func (m *ReplicateEventsV2Request) GetNamespaceId() string

+ func (m *ReplicateEventsV2Request) GetNewRunEvents() *v14.DataBlob

+ func (m *ReplicateEventsV2Request) GetVersionHistoryItems() []*v18.VersionHistoryItem

+ func (m *ReplicateEventsV2Request) GetWorkflowExecution() *v14.WorkflowExecution

+ func (m *ReplicateEventsV2Request) Marshal() (dAtA []byte, err error)

+ func (m *ReplicateEventsV2Request) MarshalTo(dAtA []byte) (int, error)

+ func (m *ReplicateEventsV2Request) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ReplicateEventsV2Request) Reset()

+ func (m *ReplicateEventsV2Request) Size() (n int)

+ func (m *ReplicateEventsV2Request) Unmarshal(dAtA []byte) error

+ func (m *ReplicateEventsV2Request) XXX_DiscardUnknown()

+ func (m *ReplicateEventsV2Request) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ReplicateEventsV2Request) XXX_Merge(src proto.Message)

+ func (m *ReplicateEventsV2Request) XXX_Size() int

+ func (m *ReplicateEventsV2Request) XXX_Unmarshal(b []byte) error

+ func (this *ReplicateEventsV2Request) Equal(that interface{}) bool

+ func (this *ReplicateEventsV2Request) GoString() string

+ func (this *ReplicateEventsV2Request) String() string

+ type ReplicateEventsV2Response struct

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

+ func (*ReplicateEventsV2Response) ProtoMessage()

+ func (m *ReplicateEventsV2Response) Marshal() (dAtA []byte, err error)

+ func (m *ReplicateEventsV2Response) MarshalTo(dAtA []byte) (int, error)

+ func (m *ReplicateEventsV2Response) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ReplicateEventsV2Response) Reset()

+ func (m *ReplicateEventsV2Response) Size() (n int)

+ func (m *ReplicateEventsV2Response) Unmarshal(dAtA []byte) error

+ func (m *ReplicateEventsV2Response) XXX_DiscardUnknown()

+ func (m *ReplicateEventsV2Response) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ReplicateEventsV2Response) XXX_Merge(src proto.Message)

+ func (m *ReplicateEventsV2Response) XXX_Size() int

+ func (m *ReplicateEventsV2Response) XXX_Unmarshal(b []byte) error

+ func (this *ReplicateEventsV2Response) Equal(that interface{}) bool

+ func (this *ReplicateEventsV2Response) GoString() string

+ func (this *ReplicateEventsV2Response) String() string

+ type ReplicateRawEventsRequest struct

+ EventStoreVersion int32

+ History *v14.DataBlob

+ NamespaceId string

+ NewRunEventStoreVersion int32

+ NewRunHistory *v14.DataBlob

+ ReplicationInfo map[string]*v16.ReplicationInfo

+ WorkflowExecution *v14.WorkflowExecution

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

+ func (*ReplicateRawEventsRequest) ProtoMessage()

+ func (m *ReplicateRawEventsRequest) GetEventStoreVersion() int32

+ func (m *ReplicateRawEventsRequest) GetHistory() *v14.DataBlob

+ func (m *ReplicateRawEventsRequest) GetNamespaceId() string

+ func (m *ReplicateRawEventsRequest) GetNewRunEventStoreVersion() int32

+ func (m *ReplicateRawEventsRequest) GetNewRunHistory() *v14.DataBlob

+ func (m *ReplicateRawEventsRequest) GetReplicationInfo() map[string]*v16.ReplicationInfo

+ func (m *ReplicateRawEventsRequest) GetWorkflowExecution() *v14.WorkflowExecution

+ func (m *ReplicateRawEventsRequest) Marshal() (dAtA []byte, err error)

+ func (m *ReplicateRawEventsRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *ReplicateRawEventsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ReplicateRawEventsRequest) Reset()

+ func (m *ReplicateRawEventsRequest) Size() (n int)

+ func (m *ReplicateRawEventsRequest) Unmarshal(dAtA []byte) error

+ func (m *ReplicateRawEventsRequest) XXX_DiscardUnknown()

+ func (m *ReplicateRawEventsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ReplicateRawEventsRequest) XXX_Merge(src proto.Message)

+ func (m *ReplicateRawEventsRequest) XXX_Size() int

+ func (m *ReplicateRawEventsRequest) XXX_Unmarshal(b []byte) error

+ func (this *ReplicateRawEventsRequest) Equal(that interface{}) bool

+ func (this *ReplicateRawEventsRequest) GoString() string

+ func (this *ReplicateRawEventsRequest) String() string

+ type ReplicateRawEventsResponse struct

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

+ func (*ReplicateRawEventsResponse) ProtoMessage()

+ func (m *ReplicateRawEventsResponse) Marshal() (dAtA []byte, err error)

+ func (m *ReplicateRawEventsResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *ReplicateRawEventsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ReplicateRawEventsResponse) Reset()

+ func (m *ReplicateRawEventsResponse) Size() (n int)

+ func (m *ReplicateRawEventsResponse) Unmarshal(dAtA []byte) error

+ func (m *ReplicateRawEventsResponse) XXX_DiscardUnknown()

+ func (m *ReplicateRawEventsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ReplicateRawEventsResponse) XXX_Merge(src proto.Message)

+ func (m *ReplicateRawEventsResponse) XXX_Size() int

+ func (m *ReplicateRawEventsResponse) XXX_Unmarshal(b []byte) error

+ func (this *ReplicateRawEventsResponse) Equal(that interface{}) bool

+ func (this *ReplicateRawEventsResponse) GoString() string

+ func (this *ReplicateRawEventsResponse) String() string

+ type RequestCancelWorkflowExecutionRequest struct

+ CancelRequest *v1.RequestCancelWorkflowExecutionRequest

+ ChildWorkflowOnly bool

+ ExternalInitiatedEventId int64

+ ExternalWorkflowExecution *v14.WorkflowExecution

+ NamespaceId string

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

+ func (*RequestCancelWorkflowExecutionRequest) ProtoMessage()

+ func (m *RequestCancelWorkflowExecutionRequest) GetCancelRequest() *v1.RequestCancelWorkflowExecutionRequest

+ func (m *RequestCancelWorkflowExecutionRequest) GetChildWorkflowOnly() bool

+ func (m *RequestCancelWorkflowExecutionRequest) GetExternalInitiatedEventId() int64

+ func (m *RequestCancelWorkflowExecutionRequest) GetExternalWorkflowExecution() *v14.WorkflowExecution

+ func (m *RequestCancelWorkflowExecutionRequest) GetNamespaceId() string

+ func (m *RequestCancelWorkflowExecutionRequest) Marshal() (dAtA []byte, err error)

+ func (m *RequestCancelWorkflowExecutionRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *RequestCancelWorkflowExecutionRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *RequestCancelWorkflowExecutionRequest) Reset()

+ func (m *RequestCancelWorkflowExecutionRequest) Size() (n int)

+ func (m *RequestCancelWorkflowExecutionRequest) Unmarshal(dAtA []byte) error

+ func (m *RequestCancelWorkflowExecutionRequest) XXX_DiscardUnknown()

+ func (m *RequestCancelWorkflowExecutionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *RequestCancelWorkflowExecutionRequest) XXX_Merge(src proto.Message)

+ func (m *RequestCancelWorkflowExecutionRequest) XXX_Size() int

+ func (m *RequestCancelWorkflowExecutionRequest) XXX_Unmarshal(b []byte) error

+ func (this *RequestCancelWorkflowExecutionRequest) Equal(that interface{}) bool

+ func (this *RequestCancelWorkflowExecutionRequest) GoString() string

+ func (this *RequestCancelWorkflowExecutionRequest) String() string

+ type RequestCancelWorkflowExecutionResponse struct

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

+ func (*RequestCancelWorkflowExecutionResponse) ProtoMessage()

+ func (m *RequestCancelWorkflowExecutionResponse) Marshal() (dAtA []byte, err error)

+ func (m *RequestCancelWorkflowExecutionResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *RequestCancelWorkflowExecutionResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *RequestCancelWorkflowExecutionResponse) Reset()

+ func (m *RequestCancelWorkflowExecutionResponse) Size() (n int)

+ func (m *RequestCancelWorkflowExecutionResponse) Unmarshal(dAtA []byte) error

+ func (m *RequestCancelWorkflowExecutionResponse) XXX_DiscardUnknown()

+ func (m *RequestCancelWorkflowExecutionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *RequestCancelWorkflowExecutionResponse) XXX_Merge(src proto.Message)

+ func (m *RequestCancelWorkflowExecutionResponse) XXX_Size() int

+ func (m *RequestCancelWorkflowExecutionResponse) XXX_Unmarshal(b []byte) error

+ func (this *RequestCancelWorkflowExecutionResponse) Equal(that interface{}) bool

+ func (this *RequestCancelWorkflowExecutionResponse) GoString() string

+ func (this *RequestCancelWorkflowExecutionResponse) String() string

+ type ResetStickyTaskQueueRequest struct

+ Execution *v14.WorkflowExecution

+ NamespaceId string

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

+ func (*ResetStickyTaskQueueRequest) ProtoMessage()

+ func (m *ResetStickyTaskQueueRequest) GetExecution() *v14.WorkflowExecution

+ func (m *ResetStickyTaskQueueRequest) GetNamespaceId() string

+ func (m *ResetStickyTaskQueueRequest) Marshal() (dAtA []byte, err error)

+ func (m *ResetStickyTaskQueueRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *ResetStickyTaskQueueRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ResetStickyTaskQueueRequest) Reset()

+ func (m *ResetStickyTaskQueueRequest) Size() (n int)

+ func (m *ResetStickyTaskQueueRequest) Unmarshal(dAtA []byte) error

+ func (m *ResetStickyTaskQueueRequest) XXX_DiscardUnknown()

+ func (m *ResetStickyTaskQueueRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ResetStickyTaskQueueRequest) XXX_Merge(src proto.Message)

+ func (m *ResetStickyTaskQueueRequest) XXX_Size() int

+ func (m *ResetStickyTaskQueueRequest) XXX_Unmarshal(b []byte) error

+ func (this *ResetStickyTaskQueueRequest) Equal(that interface{}) bool

+ func (this *ResetStickyTaskQueueRequest) GoString() string

+ func (this *ResetStickyTaskQueueRequest) String() string

+ type ResetStickyTaskQueueResponse struct

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

+ func (*ResetStickyTaskQueueResponse) ProtoMessage()

+ func (m *ResetStickyTaskQueueResponse) Marshal() (dAtA []byte, err error)

+ func (m *ResetStickyTaskQueueResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *ResetStickyTaskQueueResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ResetStickyTaskQueueResponse) Reset()

+ func (m *ResetStickyTaskQueueResponse) Size() (n int)

+ func (m *ResetStickyTaskQueueResponse) Unmarshal(dAtA []byte) error

+ func (m *ResetStickyTaskQueueResponse) XXX_DiscardUnknown()

+ func (m *ResetStickyTaskQueueResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ResetStickyTaskQueueResponse) XXX_Merge(src proto.Message)

+ func (m *ResetStickyTaskQueueResponse) XXX_Size() int

+ func (m *ResetStickyTaskQueueResponse) XXX_Unmarshal(b []byte) error

+ func (this *ResetStickyTaskQueueResponse) Equal(that interface{}) bool

+ func (this *ResetStickyTaskQueueResponse) GoString() string

+ func (this *ResetStickyTaskQueueResponse) String() string

+ type ResetWorkflowExecutionRequest struct

+ NamespaceId string

+ ResetRequest *v1.ResetWorkflowExecutionRequest

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

+ func (*ResetWorkflowExecutionRequest) ProtoMessage()

+ func (m *ResetWorkflowExecutionRequest) GetNamespaceId() string

+ func (m *ResetWorkflowExecutionRequest) GetResetRequest() *v1.ResetWorkflowExecutionRequest

+ func (m *ResetWorkflowExecutionRequest) Marshal() (dAtA []byte, err error)

+ func (m *ResetWorkflowExecutionRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *ResetWorkflowExecutionRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ResetWorkflowExecutionRequest) Reset()

+ func (m *ResetWorkflowExecutionRequest) Size() (n int)

+ func (m *ResetWorkflowExecutionRequest) Unmarshal(dAtA []byte) error

+ func (m *ResetWorkflowExecutionRequest) XXX_DiscardUnknown()

+ func (m *ResetWorkflowExecutionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ResetWorkflowExecutionRequest) XXX_Merge(src proto.Message)

+ func (m *ResetWorkflowExecutionRequest) XXX_Size() int

+ func (m *ResetWorkflowExecutionRequest) XXX_Unmarshal(b []byte) error

+ func (this *ResetWorkflowExecutionRequest) Equal(that interface{}) bool

+ func (this *ResetWorkflowExecutionRequest) GoString() string

+ func (this *ResetWorkflowExecutionRequest) String() string

+ type ResetWorkflowExecutionResponse struct

+ RunId string

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

+ func (*ResetWorkflowExecutionResponse) ProtoMessage()

+ func (m *ResetWorkflowExecutionResponse) GetRunId() string

+ func (m *ResetWorkflowExecutionResponse) Marshal() (dAtA []byte, err error)

+ func (m *ResetWorkflowExecutionResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *ResetWorkflowExecutionResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ResetWorkflowExecutionResponse) Reset()

+ func (m *ResetWorkflowExecutionResponse) Size() (n int)

+ func (m *ResetWorkflowExecutionResponse) Unmarshal(dAtA []byte) error

+ func (m *ResetWorkflowExecutionResponse) XXX_DiscardUnknown()

+ func (m *ResetWorkflowExecutionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ResetWorkflowExecutionResponse) XXX_Merge(src proto.Message)

+ func (m *ResetWorkflowExecutionResponse) XXX_Size() int

+ func (m *ResetWorkflowExecutionResponse) XXX_Unmarshal(b []byte) error

+ func (this *ResetWorkflowExecutionResponse) Equal(that interface{}) bool

+ func (this *ResetWorkflowExecutionResponse) GoString() string

+ func (this *ResetWorkflowExecutionResponse) String() string

+ type RespondActivityTaskCanceledRequest struct

+ CancelRequest *v1.RespondActivityTaskCanceledRequest

+ NamespaceId string

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

+ func (*RespondActivityTaskCanceledRequest) ProtoMessage()

+ func (m *RespondActivityTaskCanceledRequest) GetCancelRequest() *v1.RespondActivityTaskCanceledRequest

+ func (m *RespondActivityTaskCanceledRequest) GetNamespaceId() string

+ func (m *RespondActivityTaskCanceledRequest) Marshal() (dAtA []byte, err error)

+ func (m *RespondActivityTaskCanceledRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *RespondActivityTaskCanceledRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *RespondActivityTaskCanceledRequest) Reset()

+ func (m *RespondActivityTaskCanceledRequest) Size() (n int)

+ func (m *RespondActivityTaskCanceledRequest) Unmarshal(dAtA []byte) error

+ func (m *RespondActivityTaskCanceledRequest) XXX_DiscardUnknown()

+ func (m *RespondActivityTaskCanceledRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *RespondActivityTaskCanceledRequest) XXX_Merge(src proto.Message)

+ func (m *RespondActivityTaskCanceledRequest) XXX_Size() int

+ func (m *RespondActivityTaskCanceledRequest) XXX_Unmarshal(b []byte) error

+ func (this *RespondActivityTaskCanceledRequest) Equal(that interface{}) bool

+ func (this *RespondActivityTaskCanceledRequest) GoString() string

+ func (this *RespondActivityTaskCanceledRequest) String() string

+ type RespondActivityTaskCanceledResponse struct

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

+ func (*RespondActivityTaskCanceledResponse) ProtoMessage()

+ func (m *RespondActivityTaskCanceledResponse) Marshal() (dAtA []byte, err error)

+ func (m *RespondActivityTaskCanceledResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *RespondActivityTaskCanceledResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *RespondActivityTaskCanceledResponse) Reset()

+ func (m *RespondActivityTaskCanceledResponse) Size() (n int)

+ func (m *RespondActivityTaskCanceledResponse) Unmarshal(dAtA []byte) error

+ func (m *RespondActivityTaskCanceledResponse) XXX_DiscardUnknown()

+ func (m *RespondActivityTaskCanceledResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *RespondActivityTaskCanceledResponse) XXX_Merge(src proto.Message)

+ func (m *RespondActivityTaskCanceledResponse) XXX_Size() int

+ func (m *RespondActivityTaskCanceledResponse) XXX_Unmarshal(b []byte) error

+ func (this *RespondActivityTaskCanceledResponse) Equal(that interface{}) bool

+ func (this *RespondActivityTaskCanceledResponse) GoString() string

+ func (this *RespondActivityTaskCanceledResponse) String() string

+ type RespondActivityTaskCompletedRequest struct

+ CompleteRequest *v1.RespondActivityTaskCompletedRequest

+ NamespaceId string

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

+ func (*RespondActivityTaskCompletedRequest) ProtoMessage()

+ func (m *RespondActivityTaskCompletedRequest) GetCompleteRequest() *v1.RespondActivityTaskCompletedRequest

+ func (m *RespondActivityTaskCompletedRequest) GetNamespaceId() string

+ func (m *RespondActivityTaskCompletedRequest) Marshal() (dAtA []byte, err error)

+ func (m *RespondActivityTaskCompletedRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *RespondActivityTaskCompletedRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *RespondActivityTaskCompletedRequest) Reset()

+ func (m *RespondActivityTaskCompletedRequest) Size() (n int)

+ func (m *RespondActivityTaskCompletedRequest) Unmarshal(dAtA []byte) error

+ func (m *RespondActivityTaskCompletedRequest) XXX_DiscardUnknown()

+ func (m *RespondActivityTaskCompletedRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *RespondActivityTaskCompletedRequest) XXX_Merge(src proto.Message)

+ func (m *RespondActivityTaskCompletedRequest) XXX_Size() int

+ func (m *RespondActivityTaskCompletedRequest) XXX_Unmarshal(b []byte) error

+ func (this *RespondActivityTaskCompletedRequest) Equal(that interface{}) bool

+ func (this *RespondActivityTaskCompletedRequest) GoString() string

+ func (this *RespondActivityTaskCompletedRequest) String() string

+ type RespondActivityTaskCompletedResponse struct

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

+ func (*RespondActivityTaskCompletedResponse) ProtoMessage()

+ func (m *RespondActivityTaskCompletedResponse) Marshal() (dAtA []byte, err error)

+ func (m *RespondActivityTaskCompletedResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *RespondActivityTaskCompletedResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *RespondActivityTaskCompletedResponse) Reset()

+ func (m *RespondActivityTaskCompletedResponse) Size() (n int)

+ func (m *RespondActivityTaskCompletedResponse) Unmarshal(dAtA []byte) error

+ func (m *RespondActivityTaskCompletedResponse) XXX_DiscardUnknown()

+ func (m *RespondActivityTaskCompletedResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *RespondActivityTaskCompletedResponse) XXX_Merge(src proto.Message)

+ func (m *RespondActivityTaskCompletedResponse) XXX_Size() int

+ func (m *RespondActivityTaskCompletedResponse) XXX_Unmarshal(b []byte) error

+ func (this *RespondActivityTaskCompletedResponse) Equal(that interface{}) bool

+ func (this *RespondActivityTaskCompletedResponse) GoString() string

+ func (this *RespondActivityTaskCompletedResponse) String() string

+ type RespondActivityTaskFailedRequest struct

+ FailedRequest *v1.RespondActivityTaskFailedRequest

+ NamespaceId string

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

+ func (*RespondActivityTaskFailedRequest) ProtoMessage()

+ func (m *RespondActivityTaskFailedRequest) GetFailedRequest() *v1.RespondActivityTaskFailedRequest

+ func (m *RespondActivityTaskFailedRequest) GetNamespaceId() string

+ func (m *RespondActivityTaskFailedRequest) Marshal() (dAtA []byte, err error)

+ func (m *RespondActivityTaskFailedRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *RespondActivityTaskFailedRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *RespondActivityTaskFailedRequest) Reset()

+ func (m *RespondActivityTaskFailedRequest) Size() (n int)

+ func (m *RespondActivityTaskFailedRequest) Unmarshal(dAtA []byte) error

+ func (m *RespondActivityTaskFailedRequest) XXX_DiscardUnknown()

+ func (m *RespondActivityTaskFailedRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *RespondActivityTaskFailedRequest) XXX_Merge(src proto.Message)

+ func (m *RespondActivityTaskFailedRequest) XXX_Size() int

+ func (m *RespondActivityTaskFailedRequest) XXX_Unmarshal(b []byte) error

+ func (this *RespondActivityTaskFailedRequest) Equal(that interface{}) bool

+ func (this *RespondActivityTaskFailedRequest) GoString() string

+ func (this *RespondActivityTaskFailedRequest) String() string

+ type RespondActivityTaskFailedResponse struct

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

+ func (*RespondActivityTaskFailedResponse) ProtoMessage()

+ func (m *RespondActivityTaskFailedResponse) Marshal() (dAtA []byte, err error)

+ func (m *RespondActivityTaskFailedResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *RespondActivityTaskFailedResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *RespondActivityTaskFailedResponse) Reset()

+ func (m *RespondActivityTaskFailedResponse) Size() (n int)

+ func (m *RespondActivityTaskFailedResponse) Unmarshal(dAtA []byte) error

+ func (m *RespondActivityTaskFailedResponse) XXX_DiscardUnknown()

+ func (m *RespondActivityTaskFailedResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *RespondActivityTaskFailedResponse) XXX_Merge(src proto.Message)

+ func (m *RespondActivityTaskFailedResponse) XXX_Size() int

+ func (m *RespondActivityTaskFailedResponse) XXX_Unmarshal(b []byte) error

+ func (this *RespondActivityTaskFailedResponse) Equal(that interface{}) bool

+ func (this *RespondActivityTaskFailedResponse) GoString() string

+ func (this *RespondActivityTaskFailedResponse) String() string

+ type RespondWorkflowTaskCompletedRequest struct

+ CompleteRequest *v1.RespondWorkflowTaskCompletedRequest

+ NamespaceId string

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

+ func (*RespondWorkflowTaskCompletedRequest) ProtoMessage()

+ func (m *RespondWorkflowTaskCompletedRequest) GetCompleteRequest() *v1.RespondWorkflowTaskCompletedRequest

+ func (m *RespondWorkflowTaskCompletedRequest) GetNamespaceId() string

+ func (m *RespondWorkflowTaskCompletedRequest) Marshal() (dAtA []byte, err error)

+ func (m *RespondWorkflowTaskCompletedRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *RespondWorkflowTaskCompletedRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *RespondWorkflowTaskCompletedRequest) Reset()

+ func (m *RespondWorkflowTaskCompletedRequest) Size() (n int)

+ func (m *RespondWorkflowTaskCompletedRequest) Unmarshal(dAtA []byte) error

+ func (m *RespondWorkflowTaskCompletedRequest) XXX_DiscardUnknown()

+ func (m *RespondWorkflowTaskCompletedRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *RespondWorkflowTaskCompletedRequest) XXX_Merge(src proto.Message)

+ func (m *RespondWorkflowTaskCompletedRequest) XXX_Size() int

+ func (m *RespondWorkflowTaskCompletedRequest) XXX_Unmarshal(b []byte) error

+ func (this *RespondWorkflowTaskCompletedRequest) Equal(that interface{}) bool

+ func (this *RespondWorkflowTaskCompletedRequest) GoString() string

+ func (this *RespondWorkflowTaskCompletedRequest) String() string

+ type RespondWorkflowTaskCompletedResponse struct

+ StartedResponse *RecordWorkflowTaskStartedResponse

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

+ func (*RespondWorkflowTaskCompletedResponse) ProtoMessage()

+ func (m *RespondWorkflowTaskCompletedResponse) GetStartedResponse() *RecordWorkflowTaskStartedResponse

+ func (m *RespondWorkflowTaskCompletedResponse) Marshal() (dAtA []byte, err error)

+ func (m *RespondWorkflowTaskCompletedResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *RespondWorkflowTaskCompletedResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *RespondWorkflowTaskCompletedResponse) Reset()

+ func (m *RespondWorkflowTaskCompletedResponse) Size() (n int)

+ func (m *RespondWorkflowTaskCompletedResponse) Unmarshal(dAtA []byte) error

+ func (m *RespondWorkflowTaskCompletedResponse) XXX_DiscardUnknown()

+ func (m *RespondWorkflowTaskCompletedResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *RespondWorkflowTaskCompletedResponse) XXX_Merge(src proto.Message)

+ func (m *RespondWorkflowTaskCompletedResponse) XXX_Size() int

+ func (m *RespondWorkflowTaskCompletedResponse) XXX_Unmarshal(b []byte) error

+ func (this *RespondWorkflowTaskCompletedResponse) Equal(that interface{}) bool

+ func (this *RespondWorkflowTaskCompletedResponse) GoString() string

+ func (this *RespondWorkflowTaskCompletedResponse) String() string

+ type RespondWorkflowTaskFailedRequest struct

+ FailedRequest *v1.RespondWorkflowTaskFailedRequest

+ NamespaceId string

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

+ func (*RespondWorkflowTaskFailedRequest) ProtoMessage()

+ func (m *RespondWorkflowTaskFailedRequest) GetFailedRequest() *v1.RespondWorkflowTaskFailedRequest

+ func (m *RespondWorkflowTaskFailedRequest) GetNamespaceId() string

+ func (m *RespondWorkflowTaskFailedRequest) Marshal() (dAtA []byte, err error)

+ func (m *RespondWorkflowTaskFailedRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *RespondWorkflowTaskFailedRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *RespondWorkflowTaskFailedRequest) Reset()

+ func (m *RespondWorkflowTaskFailedRequest) Size() (n int)

+ func (m *RespondWorkflowTaskFailedRequest) Unmarshal(dAtA []byte) error

+ func (m *RespondWorkflowTaskFailedRequest) XXX_DiscardUnknown()

+ func (m *RespondWorkflowTaskFailedRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *RespondWorkflowTaskFailedRequest) XXX_Merge(src proto.Message)

+ func (m *RespondWorkflowTaskFailedRequest) XXX_Size() int

+ func (m *RespondWorkflowTaskFailedRequest) XXX_Unmarshal(b []byte) error

+ func (this *RespondWorkflowTaskFailedRequest) Equal(that interface{}) bool

+ func (this *RespondWorkflowTaskFailedRequest) GoString() string

+ func (this *RespondWorkflowTaskFailedRequest) String() string

+ type RespondWorkflowTaskFailedResponse struct

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

+ func (*RespondWorkflowTaskFailedResponse) ProtoMessage()

+ func (m *RespondWorkflowTaskFailedResponse) Marshal() (dAtA []byte, err error)

+ func (m *RespondWorkflowTaskFailedResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *RespondWorkflowTaskFailedResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *RespondWorkflowTaskFailedResponse) Reset()

+ func (m *RespondWorkflowTaskFailedResponse) Size() (n int)

+ func (m *RespondWorkflowTaskFailedResponse) Unmarshal(dAtA []byte) error

+ func (m *RespondWorkflowTaskFailedResponse) XXX_DiscardUnknown()

+ func (m *RespondWorkflowTaskFailedResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *RespondWorkflowTaskFailedResponse) XXX_Merge(src proto.Message)

+ func (m *RespondWorkflowTaskFailedResponse) XXX_Size() int

+ func (m *RespondWorkflowTaskFailedResponse) XXX_Unmarshal(b []byte) error

+ func (this *RespondWorkflowTaskFailedResponse) Equal(that interface{}) bool

+ func (this *RespondWorkflowTaskFailedResponse) GoString() string

+ func (this *RespondWorkflowTaskFailedResponse) String() string

+ type ScheduleWorkflowTaskRequest struct

+ IsFirstWorkflowTask bool

+ NamespaceId string

+ WorkflowExecution *v14.WorkflowExecution

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

+ func (*ScheduleWorkflowTaskRequest) ProtoMessage()

+ func (m *ScheduleWorkflowTaskRequest) GetIsFirstWorkflowTask() bool

+ func (m *ScheduleWorkflowTaskRequest) GetNamespaceId() string

+ func (m *ScheduleWorkflowTaskRequest) GetWorkflowExecution() *v14.WorkflowExecution

+ func (m *ScheduleWorkflowTaskRequest) Marshal() (dAtA []byte, err error)

+ func (m *ScheduleWorkflowTaskRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *ScheduleWorkflowTaskRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ScheduleWorkflowTaskRequest) Reset()

+ func (m *ScheduleWorkflowTaskRequest) Size() (n int)

+ func (m *ScheduleWorkflowTaskRequest) Unmarshal(dAtA []byte) error

+ func (m *ScheduleWorkflowTaskRequest) XXX_DiscardUnknown()

+ func (m *ScheduleWorkflowTaskRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ScheduleWorkflowTaskRequest) XXX_Merge(src proto.Message)

+ func (m *ScheduleWorkflowTaskRequest) XXX_Size() int

+ func (m *ScheduleWorkflowTaskRequest) XXX_Unmarshal(b []byte) error

+ func (this *ScheduleWorkflowTaskRequest) Equal(that interface{}) bool

+ func (this *ScheduleWorkflowTaskRequest) GoString() string

+ func (this *ScheduleWorkflowTaskRequest) String() string

+ type ScheduleWorkflowTaskResponse struct

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

+ func (*ScheduleWorkflowTaskResponse) ProtoMessage()

+ func (m *ScheduleWorkflowTaskResponse) Marshal() (dAtA []byte, err error)

+ func (m *ScheduleWorkflowTaskResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *ScheduleWorkflowTaskResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ScheduleWorkflowTaskResponse) Reset()

+ func (m *ScheduleWorkflowTaskResponse) Size() (n int)

+ func (m *ScheduleWorkflowTaskResponse) Unmarshal(dAtA []byte) error

+ func (m *ScheduleWorkflowTaskResponse) XXX_DiscardUnknown()

+ func (m *ScheduleWorkflowTaskResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ScheduleWorkflowTaskResponse) XXX_Merge(src proto.Message)

+ func (m *ScheduleWorkflowTaskResponse) XXX_Size() int

+ func (m *ScheduleWorkflowTaskResponse) XXX_Unmarshal(b []byte) error

+ func (this *ScheduleWorkflowTaskResponse) Equal(that interface{}) bool

+ func (this *ScheduleWorkflowTaskResponse) GoString() string

+ func (this *ScheduleWorkflowTaskResponse) String() string

+ type SignalWithStartWorkflowExecutionRequest struct

+ NamespaceId string

+ SignalWithStartRequest *v1.SignalWithStartWorkflowExecutionRequest

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

+ func (*SignalWithStartWorkflowExecutionRequest) ProtoMessage()

+ func (m *SignalWithStartWorkflowExecutionRequest) GetNamespaceId() string

+ func (m *SignalWithStartWorkflowExecutionRequest) GetSignalWithStartRequest() *v1.SignalWithStartWorkflowExecutionRequest

+ func (m *SignalWithStartWorkflowExecutionRequest) Marshal() (dAtA []byte, err error)

+ func (m *SignalWithStartWorkflowExecutionRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *SignalWithStartWorkflowExecutionRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *SignalWithStartWorkflowExecutionRequest) Reset()

+ func (m *SignalWithStartWorkflowExecutionRequest) Size() (n int)

+ func (m *SignalWithStartWorkflowExecutionRequest) Unmarshal(dAtA []byte) error

+ func (m *SignalWithStartWorkflowExecutionRequest) XXX_DiscardUnknown()

+ func (m *SignalWithStartWorkflowExecutionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *SignalWithStartWorkflowExecutionRequest) XXX_Merge(src proto.Message)

+ func (m *SignalWithStartWorkflowExecutionRequest) XXX_Size() int

+ func (m *SignalWithStartWorkflowExecutionRequest) XXX_Unmarshal(b []byte) error

+ func (this *SignalWithStartWorkflowExecutionRequest) Equal(that interface{}) bool

+ func (this *SignalWithStartWorkflowExecutionRequest) GoString() string

+ func (this *SignalWithStartWorkflowExecutionRequest) String() string

+ type SignalWithStartWorkflowExecutionResponse struct

+ RunId string

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

+ func (*SignalWithStartWorkflowExecutionResponse) ProtoMessage()

+ func (m *SignalWithStartWorkflowExecutionResponse) GetRunId() string

+ func (m *SignalWithStartWorkflowExecutionResponse) Marshal() (dAtA []byte, err error)

+ func (m *SignalWithStartWorkflowExecutionResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *SignalWithStartWorkflowExecutionResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *SignalWithStartWorkflowExecutionResponse) Reset()

+ func (m *SignalWithStartWorkflowExecutionResponse) Size() (n int)

+ func (m *SignalWithStartWorkflowExecutionResponse) Unmarshal(dAtA []byte) error

+ func (m *SignalWithStartWorkflowExecutionResponse) XXX_DiscardUnknown()

+ func (m *SignalWithStartWorkflowExecutionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *SignalWithStartWorkflowExecutionResponse) XXX_Merge(src proto.Message)

+ func (m *SignalWithStartWorkflowExecutionResponse) XXX_Size() int

+ func (m *SignalWithStartWorkflowExecutionResponse) XXX_Unmarshal(b []byte) error

+ func (this *SignalWithStartWorkflowExecutionResponse) Equal(that interface{}) bool

+ func (this *SignalWithStartWorkflowExecutionResponse) GoString() string

+ func (this *SignalWithStartWorkflowExecutionResponse) String() string

+ type SignalWorkflowExecutionRequest struct

+ ChildWorkflowOnly bool

+ ExternalWorkflowExecution *v14.WorkflowExecution

+ NamespaceId string

+ SignalRequest *v1.SignalWorkflowExecutionRequest

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

+ func (*SignalWorkflowExecutionRequest) ProtoMessage()

+ func (m *SignalWorkflowExecutionRequest) GetChildWorkflowOnly() bool

+ func (m *SignalWorkflowExecutionRequest) GetExternalWorkflowExecution() *v14.WorkflowExecution

+ func (m *SignalWorkflowExecutionRequest) GetNamespaceId() string

+ func (m *SignalWorkflowExecutionRequest) GetSignalRequest() *v1.SignalWorkflowExecutionRequest

+ func (m *SignalWorkflowExecutionRequest) Marshal() (dAtA []byte, err error)

+ func (m *SignalWorkflowExecutionRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *SignalWorkflowExecutionRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *SignalWorkflowExecutionRequest) Reset()

+ func (m *SignalWorkflowExecutionRequest) Size() (n int)

+ func (m *SignalWorkflowExecutionRequest) Unmarshal(dAtA []byte) error

+ func (m *SignalWorkflowExecutionRequest) XXX_DiscardUnknown()

+ func (m *SignalWorkflowExecutionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *SignalWorkflowExecutionRequest) XXX_Merge(src proto.Message)

+ func (m *SignalWorkflowExecutionRequest) XXX_Size() int

+ func (m *SignalWorkflowExecutionRequest) XXX_Unmarshal(b []byte) error

+ func (this *SignalWorkflowExecutionRequest) Equal(that interface{}) bool

+ func (this *SignalWorkflowExecutionRequest) GoString() string

+ func (this *SignalWorkflowExecutionRequest) String() string

+ type SignalWorkflowExecutionResponse struct

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

+ func (*SignalWorkflowExecutionResponse) ProtoMessage()

+ func (m *SignalWorkflowExecutionResponse) Marshal() (dAtA []byte, err error)

+ func (m *SignalWorkflowExecutionResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *SignalWorkflowExecutionResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *SignalWorkflowExecutionResponse) Reset()

+ func (m *SignalWorkflowExecutionResponse) Size() (n int)

+ func (m *SignalWorkflowExecutionResponse) Unmarshal(dAtA []byte) error

+ func (m *SignalWorkflowExecutionResponse) XXX_DiscardUnknown()

+ func (m *SignalWorkflowExecutionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *SignalWorkflowExecutionResponse) XXX_Merge(src proto.Message)

+ func (m *SignalWorkflowExecutionResponse) XXX_Size() int

+ func (m *SignalWorkflowExecutionResponse) XXX_Unmarshal(b []byte) error

+ func (this *SignalWorkflowExecutionResponse) Equal(that interface{}) bool

+ func (this *SignalWorkflowExecutionResponse) GoString() string

+ func (this *SignalWorkflowExecutionResponse) String() string

+ type StartWorkflowExecutionRequest struct

+ Attempt int32

+ ContinueAsNewInitiator v12.ContinueAsNewInitiator

+ ContinuedFailure *v13.Failure

+ FirstWorkflowTaskBackoffSeconds int32

+ LastCompletionResult *v14.Payloads

+ NamespaceId string

+ ParentExecutionInfo *v11.ParentExecutionInfo

+ StartRequest *v1.StartWorkflowExecutionRequest

+ WorkflowExecutionExpirationTimestamp int64

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

+ func (*StartWorkflowExecutionRequest) ProtoMessage()

+ func (m *StartWorkflowExecutionRequest) GetAttempt() int32

+ func (m *StartWorkflowExecutionRequest) GetContinueAsNewInitiator() v12.ContinueAsNewInitiator

+ func (m *StartWorkflowExecutionRequest) GetContinuedFailure() *v13.Failure

+ func (m *StartWorkflowExecutionRequest) GetFirstWorkflowTaskBackoffSeconds() int32

+ func (m *StartWorkflowExecutionRequest) GetLastCompletionResult() *v14.Payloads

+ func (m *StartWorkflowExecutionRequest) GetNamespaceId() string

+ func (m *StartWorkflowExecutionRequest) GetParentExecutionInfo() *v11.ParentExecutionInfo

+ func (m *StartWorkflowExecutionRequest) GetStartRequest() *v1.StartWorkflowExecutionRequest

+ func (m *StartWorkflowExecutionRequest) GetWorkflowExecutionExpirationTimestamp() int64

+ func (m *StartWorkflowExecutionRequest) Marshal() (dAtA []byte, err error)

+ func (m *StartWorkflowExecutionRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *StartWorkflowExecutionRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *StartWorkflowExecutionRequest) Reset()

+ func (m *StartWorkflowExecutionRequest) Size() (n int)

+ func (m *StartWorkflowExecutionRequest) Unmarshal(dAtA []byte) error

+ func (m *StartWorkflowExecutionRequest) XXX_DiscardUnknown()

+ func (m *StartWorkflowExecutionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *StartWorkflowExecutionRequest) XXX_Merge(src proto.Message)

+ func (m *StartWorkflowExecutionRequest) XXX_Size() int

+ func (m *StartWorkflowExecutionRequest) XXX_Unmarshal(b []byte) error

+ func (this *StartWorkflowExecutionRequest) Equal(that interface{}) bool

+ func (this *StartWorkflowExecutionRequest) GoString() string

+ func (this *StartWorkflowExecutionRequest) String() string

+ type StartWorkflowExecutionResponse struct

+ RunId string

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

+ func (*StartWorkflowExecutionResponse) ProtoMessage()

+ func (m *StartWorkflowExecutionResponse) GetRunId() string

+ func (m *StartWorkflowExecutionResponse) Marshal() (dAtA []byte, err error)

+ func (m *StartWorkflowExecutionResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *StartWorkflowExecutionResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *StartWorkflowExecutionResponse) Reset()

+ func (m *StartWorkflowExecutionResponse) Size() (n int)

+ func (m *StartWorkflowExecutionResponse) Unmarshal(dAtA []byte) error

+ func (m *StartWorkflowExecutionResponse) XXX_DiscardUnknown()

+ func (m *StartWorkflowExecutionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *StartWorkflowExecutionResponse) XXX_Merge(src proto.Message)

+ func (m *StartWorkflowExecutionResponse) XXX_Size() int

+ func (m *StartWorkflowExecutionResponse) XXX_Unmarshal(b []byte) error

+ func (this *StartWorkflowExecutionResponse) Equal(that interface{}) bool

+ func (this *StartWorkflowExecutionResponse) GoString() string

+ func (this *StartWorkflowExecutionResponse) String() string

+ type SyncActivityRequest struct

+ Attempt int32

+ Details *v14.Payloads

+ LastFailure *v13.Failure

+ LastHeartbeatTime int64

+ LastWorkerIdentity string

+ NamespaceId string

+ RunId string

+ ScheduledId int64

+ ScheduledTime int64

+ StartedId int64

+ StartedTime int64

+ Version int64

+ VersionHistory *v18.VersionHistory

+ WorkflowId string

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

+ func (*SyncActivityRequest) ProtoMessage()

+ func (m *SyncActivityRequest) GetAttempt() int32

+ func (m *SyncActivityRequest) GetDetails() *v14.Payloads

+ func (m *SyncActivityRequest) GetLastFailure() *v13.Failure

+ func (m *SyncActivityRequest) GetLastHeartbeatTime() int64

+ func (m *SyncActivityRequest) GetLastWorkerIdentity() string

+ func (m *SyncActivityRequest) GetNamespaceId() string

+ func (m *SyncActivityRequest) GetRunId() string

+ func (m *SyncActivityRequest) GetScheduledId() int64

+ func (m *SyncActivityRequest) GetScheduledTime() int64

+ func (m *SyncActivityRequest) GetStartedId() int64

+ func (m *SyncActivityRequest) GetStartedTime() int64

+ func (m *SyncActivityRequest) GetVersion() int64

+ func (m *SyncActivityRequest) GetVersionHistory() *v18.VersionHistory

+ func (m *SyncActivityRequest) GetWorkflowId() string

+ func (m *SyncActivityRequest) Marshal() (dAtA []byte, err error)

+ func (m *SyncActivityRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *SyncActivityRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *SyncActivityRequest) Reset()

+ func (m *SyncActivityRequest) Size() (n int)

+ func (m *SyncActivityRequest) Unmarshal(dAtA []byte) error

+ func (m *SyncActivityRequest) XXX_DiscardUnknown()

+ func (m *SyncActivityRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *SyncActivityRequest) XXX_Merge(src proto.Message)

+ func (m *SyncActivityRequest) XXX_Size() int

+ func (m *SyncActivityRequest) XXX_Unmarshal(b []byte) error

+ func (this *SyncActivityRequest) Equal(that interface{}) bool

+ func (this *SyncActivityRequest) GoString() string

+ func (this *SyncActivityRequest) String() string

+ type SyncActivityResponse struct

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

+ func (*SyncActivityResponse) ProtoMessage()

+ func (m *SyncActivityResponse) Marshal() (dAtA []byte, err error)

+ func (m *SyncActivityResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *SyncActivityResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *SyncActivityResponse) Reset()

+ func (m *SyncActivityResponse) Size() (n int)

+ func (m *SyncActivityResponse) Unmarshal(dAtA []byte) error

+ func (m *SyncActivityResponse) XXX_DiscardUnknown()

+ func (m *SyncActivityResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *SyncActivityResponse) XXX_Merge(src proto.Message)

+ func (m *SyncActivityResponse) XXX_Size() int

+ func (m *SyncActivityResponse) XXX_Unmarshal(b []byte) error

+ func (this *SyncActivityResponse) Equal(that interface{}) bool

+ func (this *SyncActivityResponse) GoString() string

+ func (this *SyncActivityResponse) String() string

+ type SyncShardStatusRequest struct

+ ShardId int64

+ SourceCluster string

+ Timestamp int64

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

+ func (*SyncShardStatusRequest) ProtoMessage()

+ func (m *SyncShardStatusRequest) GetShardId() int64

+ func (m *SyncShardStatusRequest) GetSourceCluster() string

+ func (m *SyncShardStatusRequest) GetTimestamp() int64

+ func (m *SyncShardStatusRequest) Marshal() (dAtA []byte, err error)

+ func (m *SyncShardStatusRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *SyncShardStatusRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *SyncShardStatusRequest) Reset()

+ func (m *SyncShardStatusRequest) Size() (n int)

+ func (m *SyncShardStatusRequest) Unmarshal(dAtA []byte) error

+ func (m *SyncShardStatusRequest) XXX_DiscardUnknown()

+ func (m *SyncShardStatusRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *SyncShardStatusRequest) XXX_Merge(src proto.Message)

+ func (m *SyncShardStatusRequest) XXX_Size() int

+ func (m *SyncShardStatusRequest) XXX_Unmarshal(b []byte) error

+ func (this *SyncShardStatusRequest) Equal(that interface{}) bool

+ func (this *SyncShardStatusRequest) GoString() string

+ func (this *SyncShardStatusRequest) String() string

+ type SyncShardStatusResponse struct

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

+ func (*SyncShardStatusResponse) ProtoMessage()

+ func (m *SyncShardStatusResponse) Marshal() (dAtA []byte, err error)

+ func (m *SyncShardStatusResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *SyncShardStatusResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *SyncShardStatusResponse) Reset()

+ func (m *SyncShardStatusResponse) Size() (n int)

+ func (m *SyncShardStatusResponse) Unmarshal(dAtA []byte) error

+ func (m *SyncShardStatusResponse) XXX_DiscardUnknown()

+ func (m *SyncShardStatusResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *SyncShardStatusResponse) XXX_Merge(src proto.Message)

+ func (m *SyncShardStatusResponse) XXX_Size() int

+ func (m *SyncShardStatusResponse) XXX_Unmarshal(b []byte) error

+ func (this *SyncShardStatusResponse) Equal(that interface{}) bool

+ func (this *SyncShardStatusResponse) GoString() string

+ func (this *SyncShardStatusResponse) String() string

+ type TerminateWorkflowExecutionRequest struct

+ NamespaceId string

+ TerminateRequest *v1.TerminateWorkflowExecutionRequest

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

+ func (*TerminateWorkflowExecutionRequest) ProtoMessage()

+ func (m *TerminateWorkflowExecutionRequest) GetNamespaceId() string

+ func (m *TerminateWorkflowExecutionRequest) GetTerminateRequest() *v1.TerminateWorkflowExecutionRequest

+ func (m *TerminateWorkflowExecutionRequest) Marshal() (dAtA []byte, err error)

+ func (m *TerminateWorkflowExecutionRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *TerminateWorkflowExecutionRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *TerminateWorkflowExecutionRequest) Reset()

+ func (m *TerminateWorkflowExecutionRequest) Size() (n int)

+ func (m *TerminateWorkflowExecutionRequest) Unmarshal(dAtA []byte) error

+ func (m *TerminateWorkflowExecutionRequest) XXX_DiscardUnknown()

+ func (m *TerminateWorkflowExecutionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *TerminateWorkflowExecutionRequest) XXX_Merge(src proto.Message)

+ func (m *TerminateWorkflowExecutionRequest) XXX_Size() int

+ func (m *TerminateWorkflowExecutionRequest) XXX_Unmarshal(b []byte) error

+ func (this *TerminateWorkflowExecutionRequest) Equal(that interface{}) bool

+ func (this *TerminateWorkflowExecutionRequest) GoString() string

+ func (this *TerminateWorkflowExecutionRequest) String() string

+ type TerminateWorkflowExecutionResponse struct

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

+ func (*TerminateWorkflowExecutionResponse) ProtoMessage()

+ func (m *TerminateWorkflowExecutionResponse) Marshal() (dAtA []byte, err error)

+ func (m *TerminateWorkflowExecutionResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *TerminateWorkflowExecutionResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *TerminateWorkflowExecutionResponse) Reset()

+ func (m *TerminateWorkflowExecutionResponse) Size() (n int)

+ func (m *TerminateWorkflowExecutionResponse) Unmarshal(dAtA []byte) error

+ func (m *TerminateWorkflowExecutionResponse) XXX_DiscardUnknown()

+ func (m *TerminateWorkflowExecutionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *TerminateWorkflowExecutionResponse) XXX_Merge(src proto.Message)

+ func (m *TerminateWorkflowExecutionResponse) XXX_Size() int

+ func (m *TerminateWorkflowExecutionResponse) XXX_Unmarshal(b []byte) error

+ func (this *TerminateWorkflowExecutionResponse) Equal(that interface{}) bool

+ func (this *TerminateWorkflowExecutionResponse) GoString() string

+ func (this *TerminateWorkflowExecutionResponse) String() string

+ type UnimplementedHistoryServiceServer struct

+ func (*UnimplementedHistoryServiceServer) CloseShard(ctx context.Context, req *CloseShardRequest) (*CloseShardResponse, error)

+ func (*UnimplementedHistoryServiceServer) DescribeHistoryHost(ctx context.Context, req *DescribeHistoryHostRequest) (*DescribeHistoryHostResponse, error)

+ func (*UnimplementedHistoryServiceServer) DescribeMutableState(ctx context.Context, req *DescribeMutableStateRequest) (*DescribeMutableStateResponse, error)

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

+ func (*UnimplementedHistoryServiceServer) GetDLQMessages(ctx context.Context, req *GetDLQMessagesRequest) (*GetDLQMessagesResponse, error)

+ func (*UnimplementedHistoryServiceServer) GetDLQReplicationMessages(ctx context.Context, req *GetDLQReplicationMessagesRequest) (*GetDLQReplicationMessagesResponse, error)

+ func (*UnimplementedHistoryServiceServer) GetMutableState(ctx context.Context, req *GetMutableStateRequest) (*GetMutableStateResponse, error)

+ func (*UnimplementedHistoryServiceServer) GetReplicationMessages(ctx context.Context, req *GetReplicationMessagesRequest) (*GetReplicationMessagesResponse, error)

+ func (*UnimplementedHistoryServiceServer) MergeDLQMessages(ctx context.Context, req *MergeDLQMessagesRequest) (*MergeDLQMessagesResponse, error)

+ func (*UnimplementedHistoryServiceServer) PollMutableState(ctx context.Context, req *PollMutableStateRequest) (*PollMutableStateResponse, error)

+ func (*UnimplementedHistoryServiceServer) PurgeDLQMessages(ctx context.Context, req *PurgeDLQMessagesRequest) (*PurgeDLQMessagesResponse, error)

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

+ func (*UnimplementedHistoryServiceServer) ReapplyEvents(ctx context.Context, req *ReapplyEventsRequest) (*ReapplyEventsResponse, error)

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

+ func (*UnimplementedHistoryServiceServer) RecordActivityTaskStarted(ctx context.Context, req *RecordActivityTaskStartedRequest) (*RecordActivityTaskStartedResponse, error)

+ func (*UnimplementedHistoryServiceServer) RecordChildExecutionCompleted(ctx context.Context, req *RecordChildExecutionCompletedRequest) (*RecordChildExecutionCompletedResponse, error)

+ func (*UnimplementedHistoryServiceServer) RecordWorkflowTaskStarted(ctx context.Context, req *RecordWorkflowTaskStartedRequest) (*RecordWorkflowTaskStartedResponse, error)

+ func (*UnimplementedHistoryServiceServer) RefreshWorkflowTasks(ctx context.Context, req *RefreshWorkflowTasksRequest) (*RefreshWorkflowTasksResponse, error)

+ func (*UnimplementedHistoryServiceServer) RemoveSignalMutableState(ctx context.Context, req *RemoveSignalMutableStateRequest) (*RemoveSignalMutableStateResponse, error)

+ func (*UnimplementedHistoryServiceServer) RemoveTask(ctx context.Context, req *RemoveTaskRequest) (*RemoveTaskResponse, error)

+ func (*UnimplementedHistoryServiceServer) ReplicateEvents(ctx context.Context, req *ReplicateEventsRequest) (*ReplicateEventsResponse, error)

+ func (*UnimplementedHistoryServiceServer) ReplicateEventsV2(ctx context.Context, req *ReplicateEventsV2Request) (*ReplicateEventsV2Response, error)

+ func (*UnimplementedHistoryServiceServer) ReplicateRawEvents(ctx context.Context, req *ReplicateRawEventsRequest) (*ReplicateRawEventsResponse, error)

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

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

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

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

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

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

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

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

+ func (*UnimplementedHistoryServiceServer) ScheduleWorkflowTask(ctx context.Context, req *ScheduleWorkflowTaskRequest) (*ScheduleWorkflowTaskResponse, error)

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

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

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

+ func (*UnimplementedHistoryServiceServer) SyncActivity(ctx context.Context, req *SyncActivityRequest) (*SyncActivityResponse, error)

+ func (*UnimplementedHistoryServiceServer) SyncShardStatus(ctx context.Context, req *SyncShardStatusRequest) (*SyncShardStatusResponse, error)

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