adminservice

Dec 23, 2024

Changes in this version

+ const AdminService_ForceUnloadTaskQueuePartition_FullMethodName

type AdminServiceClient

+ ForceUnloadTaskQueuePartition func(ctx context.Context, in *ForceUnloadTaskQueuePartitionRequest, ...) (*ForceUnloadTaskQueuePartitionResponse, error)

type AdminServiceServer

+ ForceUnloadTaskQueuePartition func(context.Context, *ForceUnloadTaskQueuePartitionRequest) (*ForceUnloadTaskQueuePartitionResponse, error)

+ type ForceUnloadTaskQueuePartitionRequest struct

+ Namespace string

+ TaskQueuePartition *v113.TaskQueuePartition

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

+ func (*ForceUnloadTaskQueuePartitionRequest) ProtoMessage()

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

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

+ func (val *ForceUnloadTaskQueuePartitionRequest) Size() int

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

+ func (x *ForceUnloadTaskQueuePartitionRequest) GetNamespace() string

+ func (x *ForceUnloadTaskQueuePartitionRequest) GetTaskQueuePartition() *v113.TaskQueuePartition

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

+ func (x *ForceUnloadTaskQueuePartitionRequest) Reset()

+ func (x *ForceUnloadTaskQueuePartitionRequest) String() string

+ type ForceUnloadTaskQueuePartitionResponse struct

+ WasLoaded bool

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

+ func (*ForceUnloadTaskQueuePartitionResponse) ProtoMessage()

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

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

+ func (val *ForceUnloadTaskQueuePartitionResponse) Size() int

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

+ func (x *ForceUnloadTaskQueuePartitionResponse) GetWasLoaded() bool

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

+ func (x *ForceUnloadTaskQueuePartitionResponse) Reset()

+ func (x *ForceUnloadTaskQueuePartitionResponse) String() string

type SyncWorkflowStateResponse

+ VersionedTransitionArtifact *v15.VersionedTransitionArtifact

+ func (x *SyncWorkflowStateResponse) GetVersionedTransitionArtifact() *v15.VersionedTransitionArtifact

type UnimplementedAdminServiceServer

+ func (UnimplementedAdminServiceServer) ForceUnloadTaskQueuePartition(context.Context, *ForceUnloadTaskQueuePartitionRequest) (*ForceUnloadTaskQueuePartitionResponse, error)

Sep 25, 2024

retracted

Changes in this version

+ const AdminService_DescribeTaskQueuePartition_FullMethodName

+ const AdminService_GenerateLastHistoryReplicationTasks_FullMethodName

+ const AdminService_SyncWorkflowState_FullMethodName

type AdminServiceClient

+ DescribeTaskQueuePartition func(ctx context.Context, in *DescribeTaskQueuePartitionRequest, ...) (*DescribeTaskQueuePartitionResponse, error)

+ GenerateLastHistoryReplicationTasks func(ctx context.Context, in *GenerateLastHistoryReplicationTasksRequest, ...) (*GenerateLastHistoryReplicationTasksResponse, error)

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

type AdminServiceServer

+ DescribeTaskQueuePartition func(context.Context, *DescribeTaskQueuePartitionRequest) (*DescribeTaskQueuePartitionResponse, error)

+ GenerateLastHistoryReplicationTasks func(context.Context, *GenerateLastHistoryReplicationTasksRequest) (*GenerateLastHistoryReplicationTasksResponse, error)

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

+ type DescribeTaskQueuePartitionRequest struct

+ BuildIds *v114.TaskQueueVersionSelection

+ Namespace string

+ TaskQueuePartition *v113.TaskQueuePartition

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

+ func (*DescribeTaskQueuePartitionRequest) ProtoMessage()

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

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

+ func (val *DescribeTaskQueuePartitionRequest) Size() int

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

+ func (x *DescribeTaskQueuePartitionRequest) GetBuildIds() *v114.TaskQueueVersionSelection

+ func (x *DescribeTaskQueuePartitionRequest) GetNamespace() string

+ func (x *DescribeTaskQueuePartitionRequest) GetTaskQueuePartition() *v113.TaskQueuePartition

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

+ func (x *DescribeTaskQueuePartitionRequest) Reset()

+ func (x *DescribeTaskQueuePartitionRequest) String() string

+ type DescribeTaskQueuePartitionResponse struct

+ VersionsInfoInternal map[string]*v113.TaskQueueVersionInfoInternal

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

+ func (*DescribeTaskQueuePartitionResponse) ProtoMessage()

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

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

+ func (val *DescribeTaskQueuePartitionResponse) Size() int

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

+ func (x *DescribeTaskQueuePartitionResponse) GetVersionsInfoInternal() map[string]*v113.TaskQueueVersionInfoInternal

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

+ func (x *DescribeTaskQueuePartitionResponse) Reset()

+ func (x *DescribeTaskQueuePartitionResponse) String() string

+ type GenerateLastHistoryReplicationTasksRequest struct

+ Execution *v1.WorkflowExecution

+ Namespace string

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

+ func (*GenerateLastHistoryReplicationTasksRequest) ProtoMessage()

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

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

+ func (val *GenerateLastHistoryReplicationTasksRequest) Size() int

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

+ func (x *GenerateLastHistoryReplicationTasksRequest) GetExecution() *v1.WorkflowExecution

+ func (x *GenerateLastHistoryReplicationTasksRequest) GetNamespace() string

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

+ func (x *GenerateLastHistoryReplicationTasksRequest) Reset()

+ func (x *GenerateLastHistoryReplicationTasksRequest) String() string

+ type GenerateLastHistoryReplicationTasksResponse struct

+ HistoryLength int64

+ StateTransitionCount int64

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

+ func (*GenerateLastHistoryReplicationTasksResponse) ProtoMessage()

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

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

+ func (val *GenerateLastHistoryReplicationTasksResponse) Size() int

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

+ func (x *GenerateLastHistoryReplicationTasksResponse) GetHistoryLength() int64

+ func (x *GenerateLastHistoryReplicationTasksResponse) GetStateTransitionCount() int64

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

+ func (x *GenerateLastHistoryReplicationTasksResponse) Reset()

+ func (x *GenerateLastHistoryReplicationTasksResponse) String() string

+ type InternalTaskQueueStatus struct

+ AckLevel int64

+ ReadBufferLength int64

+ ReadLevel int64

+ TaskIdBlock *v114.TaskIdBlock

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

+ func (*InternalTaskQueueStatus) ProtoMessage()

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

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

+ func (val *InternalTaskQueueStatus) Size() int

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

+ func (x *InternalTaskQueueStatus) GetAckLevel() int64

+ func (x *InternalTaskQueueStatus) GetReadBufferLength() int64

+ func (x *InternalTaskQueueStatus) GetReadLevel() int64

+ func (x *InternalTaskQueueStatus) GetTaskIdBlock() *v114.TaskIdBlock

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

+ func (x *InternalTaskQueueStatus) Reset()

+ func (x *InternalTaskQueueStatus) String() string

+ type SyncWorkflowStateRequest struct

+ Execution *v1.WorkflowExecution

+ NamespaceId string

+ TargetClusterId int32

+ VersionHistories *v11.VersionHistories

+ VersionedTransition *v12.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() *v1.WorkflowExecution

+ func (x *SyncWorkflowStateRequest) GetNamespaceId() string

+ func (x *SyncWorkflowStateRequest) GetTargetClusterId() int32

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

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

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

+ func (x *SyncWorkflowStateRequest) Reset()

+ func (x *SyncWorkflowStateRequest) String() string

+ type SyncWorkflowStateResponse struct

+ Attributes isSyncWorkflowStateResponse_Attributes

+ EventBatches []*v1.DataBlob

+ NewRunInfo *v15.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() []*v1.DataBlob

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

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

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

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

+ func (x *SyncWorkflowStateResponse) Reset()

+ func (x *SyncWorkflowStateResponse) String() string

+ type SyncWorkflowStateResponse_Mutation struct

+ Mutation *v15.SyncWorkflowStateMutationAttributes

+ type SyncWorkflowStateResponse_Snapshot struct

+ Snapshot *v15.SyncWorkflowStateSnapshotAttributes

type UnimplementedAdminServiceServer

+ func (UnimplementedAdminServiceServer) DescribeTaskQueuePartition(context.Context, *DescribeTaskQueuePartitionRequest) (*DescribeTaskQueuePartitionResponse, error)

+ func (UnimplementedAdminServiceServer) GenerateLastHistoryReplicationTasks(context.Context, *GenerateLastHistoryReplicationTasksRequest) (*GenerateLastHistoryReplicationTasksResponse, error)

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

Sep 6, 2024

Changes in this version

+ const AdminService_DeepHealthCheck_FullMethodName

type AdminServiceClient

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

type AdminServiceServer

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

+ type DeepHealthCheckRequest struct

+ 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) ProtoReflect() protoreflect.Message

+ func (x *DeepHealthCheckRequest) Reset()

+ func (x *DeepHealthCheckRequest) String() string

+ type DeepHealthCheckResponse struct

+ State v14.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() v14.HealthState

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

+ func (x *DeepHealthCheckResponse) Reset()

+ func (x *DeepHealthCheckResponse) String() string

type DescribeClusterResponse

+ HttpAddress string

+ func (x *DescribeClusterResponse) GetHttpAddress() string

type UnimplementedAdminServiceServer

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

May 31, 2024

Changes in this version

+ const AdminService_GetWorkflowExecutionRawHistory_FullMethodName

type AddOrUpdateRemoteClusterRequest

+ FrontendHttpAddress string

+ func (x *AddOrUpdateRemoteClusterRequest) GetFrontendHttpAddress() string

type GetNamespaceResponse

+ OutgoingServices []*v12.NexusOutgoingService

+ func (x *GetNamespaceResponse) GetOutgoingServices() []*v12.NexusOutgoingService

type GetWorkflowExecutionRawHistoryRequest

+ EndEventId int64

+ EndEventVersion int64

+ NamespaceId string

+ StartEventId int64

+ StartEventVersion int64

+ func (x *GetWorkflowExecutionRawHistoryRequest) GetEndEventId() int64

+ func (x *GetWorkflowExecutionRawHistoryRequest) GetEndEventVersion() int64

+ func (x *GetWorkflowExecutionRawHistoryRequest) GetNamespaceId() string

+ func (x *GetWorkflowExecutionRawHistoryRequest) GetStartEventId() int64

+ func (x *GetWorkflowExecutionRawHistoryRequest) GetStartEventVersion() int64

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

type GetWorkflowExecutionRawHistoryResponse

+ HistoryNodeIds []int64

+ VersionHistory *v11.VersionHistory

+ func (x *GetWorkflowExecutionRawHistoryResponse) GetHistoryNodeIds() []int64

+ func (x *GetWorkflowExecutionRawHistoryResponse) GetVersionHistory() *v11.VersionHistory

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

Mar 22, 2024

Changes in this version

+ const AdminService_AddOrUpdateRemoteCluster_FullMethodName

+ const AdminService_AddSearchAttributes_FullMethodName

+ const AdminService_AddTasks_FullMethodName

+ const AdminService_CancelDLQJob_FullMethodName

+ const AdminService_CloseShard_FullMethodName

+ const AdminService_DeleteWorkflowExecution_FullMethodName

+ const AdminService_DescribeCluster_FullMethodName

+ const AdminService_DescribeDLQJob_FullMethodName

+ const AdminService_DescribeHistoryHost_FullMethodName

+ const AdminService_DescribeMutableState_FullMethodName

+ const AdminService_GetDLQMessages_FullMethodName

+ const AdminService_GetDLQReplicationMessages_FullMethodName

+ const AdminService_GetDLQTasks_FullMethodName

+ const AdminService_GetNamespaceReplicationMessages_FullMethodName

+ const AdminService_GetNamespace_FullMethodName

+ const AdminService_GetReplicationMessages_FullMethodName

+ const AdminService_GetSearchAttributes_FullMethodName

+ const AdminService_GetShard_FullMethodName

+ const AdminService_GetTaskQueueTasks_FullMethodName

+ const AdminService_GetWorkflowExecutionRawHistoryV2_FullMethodName

+ const AdminService_ImportWorkflowExecution_FullMethodName

+ const AdminService_ListClusterMembers_FullMethodName

+ const AdminService_ListClusters_FullMethodName

+ const AdminService_ListHistoryTasks_FullMethodName

+ const AdminService_ListQueues_FullMethodName

+ const AdminService_MergeDLQMessages_FullMethodName

+ const AdminService_MergeDLQTasks_FullMethodName

+ const AdminService_PurgeDLQMessages_FullMethodName

+ const AdminService_PurgeDLQTasks_FullMethodName

+ const AdminService_ReapplyEvents_FullMethodName

+ const AdminService_RebuildMutableState_FullMethodName

+ const AdminService_RefreshWorkflowTasks_FullMethodName

+ const AdminService_RemoveRemoteCluster_FullMethodName

+ const AdminService_RemoveSearchAttributes_FullMethodName

+ const AdminService_RemoveTask_FullMethodName

+ const AdminService_ResendReplicationTasks_FullMethodName

+ const AdminService_StreamWorkflowReplicationMessages_FullMethodName

+ var AdminService_ServiceDesc = grpc.ServiceDesc

+ var File_temporal_server_api_adminservice_v1_request_response_proto protoreflect.FileDescriptor

+ var File_temporal_server_api_adminservice_v1_service_proto protoreflect.FileDescriptor

type AddOrUpdateRemoteClusterRequest

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

type AddOrUpdateRemoteClusterResponse

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

type AddSearchAttributesRequest

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

type AddSearchAttributesResponse

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

+ 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 *v1.DataBlob

+ CategoryId int32

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

+ func (*AddTasksRequest_Task) ProtoMessage()

+ func (x *AddTasksRequest_Task) GetBlob() *v1.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 AdminServiceClient

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

+ CancelDLQJob func(ctx context.Context, in *CancelDLQJobRequest, opts ...grpc.CallOption) (*CancelDLQJobResponse, error)

+ DescribeDLQJob func(ctx context.Context, in *DescribeDLQJobRequest, opts ...grpc.CallOption) (*DescribeDLQJobResponse, error)

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

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

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

+ MergeDLQTasks func(ctx context.Context, in *MergeDLQTasksRequest, opts ...grpc.CallOption) (*MergeDLQTasksResponse, error)

+ PurgeDLQTasks func(ctx context.Context, in *PurgeDLQTasksRequest, opts ...grpc.CallOption) (*PurgeDLQTasksResponse, error)

type AdminServiceServer

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

+ CancelDLQJob func(context.Context, *CancelDLQJobRequest) (*CancelDLQJobResponse, error)

+ DescribeDLQJob func(context.Context, *DescribeDLQJobRequest) (*DescribeDLQJobResponse, error)

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

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

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

+ MergeDLQTasks func(context.Context, *MergeDLQTasksRequest) (*MergeDLQTasksResponse, error)

+ PurgeDLQTasks func(context.Context, *PurgeDLQTasksRequest) (*PurgeDLQTasksResponse, error)

+ type CancelDLQJobRequest struct

+ JobToken string

+ Reason string

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

+ func (*CancelDLQJobRequest) ProtoMessage()

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

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

+ func (val *CancelDLQJobRequest) Size() int

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

+ func (x *CancelDLQJobRequest) GetJobToken() string

+ func (x *CancelDLQJobRequest) GetReason() string

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

+ func (x *CancelDLQJobRequest) Reset()

+ func (x *CancelDLQJobRequest) String() string

+ type CancelDLQJobResponse struct

+ Canceled bool

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

+ func (*CancelDLQJobResponse) ProtoMessage()

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

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

+ func (val *CancelDLQJobResponse) Size() int

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

+ func (x *CancelDLQJobResponse) GetCanceled() bool

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

+ func (x *CancelDLQJobResponse) Reset()

+ func (x *CancelDLQJobResponse) String() string

type CloseShardRequest

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

type CloseShardResponse

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

+ type DLQJobToken struct

+ RunId string

+ WorkflowId string

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

+ func (*DLQJobToken) ProtoMessage()

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

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

+ func (val *DLQJobToken) Size() int

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

+ func (x *DLQJobToken) GetRunId() string

+ func (x *DLQJobToken) GetWorkflowId() string

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

+ func (x *DLQJobToken) Reset()

+ func (x *DLQJobToken) String() string

type DeleteWorkflowExecutionRequest

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

type DeleteWorkflowExecutionResponse

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

type DescribeClusterRequest

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

type DescribeClusterResponse

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

+ type DescribeDLQJobRequest struct

+ JobToken string

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

+ func (*DescribeDLQJobRequest) ProtoMessage()

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

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

+ func (val *DescribeDLQJobRequest) Size() int

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

+ func (x *DescribeDLQJobRequest) GetJobToken() string

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

+ func (x *DescribeDLQJobRequest) Reset()

+ func (x *DescribeDLQJobRequest) String() string

+ type DescribeDLQJobResponse struct

+ DlqKey *v112.HistoryDLQKey

+ EndTime *timestamppb.Timestamp

+ LastProcessedMessageId int64

+ MaxMessageId int64

+ MessagesProcessed int64

+ OperationState v14.DLQOperationState

+ OperationType v14.DLQOperationType

+ StartTime *timestamppb.Timestamp

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

+ func (*DescribeDLQJobResponse) ProtoMessage()

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

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

+ func (val *DescribeDLQJobResponse) Size() int

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

+ func (x *DescribeDLQJobResponse) GetDlqKey() *v112.HistoryDLQKey

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

+ func (x *DescribeDLQJobResponse) GetLastProcessedMessageId() int64

+ func (x *DescribeDLQJobResponse) GetMaxMessageId() int64

+ func (x *DescribeDLQJobResponse) GetMessagesProcessed() int64

+ func (x *DescribeDLQJobResponse) GetOperationState() v14.DLQOperationState

+ func (x *DescribeDLQJobResponse) GetOperationType() v14.DLQOperationType

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

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

+ func (x *DescribeDLQJobResponse) Reset()

+ func (x *DescribeDLQJobResponse) String() string

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 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 *v112.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() *v112.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 []*v112.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() []*v112.HistoryDLQTask

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

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

+ func (x *GetDLQTasksResponse) Reset()

+ func (x *GetDLQTasksResponse) String() string

type GetNamespaceReplicationMessagesRequest

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

type GetNamespaceReplicationMessagesResponse

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

type GetNamespaceRequest

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

type GetNamespaceResponse

+ IsGlobalNamespace bool

+ func (x *GetNamespaceResponse) GetIsGlobalNamespace() bool

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

type GetReplicationMessagesRequest

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

type GetReplicationMessagesResponse

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

type GetSearchAttributesRequest

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

type GetSearchAttributesResponse

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

type GetShardRequest

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

type GetShardResponse

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

type GetTaskQueueTasksRequest

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

type GetTaskQueueTasksResponse

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

type GetWorkflowExecutionRawHistoryV2Request

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

type GetWorkflowExecutionRawHistoryV2Response

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

+ type ImportWorkflowExecutionRequest struct

+ Execution *v1.WorkflowExecution

+ HistoryBatches []*v1.DataBlob

+ Namespace string

+ Token []byte

+ VersionHistory *v11.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() *v1.WorkflowExecution

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

+ func (x *ImportWorkflowExecutionRequest) GetNamespace() string

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

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

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

+ func (x *ImportWorkflowExecutionRequest) Reset()

+ func (x *ImportWorkflowExecutionRequest) String() string

+ type ImportWorkflowExecutionResponse struct

+ 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) GetToken() []byte

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

+ func (x *ImportWorkflowExecutionResponse) Reset()

+ func (x *ImportWorkflowExecutionResponse) String() string

type ListClusterMembersRequest

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

type ListClusterMembersResponse

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

type ListClustersRequest

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

type ListClustersResponse

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

type ListHistoryTasksRequest

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

type ListHistoryTasksResponse

+ func (x *ListHistoryTasksResponse) 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 MergeDLQTasksRequest struct

+ BatchSize int32

+ DlqKey *v112.HistoryDLQKey

+ InclusiveMaxTaskMetadata *v112.HistoryDLQTaskMetadata

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

+ func (*MergeDLQTasksRequest) ProtoMessage()

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

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

+ func (val *MergeDLQTasksRequest) Size() int

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

+ func (x *MergeDLQTasksRequest) GetBatchSize() int32

+ func (x *MergeDLQTasksRequest) GetDlqKey() *v112.HistoryDLQKey

+ func (x *MergeDLQTasksRequest) GetInclusiveMaxTaskMetadata() *v112.HistoryDLQTaskMetadata

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

+ func (x *MergeDLQTasksRequest) Reset()

+ func (x *MergeDLQTasksRequest) String() string

+ type MergeDLQTasksResponse struct

+ JobToken []byte

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

+ func (*MergeDLQTasksResponse) ProtoMessage()

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

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

+ func (val *MergeDLQTasksResponse) Size() int

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

+ func (x *MergeDLQTasksResponse) GetJobToken() []byte

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

+ func (x *MergeDLQTasksResponse) Reset()

+ func (x *MergeDLQTasksResponse) String() string

type PurgeDLQMessagesRequest

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

type PurgeDLQMessagesResponse

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

+ type PurgeDLQTasksRequest struct

+ DlqKey *v112.HistoryDLQKey

+ InclusiveMaxTaskMetadata *v112.HistoryDLQTaskMetadata

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

+ func (*PurgeDLQTasksRequest) ProtoMessage()

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

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

+ func (val *PurgeDLQTasksRequest) Size() int

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

+ func (x *PurgeDLQTasksRequest) GetDlqKey() *v112.HistoryDLQKey

+ func (x *PurgeDLQTasksRequest) GetInclusiveMaxTaskMetadata() *v112.HistoryDLQTaskMetadata

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

+ func (x *PurgeDLQTasksRequest) Reset()

+ func (x *PurgeDLQTasksRequest) String() string

+ type PurgeDLQTasksResponse struct

+ JobToken []byte

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

+ func (*PurgeDLQTasksResponse) ProtoMessage()

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

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

+ func (val *PurgeDLQTasksResponse) Size() int

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

+ func (x *PurgeDLQTasksResponse) GetJobToken() []byte

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

+ func (x *PurgeDLQTasksResponse) Reset()

+ func (x *PurgeDLQTasksResponse) String() string

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 RefreshWorkflowTasksRequest

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

type RefreshWorkflowTasksResponse

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

type RemoveRemoteClusterRequest

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

type RemoveRemoteClusterResponse

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

type RemoveSearchAttributesRequest

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

type RemoveSearchAttributesResponse

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

type RemoveTaskRequest

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

type RemoveTaskResponse

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

type ResendReplicationTasksRequest

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

type ResendReplicationTasksResponse

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

type StreamWorkflowReplicationMessagesRequest

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

type StreamWorkflowReplicationMessagesResponse

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

type Task

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

type UnimplementedAdminServiceServer

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

+ func (UnimplementedAdminServiceServer) CancelDLQJob(context.Context, *CancelDLQJobRequest) (*CancelDLQJobResponse, error)

+ func (UnimplementedAdminServiceServer) DescribeDLQJob(context.Context, *DescribeDLQJobRequest) (*DescribeDLQJobResponse, error)

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

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

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

+ func (UnimplementedAdminServiceServer) MergeDLQTasks(context.Context, *MergeDLQTasksRequest) (*MergeDLQTasksResponse, error)

+ func (UnimplementedAdminServiceServer) PurgeDLQTasks(context.Context, *PurgeDLQTasksRequest) (*PurgeDLQTasksResponse, error)

+ type UnsafeAdminServiceServer interface

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

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

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 AdminServiceClient

+ GetNamespace func(ctx context.Context, in *GetNamespaceRequest, opts ...grpc.CallOption) (*GetNamespaceResponse, error)

type AdminServiceServer

+ GetNamespace func(context.Context, *GetNamespaceRequest) (*GetNamespaceResponse, error)

type DescribeClusterResponse

+ Tags map[string]string

+ func (m *DescribeClusterResponse) GetTags() map[string]string

+ type GetNamespaceRequest struct

+ Attributes isGetNamespaceRequest_Attributes

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

+ func (*GetNamespaceRequest) ProtoMessage()

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

+ func (m *GetNamespaceRequest) GetAttributes() isGetNamespaceRequest_Attributes

+ func (m *GetNamespaceRequest) GetId() string

+ func (m *GetNamespaceRequest) GetNamespace() string

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

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

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

+ func (m *GetNamespaceRequest) Reset()

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

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

+ func (m *GetNamespaceRequest) XXX_DiscardUnknown()

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

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

+ func (m *GetNamespaceRequest) XXX_Size() int

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

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

+ func (this *GetNamespaceRequest) GoString() string

+ func (this *GetNamespaceRequest) String() string

+ type GetNamespaceRequest_Id struct

+ Id string

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

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

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

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

+ func (this *GetNamespaceRequest_Id) GoString() string

+ func (this *GetNamespaceRequest_Id) String() string

+ type GetNamespaceRequest_Namespace struct

+ Namespace string

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

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

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

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

+ func (this *GetNamespaceRequest_Namespace) GoString() string

+ func (this *GetNamespaceRequest_Namespace) String() string

+ type GetNamespaceResponse struct

+ Config *v110.NamespaceConfig

+ ConfigVersion int64

+ FailoverHistory []*v111.FailoverStatus

+ FailoverVersion int64

+ Info *v110.NamespaceInfo

+ ReplicationConfig *v111.NamespaceReplicationConfig

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

+ func (*GetNamespaceResponse) ProtoMessage()

+ func (m *GetNamespaceResponse) GetConfig() *v110.NamespaceConfig

+ func (m *GetNamespaceResponse) GetConfigVersion() int64

+ func (m *GetNamespaceResponse) GetFailoverHistory() []*v111.FailoverStatus

+ func (m *GetNamespaceResponse) GetFailoverVersion() int64

+ func (m *GetNamespaceResponse) GetInfo() *v110.NamespaceInfo

+ func (m *GetNamespaceResponse) GetReplicationConfig() *v111.NamespaceReplicationConfig

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

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

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

+ func (m *GetNamespaceResponse) Reset()

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

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

+ func (m *GetNamespaceResponse) XXX_DiscardUnknown()

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

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

+ func (m *GetNamespaceResponse) XXX_Size() int

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

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

+ func (this *GetNamespaceResponse) GoString() string

+ func (this *GetNamespaceResponse) String() string

type UnimplementedAdminServiceServer

+ func (*UnimplementedAdminServiceServer) GetNamespace(ctx context.Context, req *GetNamespaceRequest) (*GetNamespaceResponse, 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 AdminServiceClient

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

type AdminServiceServer

+ StreamWorkflowReplicationMessages func(AdminService_StreamWorkflowReplicationMessagesServer) error

+ type AdminService_StreamWorkflowReplicationMessagesClient interface

+ Recv func() (*StreamWorkflowReplicationMessagesResponse, error)

+ Send func(*StreamWorkflowReplicationMessagesRequest) error

+ type AdminService_StreamWorkflowReplicationMessagesServer interface

+ Recv func() (*StreamWorkflowReplicationMessagesRequest, error)

+ Send func(*StreamWorkflowReplicationMessagesResponse) error

type GetDLQMessagesResponse

+ ReplicationTasksInfo []*v15.ReplicationTaskInfo

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

+ 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() *v15.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 *v15.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() *v15.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 *v15.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 UnimplementedAdminServiceServer

+ func (*UnimplementedAdminServiceServer) StreamWorkflowReplicationMessages(srv AdminService_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

Feb 17, 2023 GO-2024-2689

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

Changes in this version

type AddSearchAttributesRequest

+ Namespace string

+ func (m *AddSearchAttributesRequest) GetNamespace() string

type GetSearchAttributesRequest

+ Namespace string

+ func (m *GetSearchAttributesRequest) GetNamespace() string

type RemoveSearchAttributesRequest

+ Namespace string

+ func (m *RemoveSearchAttributesRequest) GetNamespace() 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

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

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 AdminServiceClient

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

type AdminServiceServer

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

+ type DeleteWorkflowExecutionRequest struct

+ Execution *v1.WorkflowExecution

+ Namespace string

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

+ func (*DeleteWorkflowExecutionRequest) ProtoMessage()

+ func (m *DeleteWorkflowExecutionRequest) GetExecution() *v1.WorkflowExecution

+ func (m *DeleteWorkflowExecutionRequest) GetNamespace() string

+ 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

+ Warnings []string

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

+ func (*DeleteWorkflowExecutionResponse) ProtoMessage()

+ func (m *DeleteWorkflowExecutionResponse) GetWarnings() []string

+ 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 GetWorkflowExecutionRawHistoryV2Request

+ NamespaceId string

+ func (m *GetWorkflowExecutionRawHistoryV2Request) GetNamespaceId() string

type GetWorkflowExecutionRawHistoryV2Response

+ HistoryNodeIds []int64

+ func (m *GetWorkflowExecutionRawHistoryV2Response) GetHistoryNodeIds() []int64

type ReapplyEventsRequest

+ NamespaceId string

+ func (m *ReapplyEventsRequest) GetNamespaceId() string

type RefreshWorkflowTasksRequest

+ NamespaceId string

+ func (m *RefreshWorkflowTasksRequest) GetNamespaceId() string

type UnimplementedAdminServiceServer

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

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 AdminServiceClient

+ ListHistoryTasks func(ctx context.Context, in *ListHistoryTasksRequest, opts ...grpc.CallOption) (*ListHistoryTasksResponse, error)

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

type AdminServiceServer

+ ListHistoryTasks func(context.Context, *ListHistoryTasksRequest) (*ListHistoryTasksResponse, error)

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

type GetTaskQueueTasksRequest

+ NextPageToken []byte

+ func (m *GetTaskQueueTasksRequest) GetNextPageToken() []byte

type GetTaskQueueTasksResponse

+ NextPageToken []byte

+ func (m *GetTaskQueueTasksResponse) GetNextPageToken() []byte

+ type ListHistoryTasksRequest struct

+ BatchSize int32

+ Category v13.TaskCategory

+ NextPageToken []byte

+ ShardId int32

+ TaskRange *v14.TaskRange

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

+ func (*ListHistoryTasksRequest) ProtoMessage()

+ func (m *ListHistoryTasksRequest) GetBatchSize() int32

+ func (m *ListHistoryTasksRequest) GetCategory() v13.TaskCategory

+ func (m *ListHistoryTasksRequest) GetNextPageToken() []byte

+ func (m *ListHistoryTasksRequest) GetShardId() int32

+ func (m *ListHistoryTasksRequest) GetTaskRange() *v14.TaskRange

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

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

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

+ func (m *ListHistoryTasksRequest) Reset()

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

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

+ func (m *ListHistoryTasksRequest) XXX_DiscardUnknown()

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

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

+ func (m *ListHistoryTasksRequest) XXX_Size() int

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

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

+ func (this *ListHistoryTasksRequest) GoString() string

+ func (this *ListHistoryTasksRequest) String() string

+ type ListHistoryTasksResponse struct

+ NextPageToken []byte

+ Tasks []*Task

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

+ func (*ListHistoryTasksResponse) ProtoMessage()

+ func (m *ListHistoryTasksResponse) GetNextPageToken() []byte

+ func (m *ListHistoryTasksResponse) GetTasks() []*Task

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

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

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

+ func (m *ListHistoryTasksResponse) Reset()

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

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

+ func (m *ListHistoryTasksResponse) XXX_DiscardUnknown()

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

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

+ func (m *ListHistoryTasksResponse) XXX_Size() int

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

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

+ func (this *ListHistoryTasksResponse) GoString() string

+ func (this *ListHistoryTasksResponse) String() string

+ type RebuildMutableStateRequest struct

+ Execution *v1.WorkflowExecution

+ Namespace string

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

+ func (*RebuildMutableStateRequest) ProtoMessage()

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

+ func (m *RebuildMutableStateRequest) GetNamespace() 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 UnimplementedAdminServiceServer

+ func (*UnimplementedAdminServiceServer) ListHistoryTasks(ctx context.Context, req *ListHistoryTasksRequest) (*ListHistoryTasksResponse, error)

+ func (*UnimplementedAdminServiceServer) 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 AdminServiceClient

+ ListClusters func(ctx context.Context, in *ListClustersRequest, opts ...grpc.CallOption) (*ListClustersResponse, error)

type AdminServiceServer

+ ListClusters func(context.Context, *ListClustersRequest) (*ListClustersResponse, error)

+ type ListClustersRequest struct

+ NextPageToken []byte

+ PageSize int32

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

+ func (*ListClustersRequest) ProtoMessage()

+ func (m *ListClustersRequest) GetNextPageToken() []byte

+ func (m *ListClustersRequest) GetPageSize() int32

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

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

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

+ func (m *ListClustersRequest) Reset()

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

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

+ func (m *ListClustersRequest) XXX_DiscardUnknown()

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

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

+ func (m *ListClustersRequest) XXX_Size() int

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

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

+ func (this *ListClustersRequest) GoString() string

+ func (this *ListClustersRequest) String() string

+ type ListClustersResponse struct

+ Clusters []*v11.ClusterMetadata

+ NextPageToken []byte

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

+ func (*ListClustersResponse) ProtoMessage()

+ func (m *ListClustersResponse) GetClusters() []*v11.ClusterMetadata

+ func (m *ListClustersResponse) GetNextPageToken() []byte

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

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

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

+ func (m *ListClustersResponse) Reset()

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

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

+ func (m *ListClustersResponse) XXX_DiscardUnknown()

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

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

+ func (m *ListClustersResponse) XXX_Size() int

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

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

+ func (this *ListClustersResponse) GoString() string

+ func (this *ListClustersResponse) String() string

type UnimplementedAdminServiceServer

+ func (*UnimplementedAdminServiceServer) ListClusters(ctx context.Context, req *ListClustersRequest) (*ListClustersResponse, 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 AddOrUpdateRemoteClusterRequest struct

+ EnableRemoteClusterConnection bool

+ FrontendAddress string

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

+ func (*AddOrUpdateRemoteClusterRequest) ProtoMessage()

+ func (m *AddOrUpdateRemoteClusterRequest) GetEnableRemoteClusterConnection() bool

+ func (m *AddOrUpdateRemoteClusterRequest) GetFrontendAddress() string

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

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

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

+ func (m *AddOrUpdateRemoteClusterRequest) Reset()

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

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

+ func (m *AddOrUpdateRemoteClusterRequest) XXX_DiscardUnknown()

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

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

+ func (m *AddOrUpdateRemoteClusterRequest) XXX_Size() int

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

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

+ func (this *AddOrUpdateRemoteClusterRequest) GoString() string

+ func (this *AddOrUpdateRemoteClusterRequest) String() string

+ type AddOrUpdateRemoteClusterResponse struct

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

+ func (*AddOrUpdateRemoteClusterResponse) ProtoMessage()

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

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

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

+ func (m *AddOrUpdateRemoteClusterResponse) Reset()

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

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

+ func (m *AddOrUpdateRemoteClusterResponse) XXX_DiscardUnknown()

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

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

+ func (m *AddOrUpdateRemoteClusterResponse) XXX_Size() int

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

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

+ func (this *AddOrUpdateRemoteClusterResponse) GoString() string

+ func (this *AddOrUpdateRemoteClusterResponse) String() string

type AdminServiceClient

+ AddOrUpdateRemoteCluster func(ctx context.Context, in *AddOrUpdateRemoteClusterRequest, ...) (*AddOrUpdateRemoteClusterResponse, error)

+ GetShard func(ctx context.Context, in *GetShardRequest, opts ...grpc.CallOption) (*GetShardResponse, error)

+ GetTaskQueueTasks func(ctx context.Context, in *GetTaskQueueTasksRequest, opts ...grpc.CallOption) (*GetTaskQueueTasksResponse, error)

+ ListClusterMembers func(ctx context.Context, in *ListClusterMembersRequest, opts ...grpc.CallOption) (*ListClusterMembersResponse, error)

+ ListReplicationTasks func(ctx context.Context, in *ListReplicationTasksRequest, opts ...grpc.CallOption) (*ListReplicationTasksResponse, error)

+ ListTimerTasks func(ctx context.Context, in *ListTimerTasksRequest, opts ...grpc.CallOption) (*ListTimerTasksResponse, error)

+ ListTransferTasks func(ctx context.Context, in *ListTransferTasksRequest, opts ...grpc.CallOption) (*ListTransferTasksResponse, error)

+ ListVisibilityTasks func(ctx context.Context, in *ListVisibilityTasksRequest, opts ...grpc.CallOption) (*ListVisibilityTasksResponse, error)

+ RemoveRemoteCluster func(ctx context.Context, in *RemoveRemoteClusterRequest, opts ...grpc.CallOption) (*RemoveRemoteClusterResponse, error)

type AdminServiceServer

+ AddOrUpdateRemoteCluster func(context.Context, *AddOrUpdateRemoteClusterRequest) (*AddOrUpdateRemoteClusterResponse, error)

+ GetShard func(context.Context, *GetShardRequest) (*GetShardResponse, error)

+ GetTaskQueueTasks func(context.Context, *GetTaskQueueTasksRequest) (*GetTaskQueueTasksResponse, error)

+ ListClusterMembers func(context.Context, *ListClusterMembersRequest) (*ListClusterMembersResponse, error)

+ ListReplicationTasks func(context.Context, *ListReplicationTasksRequest) (*ListReplicationTasksResponse, error)

+ ListTimerTasks func(context.Context, *ListTimerTasksRequest) (*ListTimerTasksResponse, error)

+ ListTransferTasks func(context.Context, *ListTransferTasksRequest) (*ListTransferTasksResponse, error)

+ ListVisibilityTasks func(context.Context, *ListVisibilityTasksRequest) (*ListVisibilityTasksResponse, error)

+ RemoveRemoteCluster func(context.Context, *RemoveRemoteClusterRequest) (*RemoveRemoteClusterResponse, error)

type DescribeClusterRequest

+ ClusterName string

+ func (m *DescribeClusterRequest) GetClusterName() string

type DescribeClusterResponse

+ ClusterId string

+ ClusterName string

+ FailoverVersionIncrement int64

+ HistoryShardCount int32

+ InitialFailoverVersion int64

+ IsGlobalNamespaceEnabled bool

+ PersistenceStore string

+ VersionInfo *v19.VersionInfo

+ VisibilityStore string

+ func (m *DescribeClusterResponse) GetClusterId() string

+ func (m *DescribeClusterResponse) GetClusterName() string

+ func (m *DescribeClusterResponse) GetFailoverVersionIncrement() int64

+ func (m *DescribeClusterResponse) GetHistoryShardCount() int32

+ func (m *DescribeClusterResponse) GetInitialFailoverVersion() int64

+ func (m *DescribeClusterResponse) GetIsGlobalNamespaceEnabled() bool

+ func (m *DescribeClusterResponse) GetPersistenceStore() string

+ func (m *DescribeClusterResponse) GetVersionInfo() *v19.VersionInfo

+ func (m *DescribeClusterResponse) GetVisibilityStore() 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 *v11.ShardInfo

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

+ func (*GetShardResponse) ProtoMessage()

+ func (m *GetShardResponse) GetShardInfo() *v11.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 GetTaskQueueTasksRequest struct

+ BatchSize int32

+ MaxTaskId int64

+ MinTaskId int64

+ Namespace string

+ TaskQueue string

+ TaskQueueType v16.TaskQueueType

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

+ func (*GetTaskQueueTasksRequest) ProtoMessage()

+ func (m *GetTaskQueueTasksRequest) GetBatchSize() int32

+ func (m *GetTaskQueueTasksRequest) GetMaxTaskId() int64

+ func (m *GetTaskQueueTasksRequest) GetMinTaskId() int64

+ func (m *GetTaskQueueTasksRequest) GetNamespace() string

+ func (m *GetTaskQueueTasksRequest) GetTaskQueue() string

+ func (m *GetTaskQueueTasksRequest) GetTaskQueueType() v16.TaskQueueType

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

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

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

+ func (m *GetTaskQueueTasksRequest) Reset()

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

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

+ func (m *GetTaskQueueTasksRequest) XXX_DiscardUnknown()

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

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

+ func (m *GetTaskQueueTasksRequest) XXX_Size() int

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

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

+ func (this *GetTaskQueueTasksRequest) GoString() string

+ func (this *GetTaskQueueTasksRequest) String() string

+ type GetTaskQueueTasksResponse struct

+ Tasks []*v11.AllocatedTaskInfo

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

+ func (*GetTaskQueueTasksResponse) ProtoMessage()

+ func (m *GetTaskQueueTasksResponse) GetTasks() []*v11.AllocatedTaskInfo

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

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

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

+ func (m *GetTaskQueueTasksResponse) Reset()

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

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

+ func (m *GetTaskQueueTasksResponse) XXX_DiscardUnknown()

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

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

+ func (m *GetTaskQueueTasksResponse) XXX_Size() int

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

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

+ func (this *GetTaskQueueTasksResponse) GoString() string

+ func (this *GetTaskQueueTasksResponse) String() string

+ type ListClusterMembersRequest struct

+ HostId string

+ LastHeartbeatWithin *time.Duration

+ NextPageToken []byte

+ PageSize int32

+ Role v13.ClusterMemberRole

+ RpcAddress string

+ SessionStartedAfterTime *time.Time

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

+ func (*ListClusterMembersRequest) ProtoMessage()

+ func (m *ListClusterMembersRequest) GetHostId() string

+ func (m *ListClusterMembersRequest) GetLastHeartbeatWithin() *time.Duration

+ func (m *ListClusterMembersRequest) GetNextPageToken() []byte

+ func (m *ListClusterMembersRequest) GetPageSize() int32

+ func (m *ListClusterMembersRequest) GetRole() v13.ClusterMemberRole

+ func (m *ListClusterMembersRequest) GetRpcAddress() string

+ func (m *ListClusterMembersRequest) GetSessionStartedAfterTime() *time.Time

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

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

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

+ func (m *ListClusterMembersRequest) Reset()

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

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

+ func (m *ListClusterMembersRequest) XXX_DiscardUnknown()

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

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

+ func (m *ListClusterMembersRequest) XXX_Size() int

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

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

+ func (this *ListClusterMembersRequest) GoString() string

+ func (this *ListClusterMembersRequest) String() string

+ type ListClusterMembersResponse struct

+ ActiveMembers []*v18.ClusterMember

+ NextPageToken []byte

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

+ func (*ListClusterMembersResponse) ProtoMessage()

+ func (m *ListClusterMembersResponse) GetActiveMembers() []*v18.ClusterMember

+ func (m *ListClusterMembersResponse) GetNextPageToken() []byte

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

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

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

+ func (m *ListClusterMembersResponse) Reset()

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

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

+ func (m *ListClusterMembersResponse) XXX_DiscardUnknown()

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

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

+ func (m *ListClusterMembersResponse) XXX_Size() int

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

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

+ func (this *ListClusterMembersResponse) GoString() string

+ func (this *ListClusterMembersResponse) String() string

+ type ListReplicationTasksRequest struct

+ BatchSize int32

+ MaxTaskId int64

+ MinTaskId int64

+ NextPageToken []byte

+ ShardId int32

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

+ func (*ListReplicationTasksRequest) ProtoMessage()

+ func (m *ListReplicationTasksRequest) GetBatchSize() int32

+ func (m *ListReplicationTasksRequest) GetMaxTaskId() int64

+ func (m *ListReplicationTasksRequest) GetMinTaskId() int64

+ func (m *ListReplicationTasksRequest) GetNextPageToken() []byte

+ func (m *ListReplicationTasksRequest) GetShardId() int32

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

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

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

+ func (m *ListReplicationTasksRequest) Reset()

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

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

+ func (m *ListReplicationTasksRequest) XXX_DiscardUnknown()

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

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

+ func (m *ListReplicationTasksRequest) XXX_Size() int

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

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

+ func (this *ListReplicationTasksRequest) GoString() string

+ func (this *ListReplicationTasksRequest) String() string

+ type ListReplicationTasksResponse struct

+ NextPageToken []byte

+ Tasks []*Task

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

+ func (*ListReplicationTasksResponse) ProtoMessage()

+ func (m *ListReplicationTasksResponse) GetNextPageToken() []byte

+ func (m *ListReplicationTasksResponse) GetTasks() []*Task

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

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

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

+ func (m *ListReplicationTasksResponse) Reset()

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

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

+ func (m *ListReplicationTasksResponse) XXX_DiscardUnknown()

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

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

+ func (m *ListReplicationTasksResponse) XXX_Size() int

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

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

+ func (this *ListReplicationTasksResponse) GoString() string

+ func (this *ListReplicationTasksResponse) String() string

+ type ListTimerTasksRequest struct

+ BatchSize int32

+ MaxTime *time.Time

+ MinTime *time.Time

+ NextPageToken []byte

+ ShardId int32

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

+ func (*ListTimerTasksRequest) ProtoMessage()

+ func (m *ListTimerTasksRequest) GetBatchSize() int32

+ func (m *ListTimerTasksRequest) GetMaxTime() *time.Time

+ func (m *ListTimerTasksRequest) GetMinTime() *time.Time

+ func (m *ListTimerTasksRequest) GetNextPageToken() []byte

+ func (m *ListTimerTasksRequest) GetShardId() int32

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

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

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

+ func (m *ListTimerTasksRequest) Reset()

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

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

+ func (m *ListTimerTasksRequest) XXX_DiscardUnknown()

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

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

+ func (m *ListTimerTasksRequest) XXX_Size() int

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

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

+ func (this *ListTimerTasksRequest) GoString() string

+ func (this *ListTimerTasksRequest) String() string

+ type ListTimerTasksResponse struct

+ NextPageToken []byte

+ Tasks []*Task

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

+ func (*ListTimerTasksResponse) ProtoMessage()

+ func (m *ListTimerTasksResponse) GetNextPageToken() []byte

+ func (m *ListTimerTasksResponse) GetTasks() []*Task

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

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

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

+ func (m *ListTimerTasksResponse) Reset()

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

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

+ func (m *ListTimerTasksResponse) XXX_DiscardUnknown()

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

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

+ func (m *ListTimerTasksResponse) XXX_Size() int

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

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

+ func (this *ListTimerTasksResponse) GoString() string

+ func (this *ListTimerTasksResponse) String() string

+ type ListTransferTasksRequest struct

+ BatchSize int32

+ MaxTaskId int64

+ MinTaskId int64

+ NextPageToken []byte

+ ShardId int32

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

+ func (*ListTransferTasksRequest) ProtoMessage()

+ func (m *ListTransferTasksRequest) GetBatchSize() int32

+ func (m *ListTransferTasksRequest) GetMaxTaskId() int64

+ func (m *ListTransferTasksRequest) GetMinTaskId() int64

+ func (m *ListTransferTasksRequest) GetNextPageToken() []byte

+ func (m *ListTransferTasksRequest) GetShardId() int32

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

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

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

+ func (m *ListTransferTasksRequest) Reset()

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

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

+ func (m *ListTransferTasksRequest) XXX_DiscardUnknown()

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

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

+ func (m *ListTransferTasksRequest) XXX_Size() int

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

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

+ func (this *ListTransferTasksRequest) GoString() string

+ func (this *ListTransferTasksRequest) String() string

+ type ListTransferTasksResponse struct

+ NextPageToken []byte

+ Tasks []*Task

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

+ func (*ListTransferTasksResponse) ProtoMessage()

+ func (m *ListTransferTasksResponse) GetNextPageToken() []byte

+ func (m *ListTransferTasksResponse) GetTasks() []*Task

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

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

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

+ func (m *ListTransferTasksResponse) Reset()

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

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

+ func (m *ListTransferTasksResponse) XXX_DiscardUnknown()

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

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

+ func (m *ListTransferTasksResponse) XXX_Size() int

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

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

+ func (this *ListTransferTasksResponse) GoString() string

+ func (this *ListTransferTasksResponse) String() string

+ type ListVisibilityTasksRequest struct

+ BatchSize int32

+ MaxReadLevel int64

+ NextPageToken []byte

+ ReadLevel int64

+ ShardId int32

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

+ func (*ListVisibilityTasksRequest) ProtoMessage()

+ func (m *ListVisibilityTasksRequest) GetBatchSize() int32

+ func (m *ListVisibilityTasksRequest) GetMaxReadLevel() int64

+ func (m *ListVisibilityTasksRequest) GetNextPageToken() []byte

+ func (m *ListVisibilityTasksRequest) GetReadLevel() int64

+ func (m *ListVisibilityTasksRequest) GetShardId() int32

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

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

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

+ func (m *ListVisibilityTasksRequest) Reset()

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

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

+ func (m *ListVisibilityTasksRequest) XXX_DiscardUnknown()

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

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

+ func (m *ListVisibilityTasksRequest) XXX_Size() int

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

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

+ func (this *ListVisibilityTasksRequest) GoString() string

+ func (this *ListVisibilityTasksRequest) String() string

+ type ListVisibilityTasksResponse struct

+ NextPageToken []byte

+ Tasks []*Task

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

+ func (*ListVisibilityTasksResponse) ProtoMessage()

+ func (m *ListVisibilityTasksResponse) GetNextPageToken() []byte

+ func (m *ListVisibilityTasksResponse) GetTasks() []*Task

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

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

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

+ func (m *ListVisibilityTasksResponse) Reset()

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

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

+ func (m *ListVisibilityTasksResponse) XXX_DiscardUnknown()

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

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

+ func (m *ListVisibilityTasksResponse) XXX_Size() int

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

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

+ func (this *ListVisibilityTasksResponse) GoString() string

+ func (this *ListVisibilityTasksResponse) String() string

+ type RemoveRemoteClusterRequest struct

+ ClusterName string

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

+ func (*RemoveRemoteClusterRequest) ProtoMessage()

+ func (m *RemoveRemoteClusterRequest) GetClusterName() string

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

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

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

+ func (m *RemoveRemoteClusterRequest) Reset()

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

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

+ func (m *RemoveRemoteClusterRequest) XXX_DiscardUnknown()

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

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

+ func (m *RemoveRemoteClusterRequest) XXX_Size() int

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

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

+ func (this *RemoveRemoteClusterRequest) GoString() string

+ func (this *RemoveRemoteClusterRequest) String() string

+ type RemoveRemoteClusterResponse struct

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

+ func (*RemoveRemoteClusterResponse) ProtoMessage()

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

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

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

+ func (m *RemoveRemoteClusterResponse) Reset()

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

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

+ func (m *RemoveRemoteClusterResponse) XXX_DiscardUnknown()

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

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

+ func (m *RemoveRemoteClusterResponse) XXX_Size() int

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

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

+ func (this *RemoveRemoteClusterResponse) GoString() string

+ func (this *RemoveRemoteClusterResponse) String() string

+ type Task struct

+ FireTime *time.Time

+ NamespaceId string

+ RunId string

+ TaskId int64

+ TaskType v13.TaskType

+ Version int64

+ WorkflowId string

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

+ func (*Task) ProtoMessage()

+ func (m *Task) GetFireTime() *time.Time

+ func (m *Task) GetNamespaceId() string

+ func (m *Task) GetRunId() string

+ func (m *Task) GetTaskId() int64

+ func (m *Task) GetTaskType() v13.TaskType

+ func (m *Task) GetVersion() int64

+ func (m *Task) GetWorkflowId() string

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

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

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

+ func (m *Task) Reset()

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

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

+ func (m *Task) XXX_DiscardUnknown()

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

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

+ func (m *Task) XXX_Size() int

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

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

+ func (this *Task) GoString() string

+ func (this *Task) String() string

type UnimplementedAdminServiceServer

+ func (*UnimplementedAdminServiceServer) AddOrUpdateRemoteCluster(ctx context.Context, req *AddOrUpdateRemoteClusterRequest) (*AddOrUpdateRemoteClusterResponse, error)

+ func (*UnimplementedAdminServiceServer) GetShard(ctx context.Context, req *GetShardRequest) (*GetShardResponse, error)

+ func (*UnimplementedAdminServiceServer) GetTaskQueueTasks(ctx context.Context, req *GetTaskQueueTasksRequest) (*GetTaskQueueTasksResponse, error)

+ func (*UnimplementedAdminServiceServer) ListClusterMembers(ctx context.Context, req *ListClusterMembersRequest) (*ListClusterMembersResponse, error)

+ func (*UnimplementedAdminServiceServer) ListReplicationTasks(ctx context.Context, req *ListReplicationTasksRequest) (*ListReplicationTasksResponse, error)

+ func (*UnimplementedAdminServiceServer) ListTimerTasks(ctx context.Context, req *ListTimerTasksRequest) (*ListTimerTasksResponse, error)

+ func (*UnimplementedAdminServiceServer) ListTransferTasks(ctx context.Context, req *ListTransferTasksRequest) (*ListTransferTasksResponse, error)

+ func (*UnimplementedAdminServiceServer) ListVisibilityTasks(ctx context.Context, req *ListVisibilityTasksRequest) (*ListVisibilityTasksResponse, error)

+ func (*UnimplementedAdminServiceServer) RemoveRemoteCluster(ctx context.Context, req *RemoveRemoteClusterRequest) (*RemoveRemoteClusterResponse, 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

Changes in this version

type AddSearchAttributesRequest

+ SkipSchemaUpdate bool

+ func (m *AddSearchAttributesRequest) GetSkipSchemaUpdate() bool

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

Changes in this version

type AdminServiceClient

+ RemoveSearchAttributes func(ctx context.Context, in *RemoveSearchAttributesRequest, ...) (*RemoveSearchAttributesResponse, error)

type AdminServiceServer

+ RemoveSearchAttributes func(context.Context, *RemoveSearchAttributesRequest) (*RemoveSearchAttributesResponse, error)

+ type RemoveSearchAttributesRequest struct

+ IndexName string

+ SearchAttributes []string

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

+ func (*RemoveSearchAttributesRequest) ProtoMessage()

+ func (m *RemoveSearchAttributesRequest) GetIndexName() string

+ func (m *RemoveSearchAttributesRequest) GetSearchAttributes() []string

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

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

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

+ func (m *RemoveSearchAttributesRequest) Reset()

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

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

+ func (m *RemoveSearchAttributesRequest) XXX_DiscardUnknown()

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

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

+ func (m *RemoveSearchAttributesRequest) XXX_Size() int

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

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

+ func (this *RemoveSearchAttributesRequest) GoString() string

+ func (this *RemoveSearchAttributesRequest) String() string

+ type RemoveSearchAttributesResponse struct

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

+ func (*RemoveSearchAttributesResponse) ProtoMessage()

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

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

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

+ func (m *RemoveSearchAttributesResponse) Reset()

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

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

+ func (m *RemoveSearchAttributesResponse) XXX_DiscardUnknown()

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

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

+ func (m *RemoveSearchAttributesResponse) XXX_Size() int

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

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

+ func (this *RemoveSearchAttributesResponse) GoString() string

+ func (this *RemoveSearchAttributesResponse) String() string

type UnimplementedAdminServiceServer

+ func (*UnimplementedAdminServiceServer) RemoveSearchAttributes(ctx context.Context, req *RemoveSearchAttributesRequest) (*RemoveSearchAttributesResponse, error)

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

Changes in this version

+ type AddSearchAttributesRequest struct

+ IndexName string

+ SearchAttributes map[string]v16.IndexedValueType

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

+ func (*AddSearchAttributesRequest) ProtoMessage()

+ func (m *AddSearchAttributesRequest) GetIndexName() string

+ func (m *AddSearchAttributesRequest) GetSearchAttributes() map[string]v16.IndexedValueType

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

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

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

+ func (m *AddSearchAttributesRequest) Reset()

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

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

+ func (m *AddSearchAttributesRequest) XXX_DiscardUnknown()

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

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

+ func (m *AddSearchAttributesRequest) XXX_Size() int

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

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

+ func (this *AddSearchAttributesRequest) GoString() string

+ func (this *AddSearchAttributesRequest) String() string

+ type AddSearchAttributesResponse struct

+ AddWorkflowExecutionInfo *v17.WorkflowExecutionInfo

+ CustomAttributes map[string]v16.IndexedValueType

+ Mapping map[string]string

+ SystemAttributes map[string]v16.IndexedValueType

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

+ func (*AddSearchAttributesResponse) ProtoMessage()

+ func (m *AddSearchAttributesResponse) GetAddWorkflowExecutionInfo() *v17.WorkflowExecutionInfo

+ func (m *AddSearchAttributesResponse) GetCustomAttributes() map[string]v16.IndexedValueType

+ func (m *AddSearchAttributesResponse) GetMapping() map[string]string

+ func (m *AddSearchAttributesResponse) GetSystemAttributes() map[string]v16.IndexedValueType

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

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

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

+ func (m *AddSearchAttributesResponse) Reset()

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

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

+ func (m *AddSearchAttributesResponse) XXX_DiscardUnknown()

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

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

+ func (m *AddSearchAttributesResponse) XXX_Size() int

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

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

+ func (this *AddSearchAttributesResponse) GoString() string

+ func (this *AddSearchAttributesResponse) String() string

type AdminServiceClient

+ AddSearchAttributes func(ctx context.Context, in *AddSearchAttributesRequest, opts ...grpc.CallOption) (*AddSearchAttributesResponse, error)

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

type AdminServiceServer

+ AddSearchAttributes func(context.Context, *AddSearchAttributesRequest) (*AddSearchAttributesResponse, error)

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

+ type GetSearchAttributesRequest struct

+ IndexName string

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

+ func (*GetSearchAttributesRequest) ProtoMessage()

+ func (m *GetSearchAttributesRequest) GetIndexName() string

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

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

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

+ func (m *GetSearchAttributesRequest) Reset()

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

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

+ func (m *GetSearchAttributesRequest) XXX_DiscardUnknown()

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

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

+ func (m *GetSearchAttributesRequest) XXX_Size() int

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

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

+ func (this *GetSearchAttributesRequest) GoString() string

+ func (this *GetSearchAttributesRequest) String() string

+ type GetSearchAttributesResponse struct

+ AddWorkflowExecutionInfo *v17.WorkflowExecutionInfo

+ CustomAttributes map[string]v16.IndexedValueType

+ Mapping map[string]string

+ SystemAttributes map[string]v16.IndexedValueType

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

+ func (*GetSearchAttributesResponse) ProtoMessage()

+ func (m *GetSearchAttributesResponse) GetAddWorkflowExecutionInfo() *v17.WorkflowExecutionInfo

+ func (m *GetSearchAttributesResponse) GetCustomAttributes() map[string]v16.IndexedValueType

+ func (m *GetSearchAttributesResponse) GetMapping() map[string]string

+ func (m *GetSearchAttributesResponse) GetSystemAttributes() map[string]v16.IndexedValueType

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

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

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

+ func (m *GetSearchAttributesResponse) Reset()

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

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

+ func (m *GetSearchAttributesResponse) XXX_DiscardUnknown()

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

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

+ func (m *GetSearchAttributesResponse) XXX_Size() int

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

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

+ func (this *GetSearchAttributesResponse) GoString() string

+ func (this *GetSearchAttributesResponse) String() string

type UnimplementedAdminServiceServer

+ func (*UnimplementedAdminServiceServer) AddSearchAttributes(ctx context.Context, req *AddSearchAttributesRequest) (*AddSearchAttributesResponse, error)

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

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

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

Changes in this version

type AdminServiceClient

+ DescribeMutableState func(ctx context.Context, in *DescribeMutableStateRequest, opts ...grpc.CallOption) (*DescribeMutableStateResponse, error)

type AdminServiceServer

+ DescribeMutableState func(context.Context, *DescribeMutableStateRequest) (*DescribeMutableStateResponse, error)

+ type DescribeMutableStateRequest struct

+ Execution *v1.WorkflowExecution

+ Namespace string

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

+ func (*DescribeMutableStateRequest) ProtoMessage()

+ func (m *DescribeMutableStateRequest) GetExecution() *v1.WorkflowExecution

+ func (m *DescribeMutableStateRequest) GetNamespace() 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

+ CacheMutableState *v11.WorkflowMutableState

+ DatabaseMutableState *v11.WorkflowMutableState

+ HistoryAddr string

+ ShardId string

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

+ func (*DescribeMutableStateResponse) ProtoMessage()

+ func (m *DescribeMutableStateResponse) GetCacheMutableState() *v11.WorkflowMutableState

+ func (m *DescribeMutableStateResponse) GetDatabaseMutableState() *v11.WorkflowMutableState

+ func (m *DescribeMutableStateResponse) GetHistoryAddr() string

+ func (m *DescribeMutableStateResponse) GetShardId() 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 UnimplementedAdminServiceServer

+ func (*UnimplementedAdminServiceServer) DescribeMutableState(ctx context.Context, req *DescribeMutableStateRequest) (*DescribeMutableStateResponse, error)

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

Changes in this version

type DescribeClusterResponse

+ ServerVersion string

+ SupportedClients map[string]string

+ func (m *DescribeClusterResponse) GetServerVersion() string

+ func (m *DescribeClusterResponse) GetSupportedClients() map[string]string

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 DescribeWorkflowExecutionResponse

+ BranchId string

+ TreeId string

+ func (m *DescribeWorkflowExecutionResponse) GetBranchId() string

+ func (m *DescribeWorkflowExecutionResponse) 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

+ Namespace string

+ ShardId int32

+ WorkflowExecution *v1.WorkflowExecution

+ func (m *DescribeHistoryHostRequest) GetNamespace() string

+ func (m *DescribeHistoryHostRequest) GetShardId() int32

+ func (m *DescribeHistoryHostRequest) GetWorkflowExecution() *v1.WorkflowExecution

type DescribeHistoryHostResponse

+ ShardsNumber int32

+ func (m *DescribeHistoryHostResponse) GetShardsNumber() int32

type DescribeWorkflowExecutionResponse

+ CacheMutableState string

+ DatabaseMutableState string

+ func (m *DescribeWorkflowExecutionResponse) GetCacheMutableState() string

+ func (m *DescribeWorkflowExecutionResponse) GetDatabaseMutableState() string

type GetReplicationMessagesResponse

+ ShardMessages map[int32]*v13.ReplicationMessages

+ func (m *GetReplicationMessagesResponse) GetShardMessages() map[int32]*v13.ReplicationMessages

type RemoveTaskRequest

+ VisibilityTime *time.Time

+ func (m *RemoveTaskRequest) GetVisibilityTime() *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 RegisterAdminServiceServer(s *grpc.Server, srv AdminServiceServer)

+ type AddSearchAttributeRequest struct

+ SearchAttribute map[string]v15.IndexedValueType

+ SecurityToken string

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

+ func (*AddSearchAttributeRequest) ProtoMessage()

+ func (m *AddSearchAttributeRequest) GetSearchAttribute() map[string]v15.IndexedValueType

+ func (m *AddSearchAttributeRequest) GetSecurityToken() string

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

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

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

+ func (m *AddSearchAttributeRequest) Reset()

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

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

+ func (m *AddSearchAttributeRequest) XXX_DiscardUnknown()

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

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

+ func (m *AddSearchAttributeRequest) XXX_Size() int

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

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

+ func (this *AddSearchAttributeRequest) GoString() string

+ func (this *AddSearchAttributeRequest) String() string

+ type AddSearchAttributeResponse struct

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

+ func (*AddSearchAttributeResponse) ProtoMessage()

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

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

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

+ func (m *AddSearchAttributeResponse) Reset()

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

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

+ func (m *AddSearchAttributeResponse) XXX_DiscardUnknown()

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

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

+ func (m *AddSearchAttributeResponse) XXX_Size() int

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

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

+ func (this *AddSearchAttributeResponse) GoString() string

+ func (this *AddSearchAttributeResponse) String() string

+ type AdminServiceClient interface

+ AddSearchAttribute func(ctx context.Context, in *AddSearchAttributeRequest, opts ...grpc.CallOption) (*AddSearchAttributeResponse, error)

+ CloseShard func(ctx context.Context, in *CloseShardRequest, opts ...grpc.CallOption) (*CloseShardResponse, error)

+ DescribeCluster func(ctx context.Context, in *DescribeClusterRequest, opts ...grpc.CallOption) (*DescribeClusterResponse, error)

+ DescribeHistoryHost func(ctx context.Context, in *DescribeHistoryHostRequest, opts ...grpc.CallOption) (*DescribeHistoryHostResponse, 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)

+ GetNamespaceReplicationMessages func(ctx context.Context, in *GetNamespaceReplicationMessagesRequest, ...) (*GetNamespaceReplicationMessagesResponse, error)

+ GetReplicationMessages func(ctx context.Context, in *GetReplicationMessagesRequest, ...) (*GetReplicationMessagesResponse, error)

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

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

+ MergeDLQMessages func(ctx context.Context, in *MergeDLQMessagesRequest, opts ...grpc.CallOption) (*MergeDLQMessagesResponse, error)

+ PurgeDLQMessages func(ctx context.Context, in *PurgeDLQMessagesRequest, opts ...grpc.CallOption) (*PurgeDLQMessagesResponse, error)

+ ReapplyEvents func(ctx context.Context, in *ReapplyEventsRequest, opts ...grpc.CallOption) (*ReapplyEventsResponse, error)

+ RefreshWorkflowTasks func(ctx context.Context, in *RefreshWorkflowTasksRequest, opts ...grpc.CallOption) (*RefreshWorkflowTasksResponse, error)

+ RemoveTask func(ctx context.Context, in *RemoveTaskRequest, opts ...grpc.CallOption) (*RemoveTaskResponse, error)

+ ResendReplicationTasks func(ctx context.Context, in *ResendReplicationTasksRequest, ...) (*ResendReplicationTasksResponse, error)

+ func NewAdminServiceClient(cc *grpc.ClientConn) AdminServiceClient

+ type AdminServiceServer interface

+ AddSearchAttribute func(context.Context, *AddSearchAttributeRequest) (*AddSearchAttributeResponse, error)

+ CloseShard func(context.Context, *CloseShardRequest) (*CloseShardResponse, error)

+ DescribeCluster func(context.Context, *DescribeClusterRequest) (*DescribeClusterResponse, error)

+ DescribeHistoryHost func(context.Context, *DescribeHistoryHostRequest) (*DescribeHistoryHostResponse, error)

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

+ GetDLQMessages func(context.Context, *GetDLQMessagesRequest) (*GetDLQMessagesResponse, error)

+ GetDLQReplicationMessages func(context.Context, *GetDLQReplicationMessagesRequest) (*GetDLQReplicationMessagesResponse, error)

+ GetNamespaceReplicationMessages func(context.Context, *GetNamespaceReplicationMessagesRequest) (*GetNamespaceReplicationMessagesResponse, error)

+ GetReplicationMessages func(context.Context, *GetReplicationMessagesRequest) (*GetReplicationMessagesResponse, error)

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

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

+ MergeDLQMessages func(context.Context, *MergeDLQMessagesRequest) (*MergeDLQMessagesResponse, error)

+ PurgeDLQMessages func(context.Context, *PurgeDLQMessagesRequest) (*PurgeDLQMessagesResponse, error)

+ ReapplyEvents func(context.Context, *ReapplyEventsRequest) (*ReapplyEventsResponse, error)

+ RefreshWorkflowTasks func(context.Context, *RefreshWorkflowTasksRequest) (*RefreshWorkflowTasksResponse, error)

+ RemoveTask func(context.Context, *RemoveTaskRequest) (*RemoveTaskResponse, error)

+ ResendReplicationTasks func(context.Context, *ResendReplicationTasksRequest) (*ResendReplicationTasksResponse, error)

+ 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 DescribeClusterRequest struct

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

+ func (*DescribeClusterRequest) ProtoMessage()

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

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

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

+ func (m *DescribeClusterRequest) Reset()

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

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

+ func (m *DescribeClusterRequest) XXX_DiscardUnknown()

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

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

+ func (m *DescribeClusterRequest) XXX_Size() int

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

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

+ func (this *DescribeClusterRequest) GoString() string

+ func (this *DescribeClusterRequest) String() string

+ type DescribeClusterResponse struct

+ MembershipInfo *v17.MembershipInfo

+ SupportedClientVersions *v16.SupportedSDKVersions

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

+ func (*DescribeClusterResponse) ProtoMessage()

+ func (m *DescribeClusterResponse) GetMembershipInfo() *v17.MembershipInfo

+ func (m *DescribeClusterResponse) GetSupportedClientVersions() *v16.SupportedSDKVersions

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

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

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

+ func (m *DescribeClusterResponse) Reset()

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

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

+ func (m *DescribeClusterResponse) XXX_DiscardUnknown()

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

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

+ func (m *DescribeClusterResponse) XXX_Size() int

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

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

+ func (this *DescribeClusterResponse) GoString() string

+ func (this *DescribeClusterResponse) String() string

+ type DescribeHistoryHostRequest struct

+ ExecutionForHost *v1.WorkflowExecution

+ HostAddress string

+ ShardIdForHost int32

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

+ func (*DescribeHistoryHostRequest) ProtoMessage()

+ func (m *DescribeHistoryHostRequest) GetExecutionForHost() *v1.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 *v11.NamespaceCacheInfo

+ NumberOfShards int32

+ ShardControllerStatus string

+ ShardIds []int32

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

+ func (*DescribeHistoryHostResponse) ProtoMessage()

+ func (m *DescribeHistoryHostResponse) GetAddress() string

+ func (m *DescribeHistoryHostResponse) GetNamespaceCache() *v11.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 DescribeWorkflowExecutionRequest struct

+ Execution *v1.WorkflowExecution

+ Namespace string

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

+ func (*DescribeWorkflowExecutionRequest) ProtoMessage()

+ func (m *DescribeWorkflowExecutionRequest) GetExecution() *v1.WorkflowExecution

+ func (m *DescribeWorkflowExecutionRequest) GetNamespace() string

+ 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

+ HistoryAddr string

+ MutableStateInCache string

+ MutableStateInDatabase string

+ ShardId string

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

+ func (*DescribeWorkflowExecutionResponse) ProtoMessage()

+ func (m *DescribeWorkflowExecutionResponse) GetHistoryAddr() string

+ func (m *DescribeWorkflowExecutionResponse) GetMutableStateInCache() string

+ func (m *DescribeWorkflowExecutionResponse) GetMutableStateInDatabase() string

+ func (m *DescribeWorkflowExecutionResponse) GetShardId() string

+ 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 v12.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() v12.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 []*v13.ReplicationTask

+ Type v12.DeadLetterQueueType

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

+ func (*GetDLQMessagesResponse) ProtoMessage()

+ func (m *GetDLQMessagesResponse) GetNextPageToken() []byte

+ func (m *GetDLQMessagesResponse) GetReplicationTasks() []*v13.ReplicationTask

+ func (m *GetDLQMessagesResponse) GetType() v12.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 []*v13.ReplicationTaskInfo

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

+ func (*GetDLQReplicationMessagesRequest) ProtoMessage()

+ func (m *GetDLQReplicationMessagesRequest) GetTaskInfos() []*v13.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 []*v13.ReplicationTask

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

+ func (*GetDLQReplicationMessagesResponse) ProtoMessage()

+ func (m *GetDLQReplicationMessagesResponse) GetReplicationTasks() []*v13.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 GetNamespaceReplicationMessagesRequest struct

+ ClusterName string

+ LastProcessedMessageId int64

+ LastRetrievedMessageId int64

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

+ func (*GetNamespaceReplicationMessagesRequest) ProtoMessage()

+ func (m *GetNamespaceReplicationMessagesRequest) GetClusterName() string

+ func (m *GetNamespaceReplicationMessagesRequest) GetLastProcessedMessageId() int64

+ func (m *GetNamespaceReplicationMessagesRequest) GetLastRetrievedMessageId() int64

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

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

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

+ func (m *GetNamespaceReplicationMessagesRequest) Reset()

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

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

+ func (m *GetNamespaceReplicationMessagesRequest) XXX_DiscardUnknown()

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

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

+ func (m *GetNamespaceReplicationMessagesRequest) XXX_Size() int

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

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

+ func (this *GetNamespaceReplicationMessagesRequest) GoString() string

+ func (this *GetNamespaceReplicationMessagesRequest) String() string

+ type GetNamespaceReplicationMessagesResponse struct

+ Messages *v13.ReplicationMessages

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

+ func (*GetNamespaceReplicationMessagesResponse) ProtoMessage()

+ func (m *GetNamespaceReplicationMessagesResponse) GetMessages() *v13.ReplicationMessages

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

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

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

+ func (m *GetNamespaceReplicationMessagesResponse) Reset()

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

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

+ func (m *GetNamespaceReplicationMessagesResponse) XXX_DiscardUnknown()

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

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

+ func (m *GetNamespaceReplicationMessagesResponse) XXX_Size() int

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

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

+ func (this *GetNamespaceReplicationMessagesResponse) GoString() string

+ func (this *GetNamespaceReplicationMessagesResponse) String() string

+ type GetReplicationMessagesRequest struct

+ ClusterName string

+ Tokens []*v13.ReplicationToken

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

+ func (*GetReplicationMessagesRequest) ProtoMessage()

+ func (m *GetReplicationMessagesRequest) GetClusterName() string

+ func (m *GetReplicationMessagesRequest) GetTokens() []*v13.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]*v13.ReplicationMessages

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

+ func (*GetReplicationMessagesResponse) ProtoMessage()

+ func (m *GetReplicationMessagesResponse) GetMessagesByShard() map[int32]*v13.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 GetWorkflowExecutionRawHistoryRequest struct

+ Execution *v1.WorkflowExecution

+ FirstEventId int64

+ MaximumPageSize int32

+ Namespace string

+ NextEventId int64

+ NextPageToken []byte

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

+ func (*GetWorkflowExecutionRawHistoryRequest) ProtoMessage()

+ func (m *GetWorkflowExecutionRawHistoryRequest) GetExecution() *v1.WorkflowExecution

+ func (m *GetWorkflowExecutionRawHistoryRequest) GetFirstEventId() int64

+ func (m *GetWorkflowExecutionRawHistoryRequest) GetMaximumPageSize() int32

+ func (m *GetWorkflowExecutionRawHistoryRequest) GetNamespace() string

+ func (m *GetWorkflowExecutionRawHistoryRequest) GetNextEventId() int64

+ func (m *GetWorkflowExecutionRawHistoryRequest) GetNextPageToken() []byte

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

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

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

+ func (m *GetWorkflowExecutionRawHistoryRequest) Reset()

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

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

+ func (m *GetWorkflowExecutionRawHistoryRequest) XXX_DiscardUnknown()

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

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

+ func (m *GetWorkflowExecutionRawHistoryRequest) XXX_Size() int

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

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

+ func (this *GetWorkflowExecutionRawHistoryRequest) GoString() string

+ func (this *GetWorkflowExecutionRawHistoryRequest) String() string

+ type GetWorkflowExecutionRawHistoryResponse struct

+ EventStoreVersion int32

+ HistoryBatches []*v1.DataBlob

+ NextPageToken []byte

+ ReplicationInfo map[string]*v13.ReplicationInfo

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

+ func (*GetWorkflowExecutionRawHistoryResponse) ProtoMessage()

+ func (m *GetWorkflowExecutionRawHistoryResponse) GetEventStoreVersion() int32

+ func (m *GetWorkflowExecutionRawHistoryResponse) GetHistoryBatches() []*v1.DataBlob

+ func (m *GetWorkflowExecutionRawHistoryResponse) GetNextPageToken() []byte

+ func (m *GetWorkflowExecutionRawHistoryResponse) GetReplicationInfo() map[string]*v13.ReplicationInfo

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

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

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

+ func (m *GetWorkflowExecutionRawHistoryResponse) Reset()

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

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

+ func (m *GetWorkflowExecutionRawHistoryResponse) XXX_DiscardUnknown()

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

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

+ func (m *GetWorkflowExecutionRawHistoryResponse) XXX_Size() int

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

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

+ func (this *GetWorkflowExecutionRawHistoryResponse) GoString() string

+ func (this *GetWorkflowExecutionRawHistoryResponse) String() string

+ type GetWorkflowExecutionRawHistoryV2Request struct

+ EndEventId int64

+ EndEventVersion int64

+ Execution *v1.WorkflowExecution

+ MaximumPageSize int32

+ Namespace string

+ NextPageToken []byte

+ StartEventId int64

+ StartEventVersion int64

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

+ func (*GetWorkflowExecutionRawHistoryV2Request) ProtoMessage()

+ func (m *GetWorkflowExecutionRawHistoryV2Request) GetEndEventId() int64

+ func (m *GetWorkflowExecutionRawHistoryV2Request) GetEndEventVersion() int64

+ func (m *GetWorkflowExecutionRawHistoryV2Request) GetExecution() *v1.WorkflowExecution

+ func (m *GetWorkflowExecutionRawHistoryV2Request) GetMaximumPageSize() int32

+ func (m *GetWorkflowExecutionRawHistoryV2Request) GetNamespace() string

+ func (m *GetWorkflowExecutionRawHistoryV2Request) GetNextPageToken() []byte

+ func (m *GetWorkflowExecutionRawHistoryV2Request) GetStartEventId() int64

+ func (m *GetWorkflowExecutionRawHistoryV2Request) GetStartEventVersion() int64

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

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

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

+ func (m *GetWorkflowExecutionRawHistoryV2Request) Reset()

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

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

+ func (m *GetWorkflowExecutionRawHistoryV2Request) XXX_DiscardUnknown()

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

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

+ func (m *GetWorkflowExecutionRawHistoryV2Request) XXX_Size() int

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

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

+ func (this *GetWorkflowExecutionRawHistoryV2Request) GoString() string

+ func (this *GetWorkflowExecutionRawHistoryV2Request) String() string

+ type GetWorkflowExecutionRawHistoryV2Response struct

+ HistoryBatches []*v1.DataBlob

+ NextPageToken []byte

+ VersionHistory *v14.VersionHistory

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

+ func (*GetWorkflowExecutionRawHistoryV2Response) ProtoMessage()

+ func (m *GetWorkflowExecutionRawHistoryV2Response) GetHistoryBatches() []*v1.DataBlob

+ func (m *GetWorkflowExecutionRawHistoryV2Response) GetNextPageToken() []byte

+ func (m *GetWorkflowExecutionRawHistoryV2Response) GetVersionHistory() *v14.VersionHistory

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

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

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

+ func (m *GetWorkflowExecutionRawHistoryV2Response) Reset()

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

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

+ func (m *GetWorkflowExecutionRawHistoryV2Response) XXX_DiscardUnknown()

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

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

+ func (m *GetWorkflowExecutionRawHistoryV2Response) XXX_Size() int

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

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

+ func (this *GetWorkflowExecutionRawHistoryV2Response) GoString() string

+ func (this *GetWorkflowExecutionRawHistoryV2Response) String() string

+ type MergeDLQMessagesRequest struct

+ InclusiveEndMessageId int64

+ MaximumPageSize int32

+ NextPageToken []byte

+ ShardId int32

+ SourceCluster string

+ Type v12.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() v12.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 PurgeDLQMessagesRequest struct

+ InclusiveEndMessageId int64

+ ShardId int32

+ SourceCluster string

+ Type v12.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() v12.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 ReapplyEventsRequest struct

+ Events *v1.DataBlob

+ Namespace string

+ WorkflowExecution *v1.WorkflowExecution

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

+ func (*ReapplyEventsRequest) ProtoMessage()

+ func (m *ReapplyEventsRequest) GetEvents() *v1.DataBlob

+ func (m *ReapplyEventsRequest) GetNamespace() string

+ func (m *ReapplyEventsRequest) GetWorkflowExecution() *v1.WorkflowExecution

+ 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 RefreshWorkflowTasksRequest struct

+ Execution *v1.WorkflowExecution

+ Namespace string

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

+ func (*RefreshWorkflowTasksRequest) ProtoMessage()

+ func (m *RefreshWorkflowTasksRequest) GetExecution() *v1.WorkflowExecution

+ func (m *RefreshWorkflowTasksRequest) GetNamespace() string

+ 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 RemoveTaskRequest struct

+ Category v12.TaskCategory

+ ShardId int32

+ TaskId int64

+ VisibilityTimestamp int64

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

+ func (*RemoveTaskRequest) ProtoMessage()

+ func (m *RemoveTaskRequest) GetCategory() v12.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 ResendReplicationTasksRequest struct

+ EndEventId int64

+ EndVersion int64

+ NamespaceId string

+ RemoteCluster string

+ RunId string

+ StartEventId int64

+ StartVersion int64

+ WorkflowId string

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

+ func (*ResendReplicationTasksRequest) ProtoMessage()

+ func (m *ResendReplicationTasksRequest) GetEndEventId() int64

+ func (m *ResendReplicationTasksRequest) GetEndVersion() int64

+ func (m *ResendReplicationTasksRequest) GetNamespaceId() string

+ func (m *ResendReplicationTasksRequest) GetRemoteCluster() string

+ func (m *ResendReplicationTasksRequest) GetRunId() string

+ func (m *ResendReplicationTasksRequest) GetStartEventId() int64

+ func (m *ResendReplicationTasksRequest) GetStartVersion() int64

+ func (m *ResendReplicationTasksRequest) GetWorkflowId() string

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

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

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

+ func (m *ResendReplicationTasksRequest) Reset()

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

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

+ func (m *ResendReplicationTasksRequest) XXX_DiscardUnknown()

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

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

+ func (m *ResendReplicationTasksRequest) XXX_Size() int

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

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

+ func (this *ResendReplicationTasksRequest) GoString() string

+ func (this *ResendReplicationTasksRequest) String() string

+ type ResendReplicationTasksResponse struct

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

+ func (*ResendReplicationTasksResponse) ProtoMessage()

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

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

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

+ func (m *ResendReplicationTasksResponse) Reset()

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

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

+ func (m *ResendReplicationTasksResponse) XXX_DiscardUnknown()

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

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

+ func (m *ResendReplicationTasksResponse) XXX_Size() int

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

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

+ func (this *ResendReplicationTasksResponse) GoString() string

+ func (this *ResendReplicationTasksResponse) String() string

+ type UnimplementedAdminServiceServer struct

+ func (*UnimplementedAdminServiceServer) AddSearchAttribute(ctx context.Context, req *AddSearchAttributeRequest) (*AddSearchAttributeResponse, error)

+ func (*UnimplementedAdminServiceServer) CloseShard(ctx context.Context, req *CloseShardRequest) (*CloseShardResponse, error)

+ func (*UnimplementedAdminServiceServer) DescribeCluster(ctx context.Context, req *DescribeClusterRequest) (*DescribeClusterResponse, error)

+ func (*UnimplementedAdminServiceServer) DescribeHistoryHost(ctx context.Context, req *DescribeHistoryHostRequest) (*DescribeHistoryHostResponse, error)

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

+ func (*UnimplementedAdminServiceServer) GetDLQMessages(ctx context.Context, req *GetDLQMessagesRequest) (*GetDLQMessagesResponse, error)

+ func (*UnimplementedAdminServiceServer) GetDLQReplicationMessages(ctx context.Context, req *GetDLQReplicationMessagesRequest) (*GetDLQReplicationMessagesResponse, error)

+ func (*UnimplementedAdminServiceServer) GetNamespaceReplicationMessages(ctx context.Context, req *GetNamespaceReplicationMessagesRequest) (*GetNamespaceReplicationMessagesResponse, error)

+ func (*UnimplementedAdminServiceServer) GetReplicationMessages(ctx context.Context, req *GetReplicationMessagesRequest) (*GetReplicationMessagesResponse, error)

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

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

+ func (*UnimplementedAdminServiceServer) MergeDLQMessages(ctx context.Context, req *MergeDLQMessagesRequest) (*MergeDLQMessagesResponse, error)

+ func (*UnimplementedAdminServiceServer) PurgeDLQMessages(ctx context.Context, req *PurgeDLQMessagesRequest) (*PurgeDLQMessagesResponse, error)

+ func (*UnimplementedAdminServiceServer) ReapplyEvents(ctx context.Context, req *ReapplyEventsRequest) (*ReapplyEventsResponse, error)

+ func (*UnimplementedAdminServiceServer) RefreshWorkflowTasks(ctx context.Context, req *RefreshWorkflowTasksRequest) (*RefreshWorkflowTasksResponse, error)

+ func (*UnimplementedAdminServiceServer) RemoveTask(ctx context.Context, req *RemoveTaskRequest) (*RemoveTaskResponse, error)

+ func (*UnimplementedAdminServiceServer) ResendReplicationTasks(ctx context.Context, req *ResendReplicationTasksRequest) (*ResendReplicationTasksResponse, error)