adminv1

package
v0.0.0-...-83d5cae Latest Latest
Warning

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

Go to latest
Published: Apr 16, 2024 License: MIT Imports: 17 Imported by: 6

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	ErrInvalidLengthCluster        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowCluster          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupCluster = fmt.Errorf("proto: unexpected end of group")
)
View Source
var (
	ErrInvalidLengthHistory        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowHistory          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupHistory = fmt.Errorf("proto: unexpected end of group")
)
View Source
var (
	ErrInvalidLengthQueue        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowQueue          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupQueue = fmt.Errorf("proto: unexpected end of group")
)
View Source
var (
	ErrInvalidLengthReplication        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowReplication          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupReplication = fmt.Errorf("proto: unexpected end of group")
)
View Source
var (
	ErrInvalidLengthService        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowService          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupService = fmt.Errorf("proto: unexpected end of group")
)
View Source
var CrossClusterTaskFailedCause_name = map[int32]string{
	0: "CROSS_CLUSTER_TASK_FAILED_CAUSE_INVALID",
	1: "CROSS_CLUSTER_TASK_FAILED_CAUSE_DOMAIN_NOT_ACTIVE",
	2: "CROSS_CLUSTER_TASK_FAILED_CAUSE_DOMAIN_NOT_EXISTS",
	3: "CROSS_CLUSTER_TASK_FAILED_CAUSE_WORKFLOW_ALREADY_RUNNING",
	4: "CROSS_CLUSTER_TASK_FAILED_CAUSE_WORKFLOW_NOT_EXISTS",
	5: "CROSS_CLUSTER_TASK_FAILED_CAUSE_WORKFLOW_ALREADY_COMPLETED",
	6: "CROSS_CLUSTER_TASK_FAILED_CAUSE_UNCATEGORIZED",
}
View Source
var CrossClusterTaskFailedCause_value = map[string]int32{
	"CROSS_CLUSTER_TASK_FAILED_CAUSE_INVALID":                    0,
	"CROSS_CLUSTER_TASK_FAILED_CAUSE_DOMAIN_NOT_ACTIVE":          1,
	"CROSS_CLUSTER_TASK_FAILED_CAUSE_DOMAIN_NOT_EXISTS":          2,
	"CROSS_CLUSTER_TASK_FAILED_CAUSE_WORKFLOW_ALREADY_RUNNING":   3,
	"CROSS_CLUSTER_TASK_FAILED_CAUSE_WORKFLOW_NOT_EXISTS":        4,
	"CROSS_CLUSTER_TASK_FAILED_CAUSE_WORKFLOW_ALREADY_COMPLETED": 5,
	"CROSS_CLUSTER_TASK_FAILED_CAUSE_UNCATEGORIZED":              6,
}
View Source
var CrossClusterTaskType_name = map[int32]string{
	0: "CROSS_CLUSTER_TASK_TYPE_INVALID",
	1: "CROSS_CLUSTER_TASK_TYPE_START_CHILD_EXECUTION",
	2: "CROSS_CLUSTER_TASK_TYPE_CANCEL_EXECUTION",
	3: "CROSS_CLUSTER_TASK_TYPE_SIGNAL_EXECUTION",
	4: "CROSS_CLUSTER_TASK_TYPE_RECORD_CHILD_WORKKLOW_EXECUTION_COMPLETE",
	5: "CROSS_CLUSTER_TASK_TYPE_APPLY_PARENT_CLOSE_POLICY",
}
View Source
var CrossClusterTaskType_value = map[string]int32{
	"CROSS_CLUSTER_TASK_TYPE_INVALID":                                  0,
	"CROSS_CLUSTER_TASK_TYPE_START_CHILD_EXECUTION":                    1,
	"CROSS_CLUSTER_TASK_TYPE_CANCEL_EXECUTION":                         2,
	"CROSS_CLUSTER_TASK_TYPE_SIGNAL_EXECUTION":                         3,
	"CROSS_CLUSTER_TASK_TYPE_RECORD_CHILD_WORKKLOW_EXECUTION_COMPLETE": 4,
	"CROSS_CLUSTER_TASK_TYPE_APPLY_PARENT_CLOSE_POLICY":                5,
}
View Source
var DLQType_name = map[int32]string{
	0: "DLQ_TYPE_INVALID",
	1: "DLQ_TYPE_REPLICATION",
	2: "DLQ_TYPE_DOMAIN",
}
View Source
var DLQType_value = map[string]int32{
	"DLQ_TYPE_INVALID":     0,
	"DLQ_TYPE_REPLICATION": 1,
	"DLQ_TYPE_DOMAIN":      2,
}
View Source
var DomainOperation_name = map[int32]string{
	0: "DOMAIN_OPERATION_INVALID",
	1: "DOMAIN_OPERATION_CREATE",
	2: "DOMAIN_OPERATION_UPDATE",
}
View Source
var DomainOperation_value = map[string]int32{
	"DOMAIN_OPERATION_INVALID": 0,
	"DOMAIN_OPERATION_CREATE":  1,
	"DOMAIN_OPERATION_UPDATE":  2,
}
View Source
var GetTaskFailedCause_name = map[int32]string{
	0: "GET_TASK_FAILED_CAUSE_INVALID",
	1: "GET_TASK_FAILED_CAUSE_SERVICE_BUSY",
	2: "GET_TASK_FAILED_CAUSE_TIMEOUT",
	3: "GET_TASK_FAILED_CAUSE_SHARD_OWNERSHIP_LOST",
	4: "GET_TASK_FAILED_CAUSE_UNCATEGORIZED",
}
View Source
var GetTaskFailedCause_value = map[string]int32{
	"GET_TASK_FAILED_CAUSE_INVALID":              0,
	"GET_TASK_FAILED_CAUSE_SERVICE_BUSY":         1,
	"GET_TASK_FAILED_CAUSE_TIMEOUT":              2,
	"GET_TASK_FAILED_CAUSE_SHARD_OWNERSHIP_LOST": 3,
	"GET_TASK_FAILED_CAUSE_UNCATEGORIZED":        4,
}
View Source
var ReplicationTaskType_name = map[int32]string{
	0: "REPLICATION_TASK_TYPE_INVALID",
	1: "REPLICATION_TASK_TYPE_DOMAIN",
	2: "REPLICATION_TASK_TYPE_HISTORY",
	3: "REPLICATION_TASK_TYPE_SYNC_SHARD_STATUS",
	4: "REPLICATION_TASK_TYPE_SYNC_ACTIVITY",
	5: "REPLICATION_TASK_TYPE_HISTORY_METADATA",
	6: "REPLICATION_TASK_TYPE_HISTORY_V2",
	7: "REPLICATION_TASK_TYPE_FAILOVER_MARKER",
}
View Source
var ReplicationTaskType_value = map[string]int32{
	"REPLICATION_TASK_TYPE_INVALID":           0,
	"REPLICATION_TASK_TYPE_DOMAIN":            1,
	"REPLICATION_TASK_TYPE_HISTORY":           2,
	"REPLICATION_TASK_TYPE_SYNC_SHARD_STATUS": 3,
	"REPLICATION_TASK_TYPE_SYNC_ACTIVITY":     4,
	"REPLICATION_TASK_TYPE_HISTORY_METADATA":  5,
	"REPLICATION_TASK_TYPE_HISTORY_V2":        6,
	"REPLICATION_TASK_TYPE_FAILOVER_MARKER":   7,
}
View Source
var TaskType_name = map[int32]string{
	0: "TASK_TYPE_INVALID",
	1: "TASK_TYPE_TRANSFER",
	2: "TASK_TYPE_TIMER",
	3: "TASK_TYPE_REPLICATION",
	4: "TASK_TYPE_CROSS_CLUSTER",
}
View Source
var TaskType_value = map[string]int32{
	"TASK_TYPE_INVALID":       0,
	"TASK_TYPE_TRANSFER":      1,
	"TASK_TYPE_TIMER":         2,
	"TASK_TYPE_REPLICATION":   3,
	"TASK_TYPE_CROSS_CLUSTER": 4,
}

Functions

func BuildAdminAPIYARPCProcedures

func BuildAdminAPIYARPCProcedures(server AdminAPIYARPCServer) []transport.Procedure

BuildAdminAPIYARPCProcedures prepares an implementation of the AdminAPI service for YARPC registration.

func NewFxAdminAPIYARPCClient

func NewFxAdminAPIYARPCClient(name string, options ...protobuf.ClientOption) interface{}

NewFxAdminAPIYARPCClient provides a AdminAPIYARPCClient to an Fx application using the given name for routing.

fx.Provide(
  adminv1.NewFxAdminAPIYARPCClient("service-name"),
  ...
)

func NewFxAdminAPIYARPCProcedures

func NewFxAdminAPIYARPCProcedures() interface{}

NewFxAdminAPIYARPCProcedures provides AdminAPIYARPCServer procedures to an Fx application. It expects a AdminAPIYARPCServer to be present in the container.

fx.Provide(
  adminv1.NewFxAdminAPIYARPCProcedures(),
  ...
)

Types

type AddSearchAttributeRequest

type AddSearchAttributeRequest struct {
	SearchAttribute      map[string]v1.IndexedValueType `` /* 237-byte string literal not displayed */
	SecurityToken        string                         `protobuf:"bytes,2,opt,name=security_token,json=securityToken,proto3" json:"security_token,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                       `json:"-"`
	XXX_unrecognized     []byte                         `json:"-"`
	XXX_sizecache        int32                          `json:"-"`
}

func (*AddSearchAttributeRequest) Descriptor

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

func (*AddSearchAttributeRequest) GetSearchAttribute

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

func (*AddSearchAttributeRequest) GetSecurityToken

func (m *AddSearchAttributeRequest) GetSecurityToken() string

func (*AddSearchAttributeRequest) Marshal

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

func (*AddSearchAttributeRequest) MarshalTo

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

func (*AddSearchAttributeRequest) MarshalToSizedBuffer

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

func (*AddSearchAttributeRequest) ProtoMessage

func (*AddSearchAttributeRequest) ProtoMessage()

func (*AddSearchAttributeRequest) Reset

func (m *AddSearchAttributeRequest) Reset()

func (*AddSearchAttributeRequest) Size

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

func (*AddSearchAttributeRequest) String

func (m *AddSearchAttributeRequest) String() string

func (*AddSearchAttributeRequest) Unmarshal

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

func (*AddSearchAttributeRequest) XXX_DiscardUnknown

func (m *AddSearchAttributeRequest) XXX_DiscardUnknown()

func (*AddSearchAttributeRequest) XXX_Marshal

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

func (*AddSearchAttributeRequest) XXX_Merge

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

func (*AddSearchAttributeRequest) XXX_Size

func (m *AddSearchAttributeRequest) XXX_Size() int

func (*AddSearchAttributeRequest) XXX_Unmarshal

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

type AddSearchAttributeResponse

type AddSearchAttributeResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AddSearchAttributeResponse) Descriptor

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

func (*AddSearchAttributeResponse) Marshal

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

func (*AddSearchAttributeResponse) MarshalTo

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

func (*AddSearchAttributeResponse) MarshalToSizedBuffer

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

func (*AddSearchAttributeResponse) ProtoMessage

func (*AddSearchAttributeResponse) ProtoMessage()

func (*AddSearchAttributeResponse) Reset

func (m *AddSearchAttributeResponse) Reset()

func (*AddSearchAttributeResponse) Size

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

func (*AddSearchAttributeResponse) String

func (m *AddSearchAttributeResponse) String() string

func (*AddSearchAttributeResponse) Unmarshal

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

func (*AddSearchAttributeResponse) XXX_DiscardUnknown

func (m *AddSearchAttributeResponse) XXX_DiscardUnknown()

func (*AddSearchAttributeResponse) XXX_Marshal

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

func (*AddSearchAttributeResponse) XXX_Merge

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

func (*AddSearchAttributeResponse) XXX_Size

func (m *AddSearchAttributeResponse) XXX_Size() int

func (*AddSearchAttributeResponse) XXX_Unmarshal

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

type AdminAPIYARPCClient

type AdminAPIYARPCClient interface {
	DescribeWorkflowExecution(context.Context, *DescribeWorkflowExecutionRequest, ...yarpc.CallOption) (*DescribeWorkflowExecutionResponse, error)
	DescribeHistoryHost(context.Context, *DescribeHistoryHostRequest, ...yarpc.CallOption) (*DescribeHistoryHostResponse, error)
	DescribeShardDistribution(context.Context, *DescribeShardDistributionRequest, ...yarpc.CallOption) (*DescribeShardDistributionResponse, error)
	CloseShard(context.Context, *CloseShardRequest, ...yarpc.CallOption) (*CloseShardResponse, error)
	RemoveTask(context.Context, *RemoveTaskRequest, ...yarpc.CallOption) (*RemoveTaskResponse, error)
	ResetQueue(context.Context, *ResetQueueRequest, ...yarpc.CallOption) (*ResetQueueResponse, error)
	DescribeQueue(context.Context, *DescribeQueueRequest, ...yarpc.CallOption) (*DescribeQueueResponse, error)
	GetWorkflowExecutionRawHistoryV2(context.Context, *GetWorkflowExecutionRawHistoryV2Request, ...yarpc.CallOption) (*GetWorkflowExecutionRawHistoryV2Response, error)
	GetReplicationMessages(context.Context, *GetReplicationMessagesRequest, ...yarpc.CallOption) (*GetReplicationMessagesResponse, error)
	GetDLQReplicationMessages(context.Context, *GetDLQReplicationMessagesRequest, ...yarpc.CallOption) (*GetDLQReplicationMessagesResponse, error)
	GetDomainReplicationMessages(context.Context, *GetDomainReplicationMessagesRequest, ...yarpc.CallOption) (*GetDomainReplicationMessagesResponse, error)
	ReapplyEvents(context.Context, *ReapplyEventsRequest, ...yarpc.CallOption) (*ReapplyEventsResponse, error)
	AddSearchAttribute(context.Context, *AddSearchAttributeRequest, ...yarpc.CallOption) (*AddSearchAttributeResponse, error)
	DescribeCluster(context.Context, *DescribeClusterRequest, ...yarpc.CallOption) (*DescribeClusterResponse, error)
	CountDLQMessages(context.Context, *CountDLQMessagesRequest, ...yarpc.CallOption) (*CountDLQMessagesResponse, error)
	ReadDLQMessages(context.Context, *ReadDLQMessagesRequest, ...yarpc.CallOption) (*ReadDLQMessagesResponse, error)
	PurgeDLQMessages(context.Context, *PurgeDLQMessagesRequest, ...yarpc.CallOption) (*PurgeDLQMessagesResponse, error)
	MergeDLQMessages(context.Context, *MergeDLQMessagesRequest, ...yarpc.CallOption) (*MergeDLQMessagesResponse, error)
	RefreshWorkflowTasks(context.Context, *RefreshWorkflowTasksRequest, ...yarpc.CallOption) (*RefreshWorkflowTasksResponse, error)
	ResendReplicationTasks(context.Context, *ResendReplicationTasksRequest, ...yarpc.CallOption) (*ResendReplicationTasksResponse, error)
	GetCrossClusterTasks(context.Context, *GetCrossClusterTasksRequest, ...yarpc.CallOption) (*GetCrossClusterTasksResponse, error)
	RespondCrossClusterTasksCompleted(context.Context, *RespondCrossClusterTasksCompletedRequest, ...yarpc.CallOption) (*RespondCrossClusterTasksCompletedResponse, error)
	GetDynamicConfig(context.Context, *GetDynamicConfigRequest, ...yarpc.CallOption) (*GetDynamicConfigResponse, error)
	UpdateDynamicConfig(context.Context, *UpdateDynamicConfigRequest, ...yarpc.CallOption) (*UpdateDynamicConfigResponse, error)
	RestoreDynamicConfig(context.Context, *RestoreDynamicConfigRequest, ...yarpc.CallOption) (*RestoreDynamicConfigResponse, error)
	ListDynamicConfig(context.Context, *ListDynamicConfigRequest, ...yarpc.CallOption) (*ListDynamicConfigResponse, error)
	DeleteWorkflow(context.Context, *DeleteWorkflowRequest, ...yarpc.CallOption) (*DeleteWorkflowResponse, error)
	MaintainCorruptWorkflow(context.Context, *MaintainCorruptWorkflowRequest, ...yarpc.CallOption) (*MaintainCorruptWorkflowResponse, error)
	GetGlobalIsolationGroups(context.Context, *GetGlobalIsolationGroupsRequest, ...yarpc.CallOption) (*GetGlobalIsolationGroupsResponse, error)
	UpdateGlobalIsolationGroups(context.Context, *UpdateGlobalIsolationGroupsRequest, ...yarpc.CallOption) (*UpdateGlobalIsolationGroupsResponse, error)
	GetDomainIsolationGroups(context.Context, *GetDomainIsolationGroupsRequest, ...yarpc.CallOption) (*GetDomainIsolationGroupsResponse, error)
	UpdateDomainIsolationGroups(context.Context, *UpdateDomainIsolationGroupsRequest, ...yarpc.CallOption) (*UpdateDomainIsolationGroupsResponse, error)
	GetDomainAsyncWorkflowConfiguraton(context.Context, *GetDomainAsyncWorkflowConfiguratonRequest, ...yarpc.CallOption) (*GetDomainAsyncWorkflowConfiguratonResponse, error)
	UpdateDomainAsyncWorkflowConfiguraton(context.Context, *UpdateDomainAsyncWorkflowConfiguratonRequest, ...yarpc.CallOption) (*UpdateDomainAsyncWorkflowConfiguratonResponse, error)
}

AdminAPIYARPCClient is the YARPC client-side interface for the AdminAPI service.

func NewAdminAPIYARPCClient

func NewAdminAPIYARPCClient(clientConfig transport.ClientConfig, options ...protobuf.ClientOption) AdminAPIYARPCClient

NewAdminAPIYARPCClient builds a new YARPC client for the AdminAPI service.

type AdminAPIYARPCServer

type AdminAPIYARPCServer interface {
	DescribeWorkflowExecution(context.Context, *DescribeWorkflowExecutionRequest) (*DescribeWorkflowExecutionResponse, error)
	DescribeHistoryHost(context.Context, *DescribeHistoryHostRequest) (*DescribeHistoryHostResponse, error)
	DescribeShardDistribution(context.Context, *DescribeShardDistributionRequest) (*DescribeShardDistributionResponse, error)
	CloseShard(context.Context, *CloseShardRequest) (*CloseShardResponse, error)
	RemoveTask(context.Context, *RemoveTaskRequest) (*RemoveTaskResponse, error)
	ResetQueue(context.Context, *ResetQueueRequest) (*ResetQueueResponse, error)
	DescribeQueue(context.Context, *DescribeQueueRequest) (*DescribeQueueResponse, error)
	GetWorkflowExecutionRawHistoryV2(context.Context, *GetWorkflowExecutionRawHistoryV2Request) (*GetWorkflowExecutionRawHistoryV2Response, error)
	GetReplicationMessages(context.Context, *GetReplicationMessagesRequest) (*GetReplicationMessagesResponse, error)
	GetDLQReplicationMessages(context.Context, *GetDLQReplicationMessagesRequest) (*GetDLQReplicationMessagesResponse, error)
	GetDomainReplicationMessages(context.Context, *GetDomainReplicationMessagesRequest) (*GetDomainReplicationMessagesResponse, error)
	ReapplyEvents(context.Context, *ReapplyEventsRequest) (*ReapplyEventsResponse, error)
	AddSearchAttribute(context.Context, *AddSearchAttributeRequest) (*AddSearchAttributeResponse, error)
	DescribeCluster(context.Context, *DescribeClusterRequest) (*DescribeClusterResponse, error)
	CountDLQMessages(context.Context, *CountDLQMessagesRequest) (*CountDLQMessagesResponse, error)
	ReadDLQMessages(context.Context, *ReadDLQMessagesRequest) (*ReadDLQMessagesResponse, error)
	PurgeDLQMessages(context.Context, *PurgeDLQMessagesRequest) (*PurgeDLQMessagesResponse, error)
	MergeDLQMessages(context.Context, *MergeDLQMessagesRequest) (*MergeDLQMessagesResponse, error)
	RefreshWorkflowTasks(context.Context, *RefreshWorkflowTasksRequest) (*RefreshWorkflowTasksResponse, error)
	ResendReplicationTasks(context.Context, *ResendReplicationTasksRequest) (*ResendReplicationTasksResponse, error)
	GetCrossClusterTasks(context.Context, *GetCrossClusterTasksRequest) (*GetCrossClusterTasksResponse, error)
	RespondCrossClusterTasksCompleted(context.Context, *RespondCrossClusterTasksCompletedRequest) (*RespondCrossClusterTasksCompletedResponse, error)
	GetDynamicConfig(context.Context, *GetDynamicConfigRequest) (*GetDynamicConfigResponse, error)
	UpdateDynamicConfig(context.Context, *UpdateDynamicConfigRequest) (*UpdateDynamicConfigResponse, error)
	RestoreDynamicConfig(context.Context, *RestoreDynamicConfigRequest) (*RestoreDynamicConfigResponse, error)
	ListDynamicConfig(context.Context, *ListDynamicConfigRequest) (*ListDynamicConfigResponse, error)
	DeleteWorkflow(context.Context, *DeleteWorkflowRequest) (*DeleteWorkflowResponse, error)
	MaintainCorruptWorkflow(context.Context, *MaintainCorruptWorkflowRequest) (*MaintainCorruptWorkflowResponse, error)
	GetGlobalIsolationGroups(context.Context, *GetGlobalIsolationGroupsRequest) (*GetGlobalIsolationGroupsResponse, error)
	UpdateGlobalIsolationGroups(context.Context, *UpdateGlobalIsolationGroupsRequest) (*UpdateGlobalIsolationGroupsResponse, error)
	GetDomainIsolationGroups(context.Context, *GetDomainIsolationGroupsRequest) (*GetDomainIsolationGroupsResponse, error)
	UpdateDomainIsolationGroups(context.Context, *UpdateDomainIsolationGroupsRequest) (*UpdateDomainIsolationGroupsResponse, error)
	GetDomainAsyncWorkflowConfiguraton(context.Context, *GetDomainAsyncWorkflowConfiguratonRequest) (*GetDomainAsyncWorkflowConfiguratonResponse, error)
	UpdateDomainAsyncWorkflowConfiguraton(context.Context, *UpdateDomainAsyncWorkflowConfiguratonRequest) (*UpdateDomainAsyncWorkflowConfiguratonResponse, error)
}

AdminAPIYARPCServer is the YARPC server-side interface for the AdminAPI service.

type ApplyParentClosePolicyAttributes

type ApplyParentClosePolicyAttributes struct {
	ChildDomainId        string               `protobuf:"bytes,1,opt,name=child_domain_id,json=childDomainId,proto3" json:"child_domain_id,omitempty"`
	ChildWorkflowId      string               `protobuf:"bytes,2,opt,name=child_workflow_id,json=childWorkflowId,proto3" json:"child_workflow_id,omitempty"`
	ChildRunId           string               `protobuf:"bytes,3,opt,name=child_run_id,json=childRunId,proto3" json:"child_run_id,omitempty"`
	ParentClosePolicy    v1.ParentClosePolicy `` /* 158-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*ApplyParentClosePolicyAttributes) Descriptor

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

func (*ApplyParentClosePolicyAttributes) GetChildDomainId

func (m *ApplyParentClosePolicyAttributes) GetChildDomainId() string

func (*ApplyParentClosePolicyAttributes) GetChildRunId

func (m *ApplyParentClosePolicyAttributes) GetChildRunId() string

func (*ApplyParentClosePolicyAttributes) GetChildWorkflowId

func (m *ApplyParentClosePolicyAttributes) GetChildWorkflowId() string

func (*ApplyParentClosePolicyAttributes) GetParentClosePolicy

func (m *ApplyParentClosePolicyAttributes) GetParentClosePolicy() v1.ParentClosePolicy

func (*ApplyParentClosePolicyAttributes) Marshal

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

func (*ApplyParentClosePolicyAttributes) MarshalTo

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

func (*ApplyParentClosePolicyAttributes) MarshalToSizedBuffer

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

func (*ApplyParentClosePolicyAttributes) ProtoMessage

func (*ApplyParentClosePolicyAttributes) ProtoMessage()

func (*ApplyParentClosePolicyAttributes) Reset

func (*ApplyParentClosePolicyAttributes) Size

func (m *ApplyParentClosePolicyAttributes) Size() (n int)

func (*ApplyParentClosePolicyAttributes) String

func (*ApplyParentClosePolicyAttributes) Unmarshal

func (m *ApplyParentClosePolicyAttributes) Unmarshal(dAtA []byte) error

func (*ApplyParentClosePolicyAttributes) XXX_DiscardUnknown

func (m *ApplyParentClosePolicyAttributes) XXX_DiscardUnknown()

func (*ApplyParentClosePolicyAttributes) XXX_Marshal

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

func (*ApplyParentClosePolicyAttributes) XXX_Merge

func (*ApplyParentClosePolicyAttributes) XXX_Size

func (m *ApplyParentClosePolicyAttributes) XXX_Size() int

func (*ApplyParentClosePolicyAttributes) XXX_Unmarshal

func (m *ApplyParentClosePolicyAttributes) XXX_Unmarshal(b []byte) error

type ApplyParentClosePolicyRequest

type ApplyParentClosePolicyRequest struct {
	Child                *ApplyParentClosePolicyAttributes `protobuf:"bytes,1,opt,name=child,proto3" json:"child,omitempty"`
	Status               *ApplyParentClosePolicyStatus     `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                          `json:"-"`
	XXX_unrecognized     []byte                            `json:"-"`
	XXX_sizecache        int32                             `json:"-"`
}

func (*ApplyParentClosePolicyRequest) Descriptor

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

func (*ApplyParentClosePolicyRequest) GetChild

func (*ApplyParentClosePolicyRequest) GetStatus

func (*ApplyParentClosePolicyRequest) Marshal

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

func (*ApplyParentClosePolicyRequest) MarshalTo

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

func (*ApplyParentClosePolicyRequest) MarshalToSizedBuffer

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

func (*ApplyParentClosePolicyRequest) ProtoMessage

func (*ApplyParentClosePolicyRequest) ProtoMessage()

func (*ApplyParentClosePolicyRequest) Reset

func (m *ApplyParentClosePolicyRequest) Reset()

func (*ApplyParentClosePolicyRequest) Size

func (m *ApplyParentClosePolicyRequest) Size() (n int)

func (*ApplyParentClosePolicyRequest) String

func (*ApplyParentClosePolicyRequest) Unmarshal

func (m *ApplyParentClosePolicyRequest) Unmarshal(dAtA []byte) error

func (*ApplyParentClosePolicyRequest) XXX_DiscardUnknown

func (m *ApplyParentClosePolicyRequest) XXX_DiscardUnknown()

func (*ApplyParentClosePolicyRequest) XXX_Marshal

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

func (*ApplyParentClosePolicyRequest) XXX_Merge

func (m *ApplyParentClosePolicyRequest) XXX_Merge(src proto.Message)

func (*ApplyParentClosePolicyRequest) XXX_Size

func (m *ApplyParentClosePolicyRequest) XXX_Size() int

func (*ApplyParentClosePolicyRequest) XXX_Unmarshal

func (m *ApplyParentClosePolicyRequest) XXX_Unmarshal(b []byte) error

type ApplyParentClosePolicyResult

type ApplyParentClosePolicyResult struct {
	Child                *ApplyParentClosePolicyAttributes `protobuf:"bytes,1,opt,name=child,proto3" json:"child,omitempty"`
	FailedCause          CrossClusterTaskFailedCause       `` /* 150-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                          `json:"-"`
	XXX_unrecognized     []byte                            `json:"-"`
	XXX_sizecache        int32                             `json:"-"`
}

func (*ApplyParentClosePolicyResult) Descriptor

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

func (*ApplyParentClosePolicyResult) GetChild

func (*ApplyParentClosePolicyResult) GetFailedCause

func (*ApplyParentClosePolicyResult) Marshal

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

func (*ApplyParentClosePolicyResult) MarshalTo

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

func (*ApplyParentClosePolicyResult) MarshalToSizedBuffer

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

func (*ApplyParentClosePolicyResult) ProtoMessage

func (*ApplyParentClosePolicyResult) ProtoMessage()

func (*ApplyParentClosePolicyResult) Reset

func (m *ApplyParentClosePolicyResult) Reset()

func (*ApplyParentClosePolicyResult) Size

func (m *ApplyParentClosePolicyResult) Size() (n int)

func (*ApplyParentClosePolicyResult) String

func (*ApplyParentClosePolicyResult) Unmarshal

func (m *ApplyParentClosePolicyResult) Unmarshal(dAtA []byte) error

func (*ApplyParentClosePolicyResult) XXX_DiscardUnknown

func (m *ApplyParentClosePolicyResult) XXX_DiscardUnknown()

func (*ApplyParentClosePolicyResult) XXX_Marshal

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

func (*ApplyParentClosePolicyResult) XXX_Merge

func (m *ApplyParentClosePolicyResult) XXX_Merge(src proto.Message)

func (*ApplyParentClosePolicyResult) XXX_Size

func (m *ApplyParentClosePolicyResult) XXX_Size() int

func (*ApplyParentClosePolicyResult) XXX_Unmarshal

func (m *ApplyParentClosePolicyResult) XXX_Unmarshal(b []byte) error

type ApplyParentClosePolicyStatus

type ApplyParentClosePolicyStatus struct {
	Completed            bool                        `protobuf:"varint,1,opt,name=completed,proto3" json:"completed,omitempty"`
	FailedCause          CrossClusterTaskFailedCause `` /* 150-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                    `json:"-"`
	XXX_unrecognized     []byte                      `json:"-"`
	XXX_sizecache        int32                       `json:"-"`
}

func (*ApplyParentClosePolicyStatus) Descriptor

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

func (*ApplyParentClosePolicyStatus) GetCompleted

func (m *ApplyParentClosePolicyStatus) GetCompleted() bool

func (*ApplyParentClosePolicyStatus) GetFailedCause

func (*ApplyParentClosePolicyStatus) Marshal

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

func (*ApplyParentClosePolicyStatus) MarshalTo

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

func (*ApplyParentClosePolicyStatus) MarshalToSizedBuffer

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

func (*ApplyParentClosePolicyStatus) ProtoMessage

func (*ApplyParentClosePolicyStatus) ProtoMessage()

func (*ApplyParentClosePolicyStatus) Reset

func (m *ApplyParentClosePolicyStatus) Reset()

func (*ApplyParentClosePolicyStatus) Size

func (m *ApplyParentClosePolicyStatus) Size() (n int)

func (*ApplyParentClosePolicyStatus) String

func (*ApplyParentClosePolicyStatus) Unmarshal

func (m *ApplyParentClosePolicyStatus) Unmarshal(dAtA []byte) error

func (*ApplyParentClosePolicyStatus) XXX_DiscardUnknown

func (m *ApplyParentClosePolicyStatus) XXX_DiscardUnknown()

func (*ApplyParentClosePolicyStatus) XXX_Marshal

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

func (*ApplyParentClosePolicyStatus) XXX_Merge

func (m *ApplyParentClosePolicyStatus) XXX_Merge(src proto.Message)

func (*ApplyParentClosePolicyStatus) XXX_Size

func (m *ApplyParentClosePolicyStatus) XXX_Size() int

func (*ApplyParentClosePolicyStatus) XXX_Unmarshal

func (m *ApplyParentClosePolicyStatus) XXX_Unmarshal(b []byte) error

type CloseShardRequest

type CloseShardRequest struct {
	ShardId              int32    `protobuf:"varint,1,opt,name=shard_id,json=shardId,proto3" json:"shard_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CloseShardRequest) Descriptor

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

func (*CloseShardRequest) GetShardId

func (m *CloseShardRequest) GetShardId() int32

func (*CloseShardRequest) Marshal

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

func (*CloseShardRequest) MarshalTo

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

func (*CloseShardRequest) MarshalToSizedBuffer

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

func (*CloseShardRequest) ProtoMessage

func (*CloseShardRequest) ProtoMessage()

func (*CloseShardRequest) Reset

func (m *CloseShardRequest) Reset()

func (*CloseShardRequest) Size

func (m *CloseShardRequest) Size() (n int)

func (*CloseShardRequest) String

func (m *CloseShardRequest) String() string

func (*CloseShardRequest) Unmarshal

func (m *CloseShardRequest) Unmarshal(dAtA []byte) error

func (*CloseShardRequest) XXX_DiscardUnknown

func (m *CloseShardRequest) XXX_DiscardUnknown()

func (*CloseShardRequest) XXX_Marshal

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

func (*CloseShardRequest) XXX_Merge

func (m *CloseShardRequest) XXX_Merge(src proto.Message)

func (*CloseShardRequest) XXX_Size

func (m *CloseShardRequest) XXX_Size() int

func (*CloseShardRequest) XXX_Unmarshal

func (m *CloseShardRequest) XXX_Unmarshal(b []byte) error

type CloseShardResponse

type CloseShardResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CloseShardResponse) Descriptor

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

func (*CloseShardResponse) Marshal

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

func (*CloseShardResponse) MarshalTo

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

func (*CloseShardResponse) MarshalToSizedBuffer

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

func (*CloseShardResponse) ProtoMessage

func (*CloseShardResponse) ProtoMessage()

func (*CloseShardResponse) Reset

func (m *CloseShardResponse) Reset()

func (*CloseShardResponse) Size

func (m *CloseShardResponse) Size() (n int)

func (*CloseShardResponse) String

func (m *CloseShardResponse) String() string

func (*CloseShardResponse) Unmarshal

func (m *CloseShardResponse) Unmarshal(dAtA []byte) error

func (*CloseShardResponse) XXX_DiscardUnknown

func (m *CloseShardResponse) XXX_DiscardUnknown()

func (*CloseShardResponse) XXX_Marshal

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

func (*CloseShardResponse) XXX_Merge

func (m *CloseShardResponse) XXX_Merge(src proto.Message)

func (*CloseShardResponse) XXX_Size

func (m *CloseShardResponse) XXX_Size() int

func (*CloseShardResponse) XXX_Unmarshal

func (m *CloseShardResponse) XXX_Unmarshal(b []byte) error

type CountDLQMessagesRequest

type CountDLQMessagesRequest struct {
	ForceFetch           bool     `protobuf:"varint,1,opt,name=force_fetch,json=forceFetch,proto3" json:"force_fetch,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CountDLQMessagesRequest) Descriptor

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

func (*CountDLQMessagesRequest) GetForceFetch

func (m *CountDLQMessagesRequest) GetForceFetch() bool

func (*CountDLQMessagesRequest) Marshal

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

func (*CountDLQMessagesRequest) MarshalTo

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

func (*CountDLQMessagesRequest) MarshalToSizedBuffer

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

func (*CountDLQMessagesRequest) ProtoMessage

func (*CountDLQMessagesRequest) ProtoMessage()

func (*CountDLQMessagesRequest) Reset

func (m *CountDLQMessagesRequest) Reset()

func (*CountDLQMessagesRequest) Size

func (m *CountDLQMessagesRequest) Size() (n int)

func (*CountDLQMessagesRequest) String

func (m *CountDLQMessagesRequest) String() string

func (*CountDLQMessagesRequest) Unmarshal

func (m *CountDLQMessagesRequest) Unmarshal(dAtA []byte) error

func (*CountDLQMessagesRequest) XXX_DiscardUnknown

func (m *CountDLQMessagesRequest) XXX_DiscardUnknown()

func (*CountDLQMessagesRequest) XXX_Marshal

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

func (*CountDLQMessagesRequest) XXX_Merge

func (m *CountDLQMessagesRequest) XXX_Merge(src proto.Message)

func (*CountDLQMessagesRequest) XXX_Size

func (m *CountDLQMessagesRequest) XXX_Size() int

func (*CountDLQMessagesRequest) XXX_Unmarshal

func (m *CountDLQMessagesRequest) XXX_Unmarshal(b []byte) error

type CountDLQMessagesResponse

type CountDLQMessagesResponse struct {
	History              []*HistoryDLQCountEntry `protobuf:"bytes,1,rep,name=history,proto3" json:"history,omitempty"`
	Domain               int64                   `protobuf:"varint,2,opt,name=domain,proto3" json:"domain,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                `json:"-"`
	XXX_unrecognized     []byte                  `json:"-"`
	XXX_sizecache        int32                   `json:"-"`
}

func (*CountDLQMessagesResponse) Descriptor

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

func (*CountDLQMessagesResponse) GetDomain

func (m *CountDLQMessagesResponse) GetDomain() int64

func (*CountDLQMessagesResponse) GetHistory

func (*CountDLQMessagesResponse) Marshal

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

func (*CountDLQMessagesResponse) MarshalTo

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

func (*CountDLQMessagesResponse) MarshalToSizedBuffer

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

func (*CountDLQMessagesResponse) ProtoMessage

func (*CountDLQMessagesResponse) ProtoMessage()

func (*CountDLQMessagesResponse) Reset

func (m *CountDLQMessagesResponse) Reset()

func (*CountDLQMessagesResponse) Size

func (m *CountDLQMessagesResponse) Size() (n int)

func (*CountDLQMessagesResponse) String

func (m *CountDLQMessagesResponse) String() string

func (*CountDLQMessagesResponse) Unmarshal

func (m *CountDLQMessagesResponse) Unmarshal(dAtA []byte) error

func (*CountDLQMessagesResponse) XXX_DiscardUnknown

func (m *CountDLQMessagesResponse) XXX_DiscardUnknown()

func (*CountDLQMessagesResponse) XXX_Marshal

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

func (*CountDLQMessagesResponse) XXX_Merge

func (m *CountDLQMessagesResponse) XXX_Merge(src proto.Message)

func (*CountDLQMessagesResponse) XXX_Size

func (m *CountDLQMessagesResponse) XXX_Size() int

func (*CountDLQMessagesResponse) XXX_Unmarshal

func (m *CountDLQMessagesResponse) XXX_Unmarshal(b []byte) error

type CrossClusterApplyParentClosePolicyRequestAttributes

type CrossClusterApplyParentClosePolicyRequestAttributes struct {
	Children             []*ApplyParentClosePolicyRequest `protobuf:"bytes,1,rep,name=children,proto3" json:"children,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                         `json:"-"`
	XXX_unrecognized     []byte                           `json:"-"`
	XXX_sizecache        int32                            `json:"-"`
}

func (*CrossClusterApplyParentClosePolicyRequestAttributes) Descriptor

func (*CrossClusterApplyParentClosePolicyRequestAttributes) GetChildren

func (*CrossClusterApplyParentClosePolicyRequestAttributes) Marshal

func (*CrossClusterApplyParentClosePolicyRequestAttributes) MarshalTo

func (*CrossClusterApplyParentClosePolicyRequestAttributes) MarshalToSizedBuffer

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

func (*CrossClusterApplyParentClosePolicyRequestAttributes) ProtoMessage

func (*CrossClusterApplyParentClosePolicyRequestAttributes) Reset

func (*CrossClusterApplyParentClosePolicyRequestAttributes) Size

func (*CrossClusterApplyParentClosePolicyRequestAttributes) String

func (*CrossClusterApplyParentClosePolicyRequestAttributes) Unmarshal

func (*CrossClusterApplyParentClosePolicyRequestAttributes) XXX_DiscardUnknown

func (*CrossClusterApplyParentClosePolicyRequestAttributes) XXX_Marshal

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

func (*CrossClusterApplyParentClosePolicyRequestAttributes) XXX_Merge

func (*CrossClusterApplyParentClosePolicyRequestAttributes) XXX_Size

func (*CrossClusterApplyParentClosePolicyRequestAttributes) XXX_Unmarshal

type CrossClusterApplyParentClosePolicyResponseAttributes

type CrossClusterApplyParentClosePolicyResponseAttributes struct {
	ChildrenStatus       []*ApplyParentClosePolicyResult `protobuf:"bytes,1,rep,name=children_status,json=childrenStatus,proto3" json:"children_status,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                        `json:"-"`
	XXX_unrecognized     []byte                          `json:"-"`
	XXX_sizecache        int32                           `json:"-"`
}

func (*CrossClusterApplyParentClosePolicyResponseAttributes) Descriptor

func (*CrossClusterApplyParentClosePolicyResponseAttributes) GetChildrenStatus

func (*CrossClusterApplyParentClosePolicyResponseAttributes) Marshal

func (*CrossClusterApplyParentClosePolicyResponseAttributes) MarshalTo

func (*CrossClusterApplyParentClosePolicyResponseAttributes) MarshalToSizedBuffer

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

func (*CrossClusterApplyParentClosePolicyResponseAttributes) ProtoMessage

func (*CrossClusterApplyParentClosePolicyResponseAttributes) Reset

func (*CrossClusterApplyParentClosePolicyResponseAttributes) Size

func (*CrossClusterApplyParentClosePolicyResponseAttributes) String

func (*CrossClusterApplyParentClosePolicyResponseAttributes) Unmarshal

func (*CrossClusterApplyParentClosePolicyResponseAttributes) XXX_DiscardUnknown

func (*CrossClusterApplyParentClosePolicyResponseAttributes) XXX_Marshal

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

func (*CrossClusterApplyParentClosePolicyResponseAttributes) XXX_Merge

func (*CrossClusterApplyParentClosePolicyResponseAttributes) XXX_Size

func (*CrossClusterApplyParentClosePolicyResponseAttributes) XXX_Unmarshal

type CrossClusterCancelExecutionRequestAttributes

type CrossClusterCancelExecutionRequestAttributes struct {
	TargetDomainId          string                `protobuf:"bytes,1,opt,name=target_domain_id,json=targetDomainId,proto3" json:"target_domain_id,omitempty"`
	TargetWorkflowExecution *v1.WorkflowExecution `` /* 132-byte string literal not displayed */
	RequestId               string                `protobuf:"bytes,3,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	InitiatedEventId        int64                 `protobuf:"varint,4,opt,name=initiated_event_id,json=initiatedEventId,proto3" json:"initiated_event_id,omitempty"`
	ChildWorkflowOnly       bool                  `protobuf:"varint,5,opt,name=child_workflow_only,json=childWorkflowOnly,proto3" json:"child_workflow_only,omitempty"`
	XXX_NoUnkeyedLiteral    struct{}              `json:"-"`
	XXX_unrecognized        []byte                `json:"-"`
	XXX_sizecache           int32                 `json:"-"`
}

func (*CrossClusterCancelExecutionRequestAttributes) Descriptor

func (*CrossClusterCancelExecutionRequestAttributes) GetChildWorkflowOnly

func (m *CrossClusterCancelExecutionRequestAttributes) GetChildWorkflowOnly() bool

func (*CrossClusterCancelExecutionRequestAttributes) GetInitiatedEventId

func (m *CrossClusterCancelExecutionRequestAttributes) GetInitiatedEventId() int64

func (*CrossClusterCancelExecutionRequestAttributes) GetRequestId

func (*CrossClusterCancelExecutionRequestAttributes) GetTargetDomainId

func (*CrossClusterCancelExecutionRequestAttributes) GetTargetWorkflowExecution

func (m *CrossClusterCancelExecutionRequestAttributes) GetTargetWorkflowExecution() *v1.WorkflowExecution

func (*CrossClusterCancelExecutionRequestAttributes) Marshal

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

func (*CrossClusterCancelExecutionRequestAttributes) MarshalTo

func (*CrossClusterCancelExecutionRequestAttributes) MarshalToSizedBuffer

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

func (*CrossClusterCancelExecutionRequestAttributes) ProtoMessage

func (*CrossClusterCancelExecutionRequestAttributes) Reset

func (*CrossClusterCancelExecutionRequestAttributes) Size

func (*CrossClusterCancelExecutionRequestAttributes) String

func (*CrossClusterCancelExecutionRequestAttributes) Unmarshal

func (*CrossClusterCancelExecutionRequestAttributes) XXX_DiscardUnknown

func (m *CrossClusterCancelExecutionRequestAttributes) XXX_DiscardUnknown()

func (*CrossClusterCancelExecutionRequestAttributes) XXX_Marshal

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

func (*CrossClusterCancelExecutionRequestAttributes) XXX_Merge

func (*CrossClusterCancelExecutionRequestAttributes) XXX_Size

func (*CrossClusterCancelExecutionRequestAttributes) XXX_Unmarshal

type CrossClusterCancelExecutionResponseAttributes

type CrossClusterCancelExecutionResponseAttributes struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CrossClusterCancelExecutionResponseAttributes) Descriptor

func (*CrossClusterCancelExecutionResponseAttributes) Marshal

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

func (*CrossClusterCancelExecutionResponseAttributes) MarshalTo

func (*CrossClusterCancelExecutionResponseAttributes) MarshalToSizedBuffer

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

func (*CrossClusterCancelExecutionResponseAttributes) ProtoMessage

func (*CrossClusterCancelExecutionResponseAttributes) Reset

func (*CrossClusterCancelExecutionResponseAttributes) Size

func (*CrossClusterCancelExecutionResponseAttributes) String

func (*CrossClusterCancelExecutionResponseAttributes) Unmarshal

func (*CrossClusterCancelExecutionResponseAttributes) XXX_DiscardUnknown

func (m *CrossClusterCancelExecutionResponseAttributes) XXX_DiscardUnknown()

func (*CrossClusterCancelExecutionResponseAttributes) XXX_Marshal

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

func (*CrossClusterCancelExecutionResponseAttributes) XXX_Merge

func (*CrossClusterCancelExecutionResponseAttributes) XXX_Size

func (*CrossClusterCancelExecutionResponseAttributes) XXX_Unmarshal

type CrossClusterRecordChildWorkflowExecutionCompleteRequestAttributes

type CrossClusterRecordChildWorkflowExecutionCompleteRequestAttributes struct {
	TargetDomainId          string                `protobuf:"bytes,1,opt,name=target_domain_id,json=targetDomainId,proto3" json:"target_domain_id,omitempty"`
	TargetWorkflowExecution *v1.WorkflowExecution `` /* 132-byte string literal not displayed */
	InitiatedEventId        int64                 `protobuf:"varint,3,opt,name=initiated_event_id,json=initiatedEventId,proto3" json:"initiated_event_id,omitempty"`
	CompletionEvent         *v1.HistoryEvent      `protobuf:"bytes,4,opt,name=completion_event,json=completionEvent,proto3" json:"completion_event,omitempty"`
	XXX_NoUnkeyedLiteral    struct{}              `json:"-"`
	XXX_unrecognized        []byte                `json:"-"`
	XXX_sizecache           int32                 `json:"-"`
}

func (*CrossClusterRecordChildWorkflowExecutionCompleteRequestAttributes) Descriptor

func (*CrossClusterRecordChildWorkflowExecutionCompleteRequestAttributes) GetCompletionEvent

func (*CrossClusterRecordChildWorkflowExecutionCompleteRequestAttributes) GetInitiatedEventId

func (*CrossClusterRecordChildWorkflowExecutionCompleteRequestAttributes) GetTargetDomainId

func (*CrossClusterRecordChildWorkflowExecutionCompleteRequestAttributes) GetTargetWorkflowExecution

func (*CrossClusterRecordChildWorkflowExecutionCompleteRequestAttributes) Marshal

func (*CrossClusterRecordChildWorkflowExecutionCompleteRequestAttributes) MarshalTo

func (*CrossClusterRecordChildWorkflowExecutionCompleteRequestAttributes) MarshalToSizedBuffer

func (*CrossClusterRecordChildWorkflowExecutionCompleteRequestAttributes) ProtoMessage

func (*CrossClusterRecordChildWorkflowExecutionCompleteRequestAttributes) Reset

func (*CrossClusterRecordChildWorkflowExecutionCompleteRequestAttributes) Size

func (*CrossClusterRecordChildWorkflowExecutionCompleteRequestAttributes) String

func (*CrossClusterRecordChildWorkflowExecutionCompleteRequestAttributes) Unmarshal

func (*CrossClusterRecordChildWorkflowExecutionCompleteRequestAttributes) XXX_DiscardUnknown

func (*CrossClusterRecordChildWorkflowExecutionCompleteRequestAttributes) XXX_Marshal

func (*CrossClusterRecordChildWorkflowExecutionCompleteRequestAttributes) XXX_Merge

func (*CrossClusterRecordChildWorkflowExecutionCompleteRequestAttributes) XXX_Size

func (*CrossClusterRecordChildWorkflowExecutionCompleteRequestAttributes) XXX_Unmarshal

type CrossClusterRecordChildWorkflowExecutionCompleteResponseAttributes

type CrossClusterRecordChildWorkflowExecutionCompleteResponseAttributes struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CrossClusterRecordChildWorkflowExecutionCompleteResponseAttributes) Descriptor

func (*CrossClusterRecordChildWorkflowExecutionCompleteResponseAttributes) Marshal

func (*CrossClusterRecordChildWorkflowExecutionCompleteResponseAttributes) MarshalTo

func (*CrossClusterRecordChildWorkflowExecutionCompleteResponseAttributes) MarshalToSizedBuffer

func (*CrossClusterRecordChildWorkflowExecutionCompleteResponseAttributes) ProtoMessage

func (*CrossClusterRecordChildWorkflowExecutionCompleteResponseAttributes) Reset

func (*CrossClusterRecordChildWorkflowExecutionCompleteResponseAttributes) Size

func (*CrossClusterRecordChildWorkflowExecutionCompleteResponseAttributes) String

func (*CrossClusterRecordChildWorkflowExecutionCompleteResponseAttributes) Unmarshal

func (*CrossClusterRecordChildWorkflowExecutionCompleteResponseAttributes) XXX_DiscardUnknown

func (*CrossClusterRecordChildWorkflowExecutionCompleteResponseAttributes) XXX_Marshal

func (*CrossClusterRecordChildWorkflowExecutionCompleteResponseAttributes) XXX_Merge

func (*CrossClusterRecordChildWorkflowExecutionCompleteResponseAttributes) XXX_Size

func (*CrossClusterRecordChildWorkflowExecutionCompleteResponseAttributes) XXX_Unmarshal

type CrossClusterSignalExecutionRequestAttributes

type CrossClusterSignalExecutionRequestAttributes struct {
	TargetDomainId          string                `protobuf:"bytes,1,opt,name=target_domain_id,json=targetDomainId,proto3" json:"target_domain_id,omitempty"`
	TargetWorkflowExecution *v1.WorkflowExecution `` /* 132-byte string literal not displayed */
	RequestId               string                `protobuf:"bytes,3,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	InitiatedEventId        int64                 `protobuf:"varint,4,opt,name=initiated_event_id,json=initiatedEventId,proto3" json:"initiated_event_id,omitempty"`
	ChildWorkflowOnly       bool                  `protobuf:"varint,5,opt,name=child_workflow_only,json=childWorkflowOnly,proto3" json:"child_workflow_only,omitempty"`
	SignalName              string                `protobuf:"bytes,6,opt,name=signal_name,json=signalName,proto3" json:"signal_name,omitempty"`
	SignalInput             *v1.Payload           `protobuf:"bytes,7,opt,name=signal_input,json=signalInput,proto3" json:"signal_input,omitempty"`
	Control                 []byte                `protobuf:"bytes,8,opt,name=control,proto3" json:"control,omitempty"`
	XXX_NoUnkeyedLiteral    struct{}              `json:"-"`
	XXX_unrecognized        []byte                `json:"-"`
	XXX_sizecache           int32                 `json:"-"`
}

func (*CrossClusterSignalExecutionRequestAttributes) Descriptor

func (*CrossClusterSignalExecutionRequestAttributes) GetChildWorkflowOnly

func (m *CrossClusterSignalExecutionRequestAttributes) GetChildWorkflowOnly() bool

func (*CrossClusterSignalExecutionRequestAttributes) GetControl

func (*CrossClusterSignalExecutionRequestAttributes) GetInitiatedEventId

func (m *CrossClusterSignalExecutionRequestAttributes) GetInitiatedEventId() int64

func (*CrossClusterSignalExecutionRequestAttributes) GetRequestId

func (*CrossClusterSignalExecutionRequestAttributes) GetSignalInput

func (*CrossClusterSignalExecutionRequestAttributes) GetSignalName

func (*CrossClusterSignalExecutionRequestAttributes) GetTargetDomainId

func (*CrossClusterSignalExecutionRequestAttributes) GetTargetWorkflowExecution

func (m *CrossClusterSignalExecutionRequestAttributes) GetTargetWorkflowExecution() *v1.WorkflowExecution

func (*CrossClusterSignalExecutionRequestAttributes) Marshal

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

func (*CrossClusterSignalExecutionRequestAttributes) MarshalTo

func (*CrossClusterSignalExecutionRequestAttributes) MarshalToSizedBuffer

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

func (*CrossClusterSignalExecutionRequestAttributes) ProtoMessage

func (*CrossClusterSignalExecutionRequestAttributes) Reset

func (*CrossClusterSignalExecutionRequestAttributes) Size

func (*CrossClusterSignalExecutionRequestAttributes) String

func (*CrossClusterSignalExecutionRequestAttributes) Unmarshal

func (*CrossClusterSignalExecutionRequestAttributes) XXX_DiscardUnknown

func (m *CrossClusterSignalExecutionRequestAttributes) XXX_DiscardUnknown()

func (*CrossClusterSignalExecutionRequestAttributes) XXX_Marshal

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

func (*CrossClusterSignalExecutionRequestAttributes) XXX_Merge

func (*CrossClusterSignalExecutionRequestAttributes) XXX_Size

func (*CrossClusterSignalExecutionRequestAttributes) XXX_Unmarshal

type CrossClusterSignalExecutionResponseAttributes

type CrossClusterSignalExecutionResponseAttributes struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CrossClusterSignalExecutionResponseAttributes) Descriptor

func (*CrossClusterSignalExecutionResponseAttributes) Marshal

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

func (*CrossClusterSignalExecutionResponseAttributes) MarshalTo

func (*CrossClusterSignalExecutionResponseAttributes) MarshalToSizedBuffer

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

func (*CrossClusterSignalExecutionResponseAttributes) ProtoMessage

func (*CrossClusterSignalExecutionResponseAttributes) Reset

func (*CrossClusterSignalExecutionResponseAttributes) Size

func (*CrossClusterSignalExecutionResponseAttributes) String

func (*CrossClusterSignalExecutionResponseAttributes) Unmarshal

func (*CrossClusterSignalExecutionResponseAttributes) XXX_DiscardUnknown

func (m *CrossClusterSignalExecutionResponseAttributes) XXX_DiscardUnknown()

func (*CrossClusterSignalExecutionResponseAttributes) XXX_Marshal

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

func (*CrossClusterSignalExecutionResponseAttributes) XXX_Merge

func (*CrossClusterSignalExecutionResponseAttributes) XXX_Size

func (*CrossClusterSignalExecutionResponseAttributes) XXX_Unmarshal

type CrossClusterStartChildExecutionRequestAttributes

type CrossClusterStartChildExecutionRequestAttributes struct {
	TargetDomainId           string                                                  `protobuf:"bytes,1,opt,name=target_domain_id,json=targetDomainId,proto3" json:"target_domain_id,omitempty"`
	RequestId                string                                                  `protobuf:"bytes,2,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	InitiatedEventId         int64                                                   `protobuf:"varint,3,opt,name=initiated_event_id,json=initiatedEventId,proto3" json:"initiated_event_id,omitempty"`
	InitiatedEventAttributes *v1.StartChildWorkflowExecutionInitiatedEventAttributes `` /* 135-byte string literal not displayed */
	// targetRunID is for scheduling first decision task
	// targetWorkflowID is available in initiatedEventAttributes
	TargetRunId          string            `protobuf:"bytes,5,opt,name=target_run_id,json=targetRunId,proto3" json:"target_run_id,omitempty"`
	PartitionConfig      map[string]string `` /* 194-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*CrossClusterStartChildExecutionRequestAttributes) Descriptor

func (*CrossClusterStartChildExecutionRequestAttributes) GetInitiatedEventAttributes

func (*CrossClusterStartChildExecutionRequestAttributes) GetInitiatedEventId

func (*CrossClusterStartChildExecutionRequestAttributes) GetPartitionConfig

func (*CrossClusterStartChildExecutionRequestAttributes) GetRequestId

func (*CrossClusterStartChildExecutionRequestAttributes) GetTargetDomainId

func (*CrossClusterStartChildExecutionRequestAttributes) GetTargetRunId

func (*CrossClusterStartChildExecutionRequestAttributes) Marshal

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

func (*CrossClusterStartChildExecutionRequestAttributes) MarshalTo

func (*CrossClusterStartChildExecutionRequestAttributes) MarshalToSizedBuffer

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

func (*CrossClusterStartChildExecutionRequestAttributes) ProtoMessage

func (*CrossClusterStartChildExecutionRequestAttributes) Reset

func (*CrossClusterStartChildExecutionRequestAttributes) Size

func (*CrossClusterStartChildExecutionRequestAttributes) String

func (*CrossClusterStartChildExecutionRequestAttributes) Unmarshal

func (*CrossClusterStartChildExecutionRequestAttributes) XXX_DiscardUnknown

func (m *CrossClusterStartChildExecutionRequestAttributes) XXX_DiscardUnknown()

func (*CrossClusterStartChildExecutionRequestAttributes) XXX_Marshal

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

func (*CrossClusterStartChildExecutionRequestAttributes) XXX_Merge

func (*CrossClusterStartChildExecutionRequestAttributes) XXX_Size

func (*CrossClusterStartChildExecutionRequestAttributes) XXX_Unmarshal

type CrossClusterStartChildExecutionResponseAttributes

type CrossClusterStartChildExecutionResponseAttributes struct {
	RunId                string   `protobuf:"bytes,1,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CrossClusterStartChildExecutionResponseAttributes) Descriptor

func (*CrossClusterStartChildExecutionResponseAttributes) GetRunId

func (*CrossClusterStartChildExecutionResponseAttributes) Marshal

func (*CrossClusterStartChildExecutionResponseAttributes) MarshalTo

func (*CrossClusterStartChildExecutionResponseAttributes) MarshalToSizedBuffer

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

func (*CrossClusterStartChildExecutionResponseAttributes) ProtoMessage

func (*CrossClusterStartChildExecutionResponseAttributes) Reset

func (*CrossClusterStartChildExecutionResponseAttributes) Size

func (*CrossClusterStartChildExecutionResponseAttributes) String

func (*CrossClusterStartChildExecutionResponseAttributes) Unmarshal

func (*CrossClusterStartChildExecutionResponseAttributes) XXX_DiscardUnknown

func (m *CrossClusterStartChildExecutionResponseAttributes) XXX_DiscardUnknown()

func (*CrossClusterStartChildExecutionResponseAttributes) XXX_Marshal

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

func (*CrossClusterStartChildExecutionResponseAttributes) XXX_Merge

func (*CrossClusterStartChildExecutionResponseAttributes) XXX_Size

func (*CrossClusterStartChildExecutionResponseAttributes) XXX_Unmarshal

type CrossClusterTaskFailedCause

type CrossClusterTaskFailedCause int32
const (
	CrossClusterTaskFailedCause_CROSS_CLUSTER_TASK_FAILED_CAUSE_INVALID                    CrossClusterTaskFailedCause = 0
	CrossClusterTaskFailedCause_CROSS_CLUSTER_TASK_FAILED_CAUSE_DOMAIN_NOT_ACTIVE          CrossClusterTaskFailedCause = 1
	CrossClusterTaskFailedCause_CROSS_CLUSTER_TASK_FAILED_CAUSE_DOMAIN_NOT_EXISTS          CrossClusterTaskFailedCause = 2
	CrossClusterTaskFailedCause_CROSS_CLUSTER_TASK_FAILED_CAUSE_WORKFLOW_ALREADY_RUNNING   CrossClusterTaskFailedCause = 3
	CrossClusterTaskFailedCause_CROSS_CLUSTER_TASK_FAILED_CAUSE_WORKFLOW_NOT_EXISTS        CrossClusterTaskFailedCause = 4
	CrossClusterTaskFailedCause_CROSS_CLUSTER_TASK_FAILED_CAUSE_WORKFLOW_ALREADY_COMPLETED CrossClusterTaskFailedCause = 5
	CrossClusterTaskFailedCause_CROSS_CLUSTER_TASK_FAILED_CAUSE_UNCATEGORIZED              CrossClusterTaskFailedCause = 6
)

func (CrossClusterTaskFailedCause) EnumDescriptor

func (CrossClusterTaskFailedCause) EnumDescriptor() ([]byte, []int)

func (CrossClusterTaskFailedCause) String

type CrossClusterTaskInfo

type CrossClusterTaskInfo struct {
	DomainId             string                `protobuf:"bytes,1,opt,name=domain_id,json=domainId,proto3" json:"domain_id,omitempty"`
	WorkflowExecution    *v1.WorkflowExecution `protobuf:"bytes,2,opt,name=workflow_execution,json=workflowExecution,proto3" json:"workflow_execution,omitempty"`
	TaskType             CrossClusterTaskType  `` /* 134-byte string literal not displayed */
	TaskState            int32                 `protobuf:"varint,4,opt,name=task_state,json=taskState,proto3" json:"task_state,omitempty"`
	TaskId               int64                 `protobuf:"varint,5,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	VisibilityTimestamp  *types.Timestamp      `protobuf:"bytes,6,opt,name=visibility_timestamp,json=visibilityTimestamp,proto3" json:"visibility_timestamp,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*CrossClusterTaskInfo) Descriptor

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

func (*CrossClusterTaskInfo) GetDomainId

func (m *CrossClusterTaskInfo) GetDomainId() string

func (*CrossClusterTaskInfo) GetTaskId

func (m *CrossClusterTaskInfo) GetTaskId() int64

func (*CrossClusterTaskInfo) GetTaskState

func (m *CrossClusterTaskInfo) GetTaskState() int32

func (*CrossClusterTaskInfo) GetTaskType

func (m *CrossClusterTaskInfo) GetTaskType() CrossClusterTaskType

func (*CrossClusterTaskInfo) GetVisibilityTimestamp

func (m *CrossClusterTaskInfo) GetVisibilityTimestamp() *types.Timestamp

func (*CrossClusterTaskInfo) GetWorkflowExecution

func (m *CrossClusterTaskInfo) GetWorkflowExecution() *v1.WorkflowExecution

func (*CrossClusterTaskInfo) Marshal

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

func (*CrossClusterTaskInfo) MarshalTo

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

func (*CrossClusterTaskInfo) MarshalToSizedBuffer

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

func (*CrossClusterTaskInfo) ProtoMessage

func (*CrossClusterTaskInfo) ProtoMessage()

func (*CrossClusterTaskInfo) Reset

func (m *CrossClusterTaskInfo) Reset()

func (*CrossClusterTaskInfo) Size

func (m *CrossClusterTaskInfo) Size() (n int)

func (*CrossClusterTaskInfo) String

func (m *CrossClusterTaskInfo) String() string

func (*CrossClusterTaskInfo) Unmarshal

func (m *CrossClusterTaskInfo) Unmarshal(dAtA []byte) error

func (*CrossClusterTaskInfo) XXX_DiscardUnknown

func (m *CrossClusterTaskInfo) XXX_DiscardUnknown()

func (*CrossClusterTaskInfo) XXX_Marshal

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

func (*CrossClusterTaskInfo) XXX_Merge

func (m *CrossClusterTaskInfo) XXX_Merge(src proto.Message)

func (*CrossClusterTaskInfo) XXX_Size

func (m *CrossClusterTaskInfo) XXX_Size() int

func (*CrossClusterTaskInfo) XXX_Unmarshal

func (m *CrossClusterTaskInfo) XXX_Unmarshal(b []byte) error

type CrossClusterTaskRequest

type CrossClusterTaskRequest struct {
	TaskInfo *CrossClusterTaskInfo `protobuf:"bytes,1,opt,name=task_info,json=taskInfo,proto3" json:"task_info,omitempty"`
	// Types that are valid to be assigned to Attributes:
	//	*CrossClusterTaskRequest_StartChildExecutionAttributes
	//	*CrossClusterTaskRequest_CancelExecutionAttributes
	//	*CrossClusterTaskRequest_SignalExecutionAttributes
	//	*CrossClusterTaskRequest_RecordChildWorkflowExecutionCompleteRequestAttributes
	//	*CrossClusterTaskRequest_ApplyParentClosePolicyRequestAttributes
	Attributes           isCrossClusterTaskRequest_Attributes `protobuf_oneof:"attributes"`
	XXX_NoUnkeyedLiteral struct{}                             `json:"-"`
	XXX_unrecognized     []byte                               `json:"-"`
	XXX_sizecache        int32                                `json:"-"`
}

func (*CrossClusterTaskRequest) Descriptor

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

func (*CrossClusterTaskRequest) GetApplyParentClosePolicyRequestAttributes

func (m *CrossClusterTaskRequest) GetApplyParentClosePolicyRequestAttributes() *CrossClusterApplyParentClosePolicyRequestAttributes

func (*CrossClusterTaskRequest) GetAttributes

func (m *CrossClusterTaskRequest) GetAttributes() isCrossClusterTaskRequest_Attributes

func (*CrossClusterTaskRequest) GetCancelExecutionAttributes

func (m *CrossClusterTaskRequest) GetCancelExecutionAttributes() *CrossClusterCancelExecutionRequestAttributes

func (*CrossClusterTaskRequest) GetRecordChildWorkflowExecutionCompleteRequestAttributes

func (m *CrossClusterTaskRequest) GetRecordChildWorkflowExecutionCompleteRequestAttributes() *CrossClusterRecordChildWorkflowExecutionCompleteRequestAttributes

func (*CrossClusterTaskRequest) GetSignalExecutionAttributes

func (m *CrossClusterTaskRequest) GetSignalExecutionAttributes() *CrossClusterSignalExecutionRequestAttributes

func (*CrossClusterTaskRequest) GetStartChildExecutionAttributes

func (m *CrossClusterTaskRequest) GetStartChildExecutionAttributes() *CrossClusterStartChildExecutionRequestAttributes

func (*CrossClusterTaskRequest) GetTaskInfo

func (*CrossClusterTaskRequest) Marshal

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

func (*CrossClusterTaskRequest) MarshalTo

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

func (*CrossClusterTaskRequest) MarshalToSizedBuffer

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

func (*CrossClusterTaskRequest) ProtoMessage

func (*CrossClusterTaskRequest) ProtoMessage()

func (*CrossClusterTaskRequest) Reset

func (m *CrossClusterTaskRequest) Reset()

func (*CrossClusterTaskRequest) Size

func (m *CrossClusterTaskRequest) Size() (n int)

func (*CrossClusterTaskRequest) String

func (m *CrossClusterTaskRequest) String() string

func (*CrossClusterTaskRequest) Unmarshal

func (m *CrossClusterTaskRequest) Unmarshal(dAtA []byte) error

func (*CrossClusterTaskRequest) XXX_DiscardUnknown

func (m *CrossClusterTaskRequest) XXX_DiscardUnknown()

func (*CrossClusterTaskRequest) XXX_Marshal

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

func (*CrossClusterTaskRequest) XXX_Merge

func (m *CrossClusterTaskRequest) XXX_Merge(src proto.Message)

func (*CrossClusterTaskRequest) XXX_OneofWrappers

func (*CrossClusterTaskRequest) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*CrossClusterTaskRequest) XXX_Size

func (m *CrossClusterTaskRequest) XXX_Size() int

func (*CrossClusterTaskRequest) XXX_Unmarshal

func (m *CrossClusterTaskRequest) XXX_Unmarshal(b []byte) error

type CrossClusterTaskRequest_ApplyParentClosePolicyRequestAttributes

type CrossClusterTaskRequest_ApplyParentClosePolicyRequestAttributes struct {
	ApplyParentClosePolicyRequestAttributes *CrossClusterApplyParentClosePolicyRequestAttributes `` /* 192-byte string literal not displayed */
}

func (*CrossClusterTaskRequest_ApplyParentClosePolicyRequestAttributes) MarshalTo

func (*CrossClusterTaskRequest_ApplyParentClosePolicyRequestAttributes) MarshalToSizedBuffer

func (*CrossClusterTaskRequest_ApplyParentClosePolicyRequestAttributes) Size

type CrossClusterTaskRequest_CancelExecutionAttributes

type CrossClusterTaskRequest_CancelExecutionAttributes struct {
	CancelExecutionAttributes *CrossClusterCancelExecutionRequestAttributes `` /* 144-byte string literal not displayed */
}

func (*CrossClusterTaskRequest_CancelExecutionAttributes) MarshalTo

func (*CrossClusterTaskRequest_CancelExecutionAttributes) MarshalToSizedBuffer

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

func (*CrossClusterTaskRequest_CancelExecutionAttributes) Size

type CrossClusterTaskRequest_RecordChildWorkflowExecutionCompleteRequestAttributes

type CrossClusterTaskRequest_RecordChildWorkflowExecutionCompleteRequestAttributes struct {
	RecordChildWorkflowExecutionCompleteRequestAttributes *CrossClusterRecordChildWorkflowExecutionCompleteRequestAttributes `` /* 236-byte string literal not displayed */
}

func (*CrossClusterTaskRequest_RecordChildWorkflowExecutionCompleteRequestAttributes) MarshalTo

func (*CrossClusterTaskRequest_RecordChildWorkflowExecutionCompleteRequestAttributes) MarshalToSizedBuffer

func (*CrossClusterTaskRequest_RecordChildWorkflowExecutionCompleteRequestAttributes) Size

type CrossClusterTaskRequest_SignalExecutionAttributes

type CrossClusterTaskRequest_SignalExecutionAttributes struct {
	SignalExecutionAttributes *CrossClusterSignalExecutionRequestAttributes `` /* 144-byte string literal not displayed */
}

func (*CrossClusterTaskRequest_SignalExecutionAttributes) MarshalTo

func (*CrossClusterTaskRequest_SignalExecutionAttributes) MarshalToSizedBuffer

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

func (*CrossClusterTaskRequest_SignalExecutionAttributes) Size

type CrossClusterTaskRequest_StartChildExecutionAttributes

type CrossClusterTaskRequest_StartChildExecutionAttributes struct {
	StartChildExecutionAttributes *CrossClusterStartChildExecutionRequestAttributes `` /* 158-byte string literal not displayed */
}

func (*CrossClusterTaskRequest_StartChildExecutionAttributes) MarshalTo

func (*CrossClusterTaskRequest_StartChildExecutionAttributes) MarshalToSizedBuffer

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

func (*CrossClusterTaskRequest_StartChildExecutionAttributes) Size

type CrossClusterTaskRequests

type CrossClusterTaskRequests struct {
	TaskRequests         []*CrossClusterTaskRequest `protobuf:"bytes,1,rep,name=task_requests,json=taskRequests,proto3" json:"task_requests,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                   `json:"-"`
	XXX_unrecognized     []byte                     `json:"-"`
	XXX_sizecache        int32                      `json:"-"`
}

func (*CrossClusterTaskRequests) Descriptor

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

func (*CrossClusterTaskRequests) GetTaskRequests

func (m *CrossClusterTaskRequests) GetTaskRequests() []*CrossClusterTaskRequest

func (*CrossClusterTaskRequests) Marshal

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

func (*CrossClusterTaskRequests) MarshalTo

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

func (*CrossClusterTaskRequests) MarshalToSizedBuffer

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

func (*CrossClusterTaskRequests) ProtoMessage

func (*CrossClusterTaskRequests) ProtoMessage()

func (*CrossClusterTaskRequests) Reset

func (m *CrossClusterTaskRequests) Reset()

func (*CrossClusterTaskRequests) Size

func (m *CrossClusterTaskRequests) Size() (n int)

func (*CrossClusterTaskRequests) String

func (m *CrossClusterTaskRequests) String() string

func (*CrossClusterTaskRequests) Unmarshal

func (m *CrossClusterTaskRequests) Unmarshal(dAtA []byte) error

func (*CrossClusterTaskRequests) XXX_DiscardUnknown

func (m *CrossClusterTaskRequests) XXX_DiscardUnknown()

func (*CrossClusterTaskRequests) XXX_Marshal

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

func (*CrossClusterTaskRequests) XXX_Merge

func (m *CrossClusterTaskRequests) XXX_Merge(src proto.Message)

func (*CrossClusterTaskRequests) XXX_Size

func (m *CrossClusterTaskRequests) XXX_Size() int

func (*CrossClusterTaskRequests) XXX_Unmarshal

func (m *CrossClusterTaskRequests) XXX_Unmarshal(b []byte) error

type CrossClusterTaskResponse

type CrossClusterTaskResponse struct {
	TaskId      int64                       `protobuf:"varint,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	TaskType    CrossClusterTaskType        `` /* 134-byte string literal not displayed */
	TaskState   int32                       `protobuf:"varint,3,opt,name=task_state,json=taskState,proto3" json:"task_state,omitempty"`
	FailedCause CrossClusterTaskFailedCause `` /* 150-byte string literal not displayed */
	// Types that are valid to be assigned to Attributes:
	//	*CrossClusterTaskResponse_StartChildExecutionAttributes
	//	*CrossClusterTaskResponse_CancelExecutionAttributes
	//	*CrossClusterTaskResponse_SignalExecutionAttributes
	//	*CrossClusterTaskResponse_RecordChildWorkflowExecutionCompleteRequestAttributes
	//	*CrossClusterTaskResponse_ApplyParentClosePolicyResponseAttributes
	Attributes           isCrossClusterTaskResponse_Attributes `protobuf_oneof:"attributes"`
	XXX_NoUnkeyedLiteral struct{}                              `json:"-"`
	XXX_unrecognized     []byte                                `json:"-"`
	XXX_sizecache        int32                                 `json:"-"`
}

func (*CrossClusterTaskResponse) Descriptor

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

func (*CrossClusterTaskResponse) GetApplyParentClosePolicyResponseAttributes

func (m *CrossClusterTaskResponse) GetApplyParentClosePolicyResponseAttributes() *CrossClusterApplyParentClosePolicyResponseAttributes

func (*CrossClusterTaskResponse) GetAttributes

func (m *CrossClusterTaskResponse) GetAttributes() isCrossClusterTaskResponse_Attributes

func (*CrossClusterTaskResponse) GetCancelExecutionAttributes

func (*CrossClusterTaskResponse) GetFailedCause

func (*CrossClusterTaskResponse) GetRecordChildWorkflowExecutionCompleteRequestAttributes

func (m *CrossClusterTaskResponse) GetRecordChildWorkflowExecutionCompleteRequestAttributes() *CrossClusterRecordChildWorkflowExecutionCompleteResponseAttributes

func (*CrossClusterTaskResponse) GetSignalExecutionAttributes

func (*CrossClusterTaskResponse) GetStartChildExecutionAttributes

func (m *CrossClusterTaskResponse) GetStartChildExecutionAttributes() *CrossClusterStartChildExecutionResponseAttributes

func (*CrossClusterTaskResponse) GetTaskId

func (m *CrossClusterTaskResponse) GetTaskId() int64

func (*CrossClusterTaskResponse) GetTaskState

func (m *CrossClusterTaskResponse) GetTaskState() int32

func (*CrossClusterTaskResponse) GetTaskType

func (*CrossClusterTaskResponse) Marshal

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

func (*CrossClusterTaskResponse) MarshalTo

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

func (*CrossClusterTaskResponse) MarshalToSizedBuffer

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

func (*CrossClusterTaskResponse) ProtoMessage

func (*CrossClusterTaskResponse) ProtoMessage()

func (*CrossClusterTaskResponse) Reset

func (m *CrossClusterTaskResponse) Reset()

func (*CrossClusterTaskResponse) Size

func (m *CrossClusterTaskResponse) Size() (n int)

func (*CrossClusterTaskResponse) String

func (m *CrossClusterTaskResponse) String() string

func (*CrossClusterTaskResponse) Unmarshal

func (m *CrossClusterTaskResponse) Unmarshal(dAtA []byte) error

func (*CrossClusterTaskResponse) XXX_DiscardUnknown

func (m *CrossClusterTaskResponse) XXX_DiscardUnknown()

func (*CrossClusterTaskResponse) XXX_Marshal

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

func (*CrossClusterTaskResponse) XXX_Merge

func (m *CrossClusterTaskResponse) XXX_Merge(src proto.Message)

func (*CrossClusterTaskResponse) XXX_OneofWrappers

func (*CrossClusterTaskResponse) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*CrossClusterTaskResponse) XXX_Size

func (m *CrossClusterTaskResponse) XXX_Size() int

func (*CrossClusterTaskResponse) XXX_Unmarshal

func (m *CrossClusterTaskResponse) XXX_Unmarshal(b []byte) error

type CrossClusterTaskResponse_ApplyParentClosePolicyResponseAttributes

type CrossClusterTaskResponse_ApplyParentClosePolicyResponseAttributes struct {
	ApplyParentClosePolicyResponseAttributes *CrossClusterApplyParentClosePolicyResponseAttributes `` /* 195-byte string literal not displayed */
}

func (*CrossClusterTaskResponse_ApplyParentClosePolicyResponseAttributes) MarshalTo

func (*CrossClusterTaskResponse_ApplyParentClosePolicyResponseAttributes) MarshalToSizedBuffer

func (*CrossClusterTaskResponse_ApplyParentClosePolicyResponseAttributes) Size

type CrossClusterTaskResponse_CancelExecutionAttributes

type CrossClusterTaskResponse_CancelExecutionAttributes struct {
	CancelExecutionAttributes *CrossClusterCancelExecutionResponseAttributes `` /* 144-byte string literal not displayed */
}

func (*CrossClusterTaskResponse_CancelExecutionAttributes) MarshalTo

func (*CrossClusterTaskResponse_CancelExecutionAttributes) MarshalToSizedBuffer

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

func (*CrossClusterTaskResponse_CancelExecutionAttributes) Size

type CrossClusterTaskResponse_RecordChildWorkflowExecutionCompleteRequestAttributes

type CrossClusterTaskResponse_RecordChildWorkflowExecutionCompleteRequestAttributes struct {
	RecordChildWorkflowExecutionCompleteRequestAttributes *CrossClusterRecordChildWorkflowExecutionCompleteResponseAttributes `` /* 236-byte string literal not displayed */
}

func (*CrossClusterTaskResponse_RecordChildWorkflowExecutionCompleteRequestAttributes) MarshalTo

func (*CrossClusterTaskResponse_RecordChildWorkflowExecutionCompleteRequestAttributes) MarshalToSizedBuffer

func (*CrossClusterTaskResponse_RecordChildWorkflowExecutionCompleteRequestAttributes) Size

type CrossClusterTaskResponse_SignalExecutionAttributes

type CrossClusterTaskResponse_SignalExecutionAttributes struct {
	SignalExecutionAttributes *CrossClusterSignalExecutionResponseAttributes `` /* 144-byte string literal not displayed */
}

func (*CrossClusterTaskResponse_SignalExecutionAttributes) MarshalTo

func (*CrossClusterTaskResponse_SignalExecutionAttributes) MarshalToSizedBuffer

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

func (*CrossClusterTaskResponse_SignalExecutionAttributes) Size

type CrossClusterTaskResponse_StartChildExecutionAttributes

type CrossClusterTaskResponse_StartChildExecutionAttributes struct {
	StartChildExecutionAttributes *CrossClusterStartChildExecutionResponseAttributes `` /* 158-byte string literal not displayed */
}

func (*CrossClusterTaskResponse_StartChildExecutionAttributes) MarshalTo

func (*CrossClusterTaskResponse_StartChildExecutionAttributes) MarshalToSizedBuffer

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

func (*CrossClusterTaskResponse_StartChildExecutionAttributes) Size

type CrossClusterTaskType

type CrossClusterTaskType int32
const (
	CrossClusterTaskType_CROSS_CLUSTER_TASK_TYPE_INVALID                                  CrossClusterTaskType = 0
	CrossClusterTaskType_CROSS_CLUSTER_TASK_TYPE_START_CHILD_EXECUTION                    CrossClusterTaskType = 1
	CrossClusterTaskType_CROSS_CLUSTER_TASK_TYPE_CANCEL_EXECUTION                         CrossClusterTaskType = 2
	CrossClusterTaskType_CROSS_CLUSTER_TASK_TYPE_SIGNAL_EXECUTION                         CrossClusterTaskType = 3
	CrossClusterTaskType_CROSS_CLUSTER_TASK_TYPE_RECORD_CHILD_WORKKLOW_EXECUTION_COMPLETE CrossClusterTaskType = 4
	CrossClusterTaskType_CROSS_CLUSTER_TASK_TYPE_APPLY_PARENT_CLOSE_POLICY                CrossClusterTaskType = 5
)

func (CrossClusterTaskType) EnumDescriptor

func (CrossClusterTaskType) EnumDescriptor() ([]byte, []int)

func (CrossClusterTaskType) String

func (x CrossClusterTaskType) String() string

type DLQType

type DLQType int32
const (
	DLQType_DLQ_TYPE_INVALID     DLQType = 0
	DLQType_DLQ_TYPE_REPLICATION DLQType = 1
	DLQType_DLQ_TYPE_DOMAIN      DLQType = 2
)

func (DLQType) EnumDescriptor

func (DLQType) EnumDescriptor() ([]byte, []int)

func (DLQType) String

func (x DLQType) String() string

type DeleteWorkflowRequest

type DeleteWorkflowRequest struct {
	Domain               string                `protobuf:"bytes,1,opt,name=domain,proto3" json:"domain,omitempty"`
	WorkflowExecution    *v1.WorkflowExecution `protobuf:"bytes,2,opt,name=workflow_execution,json=workflowExecution,proto3" json:"workflow_execution,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*DeleteWorkflowRequest) Descriptor

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

func (*DeleteWorkflowRequest) GetDomain

func (m *DeleteWorkflowRequest) GetDomain() string

func (*DeleteWorkflowRequest) GetWorkflowExecution

func (m *DeleteWorkflowRequest) GetWorkflowExecution() *v1.WorkflowExecution

func (*DeleteWorkflowRequest) Marshal

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

func (*DeleteWorkflowRequest) MarshalTo

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

func (*DeleteWorkflowRequest) MarshalToSizedBuffer

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

func (*DeleteWorkflowRequest) ProtoMessage

func (*DeleteWorkflowRequest) ProtoMessage()

func (*DeleteWorkflowRequest) Reset

func (m *DeleteWorkflowRequest) Reset()

func (*DeleteWorkflowRequest) Size

func (m *DeleteWorkflowRequest) Size() (n int)

func (*DeleteWorkflowRequest) String

func (m *DeleteWorkflowRequest) String() string

func (*DeleteWorkflowRequest) Unmarshal

func (m *DeleteWorkflowRequest) Unmarshal(dAtA []byte) error

func (*DeleteWorkflowRequest) XXX_DiscardUnknown

func (m *DeleteWorkflowRequest) XXX_DiscardUnknown()

func (*DeleteWorkflowRequest) XXX_Marshal

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

func (*DeleteWorkflowRequest) XXX_Merge

func (m *DeleteWorkflowRequest) XXX_Merge(src proto.Message)

func (*DeleteWorkflowRequest) XXX_Size

func (m *DeleteWorkflowRequest) XXX_Size() int

func (*DeleteWorkflowRequest) XXX_Unmarshal

func (m *DeleteWorkflowRequest) XXX_Unmarshal(b []byte) error

type DeleteWorkflowResponse

type DeleteWorkflowResponse struct {
	HistoryDeleted       bool     `protobuf:"varint,1,opt,name=history_deleted,json=historyDeleted,proto3" json:"history_deleted,omitempty"`
	ExecutionsDeleted    bool     `protobuf:"varint,2,opt,name=executions_deleted,json=executionsDeleted,proto3" json:"executions_deleted,omitempty"`
	VisibilityDeleted    bool     `protobuf:"varint,3,opt,name=visibility_deleted,json=visibilityDeleted,proto3" json:"visibility_deleted,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DeleteWorkflowResponse) Descriptor

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

func (*DeleteWorkflowResponse) GetExecutionsDeleted

func (m *DeleteWorkflowResponse) GetExecutionsDeleted() bool

func (*DeleteWorkflowResponse) GetHistoryDeleted

func (m *DeleteWorkflowResponse) GetHistoryDeleted() bool

func (*DeleteWorkflowResponse) GetVisibilityDeleted

func (m *DeleteWorkflowResponse) GetVisibilityDeleted() bool

func (*DeleteWorkflowResponse) Marshal

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

func (*DeleteWorkflowResponse) MarshalTo

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

func (*DeleteWorkflowResponse) MarshalToSizedBuffer

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

func (*DeleteWorkflowResponse) ProtoMessage

func (*DeleteWorkflowResponse) ProtoMessage()

func (*DeleteWorkflowResponse) Reset

func (m *DeleteWorkflowResponse) Reset()

func (*DeleteWorkflowResponse) Size

func (m *DeleteWorkflowResponse) Size() (n int)

func (*DeleteWorkflowResponse) String

func (m *DeleteWorkflowResponse) String() string

func (*DeleteWorkflowResponse) Unmarshal

func (m *DeleteWorkflowResponse) Unmarshal(dAtA []byte) error

func (*DeleteWorkflowResponse) XXX_DiscardUnknown

func (m *DeleteWorkflowResponse) XXX_DiscardUnknown()

func (*DeleteWorkflowResponse) XXX_Marshal

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

func (*DeleteWorkflowResponse) XXX_Merge

func (m *DeleteWorkflowResponse) XXX_Merge(src proto.Message)

func (*DeleteWorkflowResponse) XXX_Size

func (m *DeleteWorkflowResponse) XXX_Size() int

func (*DeleteWorkflowResponse) XXX_Unmarshal

func (m *DeleteWorkflowResponse) XXX_Unmarshal(b []byte) error

type DescribeClusterRequest

type DescribeClusterRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DescribeClusterRequest) Descriptor

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

func (*DescribeClusterRequest) Marshal

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

func (*DescribeClusterRequest) MarshalTo

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

func (*DescribeClusterRequest) MarshalToSizedBuffer

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

func (*DescribeClusterRequest) ProtoMessage

func (*DescribeClusterRequest) ProtoMessage()

func (*DescribeClusterRequest) Reset

func (m *DescribeClusterRequest) Reset()

func (*DescribeClusterRequest) Size

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

func (*DescribeClusterRequest) String

func (m *DescribeClusterRequest) String() string

func (*DescribeClusterRequest) Unmarshal

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

func (*DescribeClusterRequest) XXX_DiscardUnknown

func (m *DescribeClusterRequest) XXX_DiscardUnknown()

func (*DescribeClusterRequest) XXX_Marshal

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

func (*DescribeClusterRequest) XXX_Merge

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

func (*DescribeClusterRequest) XXX_Size

func (m *DescribeClusterRequest) XXX_Size() int

func (*DescribeClusterRequest) XXX_Unmarshal

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

type DescribeClusterResponse

type DescribeClusterResponse struct {
	SupportedClientVersions *v1.SupportedClientVersions `` /* 132-byte string literal not displayed */
	MembershipInfo          *MembershipInfo             `protobuf:"bytes,2,opt,name=membership_info,json=membershipInfo,proto3" json:"membership_info,omitempty"`
	PersistenceInfo         map[string]*PersistenceInfo `` /* 194-byte string literal not displayed */
	XXX_NoUnkeyedLiteral    struct{}                    `json:"-"`
	XXX_unrecognized        []byte                      `json:"-"`
	XXX_sizecache           int32                       `json:"-"`
}

func (*DescribeClusterResponse) Descriptor

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

func (*DescribeClusterResponse) GetMembershipInfo

func (m *DescribeClusterResponse) GetMembershipInfo() *MembershipInfo

func (*DescribeClusterResponse) GetPersistenceInfo

func (m *DescribeClusterResponse) GetPersistenceInfo() map[string]*PersistenceInfo

func (*DescribeClusterResponse) GetSupportedClientVersions

func (m *DescribeClusterResponse) GetSupportedClientVersions() *v1.SupportedClientVersions

func (*DescribeClusterResponse) Marshal

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

func (*DescribeClusterResponse) MarshalTo

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

func (*DescribeClusterResponse) MarshalToSizedBuffer

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

func (*DescribeClusterResponse) ProtoMessage

func (*DescribeClusterResponse) ProtoMessage()

func (*DescribeClusterResponse) Reset

func (m *DescribeClusterResponse) Reset()

func (*DescribeClusterResponse) Size

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

func (*DescribeClusterResponse) String

func (m *DescribeClusterResponse) String() string

func (*DescribeClusterResponse) Unmarshal

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

func (*DescribeClusterResponse) XXX_DiscardUnknown

func (m *DescribeClusterResponse) XXX_DiscardUnknown()

func (*DescribeClusterResponse) XXX_Marshal

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

func (*DescribeClusterResponse) XXX_Merge

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

func (*DescribeClusterResponse) XXX_Size

func (m *DescribeClusterResponse) XXX_Size() int

func (*DescribeClusterResponse) XXX_Unmarshal

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

type DescribeHistoryHostRequest

type DescribeHistoryHostRequest struct {
	// Types that are valid to be assigned to DescribeBy:
	//	*DescribeHistoryHostRequest_HostAddress
	//	*DescribeHistoryHostRequest_ShardId
	//	*DescribeHistoryHostRequest_WorkflowExecution
	DescribeBy           isDescribeHistoryHostRequest_DescribeBy `protobuf_oneof:"describe_by"`
	XXX_NoUnkeyedLiteral struct{}                                `json:"-"`
	XXX_unrecognized     []byte                                  `json:"-"`
	XXX_sizecache        int32                                   `json:"-"`
}

func (*DescribeHistoryHostRequest) Descriptor

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

func (*DescribeHistoryHostRequest) GetDescribeBy

func (m *DescribeHistoryHostRequest) GetDescribeBy() isDescribeHistoryHostRequest_DescribeBy

func (*DescribeHistoryHostRequest) GetHostAddress

func (m *DescribeHistoryHostRequest) GetHostAddress() string

func (*DescribeHistoryHostRequest) GetShardId

func (m *DescribeHistoryHostRequest) GetShardId() int32

func (*DescribeHistoryHostRequest) GetWorkflowExecution

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

func (*DescribeHistoryHostRequest) Marshal

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

func (*DescribeHistoryHostRequest) MarshalTo

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

func (*DescribeHistoryHostRequest) MarshalToSizedBuffer

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

func (*DescribeHistoryHostRequest) ProtoMessage

func (*DescribeHistoryHostRequest) ProtoMessage()

func (*DescribeHistoryHostRequest) Reset

func (m *DescribeHistoryHostRequest) Reset()

func (*DescribeHistoryHostRequest) Size

func (m *DescribeHistoryHostRequest) Size() (n int)

func (*DescribeHistoryHostRequest) String

func (m *DescribeHistoryHostRequest) String() string

func (*DescribeHistoryHostRequest) Unmarshal

func (m *DescribeHistoryHostRequest) Unmarshal(dAtA []byte) error

func (*DescribeHistoryHostRequest) XXX_DiscardUnknown

func (m *DescribeHistoryHostRequest) XXX_DiscardUnknown()

func (*DescribeHistoryHostRequest) XXX_Marshal

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

func (*DescribeHistoryHostRequest) XXX_Merge

func (m *DescribeHistoryHostRequest) XXX_Merge(src proto.Message)

func (*DescribeHistoryHostRequest) XXX_OneofWrappers

func (*DescribeHistoryHostRequest) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*DescribeHistoryHostRequest) XXX_Size

func (m *DescribeHistoryHostRequest) XXX_Size() int

func (*DescribeHistoryHostRequest) XXX_Unmarshal

func (m *DescribeHistoryHostRequest) XXX_Unmarshal(b []byte) error

type DescribeHistoryHostRequest_HostAddress

type DescribeHistoryHostRequest_HostAddress struct {
	HostAddress string `protobuf:"bytes,1,opt,name=host_address,json=hostAddress,proto3,oneof" json:"host_address,omitempty"`
}

func (*DescribeHistoryHostRequest_HostAddress) MarshalTo

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

func (*DescribeHistoryHostRequest_HostAddress) MarshalToSizedBuffer

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

func (*DescribeHistoryHostRequest_HostAddress) Size

type DescribeHistoryHostRequest_ShardId

type DescribeHistoryHostRequest_ShardId struct {
	ShardId int32 `protobuf:"varint,2,opt,name=shard_id,json=shardId,proto3,oneof" json:"shard_id,omitempty"`
}

func (*DescribeHistoryHostRequest_ShardId) MarshalTo

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

func (*DescribeHistoryHostRequest_ShardId) MarshalToSizedBuffer

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

func (*DescribeHistoryHostRequest_ShardId) Size

type DescribeHistoryHostRequest_WorkflowExecution

type DescribeHistoryHostRequest_WorkflowExecution struct {
	WorkflowExecution *v1.WorkflowExecution `protobuf:"bytes,3,opt,name=workflow_execution,json=workflowExecution,proto3,oneof" json:"workflow_execution,omitempty"`
}

func (*DescribeHistoryHostRequest_WorkflowExecution) MarshalTo

func (*DescribeHistoryHostRequest_WorkflowExecution) MarshalToSizedBuffer

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

func (*DescribeHistoryHostRequest_WorkflowExecution) Size

type DescribeHistoryHostResponse

type DescribeHistoryHostResponse struct {
	NumberOfShards        int32            `protobuf:"varint,1,opt,name=number_of_shards,json=numberOfShards,proto3" json:"number_of_shards,omitempty"`
	ShardIds              []int32          `protobuf:"varint,2,rep,packed,name=shard_ids,json=shardIds,proto3" json:"shard_ids,omitempty"`
	DomainCache           *DomainCacheInfo `protobuf:"bytes,3,opt,name=domain_cache,json=domainCache,proto3" json:"domain_cache,omitempty"`
	ShardControllerStatus string           `` /* 126-byte string literal not displayed */
	Address               string           `protobuf:"bytes,5,opt,name=address,proto3" json:"address,omitempty"`
	XXX_NoUnkeyedLiteral  struct{}         `json:"-"`
	XXX_unrecognized      []byte           `json:"-"`
	XXX_sizecache         int32            `json:"-"`
}

func (*DescribeHistoryHostResponse) Descriptor

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

func (*DescribeHistoryHostResponse) GetAddress

func (m *DescribeHistoryHostResponse) GetAddress() string

func (*DescribeHistoryHostResponse) GetDomainCache

func (m *DescribeHistoryHostResponse) GetDomainCache() *DomainCacheInfo

func (*DescribeHistoryHostResponse) GetNumberOfShards

func (m *DescribeHistoryHostResponse) GetNumberOfShards() int32

func (*DescribeHistoryHostResponse) GetShardControllerStatus

func (m *DescribeHistoryHostResponse) GetShardControllerStatus() string

func (*DescribeHistoryHostResponse) GetShardIds

func (m *DescribeHistoryHostResponse) GetShardIds() []int32

func (*DescribeHistoryHostResponse) Marshal

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

func (*DescribeHistoryHostResponse) MarshalTo

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

func (*DescribeHistoryHostResponse) MarshalToSizedBuffer

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

func (*DescribeHistoryHostResponse) ProtoMessage

func (*DescribeHistoryHostResponse) ProtoMessage()

func (*DescribeHistoryHostResponse) Reset

func (m *DescribeHistoryHostResponse) Reset()

func (*DescribeHistoryHostResponse) Size

func (m *DescribeHistoryHostResponse) Size() (n int)

func (*DescribeHistoryHostResponse) String

func (m *DescribeHistoryHostResponse) String() string

func (*DescribeHistoryHostResponse) Unmarshal

func (m *DescribeHistoryHostResponse) Unmarshal(dAtA []byte) error

func (*DescribeHistoryHostResponse) XXX_DiscardUnknown

func (m *DescribeHistoryHostResponse) XXX_DiscardUnknown()

func (*DescribeHistoryHostResponse) XXX_Marshal

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

func (*DescribeHistoryHostResponse) XXX_Merge

func (m *DescribeHistoryHostResponse) XXX_Merge(src proto.Message)

func (*DescribeHistoryHostResponse) XXX_Size

func (m *DescribeHistoryHostResponse) XXX_Size() int

func (*DescribeHistoryHostResponse) XXX_Unmarshal

func (m *DescribeHistoryHostResponse) XXX_Unmarshal(b []byte) error

type DescribeQueueRequest

type DescribeQueueRequest struct {
	ShardId              int32    `protobuf:"varint,1,opt,name=shard_id,json=shardId,proto3" json:"shard_id,omitempty"`
	ClusterName          string   `protobuf:"bytes,2,opt,name=cluster_name,json=clusterName,proto3" json:"cluster_name,omitempty"`
	TaskType             TaskType `protobuf:"varint,3,opt,name=task_type,json=taskType,proto3,enum=uber.cadence.admin.v1.TaskType" json:"task_type,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DescribeQueueRequest) Descriptor

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

func (*DescribeQueueRequest) GetClusterName

func (m *DescribeQueueRequest) GetClusterName() string

func (*DescribeQueueRequest) GetShardId

func (m *DescribeQueueRequest) GetShardId() int32

func (*DescribeQueueRequest) GetTaskType

func (m *DescribeQueueRequest) GetTaskType() TaskType

func (*DescribeQueueRequest) Marshal

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

func (*DescribeQueueRequest) MarshalTo

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

func (*DescribeQueueRequest) MarshalToSizedBuffer

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

func (*DescribeQueueRequest) ProtoMessage

func (*DescribeQueueRequest) ProtoMessage()

func (*DescribeQueueRequest) Reset

func (m *DescribeQueueRequest) Reset()

func (*DescribeQueueRequest) Size

func (m *DescribeQueueRequest) Size() (n int)

func (*DescribeQueueRequest) String

func (m *DescribeQueueRequest) String() string

func (*DescribeQueueRequest) Unmarshal

func (m *DescribeQueueRequest) Unmarshal(dAtA []byte) error

func (*DescribeQueueRequest) XXX_DiscardUnknown

func (m *DescribeQueueRequest) XXX_DiscardUnknown()

func (*DescribeQueueRequest) XXX_Marshal

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

func (*DescribeQueueRequest) XXX_Merge

func (m *DescribeQueueRequest) XXX_Merge(src proto.Message)

func (*DescribeQueueRequest) XXX_Size

func (m *DescribeQueueRequest) XXX_Size() int

func (*DescribeQueueRequest) XXX_Unmarshal

func (m *DescribeQueueRequest) XXX_Unmarshal(b []byte) error

type DescribeQueueResponse

type DescribeQueueResponse struct {
	ProcessingQueueStates []string `` /* 126-byte string literal not displayed */
	XXX_NoUnkeyedLiteral  struct{} `json:"-"`
	XXX_unrecognized      []byte   `json:"-"`
	XXX_sizecache         int32    `json:"-"`
}

func (*DescribeQueueResponse) Descriptor

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

func (*DescribeQueueResponse) GetProcessingQueueStates

func (m *DescribeQueueResponse) GetProcessingQueueStates() []string

func (*DescribeQueueResponse) Marshal

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

func (*DescribeQueueResponse) MarshalTo

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

func (*DescribeQueueResponse) MarshalToSizedBuffer

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

func (*DescribeQueueResponse) ProtoMessage

func (*DescribeQueueResponse) ProtoMessage()

func (*DescribeQueueResponse) Reset

func (m *DescribeQueueResponse) Reset()

func (*DescribeQueueResponse) Size

func (m *DescribeQueueResponse) Size() (n int)

func (*DescribeQueueResponse) String

func (m *DescribeQueueResponse) String() string

func (*DescribeQueueResponse) Unmarshal

func (m *DescribeQueueResponse) Unmarshal(dAtA []byte) error

func (*DescribeQueueResponse) XXX_DiscardUnknown

func (m *DescribeQueueResponse) XXX_DiscardUnknown()

func (*DescribeQueueResponse) XXX_Marshal

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

func (*DescribeQueueResponse) XXX_Merge

func (m *DescribeQueueResponse) XXX_Merge(src proto.Message)

func (*DescribeQueueResponse) XXX_Size

func (m *DescribeQueueResponse) XXX_Size() int

func (*DescribeQueueResponse) XXX_Unmarshal

func (m *DescribeQueueResponse) XXX_Unmarshal(b []byte) error

type DescribeShardDistributionRequest

type DescribeShardDistributionRequest struct {
	PageSize             int32    `protobuf:"varint,1,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	PageId               int32    `protobuf:"varint,2,opt,name=page_id,json=pageId,proto3" json:"page_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DescribeShardDistributionRequest) Descriptor

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

func (*DescribeShardDistributionRequest) GetPageId

func (m *DescribeShardDistributionRequest) GetPageId() int32

func (*DescribeShardDistributionRequest) GetPageSize

func (m *DescribeShardDistributionRequest) GetPageSize() int32

func (*DescribeShardDistributionRequest) Marshal

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

func (*DescribeShardDistributionRequest) MarshalTo

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

func (*DescribeShardDistributionRequest) MarshalToSizedBuffer

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

func (*DescribeShardDistributionRequest) ProtoMessage

func (*DescribeShardDistributionRequest) ProtoMessage()

func (*DescribeShardDistributionRequest) Reset

func (*DescribeShardDistributionRequest) Size

func (m *DescribeShardDistributionRequest) Size() (n int)

func (*DescribeShardDistributionRequest) String

func (*DescribeShardDistributionRequest) Unmarshal

func (m *DescribeShardDistributionRequest) Unmarshal(dAtA []byte) error

func (*DescribeShardDistributionRequest) XXX_DiscardUnknown

func (m *DescribeShardDistributionRequest) XXX_DiscardUnknown()

func (*DescribeShardDistributionRequest) XXX_Marshal

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

func (*DescribeShardDistributionRequest) XXX_Merge

func (*DescribeShardDistributionRequest) XXX_Size

func (m *DescribeShardDistributionRequest) XXX_Size() int

func (*DescribeShardDistributionRequest) XXX_Unmarshal

func (m *DescribeShardDistributionRequest) XXX_Unmarshal(b []byte) error

type DescribeShardDistributionResponse

type DescribeShardDistributionResponse struct {
	NumberOfShards       int32            `protobuf:"varint,1,opt,name=number_of_shards,json=numberOfShards,proto3" json:"number_of_shards,omitempty"`
	Shards               map[int32]string `` /* 154-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*DescribeShardDistributionResponse) Descriptor

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

func (*DescribeShardDistributionResponse) GetNumberOfShards

func (m *DescribeShardDistributionResponse) GetNumberOfShards() int32

func (*DescribeShardDistributionResponse) GetShards

func (m *DescribeShardDistributionResponse) GetShards() map[int32]string

func (*DescribeShardDistributionResponse) Marshal

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

func (*DescribeShardDistributionResponse) MarshalTo

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

func (*DescribeShardDistributionResponse) MarshalToSizedBuffer

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

func (*DescribeShardDistributionResponse) ProtoMessage

func (*DescribeShardDistributionResponse) ProtoMessage()

func (*DescribeShardDistributionResponse) Reset

func (*DescribeShardDistributionResponse) Size

func (m *DescribeShardDistributionResponse) Size() (n int)

func (*DescribeShardDistributionResponse) String

func (*DescribeShardDistributionResponse) Unmarshal

func (m *DescribeShardDistributionResponse) Unmarshal(dAtA []byte) error

func (*DescribeShardDistributionResponse) XXX_DiscardUnknown

func (m *DescribeShardDistributionResponse) XXX_DiscardUnknown()

func (*DescribeShardDistributionResponse) XXX_Marshal

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

func (*DescribeShardDistributionResponse) XXX_Merge

func (*DescribeShardDistributionResponse) XXX_Size

func (m *DescribeShardDistributionResponse) XXX_Size() int

func (*DescribeShardDistributionResponse) XXX_Unmarshal

func (m *DescribeShardDistributionResponse) XXX_Unmarshal(b []byte) error

type DescribeWorkflowExecutionRequest

type DescribeWorkflowExecutionRequest struct {
	Domain               string                `protobuf:"bytes,1,opt,name=domain,proto3" json:"domain,omitempty"`
	WorkflowExecution    *v1.WorkflowExecution `protobuf:"bytes,2,opt,name=workflow_execution,json=workflowExecution,proto3" json:"workflow_execution,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*DescribeWorkflowExecutionRequest) Descriptor

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

func (*DescribeWorkflowExecutionRequest) GetDomain

func (*DescribeWorkflowExecutionRequest) GetWorkflowExecution

func (m *DescribeWorkflowExecutionRequest) GetWorkflowExecution() *v1.WorkflowExecution

func (*DescribeWorkflowExecutionRequest) Marshal

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

func (*DescribeWorkflowExecutionRequest) MarshalTo

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

func (*DescribeWorkflowExecutionRequest) MarshalToSizedBuffer

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

func (*DescribeWorkflowExecutionRequest) ProtoMessage

func (*DescribeWorkflowExecutionRequest) ProtoMessage()

func (*DescribeWorkflowExecutionRequest) Reset

func (*DescribeWorkflowExecutionRequest) Size

func (m *DescribeWorkflowExecutionRequest) Size() (n int)

func (*DescribeWorkflowExecutionRequest) String

func (*DescribeWorkflowExecutionRequest) Unmarshal

func (m *DescribeWorkflowExecutionRequest) Unmarshal(dAtA []byte) error

func (*DescribeWorkflowExecutionRequest) XXX_DiscardUnknown

func (m *DescribeWorkflowExecutionRequest) XXX_DiscardUnknown()

func (*DescribeWorkflowExecutionRequest) XXX_Marshal

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

func (*DescribeWorkflowExecutionRequest) XXX_Merge

func (*DescribeWorkflowExecutionRequest) XXX_Size

func (m *DescribeWorkflowExecutionRequest) XXX_Size() int

func (*DescribeWorkflowExecutionRequest) XXX_Unmarshal

func (m *DescribeWorkflowExecutionRequest) XXX_Unmarshal(b []byte) error

type DescribeWorkflowExecutionResponse

type DescribeWorkflowExecutionResponse struct {
	ShardId                int32    `protobuf:"varint,1,opt,name=shard_id,json=shardId,proto3" json:"shard_id,omitempty"`
	HistoryAddr            string   `protobuf:"bytes,2,opt,name=history_addr,json=historyAddr,proto3" json:"history_addr,omitempty"`
	MutableStateInCache    string   `protobuf:"bytes,3,opt,name=mutable_state_in_cache,json=mutableStateInCache,proto3" json:"mutable_state_in_cache,omitempty"`
	MutableStateInDatabase string   `` /* 131-byte string literal not displayed */
	XXX_NoUnkeyedLiteral   struct{} `json:"-"`
	XXX_unrecognized       []byte   `json:"-"`
	XXX_sizecache          int32    `json:"-"`
}

func (*DescribeWorkflowExecutionResponse) Descriptor

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

func (*DescribeWorkflowExecutionResponse) GetHistoryAddr

func (m *DescribeWorkflowExecutionResponse) GetHistoryAddr() string

func (*DescribeWorkflowExecutionResponse) GetMutableStateInCache

func (m *DescribeWorkflowExecutionResponse) GetMutableStateInCache() string

func (*DescribeWorkflowExecutionResponse) GetMutableStateInDatabase

func (m *DescribeWorkflowExecutionResponse) GetMutableStateInDatabase() string

func (*DescribeWorkflowExecutionResponse) GetShardId

func (m *DescribeWorkflowExecutionResponse) GetShardId() int32

func (*DescribeWorkflowExecutionResponse) Marshal

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

func (*DescribeWorkflowExecutionResponse) MarshalTo

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

func (*DescribeWorkflowExecutionResponse) MarshalToSizedBuffer

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

func (*DescribeWorkflowExecutionResponse) ProtoMessage

func (*DescribeWorkflowExecutionResponse) ProtoMessage()

func (*DescribeWorkflowExecutionResponse) Reset

func (*DescribeWorkflowExecutionResponse) Size

func (m *DescribeWorkflowExecutionResponse) Size() (n int)

func (*DescribeWorkflowExecutionResponse) String

func (*DescribeWorkflowExecutionResponse) Unmarshal

func (m *DescribeWorkflowExecutionResponse) Unmarshal(dAtA []byte) error

func (*DescribeWorkflowExecutionResponse) XXX_DiscardUnknown

func (m *DescribeWorkflowExecutionResponse) XXX_DiscardUnknown()

func (*DescribeWorkflowExecutionResponse) XXX_Marshal

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

func (*DescribeWorkflowExecutionResponse) XXX_Merge

func (*DescribeWorkflowExecutionResponse) XXX_Size

func (m *DescribeWorkflowExecutionResponse) XXX_Size() int

func (*DescribeWorkflowExecutionResponse) XXX_Unmarshal

func (m *DescribeWorkflowExecutionResponse) XXX_Unmarshal(b []byte) error

type DomainCacheInfo

type DomainCacheInfo struct {
	NumOfItemsInCacheById   int64    `` /* 135-byte string literal not displayed */
	NumOfItemsInCacheByName int64    `` /* 141-byte string literal not displayed */
	XXX_NoUnkeyedLiteral    struct{} `json:"-"`
	XXX_unrecognized        []byte   `json:"-"`
	XXX_sizecache           int32    `json:"-"`
}

func (*DomainCacheInfo) Descriptor

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

func (*DomainCacheInfo) GetNumOfItemsInCacheById

func (m *DomainCacheInfo) GetNumOfItemsInCacheById() int64

func (*DomainCacheInfo) GetNumOfItemsInCacheByName

func (m *DomainCacheInfo) GetNumOfItemsInCacheByName() int64

func (*DomainCacheInfo) Marshal

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

func (*DomainCacheInfo) MarshalTo

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

func (*DomainCacheInfo) MarshalToSizedBuffer

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

func (*DomainCacheInfo) ProtoMessage

func (*DomainCacheInfo) ProtoMessage()

func (*DomainCacheInfo) Reset

func (m *DomainCacheInfo) Reset()

func (*DomainCacheInfo) Size

func (m *DomainCacheInfo) Size() (n int)

func (*DomainCacheInfo) String

func (m *DomainCacheInfo) String() string

func (*DomainCacheInfo) Unmarshal

func (m *DomainCacheInfo) Unmarshal(dAtA []byte) error

func (*DomainCacheInfo) XXX_DiscardUnknown

func (m *DomainCacheInfo) XXX_DiscardUnknown()

func (*DomainCacheInfo) XXX_Marshal

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

func (*DomainCacheInfo) XXX_Merge

func (m *DomainCacheInfo) XXX_Merge(src proto.Message)

func (*DomainCacheInfo) XXX_Size

func (m *DomainCacheInfo) XXX_Size() int

func (*DomainCacheInfo) XXX_Unmarshal

func (m *DomainCacheInfo) XXX_Unmarshal(b []byte) error

type DomainOperation

type DomainOperation int32
const (
	DomainOperation_DOMAIN_OPERATION_INVALID DomainOperation = 0
	DomainOperation_DOMAIN_OPERATION_CREATE  DomainOperation = 1
	DomainOperation_DOMAIN_OPERATION_UPDATE  DomainOperation = 2
)

func (DomainOperation) EnumDescriptor

func (DomainOperation) EnumDescriptor() ([]byte, []int)

func (DomainOperation) String

func (x DomainOperation) String() string

type DomainTaskAttributes

type DomainTaskAttributes struct {
	DomainOperation         DomainOperation `` /* 150-byte string literal not displayed */
	Id                      string          `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	Domain                  *v1.Domain      `protobuf:"bytes,3,opt,name=domain,proto3" json:"domain,omitempty"`
	ConfigVersion           int64           `protobuf:"varint,4,opt,name=config_version,json=configVersion,proto3" json:"config_version,omitempty"`
	FailoverVersion         int64           `protobuf:"varint,5,opt,name=failover_version,json=failoverVersion,proto3" json:"failover_version,omitempty"`
	PreviousFailoverVersion int64           `` /* 133-byte string literal not displayed */
	XXX_NoUnkeyedLiteral    struct{}        `json:"-"`
	XXX_unrecognized        []byte          `json:"-"`
	XXX_sizecache           int32           `json:"-"`
}

func (*DomainTaskAttributes) Descriptor

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

func (*DomainTaskAttributes) GetConfigVersion

func (m *DomainTaskAttributes) GetConfigVersion() int64

func (*DomainTaskAttributes) GetDomain

func (m *DomainTaskAttributes) GetDomain() *v1.Domain

func (*DomainTaskAttributes) GetDomainOperation

func (m *DomainTaskAttributes) GetDomainOperation() DomainOperation

func (*DomainTaskAttributes) GetFailoverVersion

func (m *DomainTaskAttributes) GetFailoverVersion() int64

func (*DomainTaskAttributes) GetId

func (m *DomainTaskAttributes) GetId() string

func (*DomainTaskAttributes) GetPreviousFailoverVersion

func (m *DomainTaskAttributes) GetPreviousFailoverVersion() int64

func (*DomainTaskAttributes) Marshal

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

func (*DomainTaskAttributes) MarshalTo

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

func (*DomainTaskAttributes) MarshalToSizedBuffer

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

func (*DomainTaskAttributes) ProtoMessage

func (*DomainTaskAttributes) ProtoMessage()

func (*DomainTaskAttributes) Reset

func (m *DomainTaskAttributes) Reset()

func (*DomainTaskAttributes) Size

func (m *DomainTaskAttributes) Size() (n int)

func (*DomainTaskAttributes) String

func (m *DomainTaskAttributes) String() string

func (*DomainTaskAttributes) Unmarshal

func (m *DomainTaskAttributes) Unmarshal(dAtA []byte) error

func (*DomainTaskAttributes) XXX_DiscardUnknown

func (m *DomainTaskAttributes) XXX_DiscardUnknown()

func (*DomainTaskAttributes) XXX_Marshal

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

func (*DomainTaskAttributes) XXX_Merge

func (m *DomainTaskAttributes) XXX_Merge(src proto.Message)

func (*DomainTaskAttributes) XXX_Size

func (m *DomainTaskAttributes) XXX_Size() int

func (*DomainTaskAttributes) XXX_Unmarshal

func (m *DomainTaskAttributes) XXX_Unmarshal(b []byte) error

type DynamicConfigEntry

type DynamicConfigEntry struct {
	Name                 string                `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Values               []*DynamicConfigValue `protobuf:"bytes,3,rep,name=values,proto3" json:"values,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*DynamicConfigEntry) Descriptor

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

func (*DynamicConfigEntry) GetName

func (m *DynamicConfigEntry) GetName() string

func (*DynamicConfigEntry) GetValues

func (m *DynamicConfigEntry) GetValues() []*DynamicConfigValue

func (*DynamicConfigEntry) Marshal

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

func (*DynamicConfigEntry) MarshalTo

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

func (*DynamicConfigEntry) MarshalToSizedBuffer

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

func (*DynamicConfigEntry) ProtoMessage

func (*DynamicConfigEntry) ProtoMessage()

func (*DynamicConfigEntry) Reset

func (m *DynamicConfigEntry) Reset()

func (*DynamicConfigEntry) Size

func (m *DynamicConfigEntry) Size() (n int)

func (*DynamicConfigEntry) String

func (m *DynamicConfigEntry) String() string

func (*DynamicConfigEntry) Unmarshal

func (m *DynamicConfigEntry) Unmarshal(dAtA []byte) error

func (*DynamicConfigEntry) XXX_DiscardUnknown

func (m *DynamicConfigEntry) XXX_DiscardUnknown()

func (*DynamicConfigEntry) XXX_Marshal

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

func (*DynamicConfigEntry) XXX_Merge

func (m *DynamicConfigEntry) XXX_Merge(src proto.Message)

func (*DynamicConfigEntry) XXX_Size

func (m *DynamicConfigEntry) XXX_Size() int

func (*DynamicConfigEntry) XXX_Unmarshal

func (m *DynamicConfigEntry) XXX_Unmarshal(b []byte) error

type DynamicConfigFilter

type DynamicConfigFilter struct {
	Name                 string       `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Value                *v1.DataBlob `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*DynamicConfigFilter) Descriptor

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

func (*DynamicConfigFilter) GetName

func (m *DynamicConfigFilter) GetName() string

func (*DynamicConfigFilter) GetValue

func (m *DynamicConfigFilter) GetValue() *v1.DataBlob

func (*DynamicConfigFilter) Marshal

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

func (*DynamicConfigFilter) MarshalTo

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

func (*DynamicConfigFilter) MarshalToSizedBuffer

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

func (*DynamicConfigFilter) ProtoMessage

func (*DynamicConfigFilter) ProtoMessage()

func (*DynamicConfigFilter) Reset

func (m *DynamicConfigFilter) Reset()

func (*DynamicConfigFilter) Size

func (m *DynamicConfigFilter) Size() (n int)

func (*DynamicConfigFilter) String

func (m *DynamicConfigFilter) String() string

func (*DynamicConfigFilter) Unmarshal

func (m *DynamicConfigFilter) Unmarshal(dAtA []byte) error

func (*DynamicConfigFilter) XXX_DiscardUnknown

func (m *DynamicConfigFilter) XXX_DiscardUnknown()

func (*DynamicConfigFilter) XXX_Marshal

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

func (*DynamicConfigFilter) XXX_Merge

func (m *DynamicConfigFilter) XXX_Merge(src proto.Message)

func (*DynamicConfigFilter) XXX_Size

func (m *DynamicConfigFilter) XXX_Size() int

func (*DynamicConfigFilter) XXX_Unmarshal

func (m *DynamicConfigFilter) XXX_Unmarshal(b []byte) error

type DynamicConfigValue

type DynamicConfigValue struct {
	Value                *v1.DataBlob           `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	Filters              []*DynamicConfigFilter `protobuf:"bytes,2,rep,name=filters,proto3" json:"filters,omitempty"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

func (*DynamicConfigValue) Descriptor

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

func (*DynamicConfigValue) GetFilters

func (m *DynamicConfigValue) GetFilters() []*DynamicConfigFilter

func (*DynamicConfigValue) GetValue

func (m *DynamicConfigValue) GetValue() *v1.DataBlob

func (*DynamicConfigValue) Marshal

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

func (*DynamicConfigValue) MarshalTo

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

func (*DynamicConfigValue) MarshalToSizedBuffer

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

func (*DynamicConfigValue) ProtoMessage

func (*DynamicConfigValue) ProtoMessage()

func (*DynamicConfigValue) Reset

func (m *DynamicConfigValue) Reset()

func (*DynamicConfigValue) Size

func (m *DynamicConfigValue) Size() (n int)

func (*DynamicConfigValue) String

func (m *DynamicConfigValue) String() string

func (*DynamicConfigValue) Unmarshal

func (m *DynamicConfigValue) Unmarshal(dAtA []byte) error

func (*DynamicConfigValue) XXX_DiscardUnknown

func (m *DynamicConfigValue) XXX_DiscardUnknown()

func (*DynamicConfigValue) XXX_Marshal

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

func (*DynamicConfigValue) XXX_Merge

func (m *DynamicConfigValue) XXX_Merge(src proto.Message)

func (*DynamicConfigValue) XXX_Size

func (m *DynamicConfigValue) XXX_Size() int

func (*DynamicConfigValue) XXX_Unmarshal

func (m *DynamicConfigValue) XXX_Unmarshal(b []byte) error

type FailoverMarkerAttributes

type FailoverMarkerAttributes struct {
	DomainId             string           `protobuf:"bytes,1,opt,name=domain_id,json=domainId,proto3" json:"domain_id,omitempty"`
	FailoverVersion      int64            `protobuf:"varint,2,opt,name=failover_version,json=failoverVersion,proto3" json:"failover_version,omitempty"`
	CreationTime         *types.Timestamp `protobuf:"bytes,3,opt,name=creation_time,json=creationTime,proto3" json:"creation_time,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*FailoverMarkerAttributes) Descriptor

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

func (*FailoverMarkerAttributes) GetCreationTime

func (m *FailoverMarkerAttributes) GetCreationTime() *types.Timestamp

func (*FailoverMarkerAttributes) GetDomainId

func (m *FailoverMarkerAttributes) GetDomainId() string

func (*FailoverMarkerAttributes) GetFailoverVersion

func (m *FailoverMarkerAttributes) GetFailoverVersion() int64

func (*FailoverMarkerAttributes) Marshal

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

func (*FailoverMarkerAttributes) MarshalTo

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

func (*FailoverMarkerAttributes) MarshalToSizedBuffer

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

func (*FailoverMarkerAttributes) ProtoMessage

func (*FailoverMarkerAttributes) ProtoMessage()

func (*FailoverMarkerAttributes) Reset

func (m *FailoverMarkerAttributes) Reset()

func (*FailoverMarkerAttributes) Size

func (m *FailoverMarkerAttributes) Size() (n int)

func (*FailoverMarkerAttributes) String

func (m *FailoverMarkerAttributes) String() string

func (*FailoverMarkerAttributes) Unmarshal

func (m *FailoverMarkerAttributes) Unmarshal(dAtA []byte) error

func (*FailoverMarkerAttributes) XXX_DiscardUnknown

func (m *FailoverMarkerAttributes) XXX_DiscardUnknown()

func (*FailoverMarkerAttributes) XXX_Marshal

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

func (*FailoverMarkerAttributes) XXX_Merge

func (m *FailoverMarkerAttributes) XXX_Merge(src proto.Message)

func (*FailoverMarkerAttributes) XXX_Size

func (m *FailoverMarkerAttributes) XXX_Size() int

func (*FailoverMarkerAttributes) XXX_Unmarshal

func (m *FailoverMarkerAttributes) XXX_Unmarshal(b []byte) error

type FailoverMarkerToken

type FailoverMarkerToken struct {
	ShardIds             []int32                   `protobuf:"varint,1,rep,packed,name=shard_ids,json=shardIds,proto3" json:"shard_ids,omitempty"`
	FailoverMarker       *FailoverMarkerAttributes `protobuf:"bytes,2,opt,name=failover_marker,json=failoverMarker,proto3" json:"failover_marker,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

func (*FailoverMarkerToken) Descriptor

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

func (*FailoverMarkerToken) GetFailoverMarker

func (m *FailoverMarkerToken) GetFailoverMarker() *FailoverMarkerAttributes

func (*FailoverMarkerToken) GetShardIds

func (m *FailoverMarkerToken) GetShardIds() []int32

func (*FailoverMarkerToken) Marshal

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

func (*FailoverMarkerToken) MarshalTo

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

func (*FailoverMarkerToken) MarshalToSizedBuffer

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

func (*FailoverMarkerToken) ProtoMessage

func (*FailoverMarkerToken) ProtoMessage()

func (*FailoverMarkerToken) Reset

func (m *FailoverMarkerToken) Reset()

func (*FailoverMarkerToken) Size

func (m *FailoverMarkerToken) Size() (n int)

func (*FailoverMarkerToken) String

func (m *FailoverMarkerToken) String() string

func (*FailoverMarkerToken) Unmarshal

func (m *FailoverMarkerToken) Unmarshal(dAtA []byte) error

func (*FailoverMarkerToken) XXX_DiscardUnknown

func (m *FailoverMarkerToken) XXX_DiscardUnknown()

func (*FailoverMarkerToken) XXX_Marshal

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

func (*FailoverMarkerToken) XXX_Merge

func (m *FailoverMarkerToken) XXX_Merge(src proto.Message)

func (*FailoverMarkerToken) XXX_Size

func (m *FailoverMarkerToken) XXX_Size() int

func (*FailoverMarkerToken) XXX_Unmarshal

func (m *FailoverMarkerToken) XXX_Unmarshal(b []byte) error

type FxAdminAPIYARPCClientParams

type FxAdminAPIYARPCClientParams struct {
	fx.In

	Provider    yarpc.ClientConfig
	AnyResolver jsonpb.AnyResolver  `name:"yarpcfx" optional:"true"`
	Restriction restriction.Checker `optional:"true"`
}

FxAdminAPIYARPCClientParams defines the input for NewFxAdminAPIYARPCClient. It provides the paramaters to get a AdminAPIYARPCClient in an Fx application.

type FxAdminAPIYARPCClientResult

type FxAdminAPIYARPCClientResult struct {
	fx.Out

	Client AdminAPIYARPCClient
}

FxAdminAPIYARPCClientResult defines the output of NewFxAdminAPIYARPCClient. It provides a AdminAPIYARPCClient to an Fx application.

type FxAdminAPIYARPCProceduresParams

type FxAdminAPIYARPCProceduresParams struct {
	fx.In

	Server      AdminAPIYARPCServer
	AnyResolver jsonpb.AnyResolver `name:"yarpcfx" optional:"true"`
}

FxAdminAPIYARPCProceduresParams defines the input for NewFxAdminAPIYARPCProcedures. It provides the paramaters to get AdminAPIYARPCServer procedures in an Fx application.

type FxAdminAPIYARPCProceduresResult

type FxAdminAPIYARPCProceduresResult struct {
	fx.Out

	Procedures     []transport.Procedure `group:"yarpcfx"`
	ReflectionMeta reflection.ServerMeta `group:"yarpcfx"`
}

FxAdminAPIYARPCProceduresResult defines the output of NewFxAdminAPIYARPCProcedures. It provides AdminAPIYARPCServer procedures to an Fx application.

The procedures are provided to the "yarpcfx" value group. Dig 1.2 or newer must be used for this feature to work.

type GetCrossClusterTasksRequest

type GetCrossClusterTasksRequest struct {
	ShardIds             []int32  `protobuf:"varint,1,rep,packed,name=shard_ids,json=shardIds,proto3" json:"shard_ids,omitempty"`
	TargetCluster        string   `protobuf:"bytes,2,opt,name=target_cluster,json=targetCluster,proto3" json:"target_cluster,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetCrossClusterTasksRequest) Descriptor

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

func (*GetCrossClusterTasksRequest) GetShardIds

func (m *GetCrossClusterTasksRequest) GetShardIds() []int32

func (*GetCrossClusterTasksRequest) GetTargetCluster

func (m *GetCrossClusterTasksRequest) GetTargetCluster() string

func (*GetCrossClusterTasksRequest) Marshal

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

func (*GetCrossClusterTasksRequest) MarshalTo

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

func (*GetCrossClusterTasksRequest) MarshalToSizedBuffer

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

func (*GetCrossClusterTasksRequest) ProtoMessage

func (*GetCrossClusterTasksRequest) ProtoMessage()

func (*GetCrossClusterTasksRequest) Reset

func (m *GetCrossClusterTasksRequest) Reset()

func (*GetCrossClusterTasksRequest) Size

func (m *GetCrossClusterTasksRequest) Size() (n int)

func (*GetCrossClusterTasksRequest) String

func (m *GetCrossClusterTasksRequest) String() string

func (*GetCrossClusterTasksRequest) Unmarshal

func (m *GetCrossClusterTasksRequest) Unmarshal(dAtA []byte) error

func (*GetCrossClusterTasksRequest) XXX_DiscardUnknown

func (m *GetCrossClusterTasksRequest) XXX_DiscardUnknown()

func (*GetCrossClusterTasksRequest) XXX_Marshal

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

func (*GetCrossClusterTasksRequest) XXX_Merge

func (m *GetCrossClusterTasksRequest) XXX_Merge(src proto.Message)

func (*GetCrossClusterTasksRequest) XXX_Size

func (m *GetCrossClusterTasksRequest) XXX_Size() int

func (*GetCrossClusterTasksRequest) XXX_Unmarshal

func (m *GetCrossClusterTasksRequest) XXX_Unmarshal(b []byte) error

type GetCrossClusterTasksResponse

type GetCrossClusterTasksResponse struct {
	TasksByShard         map[int32]*CrossClusterTaskRequests `` /* 188-byte string literal not displayed */
	FailedCauseByShard   map[int32]GetTaskFailedCause        `` /* 255-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                            `json:"-"`
	XXX_unrecognized     []byte                              `json:"-"`
	XXX_sizecache        int32                               `json:"-"`
}

func (*GetCrossClusterTasksResponse) Descriptor

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

func (*GetCrossClusterTasksResponse) GetFailedCauseByShard

func (m *GetCrossClusterTasksResponse) GetFailedCauseByShard() map[int32]GetTaskFailedCause

func (*GetCrossClusterTasksResponse) GetTasksByShard

func (*GetCrossClusterTasksResponse) Marshal

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

func (*GetCrossClusterTasksResponse) MarshalTo

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

func (*GetCrossClusterTasksResponse) MarshalToSizedBuffer

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

func (*GetCrossClusterTasksResponse) ProtoMessage

func (*GetCrossClusterTasksResponse) ProtoMessage()

func (*GetCrossClusterTasksResponse) Reset

func (m *GetCrossClusterTasksResponse) Reset()

func (*GetCrossClusterTasksResponse) Size

func (m *GetCrossClusterTasksResponse) Size() (n int)

func (*GetCrossClusterTasksResponse) String

func (*GetCrossClusterTasksResponse) Unmarshal

func (m *GetCrossClusterTasksResponse) Unmarshal(dAtA []byte) error

func (*GetCrossClusterTasksResponse) XXX_DiscardUnknown

func (m *GetCrossClusterTasksResponse) XXX_DiscardUnknown()

func (*GetCrossClusterTasksResponse) XXX_Marshal

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

func (*GetCrossClusterTasksResponse) XXX_Merge

func (m *GetCrossClusterTasksResponse) XXX_Merge(src proto.Message)

func (*GetCrossClusterTasksResponse) XXX_Size

func (m *GetCrossClusterTasksResponse) XXX_Size() int

func (*GetCrossClusterTasksResponse) XXX_Unmarshal

func (m *GetCrossClusterTasksResponse) XXX_Unmarshal(b []byte) error

type GetDLQReplicationMessagesRequest

type GetDLQReplicationMessagesRequest struct {
	TaskInfos            []*ReplicationTaskInfo `protobuf:"bytes,1,rep,name=task_infos,json=taskInfos,proto3" json:"task_infos,omitempty"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

func (*GetDLQReplicationMessagesRequest) Descriptor

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

func (*GetDLQReplicationMessagesRequest) GetTaskInfos

func (*GetDLQReplicationMessagesRequest) Marshal

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

func (*GetDLQReplicationMessagesRequest) MarshalTo

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

func (*GetDLQReplicationMessagesRequest) MarshalToSizedBuffer

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

func (*GetDLQReplicationMessagesRequest) ProtoMessage

func (*GetDLQReplicationMessagesRequest) ProtoMessage()

func (*GetDLQReplicationMessagesRequest) Reset

func (*GetDLQReplicationMessagesRequest) Size

func (m *GetDLQReplicationMessagesRequest) Size() (n int)

func (*GetDLQReplicationMessagesRequest) String

func (*GetDLQReplicationMessagesRequest) Unmarshal

func (m *GetDLQReplicationMessagesRequest) Unmarshal(dAtA []byte) error

func (*GetDLQReplicationMessagesRequest) XXX_DiscardUnknown

func (m *GetDLQReplicationMessagesRequest) XXX_DiscardUnknown()

func (*GetDLQReplicationMessagesRequest) XXX_Marshal

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

func (*GetDLQReplicationMessagesRequest) XXX_Merge

func (*GetDLQReplicationMessagesRequest) XXX_Size

func (m *GetDLQReplicationMessagesRequest) XXX_Size() int

func (*GetDLQReplicationMessagesRequest) XXX_Unmarshal

func (m *GetDLQReplicationMessagesRequest) XXX_Unmarshal(b []byte) error

type GetDLQReplicationMessagesResponse

type GetDLQReplicationMessagesResponse struct {
	ReplicationTasks     []*ReplicationTask `protobuf:"bytes,1,rep,name=replication_tasks,json=replicationTasks,proto3" json:"replication_tasks,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*GetDLQReplicationMessagesResponse) Descriptor

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

func (*GetDLQReplicationMessagesResponse) GetReplicationTasks

func (m *GetDLQReplicationMessagesResponse) GetReplicationTasks() []*ReplicationTask

func (*GetDLQReplicationMessagesResponse) Marshal

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

func (*GetDLQReplicationMessagesResponse) MarshalTo

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

func (*GetDLQReplicationMessagesResponse) MarshalToSizedBuffer

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

func (*GetDLQReplicationMessagesResponse) ProtoMessage

func (*GetDLQReplicationMessagesResponse) ProtoMessage()

func (*GetDLQReplicationMessagesResponse) Reset

func (*GetDLQReplicationMessagesResponse) Size

func (m *GetDLQReplicationMessagesResponse) Size() (n int)

func (*GetDLQReplicationMessagesResponse) String

func (*GetDLQReplicationMessagesResponse) Unmarshal

func (m *GetDLQReplicationMessagesResponse) Unmarshal(dAtA []byte) error

func (*GetDLQReplicationMessagesResponse) XXX_DiscardUnknown

func (m *GetDLQReplicationMessagesResponse) XXX_DiscardUnknown()

func (*GetDLQReplicationMessagesResponse) XXX_Marshal

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

func (*GetDLQReplicationMessagesResponse) XXX_Merge

func (*GetDLQReplicationMessagesResponse) XXX_Size

func (m *GetDLQReplicationMessagesResponse) XXX_Size() int

func (*GetDLQReplicationMessagesResponse) XXX_Unmarshal

func (m *GetDLQReplicationMessagesResponse) XXX_Unmarshal(b []byte) error

type GetDomainAsyncWorkflowConfiguratonRequest

type GetDomainAsyncWorkflowConfiguratonRequest struct {
	Domain               string   `protobuf:"bytes,1,opt,name=domain,proto3" json:"domain,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Async workflow configuration request/response payloads

func (*GetDomainAsyncWorkflowConfiguratonRequest) Descriptor

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

func (*GetDomainAsyncWorkflowConfiguratonRequest) GetDomain

func (*GetDomainAsyncWorkflowConfiguratonRequest) Marshal

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

func (*GetDomainAsyncWorkflowConfiguratonRequest) MarshalTo

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

func (*GetDomainAsyncWorkflowConfiguratonRequest) MarshalToSizedBuffer

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

func (*GetDomainAsyncWorkflowConfiguratonRequest) ProtoMessage

func (*GetDomainAsyncWorkflowConfiguratonRequest) Reset

func (*GetDomainAsyncWorkflowConfiguratonRequest) Size

func (*GetDomainAsyncWorkflowConfiguratonRequest) String

func (*GetDomainAsyncWorkflowConfiguratonRequest) Unmarshal

func (*GetDomainAsyncWorkflowConfiguratonRequest) XXX_DiscardUnknown

func (m *GetDomainAsyncWorkflowConfiguratonRequest) XXX_DiscardUnknown()

func (*GetDomainAsyncWorkflowConfiguratonRequest) XXX_Marshal

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

func (*GetDomainAsyncWorkflowConfiguratonRequest) XXX_Merge

func (*GetDomainAsyncWorkflowConfiguratonRequest) XXX_Size

func (*GetDomainAsyncWorkflowConfiguratonRequest) XXX_Unmarshal

type GetDomainAsyncWorkflowConfiguratonResponse

type GetDomainAsyncWorkflowConfiguratonResponse struct {
	Configuration        *v1.AsyncWorkflowConfiguration `protobuf:"bytes,1,opt,name=configuration,proto3" json:"configuration,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                       `json:"-"`
	XXX_unrecognized     []byte                         `json:"-"`
	XXX_sizecache        int32                          `json:"-"`
}

func (*GetDomainAsyncWorkflowConfiguratonResponse) Descriptor

func (*GetDomainAsyncWorkflowConfiguratonResponse) GetConfiguration

func (*GetDomainAsyncWorkflowConfiguratonResponse) Marshal

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

func (*GetDomainAsyncWorkflowConfiguratonResponse) MarshalTo

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

func (*GetDomainAsyncWorkflowConfiguratonResponse) MarshalToSizedBuffer

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

func (*GetDomainAsyncWorkflowConfiguratonResponse) ProtoMessage

func (*GetDomainAsyncWorkflowConfiguratonResponse) Reset

func (*GetDomainAsyncWorkflowConfiguratonResponse) Size

func (*GetDomainAsyncWorkflowConfiguratonResponse) String

func (*GetDomainAsyncWorkflowConfiguratonResponse) Unmarshal

func (*GetDomainAsyncWorkflowConfiguratonResponse) XXX_DiscardUnknown

func (m *GetDomainAsyncWorkflowConfiguratonResponse) XXX_DiscardUnknown()

func (*GetDomainAsyncWorkflowConfiguratonResponse) XXX_Marshal

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

func (*GetDomainAsyncWorkflowConfiguratonResponse) XXX_Merge

func (*GetDomainAsyncWorkflowConfiguratonResponse) XXX_Size

func (*GetDomainAsyncWorkflowConfiguratonResponse) XXX_Unmarshal

type GetDomainIsolationGroupsRequest

type GetDomainIsolationGroupsRequest struct {
	Domain               string   `protobuf:"bytes,1,opt,name=domain,proto3" json:"domain,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

For domains

func (*GetDomainIsolationGroupsRequest) Descriptor

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

func (*GetDomainIsolationGroupsRequest) GetDomain

func (m *GetDomainIsolationGroupsRequest) GetDomain() string

func (*GetDomainIsolationGroupsRequest) Marshal

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

func (*GetDomainIsolationGroupsRequest) MarshalTo

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

func (*GetDomainIsolationGroupsRequest) MarshalToSizedBuffer

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

func (*GetDomainIsolationGroupsRequest) ProtoMessage

func (*GetDomainIsolationGroupsRequest) ProtoMessage()

func (*GetDomainIsolationGroupsRequest) Reset

func (*GetDomainIsolationGroupsRequest) Size

func (m *GetDomainIsolationGroupsRequest) Size() (n int)

func (*GetDomainIsolationGroupsRequest) String

func (*GetDomainIsolationGroupsRequest) Unmarshal

func (m *GetDomainIsolationGroupsRequest) Unmarshal(dAtA []byte) error

func (*GetDomainIsolationGroupsRequest) XXX_DiscardUnknown

func (m *GetDomainIsolationGroupsRequest) XXX_DiscardUnknown()

func (*GetDomainIsolationGroupsRequest) XXX_Marshal

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

func (*GetDomainIsolationGroupsRequest) XXX_Merge

func (m *GetDomainIsolationGroupsRequest) XXX_Merge(src proto.Message)

func (*GetDomainIsolationGroupsRequest) XXX_Size

func (m *GetDomainIsolationGroupsRequest) XXX_Size() int

func (*GetDomainIsolationGroupsRequest) XXX_Unmarshal

func (m *GetDomainIsolationGroupsRequest) XXX_Unmarshal(b []byte) error

type GetDomainIsolationGroupsResponse

type GetDomainIsolationGroupsResponse struct {
	IsolationGroups      *v1.IsolationGroupConfiguration `protobuf:"bytes,1,opt,name=isolation_groups,json=isolationGroups,proto3" json:"isolation_groups,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                        `json:"-"`
	XXX_unrecognized     []byte                          `json:"-"`
	XXX_sizecache        int32                           `json:"-"`
}

func (*GetDomainIsolationGroupsResponse) Descriptor

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

func (*GetDomainIsolationGroupsResponse) GetIsolationGroups

func (*GetDomainIsolationGroupsResponse) Marshal

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

func (*GetDomainIsolationGroupsResponse) MarshalTo

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

func (*GetDomainIsolationGroupsResponse) MarshalToSizedBuffer

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

func (*GetDomainIsolationGroupsResponse) ProtoMessage

func (*GetDomainIsolationGroupsResponse) ProtoMessage()

func (*GetDomainIsolationGroupsResponse) Reset

func (*GetDomainIsolationGroupsResponse) Size

func (m *GetDomainIsolationGroupsResponse) Size() (n int)

func (*GetDomainIsolationGroupsResponse) String

func (*GetDomainIsolationGroupsResponse) Unmarshal

func (m *GetDomainIsolationGroupsResponse) Unmarshal(dAtA []byte) error

func (*GetDomainIsolationGroupsResponse) XXX_DiscardUnknown

func (m *GetDomainIsolationGroupsResponse) XXX_DiscardUnknown()

func (*GetDomainIsolationGroupsResponse) XXX_Marshal

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

func (*GetDomainIsolationGroupsResponse) XXX_Merge

func (*GetDomainIsolationGroupsResponse) XXX_Size

func (m *GetDomainIsolationGroupsResponse) XXX_Size() int

func (*GetDomainIsolationGroupsResponse) XXX_Unmarshal

func (m *GetDomainIsolationGroupsResponse) XXX_Unmarshal(b []byte) error

type GetDomainReplicationMessagesRequest

type GetDomainReplicationMessagesRequest struct {
	// last_retrieved_message_id is where the next fetch should begin with.
	LastRetrievedMessageId *types.Int64Value `` /* 131-byte string literal not displayed */
	// last_processed_message_id is the last messageId that is processed on the passive side.
	// This can be different than last_retrieved_message_id if passive side supports prefetching messages.
	LastProcessedMessageId *types.Int64Value `` /* 131-byte string literal not displayed */
	// cluster_name is the name of the pulling cluster.
	ClusterName          string   `protobuf:"bytes,3,opt,name=cluster_name,json=clusterName,proto3" json:"cluster_name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetDomainReplicationMessagesRequest) Descriptor

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

func (*GetDomainReplicationMessagesRequest) GetClusterName

func (m *GetDomainReplicationMessagesRequest) GetClusterName() string

func (*GetDomainReplicationMessagesRequest) GetLastProcessedMessageId

func (m *GetDomainReplicationMessagesRequest) GetLastProcessedMessageId() *types.Int64Value

func (*GetDomainReplicationMessagesRequest) GetLastRetrievedMessageId

func (m *GetDomainReplicationMessagesRequest) GetLastRetrievedMessageId() *types.Int64Value

func (*GetDomainReplicationMessagesRequest) Marshal

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

func (*GetDomainReplicationMessagesRequest) MarshalTo

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

func (*GetDomainReplicationMessagesRequest) MarshalToSizedBuffer

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

func (*GetDomainReplicationMessagesRequest) ProtoMessage

func (*GetDomainReplicationMessagesRequest) ProtoMessage()

func (*GetDomainReplicationMessagesRequest) Reset

func (*GetDomainReplicationMessagesRequest) Size

func (*GetDomainReplicationMessagesRequest) String

func (*GetDomainReplicationMessagesRequest) Unmarshal

func (m *GetDomainReplicationMessagesRequest) Unmarshal(dAtA []byte) error

func (*GetDomainReplicationMessagesRequest) XXX_DiscardUnknown

func (m *GetDomainReplicationMessagesRequest) XXX_DiscardUnknown()

func (*GetDomainReplicationMessagesRequest) XXX_Marshal

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

func (*GetDomainReplicationMessagesRequest) XXX_Merge

func (*GetDomainReplicationMessagesRequest) XXX_Size

func (*GetDomainReplicationMessagesRequest) XXX_Unmarshal

func (m *GetDomainReplicationMessagesRequest) XXX_Unmarshal(b []byte) error

type GetDomainReplicationMessagesResponse

type GetDomainReplicationMessagesResponse struct {
	Messages             *ReplicationMessages `protobuf:"bytes,1,opt,name=messages,proto3" json:"messages,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*GetDomainReplicationMessagesResponse) Descriptor

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

func (*GetDomainReplicationMessagesResponse) GetMessages

func (*GetDomainReplicationMessagesResponse) Marshal

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

func (*GetDomainReplicationMessagesResponse) MarshalTo

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

func (*GetDomainReplicationMessagesResponse) MarshalToSizedBuffer

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

func (*GetDomainReplicationMessagesResponse) ProtoMessage

func (*GetDomainReplicationMessagesResponse) ProtoMessage()

func (*GetDomainReplicationMessagesResponse) Reset

func (*GetDomainReplicationMessagesResponse) Size

func (*GetDomainReplicationMessagesResponse) String

func (*GetDomainReplicationMessagesResponse) Unmarshal

func (m *GetDomainReplicationMessagesResponse) Unmarshal(dAtA []byte) error

func (*GetDomainReplicationMessagesResponse) XXX_DiscardUnknown

func (m *GetDomainReplicationMessagesResponse) XXX_DiscardUnknown()

func (*GetDomainReplicationMessagesResponse) XXX_Marshal

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

func (*GetDomainReplicationMessagesResponse) XXX_Merge

func (*GetDomainReplicationMessagesResponse) XXX_Size

func (*GetDomainReplicationMessagesResponse) XXX_Unmarshal

func (m *GetDomainReplicationMessagesResponse) XXX_Unmarshal(b []byte) error

type GetDynamicConfigRequest

type GetDynamicConfigRequest struct {
	ConfigName           string                 `protobuf:"bytes,1,opt,name=config_name,json=configName,proto3" json:"config_name,omitempty"`
	Filters              []*DynamicConfigFilter `protobuf:"bytes,2,rep,name=filters,proto3" json:"filters,omitempty"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

If get_all is True, then all provided filters are ignored and all values associated with config_name will be returned. If get_all is False and no filters are specified (or no filter match), fallback value will be returned. If get_all is False and a filter(s) is specified, value that matches filter will be returned. If config_name cannot be found in database, default value will be returned.

func (*GetDynamicConfigRequest) Descriptor

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

func (*GetDynamicConfigRequest) GetConfigName

func (m *GetDynamicConfigRequest) GetConfigName() string

func (*GetDynamicConfigRequest) GetFilters

func (m *GetDynamicConfigRequest) GetFilters() []*DynamicConfigFilter

func (*GetDynamicConfigRequest) Marshal

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

func (*GetDynamicConfigRequest) MarshalTo

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

func (*GetDynamicConfigRequest) MarshalToSizedBuffer

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

func (*GetDynamicConfigRequest) ProtoMessage

func (*GetDynamicConfigRequest) ProtoMessage()

func (*GetDynamicConfigRequest) Reset

func (m *GetDynamicConfigRequest) Reset()

func (*GetDynamicConfigRequest) Size

func (m *GetDynamicConfigRequest) Size() (n int)

func (*GetDynamicConfigRequest) String

func (m *GetDynamicConfigRequest) String() string

func (*GetDynamicConfigRequest) Unmarshal

func (m *GetDynamicConfigRequest) Unmarshal(dAtA []byte) error

func (*GetDynamicConfigRequest) XXX_DiscardUnknown

func (m *GetDynamicConfigRequest) XXX_DiscardUnknown()

func (*GetDynamicConfigRequest) XXX_Marshal

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

func (*GetDynamicConfigRequest) XXX_Merge

func (m *GetDynamicConfigRequest) XXX_Merge(src proto.Message)

func (*GetDynamicConfigRequest) XXX_Size

func (m *GetDynamicConfigRequest) XXX_Size() int

func (*GetDynamicConfigRequest) XXX_Unmarshal

func (m *GetDynamicConfigRequest) XXX_Unmarshal(b []byte) error

type GetDynamicConfigResponse

type GetDynamicConfigResponse struct {
	Value                *v1.DataBlob `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*GetDynamicConfigResponse) Descriptor

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

func (*GetDynamicConfigResponse) GetValue

func (m *GetDynamicConfigResponse) GetValue() *v1.DataBlob

func (*GetDynamicConfigResponse) Marshal

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

func (*GetDynamicConfigResponse) MarshalTo

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

func (*GetDynamicConfigResponse) MarshalToSizedBuffer

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

func (*GetDynamicConfigResponse) ProtoMessage

func (*GetDynamicConfigResponse) ProtoMessage()

func (*GetDynamicConfigResponse) Reset

func (m *GetDynamicConfigResponse) Reset()

func (*GetDynamicConfigResponse) Size

func (m *GetDynamicConfigResponse) Size() (n int)

func (*GetDynamicConfigResponse) String

func (m *GetDynamicConfigResponse) String() string

func (*GetDynamicConfigResponse) Unmarshal

func (m *GetDynamicConfigResponse) Unmarshal(dAtA []byte) error

func (*GetDynamicConfigResponse) XXX_DiscardUnknown

func (m *GetDynamicConfigResponse) XXX_DiscardUnknown()

func (*GetDynamicConfigResponse) XXX_Marshal

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

func (*GetDynamicConfigResponse) XXX_Merge

func (m *GetDynamicConfigResponse) XXX_Merge(src proto.Message)

func (*GetDynamicConfigResponse) XXX_Size

func (m *GetDynamicConfigResponse) XXX_Size() int

func (*GetDynamicConfigResponse) XXX_Unmarshal

func (m *GetDynamicConfigResponse) XXX_Unmarshal(b []byte) error

type GetGlobalIsolationGroupsRequest

type GetGlobalIsolationGroupsRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Global

func (*GetGlobalIsolationGroupsRequest) Descriptor

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

func (*GetGlobalIsolationGroupsRequest) Marshal

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

func (*GetGlobalIsolationGroupsRequest) MarshalTo

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

func (*GetGlobalIsolationGroupsRequest) MarshalToSizedBuffer

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

func (*GetGlobalIsolationGroupsRequest) ProtoMessage

func (*GetGlobalIsolationGroupsRequest) ProtoMessage()

func (*GetGlobalIsolationGroupsRequest) Reset

func (*GetGlobalIsolationGroupsRequest) Size

func (m *GetGlobalIsolationGroupsRequest) Size() (n int)

func (*GetGlobalIsolationGroupsRequest) String

func (*GetGlobalIsolationGroupsRequest) Unmarshal

func (m *GetGlobalIsolationGroupsRequest) Unmarshal(dAtA []byte) error

func (*GetGlobalIsolationGroupsRequest) XXX_DiscardUnknown

func (m *GetGlobalIsolationGroupsRequest) XXX_DiscardUnknown()

func (*GetGlobalIsolationGroupsRequest) XXX_Marshal

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

func (*GetGlobalIsolationGroupsRequest) XXX_Merge

func (m *GetGlobalIsolationGroupsRequest) XXX_Merge(src proto.Message)

func (*GetGlobalIsolationGroupsRequest) XXX_Size

func (m *GetGlobalIsolationGroupsRequest) XXX_Size() int

func (*GetGlobalIsolationGroupsRequest) XXX_Unmarshal

func (m *GetGlobalIsolationGroupsRequest) XXX_Unmarshal(b []byte) error

type GetGlobalIsolationGroupsResponse

type GetGlobalIsolationGroupsResponse struct {
	IsolationGroups      *v1.IsolationGroupConfiguration `protobuf:"bytes,1,opt,name=isolation_groups,json=isolationGroups,proto3" json:"isolation_groups,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                        `json:"-"`
	XXX_unrecognized     []byte                          `json:"-"`
	XXX_sizecache        int32                           `json:"-"`
}

func (*GetGlobalIsolationGroupsResponse) Descriptor

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

func (*GetGlobalIsolationGroupsResponse) GetIsolationGroups

func (*GetGlobalIsolationGroupsResponse) Marshal

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

func (*GetGlobalIsolationGroupsResponse) MarshalTo

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

func (*GetGlobalIsolationGroupsResponse) MarshalToSizedBuffer

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

func (*GetGlobalIsolationGroupsResponse) ProtoMessage

func (*GetGlobalIsolationGroupsResponse) ProtoMessage()

func (*GetGlobalIsolationGroupsResponse) Reset

func (*GetGlobalIsolationGroupsResponse) Size

func (m *GetGlobalIsolationGroupsResponse) Size() (n int)

func (*GetGlobalIsolationGroupsResponse) String

func (*GetGlobalIsolationGroupsResponse) Unmarshal

func (m *GetGlobalIsolationGroupsResponse) Unmarshal(dAtA []byte) error

func (*GetGlobalIsolationGroupsResponse) XXX_DiscardUnknown

func (m *GetGlobalIsolationGroupsResponse) XXX_DiscardUnknown()

func (*GetGlobalIsolationGroupsResponse) XXX_Marshal

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

func (*GetGlobalIsolationGroupsResponse) XXX_Merge

func (*GetGlobalIsolationGroupsResponse) XXX_Size

func (m *GetGlobalIsolationGroupsResponse) XXX_Size() int

func (*GetGlobalIsolationGroupsResponse) XXX_Unmarshal

func (m *GetGlobalIsolationGroupsResponse) XXX_Unmarshal(b []byte) error

type GetReplicationMessagesRequest

type GetReplicationMessagesRequest struct {
	Tokens               []*ReplicationToken `protobuf:"bytes,1,rep,name=tokens,proto3" json:"tokens,omitempty"`
	ClusterName          string              `protobuf:"bytes,2,opt,name=cluster_name,json=clusterName,proto3" json:"cluster_name,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*GetReplicationMessagesRequest) Descriptor

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

func (*GetReplicationMessagesRequest) GetClusterName

func (m *GetReplicationMessagesRequest) GetClusterName() string

func (*GetReplicationMessagesRequest) GetTokens

func (*GetReplicationMessagesRequest) Marshal

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

func (*GetReplicationMessagesRequest) MarshalTo

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

func (*GetReplicationMessagesRequest) MarshalToSizedBuffer

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

func (*GetReplicationMessagesRequest) ProtoMessage

func (*GetReplicationMessagesRequest) ProtoMessage()

func (*GetReplicationMessagesRequest) Reset

func (m *GetReplicationMessagesRequest) Reset()

func (*GetReplicationMessagesRequest) Size

func (m *GetReplicationMessagesRequest) Size() (n int)

func (*GetReplicationMessagesRequest) String

func (*GetReplicationMessagesRequest) Unmarshal

func (m *GetReplicationMessagesRequest) Unmarshal(dAtA []byte) error

func (*GetReplicationMessagesRequest) XXX_DiscardUnknown

func (m *GetReplicationMessagesRequest) XXX_DiscardUnknown()

func (*GetReplicationMessagesRequest) XXX_Marshal

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

func (*GetReplicationMessagesRequest) XXX_Merge

func (m *GetReplicationMessagesRequest) XXX_Merge(src proto.Message)

func (*GetReplicationMessagesRequest) XXX_Size

func (m *GetReplicationMessagesRequest) XXX_Size() int

func (*GetReplicationMessagesRequest) XXX_Unmarshal

func (m *GetReplicationMessagesRequest) XXX_Unmarshal(b []byte) error

type GetReplicationMessagesResponse

type GetReplicationMessagesResponse struct {
	ShardMessages        map[int32]*ReplicationMessages `` /* 189-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                       `json:"-"`
	XXX_unrecognized     []byte                         `json:"-"`
	XXX_sizecache        int32                          `json:"-"`
}

func (*GetReplicationMessagesResponse) Descriptor

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

func (*GetReplicationMessagesResponse) GetShardMessages

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

func (*GetReplicationMessagesResponse) Marshal

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

func (*GetReplicationMessagesResponse) MarshalTo

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

func (*GetReplicationMessagesResponse) MarshalToSizedBuffer

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

func (*GetReplicationMessagesResponse) ProtoMessage

func (*GetReplicationMessagesResponse) ProtoMessage()

func (*GetReplicationMessagesResponse) Reset

func (m *GetReplicationMessagesResponse) Reset()

func (*GetReplicationMessagesResponse) Size

func (m *GetReplicationMessagesResponse) Size() (n int)

func (*GetReplicationMessagesResponse) String

func (*GetReplicationMessagesResponse) Unmarshal

func (m *GetReplicationMessagesResponse) Unmarshal(dAtA []byte) error

func (*GetReplicationMessagesResponse) XXX_DiscardUnknown

func (m *GetReplicationMessagesResponse) XXX_DiscardUnknown()

func (*GetReplicationMessagesResponse) XXX_Marshal

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

func (*GetReplicationMessagesResponse) XXX_Merge

func (m *GetReplicationMessagesResponse) XXX_Merge(src proto.Message)

func (*GetReplicationMessagesResponse) XXX_Size

func (m *GetReplicationMessagesResponse) XXX_Size() int

func (*GetReplicationMessagesResponse) XXX_Unmarshal

func (m *GetReplicationMessagesResponse) XXX_Unmarshal(b []byte) error

type GetTaskFailedCause

type GetTaskFailedCause int32
const (
	GetTaskFailedCause_GET_TASK_FAILED_CAUSE_INVALID              GetTaskFailedCause = 0
	GetTaskFailedCause_GET_TASK_FAILED_CAUSE_SERVICE_BUSY         GetTaskFailedCause = 1
	GetTaskFailedCause_GET_TASK_FAILED_CAUSE_TIMEOUT              GetTaskFailedCause = 2
	GetTaskFailedCause_GET_TASK_FAILED_CAUSE_SHARD_OWNERSHIP_LOST GetTaskFailedCause = 3
	GetTaskFailedCause_GET_TASK_FAILED_CAUSE_UNCATEGORIZED        GetTaskFailedCause = 4
)

func (GetTaskFailedCause) EnumDescriptor

func (GetTaskFailedCause) EnumDescriptor() ([]byte, []int)

func (GetTaskFailedCause) String

func (x GetTaskFailedCause) String() string

type GetWorkflowExecutionRawHistoryV2Request

type GetWorkflowExecutionRawHistoryV2Request struct {
	Domain               string                `protobuf:"bytes,1,opt,name=domain,proto3" json:"domain,omitempty"`
	WorkflowExecution    *v1.WorkflowExecution `protobuf:"bytes,2,opt,name=workflow_execution,json=workflowExecution,proto3" json:"workflow_execution,omitempty"`
	StartEvent           *VersionHistoryItem   `protobuf:"bytes,3,opt,name=start_event,json=startEvent,proto3" json:"start_event,omitempty"`
	EndEvent             *VersionHistoryItem   `protobuf:"bytes,4,opt,name=end_event,json=endEvent,proto3" json:"end_event,omitempty"`
	PageSize             int32                 `protobuf:"varint,5,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	NextPageToken        []byte                `protobuf:"bytes,6,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*GetWorkflowExecutionRawHistoryV2Request) Descriptor

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

func (*GetWorkflowExecutionRawHistoryV2Request) GetDomain

func (*GetWorkflowExecutionRawHistoryV2Request) GetEndEvent

func (*GetWorkflowExecutionRawHistoryV2Request) GetNextPageToken

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

func (*GetWorkflowExecutionRawHistoryV2Request) GetPageSize

func (*GetWorkflowExecutionRawHistoryV2Request) GetStartEvent

func (*GetWorkflowExecutionRawHistoryV2Request) GetWorkflowExecution

func (*GetWorkflowExecutionRawHistoryV2Request) Marshal

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

func (*GetWorkflowExecutionRawHistoryV2Request) MarshalTo

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

func (*GetWorkflowExecutionRawHistoryV2Request) MarshalToSizedBuffer

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

func (*GetWorkflowExecutionRawHistoryV2Request) ProtoMessage

func (*GetWorkflowExecutionRawHistoryV2Request) Reset

func (*GetWorkflowExecutionRawHistoryV2Request) Size

func (*GetWorkflowExecutionRawHistoryV2Request) String

func (*GetWorkflowExecutionRawHistoryV2Request) Unmarshal

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

func (*GetWorkflowExecutionRawHistoryV2Request) XXX_DiscardUnknown

func (m *GetWorkflowExecutionRawHistoryV2Request) XXX_DiscardUnknown()

func (*GetWorkflowExecutionRawHistoryV2Request) XXX_Marshal

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

func (*GetWorkflowExecutionRawHistoryV2Request) XXX_Merge

func (*GetWorkflowExecutionRawHistoryV2Request) XXX_Size

func (*GetWorkflowExecutionRawHistoryV2Request) XXX_Unmarshal

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

type GetWorkflowExecutionRawHistoryV2Response

type GetWorkflowExecutionRawHistoryV2Response struct {
	NextPageToken        []byte          `protobuf:"bytes,1,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	HistoryBatches       []*v1.DataBlob  `protobuf:"bytes,2,rep,name=history_batches,json=historyBatches,proto3" json:"history_batches,omitempty"`
	VersionHistory       *VersionHistory `protobuf:"bytes,3,opt,name=version_history,json=versionHistory,proto3" json:"version_history,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*GetWorkflowExecutionRawHistoryV2Response) Descriptor

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

func (*GetWorkflowExecutionRawHistoryV2Response) GetHistoryBatches

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

func (*GetWorkflowExecutionRawHistoryV2Response) GetNextPageToken

func (m *GetWorkflowExecutionRawHistoryV2Response) GetNextPageToken() []byte

func (*GetWorkflowExecutionRawHistoryV2Response) GetVersionHistory

func (*GetWorkflowExecutionRawHistoryV2Response) Marshal

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

func (*GetWorkflowExecutionRawHistoryV2Response) MarshalTo

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

func (*GetWorkflowExecutionRawHistoryV2Response) MarshalToSizedBuffer

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

func (*GetWorkflowExecutionRawHistoryV2Response) ProtoMessage

func (*GetWorkflowExecutionRawHistoryV2Response) Reset

func (*GetWorkflowExecutionRawHistoryV2Response) Size

func (*GetWorkflowExecutionRawHistoryV2Response) String

func (*GetWorkflowExecutionRawHistoryV2Response) Unmarshal

func (*GetWorkflowExecutionRawHistoryV2Response) XXX_DiscardUnknown

func (m *GetWorkflowExecutionRawHistoryV2Response) XXX_DiscardUnknown()

func (*GetWorkflowExecutionRawHistoryV2Response) XXX_Marshal

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

func (*GetWorkflowExecutionRawHistoryV2Response) XXX_Merge

func (*GetWorkflowExecutionRawHistoryV2Response) XXX_Size

func (*GetWorkflowExecutionRawHistoryV2Response) XXX_Unmarshal

func (m *GetWorkflowExecutionRawHistoryV2Response) XXX_Unmarshal(b []byte) error

type HistoryDLQCountEntry

type HistoryDLQCountEntry struct {
	Count                int64    `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"`
	ShardId              int32    `protobuf:"varint,2,opt,name=shard_id,json=shardId,proto3" json:"shard_id,omitempty"`
	SourceCluster        string   `protobuf:"bytes,3,opt,name=source_cluster,json=sourceCluster,proto3" json:"source_cluster,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*HistoryDLQCountEntry) Descriptor

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

func (*HistoryDLQCountEntry) GetCount

func (m *HistoryDLQCountEntry) GetCount() int64

func (*HistoryDLQCountEntry) GetShardId

func (m *HistoryDLQCountEntry) GetShardId() int32

func (*HistoryDLQCountEntry) GetSourceCluster

func (m *HistoryDLQCountEntry) GetSourceCluster() string

func (*HistoryDLQCountEntry) Marshal

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

func (*HistoryDLQCountEntry) MarshalTo

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

func (*HistoryDLQCountEntry) MarshalToSizedBuffer

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

func (*HistoryDLQCountEntry) ProtoMessage

func (*HistoryDLQCountEntry) ProtoMessage()

func (*HistoryDLQCountEntry) Reset

func (m *HistoryDLQCountEntry) Reset()

func (*HistoryDLQCountEntry) Size

func (m *HistoryDLQCountEntry) Size() (n int)

func (*HistoryDLQCountEntry) String

func (m *HistoryDLQCountEntry) String() string

func (*HistoryDLQCountEntry) Unmarshal

func (m *HistoryDLQCountEntry) Unmarshal(dAtA []byte) error

func (*HistoryDLQCountEntry) XXX_DiscardUnknown

func (m *HistoryDLQCountEntry) XXX_DiscardUnknown()

func (*HistoryDLQCountEntry) XXX_Marshal

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

func (*HistoryDLQCountEntry) XXX_Merge

func (m *HistoryDLQCountEntry) XXX_Merge(src proto.Message)

func (*HistoryDLQCountEntry) XXX_Size

func (m *HistoryDLQCountEntry) XXX_Size() int

func (*HistoryDLQCountEntry) XXX_Unmarshal

func (m *HistoryDLQCountEntry) XXX_Unmarshal(b []byte) error

type HistoryTaskV2Attributes

type HistoryTaskV2Attributes struct {
	TaskId              int64                 `protobuf:"varint,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	DomainId            string                `protobuf:"bytes,2,opt,name=domain_id,json=domainId,proto3" json:"domain_id,omitempty"`
	WorkflowExecution   *v1.WorkflowExecution `protobuf:"bytes,3,opt,name=workflow_execution,json=workflowExecution,proto3" json:"workflow_execution,omitempty"`
	VersionHistoryItems []*VersionHistoryItem `protobuf:"bytes,4,rep,name=version_history_items,json=versionHistoryItems,proto3" json:"version_history_items,omitempty"`
	Events              *v1.DataBlob          `protobuf:"bytes,5,opt,name=events,proto3" json:"events,omitempty"`
	// New run events does not need version history since there is no prior events.
	NewRunEvents         *v1.DataBlob `protobuf:"bytes,6,opt,name=new_run_events,json=newRunEvents,proto3" json:"new_run_events,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*HistoryTaskV2Attributes) Descriptor

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

func (*HistoryTaskV2Attributes) GetDomainId

func (m *HistoryTaskV2Attributes) GetDomainId() string

func (*HistoryTaskV2Attributes) GetEvents

func (m *HistoryTaskV2Attributes) GetEvents() *v1.DataBlob

func (*HistoryTaskV2Attributes) GetNewRunEvents

func (m *HistoryTaskV2Attributes) GetNewRunEvents() *v1.DataBlob

func (*HistoryTaskV2Attributes) GetTaskId

func (m *HistoryTaskV2Attributes) GetTaskId() int64

func (*HistoryTaskV2Attributes) GetVersionHistoryItems

func (m *HistoryTaskV2Attributes) GetVersionHistoryItems() []*VersionHistoryItem

func (*HistoryTaskV2Attributes) GetWorkflowExecution

func (m *HistoryTaskV2Attributes) GetWorkflowExecution() *v1.WorkflowExecution

func (*HistoryTaskV2Attributes) Marshal

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

func (*HistoryTaskV2Attributes) MarshalTo

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

func (*HistoryTaskV2Attributes) MarshalToSizedBuffer

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

func (*HistoryTaskV2Attributes) ProtoMessage

func (*HistoryTaskV2Attributes) ProtoMessage()

func (*HistoryTaskV2Attributes) Reset

func (m *HistoryTaskV2Attributes) Reset()

func (*HistoryTaskV2Attributes) Size

func (m *HistoryTaskV2Attributes) Size() (n int)

func (*HistoryTaskV2Attributes) String

func (m *HistoryTaskV2Attributes) String() string

func (*HistoryTaskV2Attributes) Unmarshal

func (m *HistoryTaskV2Attributes) Unmarshal(dAtA []byte) error

func (*HistoryTaskV2Attributes) XXX_DiscardUnknown

func (m *HistoryTaskV2Attributes) XXX_DiscardUnknown()

func (*HistoryTaskV2Attributes) XXX_Marshal

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

func (*HistoryTaskV2Attributes) XXX_Merge

func (m *HistoryTaskV2Attributes) XXX_Merge(src proto.Message)

func (*HistoryTaskV2Attributes) XXX_Size

func (m *HistoryTaskV2Attributes) XXX_Size() int

func (*HistoryTaskV2Attributes) XXX_Unmarshal

func (m *HistoryTaskV2Attributes) XXX_Unmarshal(b []byte) error

type HostInfo

type HostInfo struct {
	Identity             string   `protobuf:"bytes,1,opt,name=identity,proto3" json:"identity,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*HostInfo) Descriptor

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

func (*HostInfo) GetIdentity

func (m *HostInfo) GetIdentity() string

func (*HostInfo) Marshal

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

func (*HostInfo) MarshalTo

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

func (*HostInfo) MarshalToSizedBuffer

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

func (*HostInfo) ProtoMessage

func (*HostInfo) ProtoMessage()

func (*HostInfo) Reset

func (m *HostInfo) Reset()

func (*HostInfo) Size

func (m *HostInfo) Size() (n int)

func (*HostInfo) String

func (m *HostInfo) String() string

func (*HostInfo) Unmarshal

func (m *HostInfo) Unmarshal(dAtA []byte) error

func (*HostInfo) XXX_DiscardUnknown

func (m *HostInfo) XXX_DiscardUnknown()

func (*HostInfo) XXX_Marshal

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

func (*HostInfo) XXX_Merge

func (m *HostInfo) XXX_Merge(src proto.Message)

func (*HostInfo) XXX_Size

func (m *HostInfo) XXX_Size() int

func (*HostInfo) XXX_Unmarshal

func (m *HostInfo) XXX_Unmarshal(b []byte) error

type ListDynamicConfigRequest

type ListDynamicConfigRequest struct {
	ConfigName           string   `protobuf:"bytes,1,opt,name=config_name,json=configName,proto3" json:"config_name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ListDynamicConfigRequest) Descriptor

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

func (*ListDynamicConfigRequest) GetConfigName

func (m *ListDynamicConfigRequest) GetConfigName() string

func (*ListDynamicConfigRequest) Marshal

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

func (*ListDynamicConfigRequest) MarshalTo

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

func (*ListDynamicConfigRequest) MarshalToSizedBuffer

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

func (*ListDynamicConfigRequest) ProtoMessage

func (*ListDynamicConfigRequest) ProtoMessage()

func (*ListDynamicConfigRequest) Reset

func (m *ListDynamicConfigRequest) Reset()

func (*ListDynamicConfigRequest) Size

func (m *ListDynamicConfigRequest) Size() (n int)

func (*ListDynamicConfigRequest) String

func (m *ListDynamicConfigRequest) String() string

func (*ListDynamicConfigRequest) Unmarshal

func (m *ListDynamicConfigRequest) Unmarshal(dAtA []byte) error

func (*ListDynamicConfigRequest) XXX_DiscardUnknown

func (m *ListDynamicConfigRequest) XXX_DiscardUnknown()

func (*ListDynamicConfigRequest) XXX_Marshal

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

func (*ListDynamicConfigRequest) XXX_Merge

func (m *ListDynamicConfigRequest) XXX_Merge(src proto.Message)

func (*ListDynamicConfigRequest) XXX_Size

func (m *ListDynamicConfigRequest) XXX_Size() int

func (*ListDynamicConfigRequest) XXX_Unmarshal

func (m *ListDynamicConfigRequest) XXX_Unmarshal(b []byte) error

type ListDynamicConfigResponse

type ListDynamicConfigResponse struct {
	Entries              []*DynamicConfigEntry `protobuf:"bytes,1,rep,name=entries,proto3" json:"entries,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*ListDynamicConfigResponse) Descriptor

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

func (*ListDynamicConfigResponse) GetEntries

func (m *ListDynamicConfigResponse) GetEntries() []*DynamicConfigEntry

func (*ListDynamicConfigResponse) Marshal

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

func (*ListDynamicConfigResponse) MarshalTo

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

func (*ListDynamicConfigResponse) MarshalToSizedBuffer

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

func (*ListDynamicConfigResponse) ProtoMessage

func (*ListDynamicConfigResponse) ProtoMessage()

func (*ListDynamicConfigResponse) Reset

func (m *ListDynamicConfigResponse) Reset()

func (*ListDynamicConfigResponse) Size

func (m *ListDynamicConfigResponse) Size() (n int)

func (*ListDynamicConfigResponse) String

func (m *ListDynamicConfigResponse) String() string

func (*ListDynamicConfigResponse) Unmarshal

func (m *ListDynamicConfigResponse) Unmarshal(dAtA []byte) error

func (*ListDynamicConfigResponse) XXX_DiscardUnknown

func (m *ListDynamicConfigResponse) XXX_DiscardUnknown()

func (*ListDynamicConfigResponse) XXX_Marshal

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

func (*ListDynamicConfigResponse) XXX_Merge

func (m *ListDynamicConfigResponse) XXX_Merge(src proto.Message)

func (*ListDynamicConfigResponse) XXX_Size

func (m *ListDynamicConfigResponse) XXX_Size() int

func (*ListDynamicConfigResponse) XXX_Unmarshal

func (m *ListDynamicConfigResponse) XXX_Unmarshal(b []byte) error

type MaintainCorruptWorkflowRequest

type MaintainCorruptWorkflowRequest struct {
	Domain               string                `protobuf:"bytes,1,opt,name=domain,proto3" json:"domain,omitempty"`
	WorkflowExecution    *v1.WorkflowExecution `protobuf:"bytes,2,opt,name=workflow_execution,json=workflowExecution,proto3" json:"workflow_execution,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*MaintainCorruptWorkflowRequest) Descriptor

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

func (*MaintainCorruptWorkflowRequest) GetDomain

func (m *MaintainCorruptWorkflowRequest) GetDomain() string

func (*MaintainCorruptWorkflowRequest) GetWorkflowExecution

func (m *MaintainCorruptWorkflowRequest) GetWorkflowExecution() *v1.WorkflowExecution

func (*MaintainCorruptWorkflowRequest) Marshal

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

func (*MaintainCorruptWorkflowRequest) MarshalTo

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

func (*MaintainCorruptWorkflowRequest) MarshalToSizedBuffer

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

func (*MaintainCorruptWorkflowRequest) ProtoMessage

func (*MaintainCorruptWorkflowRequest) ProtoMessage()

func (*MaintainCorruptWorkflowRequest) Reset

func (m *MaintainCorruptWorkflowRequest) Reset()

func (*MaintainCorruptWorkflowRequest) Size

func (m *MaintainCorruptWorkflowRequest) Size() (n int)

func (*MaintainCorruptWorkflowRequest) String

func (*MaintainCorruptWorkflowRequest) Unmarshal

func (m *MaintainCorruptWorkflowRequest) Unmarshal(dAtA []byte) error

func (*MaintainCorruptWorkflowRequest) XXX_DiscardUnknown

func (m *MaintainCorruptWorkflowRequest) XXX_DiscardUnknown()

func (*MaintainCorruptWorkflowRequest) XXX_Marshal

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

func (*MaintainCorruptWorkflowRequest) XXX_Merge

func (m *MaintainCorruptWorkflowRequest) XXX_Merge(src proto.Message)

func (*MaintainCorruptWorkflowRequest) XXX_Size

func (m *MaintainCorruptWorkflowRequest) XXX_Size() int

func (*MaintainCorruptWorkflowRequest) XXX_Unmarshal

func (m *MaintainCorruptWorkflowRequest) XXX_Unmarshal(b []byte) error

type MaintainCorruptWorkflowResponse

type MaintainCorruptWorkflowResponse struct {
	HistoryDeleted       bool     `protobuf:"varint,1,opt,name=history_deleted,json=historyDeleted,proto3" json:"history_deleted,omitempty"`
	ExecutionsDeleted    bool     `protobuf:"varint,2,opt,name=executions_deleted,json=executionsDeleted,proto3" json:"executions_deleted,omitempty"`
	VisibilityDeleted    bool     `protobuf:"varint,3,opt,name=visibility_deleted,json=visibilityDeleted,proto3" json:"visibility_deleted,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*MaintainCorruptWorkflowResponse) Descriptor

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

func (*MaintainCorruptWorkflowResponse) GetExecutionsDeleted

func (m *MaintainCorruptWorkflowResponse) GetExecutionsDeleted() bool

func (*MaintainCorruptWorkflowResponse) GetHistoryDeleted

func (m *MaintainCorruptWorkflowResponse) GetHistoryDeleted() bool

func (*MaintainCorruptWorkflowResponse) GetVisibilityDeleted

func (m *MaintainCorruptWorkflowResponse) GetVisibilityDeleted() bool

func (*MaintainCorruptWorkflowResponse) Marshal

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

func (*MaintainCorruptWorkflowResponse) MarshalTo

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

func (*MaintainCorruptWorkflowResponse) MarshalToSizedBuffer

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

func (*MaintainCorruptWorkflowResponse) ProtoMessage

func (*MaintainCorruptWorkflowResponse) ProtoMessage()

func (*MaintainCorruptWorkflowResponse) Reset

func (*MaintainCorruptWorkflowResponse) Size

func (m *MaintainCorruptWorkflowResponse) Size() (n int)

func (*MaintainCorruptWorkflowResponse) String

func (*MaintainCorruptWorkflowResponse) Unmarshal

func (m *MaintainCorruptWorkflowResponse) Unmarshal(dAtA []byte) error

func (*MaintainCorruptWorkflowResponse) XXX_DiscardUnknown

func (m *MaintainCorruptWorkflowResponse) XXX_DiscardUnknown()

func (*MaintainCorruptWorkflowResponse) XXX_Marshal

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

func (*MaintainCorruptWorkflowResponse) XXX_Merge

func (m *MaintainCorruptWorkflowResponse) XXX_Merge(src proto.Message)

func (*MaintainCorruptWorkflowResponse) XXX_Size

func (m *MaintainCorruptWorkflowResponse) XXX_Size() int

func (*MaintainCorruptWorkflowResponse) XXX_Unmarshal

func (m *MaintainCorruptWorkflowResponse) XXX_Unmarshal(b []byte) error

type MembershipInfo

type MembershipInfo struct {
	CurrentHost          *HostInfo   `protobuf:"bytes,1,opt,name=current_host,json=currentHost,proto3" json:"current_host,omitempty"`
	ReachableMembers     []string    `protobuf:"bytes,2,rep,name=reachable_members,json=reachableMembers,proto3" json:"reachable_members,omitempty"`
	Rings                []*RingInfo `protobuf:"bytes,3,rep,name=rings,proto3" json:"rings,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*MembershipInfo) Descriptor

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

func (*MembershipInfo) GetCurrentHost

func (m *MembershipInfo) GetCurrentHost() *HostInfo

func (*MembershipInfo) GetReachableMembers

func (m *MembershipInfo) GetReachableMembers() []string

func (*MembershipInfo) GetRings

func (m *MembershipInfo) GetRings() []*RingInfo

func (*MembershipInfo) Marshal

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

func (*MembershipInfo) MarshalTo

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

func (*MembershipInfo) MarshalToSizedBuffer

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

func (*MembershipInfo) ProtoMessage

func (*MembershipInfo) ProtoMessage()

func (*MembershipInfo) Reset

func (m *MembershipInfo) Reset()

func (*MembershipInfo) Size

func (m *MembershipInfo) Size() (n int)

func (*MembershipInfo) String

func (m *MembershipInfo) String() string

func (*MembershipInfo) Unmarshal

func (m *MembershipInfo) Unmarshal(dAtA []byte) error

func (*MembershipInfo) XXX_DiscardUnknown

func (m *MembershipInfo) XXX_DiscardUnknown()

func (*MembershipInfo) XXX_Marshal

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

func (*MembershipInfo) XXX_Merge

func (m *MembershipInfo) XXX_Merge(src proto.Message)

func (*MembershipInfo) XXX_Size

func (m *MembershipInfo) XXX_Size() int

func (*MembershipInfo) XXX_Unmarshal

func (m *MembershipInfo) XXX_Unmarshal(b []byte) error

type MergeDLQMessagesRequest

type MergeDLQMessagesRequest struct {
	Type                  DLQType           `protobuf:"varint,1,opt,name=type,proto3,enum=uber.cadence.admin.v1.DLQType" json:"type,omitempty"`
	ShardId               int32             `protobuf:"varint,2,opt,name=shard_id,json=shardId,proto3" json:"shard_id,omitempty"`
	SourceCluster         string            `protobuf:"bytes,3,opt,name=source_cluster,json=sourceCluster,proto3" json:"source_cluster,omitempty"`
	InclusiveEndMessageId *types.Int64Value `` /* 128-byte string literal not displayed */
	PageSize              int32             `protobuf:"varint,5,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	NextPageToken         []byte            `protobuf:"bytes,6,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	XXX_NoUnkeyedLiteral  struct{}          `json:"-"`
	XXX_unrecognized      []byte            `json:"-"`
	XXX_sizecache         int32             `json:"-"`
}

func (*MergeDLQMessagesRequest) Descriptor

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

func (*MergeDLQMessagesRequest) GetInclusiveEndMessageId

func (m *MergeDLQMessagesRequest) GetInclusiveEndMessageId() *types.Int64Value

func (*MergeDLQMessagesRequest) GetNextPageToken

func (m *MergeDLQMessagesRequest) GetNextPageToken() []byte

func (*MergeDLQMessagesRequest) GetPageSize

func (m *MergeDLQMessagesRequest) GetPageSize() int32

func (*MergeDLQMessagesRequest) GetShardId

func (m *MergeDLQMessagesRequest) GetShardId() int32

func (*MergeDLQMessagesRequest) GetSourceCluster

func (m *MergeDLQMessagesRequest) GetSourceCluster() string

func (*MergeDLQMessagesRequest) GetType

func (m *MergeDLQMessagesRequest) GetType() DLQType

func (*MergeDLQMessagesRequest) Marshal

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

func (*MergeDLQMessagesRequest) MarshalTo

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

func (*MergeDLQMessagesRequest) MarshalToSizedBuffer

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

func (*MergeDLQMessagesRequest) ProtoMessage

func (*MergeDLQMessagesRequest) ProtoMessage()

func (*MergeDLQMessagesRequest) Reset

func (m *MergeDLQMessagesRequest) Reset()

func (*MergeDLQMessagesRequest) Size

func (m *MergeDLQMessagesRequest) Size() (n int)

func (*MergeDLQMessagesRequest) String

func (m *MergeDLQMessagesRequest) String() string

func (*MergeDLQMessagesRequest) Unmarshal

func (m *MergeDLQMessagesRequest) Unmarshal(dAtA []byte) error

func (*MergeDLQMessagesRequest) XXX_DiscardUnknown

func (m *MergeDLQMessagesRequest) XXX_DiscardUnknown()

func (*MergeDLQMessagesRequest) XXX_Marshal

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

func (*MergeDLQMessagesRequest) XXX_Merge

func (m *MergeDLQMessagesRequest) XXX_Merge(src proto.Message)

func (*MergeDLQMessagesRequest) XXX_Size

func (m *MergeDLQMessagesRequest) XXX_Size() int

func (*MergeDLQMessagesRequest) XXX_Unmarshal

func (m *MergeDLQMessagesRequest) XXX_Unmarshal(b []byte) error

type MergeDLQMessagesResponse

type MergeDLQMessagesResponse struct {
	NextPageToken        []byte   `protobuf:"bytes,1,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*MergeDLQMessagesResponse) Descriptor

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

func (*MergeDLQMessagesResponse) GetNextPageToken

func (m *MergeDLQMessagesResponse) GetNextPageToken() []byte

func (*MergeDLQMessagesResponse) Marshal

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

func (*MergeDLQMessagesResponse) MarshalTo

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

func (*MergeDLQMessagesResponse) MarshalToSizedBuffer

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

func (*MergeDLQMessagesResponse) ProtoMessage

func (*MergeDLQMessagesResponse) ProtoMessage()

func (*MergeDLQMessagesResponse) Reset

func (m *MergeDLQMessagesResponse) Reset()

func (*MergeDLQMessagesResponse) Size

func (m *MergeDLQMessagesResponse) Size() (n int)

func (*MergeDLQMessagesResponse) String

func (m *MergeDLQMessagesResponse) String() string

func (*MergeDLQMessagesResponse) Unmarshal

func (m *MergeDLQMessagesResponse) Unmarshal(dAtA []byte) error

func (*MergeDLQMessagesResponse) XXX_DiscardUnknown

func (m *MergeDLQMessagesResponse) XXX_DiscardUnknown()

func (*MergeDLQMessagesResponse) XXX_Marshal

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

func (*MergeDLQMessagesResponse) XXX_Merge

func (m *MergeDLQMessagesResponse) XXX_Merge(src proto.Message)

func (*MergeDLQMessagesResponse) XXX_Size

func (m *MergeDLQMessagesResponse) XXX_Size() int

func (*MergeDLQMessagesResponse) XXX_Unmarshal

func (m *MergeDLQMessagesResponse) XXX_Unmarshal(b []byte) error

type PersistenceFeature

type PersistenceFeature struct {
	Key                  string   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Enabled              bool     `protobuf:"varint,2,opt,name=enabled,proto3" json:"enabled,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PersistenceFeature) Descriptor

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

func (*PersistenceFeature) GetEnabled

func (m *PersistenceFeature) GetEnabled() bool

func (*PersistenceFeature) GetKey

func (m *PersistenceFeature) GetKey() string

func (*PersistenceFeature) Marshal

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

func (*PersistenceFeature) MarshalTo

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

func (*PersistenceFeature) MarshalToSizedBuffer

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

func (*PersistenceFeature) ProtoMessage

func (*PersistenceFeature) ProtoMessage()

func (*PersistenceFeature) Reset

func (m *PersistenceFeature) Reset()

func (*PersistenceFeature) Size

func (m *PersistenceFeature) Size() (n int)

func (*PersistenceFeature) String

func (m *PersistenceFeature) String() string

func (*PersistenceFeature) Unmarshal

func (m *PersistenceFeature) Unmarshal(dAtA []byte) error

func (*PersistenceFeature) XXX_DiscardUnknown

func (m *PersistenceFeature) XXX_DiscardUnknown()

func (*PersistenceFeature) XXX_Marshal

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

func (*PersistenceFeature) XXX_Merge

func (m *PersistenceFeature) XXX_Merge(src proto.Message)

func (*PersistenceFeature) XXX_Size

func (m *PersistenceFeature) XXX_Size() int

func (*PersistenceFeature) XXX_Unmarshal

func (m *PersistenceFeature) XXX_Unmarshal(b []byte) error

type PersistenceInfo

type PersistenceInfo struct {
	Backend              string                `protobuf:"bytes,1,opt,name=backend,proto3" json:"backend,omitempty"`
	Settings             []*PersistenceSetting `protobuf:"bytes,2,rep,name=settings,proto3" json:"settings,omitempty"`
	Features             []*PersistenceFeature `protobuf:"bytes,3,rep,name=features,proto3" json:"features,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*PersistenceInfo) Descriptor

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

func (*PersistenceInfo) GetBackend

func (m *PersistenceInfo) GetBackend() string

func (*PersistenceInfo) GetFeatures

func (m *PersistenceInfo) GetFeatures() []*PersistenceFeature

func (*PersistenceInfo) GetSettings

func (m *PersistenceInfo) GetSettings() []*PersistenceSetting

func (*PersistenceInfo) Marshal

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

func (*PersistenceInfo) MarshalTo

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

func (*PersistenceInfo) MarshalToSizedBuffer

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

func (*PersistenceInfo) ProtoMessage

func (*PersistenceInfo) ProtoMessage()

func (*PersistenceInfo) Reset

func (m *PersistenceInfo) Reset()

func (*PersistenceInfo) Size

func (m *PersistenceInfo) Size() (n int)

func (*PersistenceInfo) String

func (m *PersistenceInfo) String() string

func (*PersistenceInfo) Unmarshal

func (m *PersistenceInfo) Unmarshal(dAtA []byte) error

func (*PersistenceInfo) XXX_DiscardUnknown

func (m *PersistenceInfo) XXX_DiscardUnknown()

func (*PersistenceInfo) XXX_Marshal

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

func (*PersistenceInfo) XXX_Merge

func (m *PersistenceInfo) XXX_Merge(src proto.Message)

func (*PersistenceInfo) XXX_Size

func (m *PersistenceInfo) XXX_Size() int

func (*PersistenceInfo) XXX_Unmarshal

func (m *PersistenceInfo) XXX_Unmarshal(b []byte) error

type PersistenceSetting

type PersistenceSetting struct {
	Key                  string   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value                string   `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PersistenceSetting) Descriptor

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

func (*PersistenceSetting) GetKey

func (m *PersistenceSetting) GetKey() string

func (*PersistenceSetting) GetValue

func (m *PersistenceSetting) GetValue() string

func (*PersistenceSetting) Marshal

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

func (*PersistenceSetting) MarshalTo

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

func (*PersistenceSetting) MarshalToSizedBuffer

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

func (*PersistenceSetting) ProtoMessage

func (*PersistenceSetting) ProtoMessage()

func (*PersistenceSetting) Reset

func (m *PersistenceSetting) Reset()

func (*PersistenceSetting) Size

func (m *PersistenceSetting) Size() (n int)

func (*PersistenceSetting) String

func (m *PersistenceSetting) String() string

func (*PersistenceSetting) Unmarshal

func (m *PersistenceSetting) Unmarshal(dAtA []byte) error

func (*PersistenceSetting) XXX_DiscardUnknown

func (m *PersistenceSetting) XXX_DiscardUnknown()

func (*PersistenceSetting) XXX_Marshal

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

func (*PersistenceSetting) XXX_Merge

func (m *PersistenceSetting) XXX_Merge(src proto.Message)

func (*PersistenceSetting) XXX_Size

func (m *PersistenceSetting) XXX_Size() int

func (*PersistenceSetting) XXX_Unmarshal

func (m *PersistenceSetting) XXX_Unmarshal(b []byte) error

type PurgeDLQMessagesRequest

type PurgeDLQMessagesRequest struct {
	Type                  DLQType           `protobuf:"varint,1,opt,name=type,proto3,enum=uber.cadence.admin.v1.DLQType" json:"type,omitempty"`
	ShardId               int32             `protobuf:"varint,2,opt,name=shard_id,json=shardId,proto3" json:"shard_id,omitempty"`
	SourceCluster         string            `protobuf:"bytes,3,opt,name=source_cluster,json=sourceCluster,proto3" json:"source_cluster,omitempty"`
	InclusiveEndMessageId *types.Int64Value `` /* 128-byte string literal not displayed */
	XXX_NoUnkeyedLiteral  struct{}          `json:"-"`
	XXX_unrecognized      []byte            `json:"-"`
	XXX_sizecache         int32             `json:"-"`
}

func (*PurgeDLQMessagesRequest) Descriptor

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

func (*PurgeDLQMessagesRequest) GetInclusiveEndMessageId

func (m *PurgeDLQMessagesRequest) GetInclusiveEndMessageId() *types.Int64Value

func (*PurgeDLQMessagesRequest) GetShardId

func (m *PurgeDLQMessagesRequest) GetShardId() int32

func (*PurgeDLQMessagesRequest) GetSourceCluster

func (m *PurgeDLQMessagesRequest) GetSourceCluster() string

func (*PurgeDLQMessagesRequest) GetType

func (m *PurgeDLQMessagesRequest) GetType() DLQType

func (*PurgeDLQMessagesRequest) Marshal

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

func (*PurgeDLQMessagesRequest) MarshalTo

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

func (*PurgeDLQMessagesRequest) MarshalToSizedBuffer

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

func (*PurgeDLQMessagesRequest) ProtoMessage

func (*PurgeDLQMessagesRequest) ProtoMessage()

func (*PurgeDLQMessagesRequest) Reset

func (m *PurgeDLQMessagesRequest) Reset()

func (*PurgeDLQMessagesRequest) Size

func (m *PurgeDLQMessagesRequest) Size() (n int)

func (*PurgeDLQMessagesRequest) String

func (m *PurgeDLQMessagesRequest) String() string

func (*PurgeDLQMessagesRequest) Unmarshal

func (m *PurgeDLQMessagesRequest) Unmarshal(dAtA []byte) error

func (*PurgeDLQMessagesRequest) XXX_DiscardUnknown

func (m *PurgeDLQMessagesRequest) XXX_DiscardUnknown()

func (*PurgeDLQMessagesRequest) XXX_Marshal

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

func (*PurgeDLQMessagesRequest) XXX_Merge

func (m *PurgeDLQMessagesRequest) XXX_Merge(src proto.Message)

func (*PurgeDLQMessagesRequest) XXX_Size

func (m *PurgeDLQMessagesRequest) XXX_Size() int

func (*PurgeDLQMessagesRequest) XXX_Unmarshal

func (m *PurgeDLQMessagesRequest) XXX_Unmarshal(b []byte) error

type PurgeDLQMessagesResponse

type PurgeDLQMessagesResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PurgeDLQMessagesResponse) Descriptor

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

func (*PurgeDLQMessagesResponse) Marshal

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

func (*PurgeDLQMessagesResponse) MarshalTo

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

func (*PurgeDLQMessagesResponse) MarshalToSizedBuffer

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

func (*PurgeDLQMessagesResponse) ProtoMessage

func (*PurgeDLQMessagesResponse) ProtoMessage()

func (*PurgeDLQMessagesResponse) Reset

func (m *PurgeDLQMessagesResponse) Reset()

func (*PurgeDLQMessagesResponse) Size

func (m *PurgeDLQMessagesResponse) Size() (n int)

func (*PurgeDLQMessagesResponse) String

func (m *PurgeDLQMessagesResponse) String() string

func (*PurgeDLQMessagesResponse) Unmarshal

func (m *PurgeDLQMessagesResponse) Unmarshal(dAtA []byte) error

func (*PurgeDLQMessagesResponse) XXX_DiscardUnknown

func (m *PurgeDLQMessagesResponse) XXX_DiscardUnknown()

func (*PurgeDLQMessagesResponse) XXX_Marshal

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

func (*PurgeDLQMessagesResponse) XXX_Merge

func (m *PurgeDLQMessagesResponse) XXX_Merge(src proto.Message)

func (*PurgeDLQMessagesResponse) XXX_Size

func (m *PurgeDLQMessagesResponse) XXX_Size() int

func (*PurgeDLQMessagesResponse) XXX_Unmarshal

func (m *PurgeDLQMessagesResponse) XXX_Unmarshal(b []byte) error

type ReadDLQMessagesRequest

type ReadDLQMessagesRequest struct {
	Type                  DLQType           `protobuf:"varint,1,opt,name=type,proto3,enum=uber.cadence.admin.v1.DLQType" json:"type,omitempty"`
	ShardId               int32             `protobuf:"varint,2,opt,name=shard_id,json=shardId,proto3" json:"shard_id,omitempty"`
	SourceCluster         string            `protobuf:"bytes,3,opt,name=source_cluster,json=sourceCluster,proto3" json:"source_cluster,omitempty"`
	InclusiveEndMessageId *types.Int64Value `` /* 128-byte string literal not displayed */
	PageSize              int32             `protobuf:"varint,5,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	NextPageToken         []byte            `protobuf:"bytes,6,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	XXX_NoUnkeyedLiteral  struct{}          `json:"-"`
	XXX_unrecognized      []byte            `json:"-"`
	XXX_sizecache         int32             `json:"-"`
}

func (*ReadDLQMessagesRequest) Descriptor

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

func (*ReadDLQMessagesRequest) GetInclusiveEndMessageId

func (m *ReadDLQMessagesRequest) GetInclusiveEndMessageId() *types.Int64Value

func (*ReadDLQMessagesRequest) GetNextPageToken

func (m *ReadDLQMessagesRequest) GetNextPageToken() []byte

func (*ReadDLQMessagesRequest) GetPageSize

func (m *ReadDLQMessagesRequest) GetPageSize() int32

func (*ReadDLQMessagesRequest) GetShardId

func (m *ReadDLQMessagesRequest) GetShardId() int32

func (*ReadDLQMessagesRequest) GetSourceCluster

func (m *ReadDLQMessagesRequest) GetSourceCluster() string

func (*ReadDLQMessagesRequest) GetType

func (m *ReadDLQMessagesRequest) GetType() DLQType

func (*ReadDLQMessagesRequest) Marshal

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

func (*ReadDLQMessagesRequest) MarshalTo

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

func (*ReadDLQMessagesRequest) MarshalToSizedBuffer

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

func (*ReadDLQMessagesRequest) ProtoMessage

func (*ReadDLQMessagesRequest) ProtoMessage()

func (*ReadDLQMessagesRequest) Reset

func (m *ReadDLQMessagesRequest) Reset()

func (*ReadDLQMessagesRequest) Size

func (m *ReadDLQMessagesRequest) Size() (n int)

func (*ReadDLQMessagesRequest) String

func (m *ReadDLQMessagesRequest) String() string

func (*ReadDLQMessagesRequest) Unmarshal

func (m *ReadDLQMessagesRequest) Unmarshal(dAtA []byte) error

func (*ReadDLQMessagesRequest) XXX_DiscardUnknown

func (m *ReadDLQMessagesRequest) XXX_DiscardUnknown()

func (*ReadDLQMessagesRequest) XXX_Marshal

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

func (*ReadDLQMessagesRequest) XXX_Merge

func (m *ReadDLQMessagesRequest) XXX_Merge(src proto.Message)

func (*ReadDLQMessagesRequest) XXX_Size

func (m *ReadDLQMessagesRequest) XXX_Size() int

func (*ReadDLQMessagesRequest) XXX_Unmarshal

func (m *ReadDLQMessagesRequest) XXX_Unmarshal(b []byte) error

type ReadDLQMessagesResponse

type ReadDLQMessagesResponse struct {
	Type                 DLQType                `protobuf:"varint,1,opt,name=type,proto3,enum=uber.cadence.admin.v1.DLQType" json:"type,omitempty"`
	ReplicationTasks     []*ReplicationTask     `protobuf:"bytes,2,rep,name=replication_tasks,json=replicationTasks,proto3" json:"replication_tasks,omitempty"`
	ReplicationTasksInfo []*ReplicationTaskInfo `protobuf:"bytes,3,rep,name=replication_tasks_info,json=replicationTasksInfo,proto3" json:"replication_tasks_info,omitempty"`
	NextPageToken        []byte                 `protobuf:"bytes,4,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

func (*ReadDLQMessagesResponse) Descriptor

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

func (*ReadDLQMessagesResponse) GetNextPageToken

func (m *ReadDLQMessagesResponse) GetNextPageToken() []byte

func (*ReadDLQMessagesResponse) GetReplicationTasks

func (m *ReadDLQMessagesResponse) GetReplicationTasks() []*ReplicationTask

func (*ReadDLQMessagesResponse) GetReplicationTasksInfo

func (m *ReadDLQMessagesResponse) GetReplicationTasksInfo() []*ReplicationTaskInfo

func (*ReadDLQMessagesResponse) GetType

func (m *ReadDLQMessagesResponse) GetType() DLQType

func (*ReadDLQMessagesResponse) Marshal

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

func (*ReadDLQMessagesResponse) MarshalTo

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

func (*ReadDLQMessagesResponse) MarshalToSizedBuffer

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

func (*ReadDLQMessagesResponse) ProtoMessage

func (*ReadDLQMessagesResponse) ProtoMessage()

func (*ReadDLQMessagesResponse) Reset

func (m *ReadDLQMessagesResponse) Reset()

func (*ReadDLQMessagesResponse) Size

func (m *ReadDLQMessagesResponse) Size() (n int)

func (*ReadDLQMessagesResponse) String

func (m *ReadDLQMessagesResponse) String() string

func (*ReadDLQMessagesResponse) Unmarshal

func (m *ReadDLQMessagesResponse) Unmarshal(dAtA []byte) error

func (*ReadDLQMessagesResponse) XXX_DiscardUnknown

func (m *ReadDLQMessagesResponse) XXX_DiscardUnknown()

func (*ReadDLQMessagesResponse) XXX_Marshal

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

func (*ReadDLQMessagesResponse) XXX_Merge

func (m *ReadDLQMessagesResponse) XXX_Merge(src proto.Message)

func (*ReadDLQMessagesResponse) XXX_Size

func (m *ReadDLQMessagesResponse) XXX_Size() int

func (*ReadDLQMessagesResponse) XXX_Unmarshal

func (m *ReadDLQMessagesResponse) XXX_Unmarshal(b []byte) error

type ReapplyEventsRequest

type ReapplyEventsRequest struct {
	Domain               string                `protobuf:"bytes,1,opt,name=domain,proto3" json:"domain,omitempty"`
	WorkflowExecution    *v1.WorkflowExecution `protobuf:"bytes,2,opt,name=workflow_execution,json=workflowExecution,proto3" json:"workflow_execution,omitempty"`
	Events               *v1.DataBlob          `protobuf:"bytes,3,opt,name=events,proto3" json:"events,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

ReapplyEventsRequest is the request for reapply events API.

func (*ReapplyEventsRequest) Descriptor

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

func (*ReapplyEventsRequest) GetDomain

func (m *ReapplyEventsRequest) GetDomain() string

func (*ReapplyEventsRequest) GetEvents

func (m *ReapplyEventsRequest) GetEvents() *v1.DataBlob

func (*ReapplyEventsRequest) GetWorkflowExecution

func (m *ReapplyEventsRequest) GetWorkflowExecution() *v1.WorkflowExecution

func (*ReapplyEventsRequest) Marshal

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

func (*ReapplyEventsRequest) MarshalTo

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

func (*ReapplyEventsRequest) MarshalToSizedBuffer

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

func (*ReapplyEventsRequest) ProtoMessage

func (*ReapplyEventsRequest) ProtoMessage()

func (*ReapplyEventsRequest) Reset

func (m *ReapplyEventsRequest) Reset()

func (*ReapplyEventsRequest) Size

func (m *ReapplyEventsRequest) Size() (n int)

func (*ReapplyEventsRequest) String

func (m *ReapplyEventsRequest) String() string

func (*ReapplyEventsRequest) Unmarshal

func (m *ReapplyEventsRequest) Unmarshal(dAtA []byte) error

func (*ReapplyEventsRequest) XXX_DiscardUnknown

func (m *ReapplyEventsRequest) XXX_DiscardUnknown()

func (*ReapplyEventsRequest) XXX_Marshal

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

func (*ReapplyEventsRequest) XXX_Merge

func (m *ReapplyEventsRequest) XXX_Merge(src proto.Message)

func (*ReapplyEventsRequest) XXX_Size

func (m *ReapplyEventsRequest) XXX_Size() int

func (*ReapplyEventsRequest) XXX_Unmarshal

func (m *ReapplyEventsRequest) XXX_Unmarshal(b []byte) error

type ReapplyEventsResponse

type ReapplyEventsResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ReapplyEventsResponse) Descriptor

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

func (*ReapplyEventsResponse) Marshal

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

func (*ReapplyEventsResponse) MarshalTo

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

func (*ReapplyEventsResponse) MarshalToSizedBuffer

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

func (*ReapplyEventsResponse) ProtoMessage

func (*ReapplyEventsResponse) ProtoMessage()

func (*ReapplyEventsResponse) Reset

func (m *ReapplyEventsResponse) Reset()

func (*ReapplyEventsResponse) Size

func (m *ReapplyEventsResponse) Size() (n int)

func (*ReapplyEventsResponse) String

func (m *ReapplyEventsResponse) String() string

func (*ReapplyEventsResponse) Unmarshal

func (m *ReapplyEventsResponse) Unmarshal(dAtA []byte) error

func (*ReapplyEventsResponse) XXX_DiscardUnknown

func (m *ReapplyEventsResponse) XXX_DiscardUnknown()

func (*ReapplyEventsResponse) XXX_Marshal

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

func (*ReapplyEventsResponse) XXX_Merge

func (m *ReapplyEventsResponse) XXX_Merge(src proto.Message)

func (*ReapplyEventsResponse) XXX_Size

func (m *ReapplyEventsResponse) XXX_Size() int

func (*ReapplyEventsResponse) XXX_Unmarshal

func (m *ReapplyEventsResponse) XXX_Unmarshal(b []byte) error

type RefreshWorkflowTasksRequest

type RefreshWorkflowTasksRequest struct {
	Domain               string                `protobuf:"bytes,1,opt,name=domain,proto3" json:"domain,omitempty"`
	WorkflowExecution    *v1.WorkflowExecution `protobuf:"bytes,2,opt,name=workflow_execution,json=workflowExecution,proto3" json:"workflow_execution,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*RefreshWorkflowTasksRequest) Descriptor

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

func (*RefreshWorkflowTasksRequest) GetDomain

func (m *RefreshWorkflowTasksRequest) GetDomain() string

func (*RefreshWorkflowTasksRequest) GetWorkflowExecution

func (m *RefreshWorkflowTasksRequest) GetWorkflowExecution() *v1.WorkflowExecution

func (*RefreshWorkflowTasksRequest) Marshal

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

func (*RefreshWorkflowTasksRequest) MarshalTo

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

func (*RefreshWorkflowTasksRequest) MarshalToSizedBuffer

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

func (*RefreshWorkflowTasksRequest) ProtoMessage

func (*RefreshWorkflowTasksRequest) ProtoMessage()

func (*RefreshWorkflowTasksRequest) Reset

func (m *RefreshWorkflowTasksRequest) Reset()

func (*RefreshWorkflowTasksRequest) Size

func (m *RefreshWorkflowTasksRequest) Size() (n int)

func (*RefreshWorkflowTasksRequest) String

func (m *RefreshWorkflowTasksRequest) String() string

func (*RefreshWorkflowTasksRequest) Unmarshal

func (m *RefreshWorkflowTasksRequest) Unmarshal(dAtA []byte) error

func (*RefreshWorkflowTasksRequest) XXX_DiscardUnknown

func (m *RefreshWorkflowTasksRequest) XXX_DiscardUnknown()

func (*RefreshWorkflowTasksRequest) XXX_Marshal

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

func (*RefreshWorkflowTasksRequest) XXX_Merge

func (m *RefreshWorkflowTasksRequest) XXX_Merge(src proto.Message)

func (*RefreshWorkflowTasksRequest) XXX_Size

func (m *RefreshWorkflowTasksRequest) XXX_Size() int

func (*RefreshWorkflowTasksRequest) XXX_Unmarshal

func (m *RefreshWorkflowTasksRequest) XXX_Unmarshal(b []byte) error

type RefreshWorkflowTasksResponse

type RefreshWorkflowTasksResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RefreshWorkflowTasksResponse) Descriptor

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

func (*RefreshWorkflowTasksResponse) Marshal

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

func (*RefreshWorkflowTasksResponse) MarshalTo

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

func (*RefreshWorkflowTasksResponse) MarshalToSizedBuffer

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

func (*RefreshWorkflowTasksResponse) ProtoMessage

func (*RefreshWorkflowTasksResponse) ProtoMessage()

func (*RefreshWorkflowTasksResponse) Reset

func (m *RefreshWorkflowTasksResponse) Reset()

func (*RefreshWorkflowTasksResponse) Size

func (m *RefreshWorkflowTasksResponse) Size() (n int)

func (*RefreshWorkflowTasksResponse) String

func (*RefreshWorkflowTasksResponse) Unmarshal

func (m *RefreshWorkflowTasksResponse) Unmarshal(dAtA []byte) error

func (*RefreshWorkflowTasksResponse) XXX_DiscardUnknown

func (m *RefreshWorkflowTasksResponse) XXX_DiscardUnknown()

func (*RefreshWorkflowTasksResponse) XXX_Marshal

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

func (*RefreshWorkflowTasksResponse) XXX_Merge

func (m *RefreshWorkflowTasksResponse) XXX_Merge(src proto.Message)

func (*RefreshWorkflowTasksResponse) XXX_Size

func (m *RefreshWorkflowTasksResponse) XXX_Size() int

func (*RefreshWorkflowTasksResponse) XXX_Unmarshal

func (m *RefreshWorkflowTasksResponse) XXX_Unmarshal(b []byte) error

type RemoveTaskRequest

type RemoveTaskRequest struct {
	ShardId              int32            `protobuf:"varint,1,opt,name=shard_id,json=shardId,proto3" json:"shard_id,omitempty"`
	TaskType             TaskType         `protobuf:"varint,2,opt,name=task_type,json=taskType,proto3,enum=uber.cadence.admin.v1.TaskType" json:"task_type,omitempty"`
	TaskId               int64            `protobuf:"varint,3,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	VisibilityTime       *types.Timestamp `protobuf:"bytes,4,opt,name=visibility_time,json=visibilityTime,proto3" json:"visibility_time,omitempty"`
	ClusterName          string           `protobuf:"bytes,5,opt,name=cluster_name,json=clusterName,proto3" json:"cluster_name,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*RemoveTaskRequest) Descriptor

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

func (*RemoveTaskRequest) GetClusterName

func (m *RemoveTaskRequest) GetClusterName() string

func (*RemoveTaskRequest) GetShardId

func (m *RemoveTaskRequest) GetShardId() int32

func (*RemoveTaskRequest) GetTaskId

func (m *RemoveTaskRequest) GetTaskId() int64

func (*RemoveTaskRequest) GetTaskType

func (m *RemoveTaskRequest) GetTaskType() TaskType

func (*RemoveTaskRequest) GetVisibilityTime

func (m *RemoveTaskRequest) GetVisibilityTime() *types.Timestamp

func (*RemoveTaskRequest) Marshal

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

func (*RemoveTaskRequest) MarshalTo

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

func (*RemoveTaskRequest) MarshalToSizedBuffer

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

func (*RemoveTaskRequest) ProtoMessage

func (*RemoveTaskRequest) ProtoMessage()

func (*RemoveTaskRequest) Reset

func (m *RemoveTaskRequest) Reset()

func (*RemoveTaskRequest) Size

func (m *RemoveTaskRequest) Size() (n int)

func (*RemoveTaskRequest) String

func (m *RemoveTaskRequest) String() string

func (*RemoveTaskRequest) Unmarshal

func (m *RemoveTaskRequest) Unmarshal(dAtA []byte) error

func (*RemoveTaskRequest) XXX_DiscardUnknown

func (m *RemoveTaskRequest) XXX_DiscardUnknown()

func (*RemoveTaskRequest) XXX_Marshal

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

func (*RemoveTaskRequest) XXX_Merge

func (m *RemoveTaskRequest) XXX_Merge(src proto.Message)

func (*RemoveTaskRequest) XXX_Size

func (m *RemoveTaskRequest) XXX_Size() int

func (*RemoveTaskRequest) XXX_Unmarshal

func (m *RemoveTaskRequest) XXX_Unmarshal(b []byte) error

type RemoveTaskResponse

type RemoveTaskResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RemoveTaskResponse) Descriptor

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

func (*RemoveTaskResponse) Marshal

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

func (*RemoveTaskResponse) MarshalTo

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

func (*RemoveTaskResponse) MarshalToSizedBuffer

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

func (*RemoveTaskResponse) ProtoMessage

func (*RemoveTaskResponse) ProtoMessage()

func (*RemoveTaskResponse) Reset

func (m *RemoveTaskResponse) Reset()

func (*RemoveTaskResponse) Size

func (m *RemoveTaskResponse) Size() (n int)

func (*RemoveTaskResponse) String

func (m *RemoveTaskResponse) String() string

func (*RemoveTaskResponse) Unmarshal

func (m *RemoveTaskResponse) Unmarshal(dAtA []byte) error

func (*RemoveTaskResponse) XXX_DiscardUnknown

func (m *RemoveTaskResponse) XXX_DiscardUnknown()

func (*RemoveTaskResponse) XXX_Marshal

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

func (*RemoveTaskResponse) XXX_Merge

func (m *RemoveTaskResponse) XXX_Merge(src proto.Message)

func (*RemoveTaskResponse) XXX_Size

func (m *RemoveTaskResponse) XXX_Size() int

func (*RemoveTaskResponse) XXX_Unmarshal

func (m *RemoveTaskResponse) XXX_Unmarshal(b []byte) error

type ReplicationMessages

type ReplicationMessages struct {
	ReplicationTasks []*ReplicationTask `protobuf:"bytes,1,rep,name=replication_tasks,json=replicationTasks,proto3" json:"replication_tasks,omitempty"`
	// This can be different than the last taskId in the above list,
	//because sender can decide to skip tasks (e.g. for completed workflows).
	LastRetrievedMessageId int64 `` /* 132-byte string literal not displayed */
	// Hint for flow control.
	HasMore              bool             `protobuf:"varint,3,opt,name=has_more,json=hasMore,proto3" json:"has_more,omitempty"`
	SyncShardStatus      *SyncShardStatus `protobuf:"bytes,4,opt,name=sync_shard_status,json=syncShardStatus,proto3" json:"sync_shard_status,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*ReplicationMessages) Descriptor

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

func (*ReplicationMessages) GetHasMore

func (m *ReplicationMessages) GetHasMore() bool

func (*ReplicationMessages) GetLastRetrievedMessageId

func (m *ReplicationMessages) GetLastRetrievedMessageId() int64

func (*ReplicationMessages) GetReplicationTasks

func (m *ReplicationMessages) GetReplicationTasks() []*ReplicationTask

func (*ReplicationMessages) GetSyncShardStatus

func (m *ReplicationMessages) GetSyncShardStatus() *SyncShardStatus

func (*ReplicationMessages) Marshal

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

func (*ReplicationMessages) MarshalTo

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

func (*ReplicationMessages) MarshalToSizedBuffer

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

func (*ReplicationMessages) ProtoMessage

func (*ReplicationMessages) ProtoMessage()

func (*ReplicationMessages) Reset

func (m *ReplicationMessages) Reset()

func (*ReplicationMessages) Size

func (m *ReplicationMessages) Size() (n int)

func (*ReplicationMessages) String

func (m *ReplicationMessages) String() string

func (*ReplicationMessages) Unmarshal

func (m *ReplicationMessages) Unmarshal(dAtA []byte) error

func (*ReplicationMessages) XXX_DiscardUnknown

func (m *ReplicationMessages) XXX_DiscardUnknown()

func (*ReplicationMessages) XXX_Marshal

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

func (*ReplicationMessages) XXX_Merge

func (m *ReplicationMessages) XXX_Merge(src proto.Message)

func (*ReplicationMessages) XXX_Size

func (m *ReplicationMessages) XXX_Size() int

func (*ReplicationMessages) XXX_Unmarshal

func (m *ReplicationMessages) XXX_Unmarshal(b []byte) error

type ReplicationTask

type ReplicationTask struct {
	TaskType     ReplicationTaskType `` /* 133-byte string literal not displayed */
	SourceTaskId int64               `protobuf:"varint,2,opt,name=source_task_id,json=sourceTaskId,proto3" json:"source_task_id,omitempty"`
	CreationTime *types.Timestamp    `protobuf:"bytes,3,opt,name=creation_time,json=creationTime,proto3" json:"creation_time,omitempty"`
	// Types that are valid to be assigned to Attributes:
	//	*ReplicationTask_DomainTaskAttributes
	//	*ReplicationTask_SyncShardStatusTaskAttributes
	//	*ReplicationTask_SyncActivityTaskAttributes
	//	*ReplicationTask_HistoryTaskV2Attributes
	//	*ReplicationTask_FailoverMarkerAttributes
	Attributes           isReplicationTask_Attributes `protobuf_oneof:"attributes"`
	XXX_NoUnkeyedLiteral struct{}                     `json:"-"`
	XXX_unrecognized     []byte                       `json:"-"`
	XXX_sizecache        int32                        `json:"-"`
}

func (*ReplicationTask) Descriptor

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

func (*ReplicationTask) GetAttributes

func (m *ReplicationTask) GetAttributes() isReplicationTask_Attributes

func (*ReplicationTask) GetCreationTime

func (m *ReplicationTask) GetCreationTime() *types.Timestamp

func (*ReplicationTask) GetDomainTaskAttributes

func (m *ReplicationTask) GetDomainTaskAttributes() *DomainTaskAttributes

func (*ReplicationTask) GetFailoverMarkerAttributes

func (m *ReplicationTask) GetFailoverMarkerAttributes() *FailoverMarkerAttributes

func (*ReplicationTask) GetHistoryTaskV2Attributes

func (m *ReplicationTask) GetHistoryTaskV2Attributes() *HistoryTaskV2Attributes

func (*ReplicationTask) GetSourceTaskId

func (m *ReplicationTask) GetSourceTaskId() int64

func (*ReplicationTask) GetSyncActivityTaskAttributes

func (m *ReplicationTask) GetSyncActivityTaskAttributes() *SyncActivityTaskAttributes

func (*ReplicationTask) GetSyncShardStatusTaskAttributes

func (m *ReplicationTask) GetSyncShardStatusTaskAttributes() *SyncShardStatusTaskAttributes

func (*ReplicationTask) GetTaskType

func (m *ReplicationTask) GetTaskType() ReplicationTaskType

func (*ReplicationTask) Marshal

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

func (*ReplicationTask) MarshalTo

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

func (*ReplicationTask) MarshalToSizedBuffer

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

func (*ReplicationTask) ProtoMessage

func (*ReplicationTask) ProtoMessage()

func (*ReplicationTask) Reset

func (m *ReplicationTask) Reset()

func (*ReplicationTask) Size

func (m *ReplicationTask) Size() (n int)

func (*ReplicationTask) String

func (m *ReplicationTask) String() string

func (*ReplicationTask) Unmarshal

func (m *ReplicationTask) Unmarshal(dAtA []byte) error

func (*ReplicationTask) XXX_DiscardUnknown

func (m *ReplicationTask) XXX_DiscardUnknown()

func (*ReplicationTask) XXX_Marshal

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

func (*ReplicationTask) XXX_Merge

func (m *ReplicationTask) XXX_Merge(src proto.Message)

func (*ReplicationTask) XXX_OneofWrappers

func (*ReplicationTask) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*ReplicationTask) XXX_Size

func (m *ReplicationTask) XXX_Size() int

func (*ReplicationTask) XXX_Unmarshal

func (m *ReplicationTask) XXX_Unmarshal(b []byte) error

type ReplicationTaskInfo

type ReplicationTaskInfo struct {
	DomainId             string                `protobuf:"bytes,1,opt,name=domain_id,json=domainId,proto3" json:"domain_id,omitempty"`
	WorkflowExecution    *v1.WorkflowExecution `protobuf:"bytes,2,opt,name=workflow_execution,json=workflowExecution,proto3" json:"workflow_execution,omitempty"`
	TaskType             int32                 `protobuf:"varint,3,opt,name=task_type,json=taskType,proto3" json:"task_type,omitempty"`
	TaskId               int64                 `protobuf:"varint,4,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	Version              int64                 `protobuf:"varint,5,opt,name=version,proto3" json:"version,omitempty"`
	FirstEventId         int64                 `protobuf:"varint,6,opt,name=first_event_id,json=firstEventId,proto3" json:"first_event_id,omitempty"`
	NextEventId          int64                 `protobuf:"varint,7,opt,name=next_event_id,json=nextEventId,proto3" json:"next_event_id,omitempty"`
	ScheduledId          int64                 `protobuf:"varint,8,opt,name=scheduled_id,json=scheduledId,proto3" json:"scheduled_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*ReplicationTaskInfo) Descriptor

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

func (*ReplicationTaskInfo) GetDomainId

func (m *ReplicationTaskInfo) GetDomainId() string

func (*ReplicationTaskInfo) GetFirstEventId

func (m *ReplicationTaskInfo) GetFirstEventId() int64

func (*ReplicationTaskInfo) GetNextEventId

func (m *ReplicationTaskInfo) GetNextEventId() int64

func (*ReplicationTaskInfo) GetScheduledId

func (m *ReplicationTaskInfo) GetScheduledId() int64

func (*ReplicationTaskInfo) GetTaskId

func (m *ReplicationTaskInfo) GetTaskId() int64

func (*ReplicationTaskInfo) GetTaskType

func (m *ReplicationTaskInfo) GetTaskType() int32

func (*ReplicationTaskInfo) GetVersion

func (m *ReplicationTaskInfo) GetVersion() int64

func (*ReplicationTaskInfo) GetWorkflowExecution

func (m *ReplicationTaskInfo) GetWorkflowExecution() *v1.WorkflowExecution

func (*ReplicationTaskInfo) Marshal

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

func (*ReplicationTaskInfo) MarshalTo

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

func (*ReplicationTaskInfo) MarshalToSizedBuffer

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

func (*ReplicationTaskInfo) ProtoMessage

func (*ReplicationTaskInfo) ProtoMessage()

func (*ReplicationTaskInfo) Reset

func (m *ReplicationTaskInfo) Reset()

func (*ReplicationTaskInfo) Size

func (m *ReplicationTaskInfo) Size() (n int)

func (*ReplicationTaskInfo) String

func (m *ReplicationTaskInfo) String() string

func (*ReplicationTaskInfo) Unmarshal

func (m *ReplicationTaskInfo) Unmarshal(dAtA []byte) error

func (*ReplicationTaskInfo) XXX_DiscardUnknown

func (m *ReplicationTaskInfo) XXX_DiscardUnknown()

func (*ReplicationTaskInfo) XXX_Marshal

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

func (*ReplicationTaskInfo) XXX_Merge

func (m *ReplicationTaskInfo) XXX_Merge(src proto.Message)

func (*ReplicationTaskInfo) XXX_Size

func (m *ReplicationTaskInfo) XXX_Size() int

func (*ReplicationTaskInfo) XXX_Unmarshal

func (m *ReplicationTaskInfo) XXX_Unmarshal(b []byte) error

type ReplicationTaskType

type ReplicationTaskType int32
const (
	ReplicationTaskType_REPLICATION_TASK_TYPE_INVALID           ReplicationTaskType = 0
	ReplicationTaskType_REPLICATION_TASK_TYPE_DOMAIN            ReplicationTaskType = 1
	ReplicationTaskType_REPLICATION_TASK_TYPE_HISTORY           ReplicationTaskType = 2
	ReplicationTaskType_REPLICATION_TASK_TYPE_SYNC_SHARD_STATUS ReplicationTaskType = 3
	ReplicationTaskType_REPLICATION_TASK_TYPE_SYNC_ACTIVITY     ReplicationTaskType = 4
	ReplicationTaskType_REPLICATION_TASK_TYPE_HISTORY_METADATA  ReplicationTaskType = 5
	ReplicationTaskType_REPLICATION_TASK_TYPE_HISTORY_V2        ReplicationTaskType = 6
	ReplicationTaskType_REPLICATION_TASK_TYPE_FAILOVER_MARKER   ReplicationTaskType = 7
)

func (ReplicationTaskType) EnumDescriptor

func (ReplicationTaskType) EnumDescriptor() ([]byte, []int)

func (ReplicationTaskType) String

func (x ReplicationTaskType) String() string

type ReplicationTask_DomainTaskAttributes

type ReplicationTask_DomainTaskAttributes struct {
	DomainTaskAttributes *DomainTaskAttributes `` /* 129-byte string literal not displayed */
}

func (*ReplicationTask_DomainTaskAttributes) MarshalTo

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

func (*ReplicationTask_DomainTaskAttributes) MarshalToSizedBuffer

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

func (*ReplicationTask_DomainTaskAttributes) Size

type ReplicationTask_FailoverMarkerAttributes

type ReplicationTask_FailoverMarkerAttributes struct {
	FailoverMarkerAttributes *FailoverMarkerAttributes `` /* 141-byte string literal not displayed */
}

func (*ReplicationTask_FailoverMarkerAttributes) MarshalTo

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

func (*ReplicationTask_FailoverMarkerAttributes) MarshalToSizedBuffer

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

func (*ReplicationTask_FailoverMarkerAttributes) Size

type ReplicationTask_HistoryTaskV2Attributes

type ReplicationTask_HistoryTaskV2Attributes struct {
	HistoryTaskV2Attributes *HistoryTaskV2Attributes `` /* 140-byte string literal not displayed */
}

func (*ReplicationTask_HistoryTaskV2Attributes) MarshalTo

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

func (*ReplicationTask_HistoryTaskV2Attributes) MarshalToSizedBuffer

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

func (*ReplicationTask_HistoryTaskV2Attributes) Size

type ReplicationTask_SyncActivityTaskAttributes

type ReplicationTask_SyncActivityTaskAttributes struct {
	SyncActivityTaskAttributes *SyncActivityTaskAttributes `` /* 149-byte string literal not displayed */
}

func (*ReplicationTask_SyncActivityTaskAttributes) MarshalTo

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

func (*ReplicationTask_SyncActivityTaskAttributes) MarshalToSizedBuffer

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

func (*ReplicationTask_SyncActivityTaskAttributes) Size

type ReplicationTask_SyncShardStatusTaskAttributes

type ReplicationTask_SyncShardStatusTaskAttributes struct {
	SyncShardStatusTaskAttributes *SyncShardStatusTaskAttributes `` /* 160-byte string literal not displayed */
}

func (*ReplicationTask_SyncShardStatusTaskAttributes) MarshalTo

func (*ReplicationTask_SyncShardStatusTaskAttributes) MarshalToSizedBuffer

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

func (*ReplicationTask_SyncShardStatusTaskAttributes) Size

type ReplicationToken

type ReplicationToken struct {
	ShardId int32 `protobuf:"varint,1,opt,name=shard_id,json=shardId,proto3" json:"shard_id,omitempty"`
	// lastRetrievedMessageId is where the next fetch should begin with.
	LastRetrievedMessageId int64 `` /* 132-byte string literal not displayed */
	// lastProcessedMessageId is the last messageId that is processed on the passive side.
	// This can be different than lastRetrievedMessageId if passive side supports prefetching messages.
	LastProcessedMessageId int64    `` /* 132-byte string literal not displayed */
	XXX_NoUnkeyedLiteral   struct{} `json:"-"`
	XXX_unrecognized       []byte   `json:"-"`
	XXX_sizecache          int32    `json:"-"`
}

func (*ReplicationToken) Descriptor

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

func (*ReplicationToken) GetLastProcessedMessageId

func (m *ReplicationToken) GetLastProcessedMessageId() int64

func (*ReplicationToken) GetLastRetrievedMessageId

func (m *ReplicationToken) GetLastRetrievedMessageId() int64

func (*ReplicationToken) GetShardId

func (m *ReplicationToken) GetShardId() int32

func (*ReplicationToken) Marshal

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

func (*ReplicationToken) MarshalTo

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

func (*ReplicationToken) MarshalToSizedBuffer

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

func (*ReplicationToken) ProtoMessage

func (*ReplicationToken) ProtoMessage()

func (*ReplicationToken) Reset

func (m *ReplicationToken) Reset()

func (*ReplicationToken) Size

func (m *ReplicationToken) Size() (n int)

func (*ReplicationToken) String

func (m *ReplicationToken) String() string

func (*ReplicationToken) Unmarshal

func (m *ReplicationToken) Unmarshal(dAtA []byte) error

func (*ReplicationToken) XXX_DiscardUnknown

func (m *ReplicationToken) XXX_DiscardUnknown()

func (*ReplicationToken) XXX_Marshal

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

func (*ReplicationToken) XXX_Merge

func (m *ReplicationToken) XXX_Merge(src proto.Message)

func (*ReplicationToken) XXX_Size

func (m *ReplicationToken) XXX_Size() int

func (*ReplicationToken) XXX_Unmarshal

func (m *ReplicationToken) XXX_Unmarshal(b []byte) error

type ResendReplicationTasksRequest

type ResendReplicationTasksRequest struct {
	DomainId             string                `protobuf:"bytes,1,opt,name=domain_id,json=domainId,proto3" json:"domain_id,omitempty"`
	WorkflowExecution    *v1.WorkflowExecution `protobuf:"bytes,2,opt,name=workflow_execution,json=workflowExecution,proto3" json:"workflow_execution,omitempty"`
	RemoteCluster        string                `protobuf:"bytes,3,opt,name=remote_cluster,json=remoteCluster,proto3" json:"remote_cluster,omitempty"`
	StartEvent           *VersionHistoryItem   `protobuf:"bytes,4,opt,name=start_event,json=startEvent,proto3" json:"start_event,omitempty"`
	EndEvent             *VersionHistoryItem   `protobuf:"bytes,5,opt,name=end_event,json=endEvent,proto3" json:"end_event,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*ResendReplicationTasksRequest) Descriptor

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

func (*ResendReplicationTasksRequest) GetDomainId

func (m *ResendReplicationTasksRequest) GetDomainId() string

func (*ResendReplicationTasksRequest) GetEndEvent

func (*ResendReplicationTasksRequest) GetRemoteCluster

func (m *ResendReplicationTasksRequest) GetRemoteCluster() string

func (*ResendReplicationTasksRequest) GetStartEvent

func (*ResendReplicationTasksRequest) GetWorkflowExecution

func (m *ResendReplicationTasksRequest) GetWorkflowExecution() *v1.WorkflowExecution

func (*ResendReplicationTasksRequest) Marshal

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

func (*ResendReplicationTasksRequest) MarshalTo

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

func (*ResendReplicationTasksRequest) MarshalToSizedBuffer

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

func (*ResendReplicationTasksRequest) ProtoMessage

func (*ResendReplicationTasksRequest) ProtoMessage()

func (*ResendReplicationTasksRequest) Reset

func (m *ResendReplicationTasksRequest) Reset()

func (*ResendReplicationTasksRequest) Size

func (m *ResendReplicationTasksRequest) Size() (n int)

func (*ResendReplicationTasksRequest) String

func (*ResendReplicationTasksRequest) Unmarshal

func (m *ResendReplicationTasksRequest) Unmarshal(dAtA []byte) error

func (*ResendReplicationTasksRequest) XXX_DiscardUnknown

func (m *ResendReplicationTasksRequest) XXX_DiscardUnknown()

func (*ResendReplicationTasksRequest) XXX_Marshal

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

func (*ResendReplicationTasksRequest) XXX_Merge

func (m *ResendReplicationTasksRequest) XXX_Merge(src proto.Message)

func (*ResendReplicationTasksRequest) XXX_Size

func (m *ResendReplicationTasksRequest) XXX_Size() int

func (*ResendReplicationTasksRequest) XXX_Unmarshal

func (m *ResendReplicationTasksRequest) XXX_Unmarshal(b []byte) error

type ResendReplicationTasksResponse

type ResendReplicationTasksResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ResendReplicationTasksResponse) Descriptor

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

func (*ResendReplicationTasksResponse) Marshal

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

func (*ResendReplicationTasksResponse) MarshalTo

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

func (*ResendReplicationTasksResponse) MarshalToSizedBuffer

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

func (*ResendReplicationTasksResponse) ProtoMessage

func (*ResendReplicationTasksResponse) ProtoMessage()

func (*ResendReplicationTasksResponse) Reset

func (m *ResendReplicationTasksResponse) Reset()

func (*ResendReplicationTasksResponse) Size

func (m *ResendReplicationTasksResponse) Size() (n int)

func (*ResendReplicationTasksResponse) String

func (*ResendReplicationTasksResponse) Unmarshal

func (m *ResendReplicationTasksResponse) Unmarshal(dAtA []byte) error

func (*ResendReplicationTasksResponse) XXX_DiscardUnknown

func (m *ResendReplicationTasksResponse) XXX_DiscardUnknown()

func (*ResendReplicationTasksResponse) XXX_Marshal

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

func (*ResendReplicationTasksResponse) XXX_Merge

func (m *ResendReplicationTasksResponse) XXX_Merge(src proto.Message)

func (*ResendReplicationTasksResponse) XXX_Size

func (m *ResendReplicationTasksResponse) XXX_Size() int

func (*ResendReplicationTasksResponse) XXX_Unmarshal

func (m *ResendReplicationTasksResponse) XXX_Unmarshal(b []byte) error

type ResetQueueRequest

type ResetQueueRequest struct {
	ShardId              int32    `protobuf:"varint,1,opt,name=shard_id,json=shardId,proto3" json:"shard_id,omitempty"`
	ClusterName          string   `protobuf:"bytes,2,opt,name=cluster_name,json=clusterName,proto3" json:"cluster_name,omitempty"`
	TaskType             TaskType `protobuf:"varint,3,opt,name=task_type,json=taskType,proto3,enum=uber.cadence.admin.v1.TaskType" json:"task_type,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ResetQueueRequest) Descriptor

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

func (*ResetQueueRequest) GetClusterName

func (m *ResetQueueRequest) GetClusterName() string

func (*ResetQueueRequest) GetShardId

func (m *ResetQueueRequest) GetShardId() int32

func (*ResetQueueRequest) GetTaskType

func (m *ResetQueueRequest) GetTaskType() TaskType

func (*ResetQueueRequest) Marshal

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

func (*ResetQueueRequest) MarshalTo

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

func (*ResetQueueRequest) MarshalToSizedBuffer

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

func (*ResetQueueRequest) ProtoMessage

func (*ResetQueueRequest) ProtoMessage()

func (*ResetQueueRequest) Reset

func (m *ResetQueueRequest) Reset()

func (*ResetQueueRequest) Size

func (m *ResetQueueRequest) Size() (n int)

func (*ResetQueueRequest) String

func (m *ResetQueueRequest) String() string

func (*ResetQueueRequest) Unmarshal

func (m *ResetQueueRequest) Unmarshal(dAtA []byte) error

func (*ResetQueueRequest) XXX_DiscardUnknown

func (m *ResetQueueRequest) XXX_DiscardUnknown()

func (*ResetQueueRequest) XXX_Marshal

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

func (*ResetQueueRequest) XXX_Merge

func (m *ResetQueueRequest) XXX_Merge(src proto.Message)

func (*ResetQueueRequest) XXX_Size

func (m *ResetQueueRequest) XXX_Size() int

func (*ResetQueueRequest) XXX_Unmarshal

func (m *ResetQueueRequest) XXX_Unmarshal(b []byte) error

type ResetQueueResponse

type ResetQueueResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ResetQueueResponse) Descriptor

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

func (*ResetQueueResponse) Marshal

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

func (*ResetQueueResponse) MarshalTo

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

func (*ResetQueueResponse) MarshalToSizedBuffer

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

func (*ResetQueueResponse) ProtoMessage

func (*ResetQueueResponse) ProtoMessage()

func (*ResetQueueResponse) Reset

func (m *ResetQueueResponse) Reset()

func (*ResetQueueResponse) Size

func (m *ResetQueueResponse) Size() (n int)

func (*ResetQueueResponse) String

func (m *ResetQueueResponse) String() string

func (*ResetQueueResponse) Unmarshal

func (m *ResetQueueResponse) Unmarshal(dAtA []byte) error

func (*ResetQueueResponse) XXX_DiscardUnknown

func (m *ResetQueueResponse) XXX_DiscardUnknown()

func (*ResetQueueResponse) XXX_Marshal

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

func (*ResetQueueResponse) XXX_Merge

func (m *ResetQueueResponse) XXX_Merge(src proto.Message)

func (*ResetQueueResponse) XXX_Size

func (m *ResetQueueResponse) XXX_Size() int

func (*ResetQueueResponse) XXX_Unmarshal

func (m *ResetQueueResponse) XXX_Unmarshal(b []byte) error

type RespondCrossClusterTasksCompletedRequest

type RespondCrossClusterTasksCompletedRequest struct {
	ShardId              int32                       `protobuf:"varint,1,opt,name=shard_id,json=shardId,proto3" json:"shard_id,omitempty"`
	TargetCluster        string                      `protobuf:"bytes,2,opt,name=target_cluster,json=targetCluster,proto3" json:"target_cluster,omitempty"`
	TaskResponses        []*CrossClusterTaskResponse `protobuf:"bytes,3,rep,name=task_responses,json=taskResponses,proto3" json:"task_responses,omitempty"`
	FetchNewTasks        bool                        `protobuf:"varint,4,opt,name=fetch_new_tasks,json=fetchNewTasks,proto3" json:"fetch_new_tasks,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                    `json:"-"`
	XXX_unrecognized     []byte                      `json:"-"`
	XXX_sizecache        int32                       `json:"-"`
}

func (*RespondCrossClusterTasksCompletedRequest) Descriptor

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

func (*RespondCrossClusterTasksCompletedRequest) GetFetchNewTasks

func (m *RespondCrossClusterTasksCompletedRequest) GetFetchNewTasks() bool

func (*RespondCrossClusterTasksCompletedRequest) GetShardId

func (*RespondCrossClusterTasksCompletedRequest) GetTargetCluster

func (m *RespondCrossClusterTasksCompletedRequest) GetTargetCluster() string

func (*RespondCrossClusterTasksCompletedRequest) GetTaskResponses

func (*RespondCrossClusterTasksCompletedRequest) Marshal

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

func (*RespondCrossClusterTasksCompletedRequest) MarshalTo

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

func (*RespondCrossClusterTasksCompletedRequest) MarshalToSizedBuffer

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

func (*RespondCrossClusterTasksCompletedRequest) ProtoMessage

func (*RespondCrossClusterTasksCompletedRequest) Reset

func (*RespondCrossClusterTasksCompletedRequest) Size

func (*RespondCrossClusterTasksCompletedRequest) String

func (*RespondCrossClusterTasksCompletedRequest) Unmarshal

func (*RespondCrossClusterTasksCompletedRequest) XXX_DiscardUnknown

func (m *RespondCrossClusterTasksCompletedRequest) XXX_DiscardUnknown()

func (*RespondCrossClusterTasksCompletedRequest) XXX_Marshal

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

func (*RespondCrossClusterTasksCompletedRequest) XXX_Merge

func (*RespondCrossClusterTasksCompletedRequest) XXX_Size

func (*RespondCrossClusterTasksCompletedRequest) XXX_Unmarshal

func (m *RespondCrossClusterTasksCompletedRequest) XXX_Unmarshal(b []byte) error

type RespondCrossClusterTasksCompletedResponse

type RespondCrossClusterTasksCompletedResponse struct {
	Tasks                *CrossClusterTaskRequests `protobuf:"bytes,1,opt,name=tasks,proto3" json:"tasks,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

func (*RespondCrossClusterTasksCompletedResponse) Descriptor

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

func (*RespondCrossClusterTasksCompletedResponse) GetTasks

func (*RespondCrossClusterTasksCompletedResponse) Marshal

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

func (*RespondCrossClusterTasksCompletedResponse) MarshalTo

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

func (*RespondCrossClusterTasksCompletedResponse) MarshalToSizedBuffer

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

func (*RespondCrossClusterTasksCompletedResponse) ProtoMessage

func (*RespondCrossClusterTasksCompletedResponse) Reset

func (*RespondCrossClusterTasksCompletedResponse) Size

func (*RespondCrossClusterTasksCompletedResponse) String

func (*RespondCrossClusterTasksCompletedResponse) Unmarshal

func (*RespondCrossClusterTasksCompletedResponse) XXX_DiscardUnknown

func (m *RespondCrossClusterTasksCompletedResponse) XXX_DiscardUnknown()

func (*RespondCrossClusterTasksCompletedResponse) XXX_Marshal

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

func (*RespondCrossClusterTasksCompletedResponse) XXX_Merge

func (*RespondCrossClusterTasksCompletedResponse) XXX_Size

func (*RespondCrossClusterTasksCompletedResponse) XXX_Unmarshal

type RestoreDynamicConfigRequest

type RestoreDynamicConfigRequest struct {
	ConfigName           string                 `protobuf:"bytes,1,opt,name=config_name,json=configName,proto3" json:"config_name,omitempty"`
	Filters              []*DynamicConfigFilter `protobuf:"bytes,2,rep,name=filters,proto3" json:"filters,omitempty"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

If no filters are specified, all values associated with config_name will be removed.

func (*RestoreDynamicConfigRequest) Descriptor

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

func (*RestoreDynamicConfigRequest) GetConfigName

func (m *RestoreDynamicConfigRequest) GetConfigName() string

func (*RestoreDynamicConfigRequest) GetFilters

func (*RestoreDynamicConfigRequest) Marshal

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

func (*RestoreDynamicConfigRequest) MarshalTo

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

func (*RestoreDynamicConfigRequest) MarshalToSizedBuffer

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

func (*RestoreDynamicConfigRequest) ProtoMessage

func (*RestoreDynamicConfigRequest) ProtoMessage()

func (*RestoreDynamicConfigRequest) Reset

func (m *RestoreDynamicConfigRequest) Reset()

func (*RestoreDynamicConfigRequest) Size

func (m *RestoreDynamicConfigRequest) Size() (n int)

func (*RestoreDynamicConfigRequest) String

func (m *RestoreDynamicConfigRequest) String() string

func (*RestoreDynamicConfigRequest) Unmarshal

func (m *RestoreDynamicConfigRequest) Unmarshal(dAtA []byte) error

func (*RestoreDynamicConfigRequest) XXX_DiscardUnknown

func (m *RestoreDynamicConfigRequest) XXX_DiscardUnknown()

func (*RestoreDynamicConfigRequest) XXX_Marshal

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

func (*RestoreDynamicConfigRequest) XXX_Merge

func (m *RestoreDynamicConfigRequest) XXX_Merge(src proto.Message)

func (*RestoreDynamicConfigRequest) XXX_Size

func (m *RestoreDynamicConfigRequest) XXX_Size() int

func (*RestoreDynamicConfigRequest) XXX_Unmarshal

func (m *RestoreDynamicConfigRequest) XXX_Unmarshal(b []byte) error

type RestoreDynamicConfigResponse

type RestoreDynamicConfigResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RestoreDynamicConfigResponse) Descriptor

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

func (*RestoreDynamicConfigResponse) Marshal

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

func (*RestoreDynamicConfigResponse) MarshalTo

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

func (*RestoreDynamicConfigResponse) MarshalToSizedBuffer

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

func (*RestoreDynamicConfigResponse) ProtoMessage

func (*RestoreDynamicConfigResponse) ProtoMessage()

func (*RestoreDynamicConfigResponse) Reset

func (m *RestoreDynamicConfigResponse) Reset()

func (*RestoreDynamicConfigResponse) Size

func (m *RestoreDynamicConfigResponse) Size() (n int)

func (*RestoreDynamicConfigResponse) String

func (*RestoreDynamicConfigResponse) Unmarshal

func (m *RestoreDynamicConfigResponse) Unmarshal(dAtA []byte) error

func (*RestoreDynamicConfigResponse) XXX_DiscardUnknown

func (m *RestoreDynamicConfigResponse) XXX_DiscardUnknown()

func (*RestoreDynamicConfigResponse) XXX_Marshal

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

func (*RestoreDynamicConfigResponse) XXX_Merge

func (m *RestoreDynamicConfigResponse) XXX_Merge(src proto.Message)

func (*RestoreDynamicConfigResponse) XXX_Size

func (m *RestoreDynamicConfigResponse) XXX_Size() int

func (*RestoreDynamicConfigResponse) XXX_Unmarshal

func (m *RestoreDynamicConfigResponse) XXX_Unmarshal(b []byte) error

type RingInfo

type RingInfo struct {
	Role                 string      `protobuf:"bytes,1,opt,name=role,proto3" json:"role,omitempty"`
	MemberCount          int32       `protobuf:"varint,2,opt,name=member_count,json=memberCount,proto3" json:"member_count,omitempty"`
	Members              []*HostInfo `protobuf:"bytes,3,rep,name=members,proto3" json:"members,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*RingInfo) Descriptor

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

func (*RingInfo) GetMemberCount

func (m *RingInfo) GetMemberCount() int32

func (*RingInfo) GetMembers

func (m *RingInfo) GetMembers() []*HostInfo

func (*RingInfo) GetRole

func (m *RingInfo) GetRole() string

func (*RingInfo) Marshal

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

func (*RingInfo) MarshalTo

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

func (*RingInfo) MarshalToSizedBuffer

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

func (*RingInfo) ProtoMessage

func (*RingInfo) ProtoMessage()

func (*RingInfo) Reset

func (m *RingInfo) Reset()

func (*RingInfo) Size

func (m *RingInfo) Size() (n int)

func (*RingInfo) String

func (m *RingInfo) String() string

func (*RingInfo) Unmarshal

func (m *RingInfo) Unmarshal(dAtA []byte) error

func (*RingInfo) XXX_DiscardUnknown

func (m *RingInfo) XXX_DiscardUnknown()

func (*RingInfo) XXX_Marshal

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

func (*RingInfo) XXX_Merge

func (m *RingInfo) XXX_Merge(src proto.Message)

func (*RingInfo) XXX_Size

func (m *RingInfo) XXX_Size() int

func (*RingInfo) XXX_Unmarshal

func (m *RingInfo) XXX_Unmarshal(b []byte) error

type SyncActivityTaskAttributes

type SyncActivityTaskAttributes struct {
	DomainId             string                `protobuf:"bytes,1,opt,name=domain_id,json=domainId,proto3" json:"domain_id,omitempty"`
	WorkflowExecution    *v1.WorkflowExecution `protobuf:"bytes,2,opt,name=workflow_execution,json=workflowExecution,proto3" json:"workflow_execution,omitempty"`
	Version              int64                 `protobuf:"varint,3,opt,name=version,proto3" json:"version,omitempty"`
	ScheduledId          int64                 `protobuf:"varint,4,opt,name=scheduled_id,json=scheduledId,proto3" json:"scheduled_id,omitempty"`
	ScheduledTime        *types.Timestamp      `protobuf:"bytes,5,opt,name=scheduled_time,json=scheduledTime,proto3" json:"scheduled_time,omitempty"`
	StartedId            int64                 `protobuf:"varint,6,opt,name=started_id,json=startedId,proto3" json:"started_id,omitempty"`
	StartedTime          *types.Timestamp      `protobuf:"bytes,7,opt,name=started_time,json=startedTime,proto3" json:"started_time,omitempty"`
	LastHeartbeatTime    *types.Timestamp      `protobuf:"bytes,8,opt,name=last_heartbeat_time,json=lastHeartbeatTime,proto3" json:"last_heartbeat_time,omitempty"`
	Details              *v1.Payload           `protobuf:"bytes,9,opt,name=details,proto3" json:"details,omitempty"`
	Attempt              int32                 `protobuf:"varint,10,opt,name=attempt,proto3" json:"attempt,omitempty"`
	LastFailure          *v1.Failure           `protobuf:"bytes,11,opt,name=last_failure,json=lastFailure,proto3" json:"last_failure,omitempty"`
	LastWorkerIdentity   string                `protobuf:"bytes,12,opt,name=last_worker_identity,json=lastWorkerIdentity,proto3" json:"last_worker_identity,omitempty"`
	VersionHistory       *VersionHistory       `protobuf:"bytes,13,opt,name=version_history,json=versionHistory,proto3" json:"version_history,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*SyncActivityTaskAttributes) Descriptor

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

func (*SyncActivityTaskAttributes) GetAttempt

func (m *SyncActivityTaskAttributes) GetAttempt() int32

func (*SyncActivityTaskAttributes) GetDetails

func (m *SyncActivityTaskAttributes) GetDetails() *v1.Payload

func (*SyncActivityTaskAttributes) GetDomainId

func (m *SyncActivityTaskAttributes) GetDomainId() string

func (*SyncActivityTaskAttributes) GetLastFailure

func (m *SyncActivityTaskAttributes) GetLastFailure() *v1.Failure

func (*SyncActivityTaskAttributes) GetLastHeartbeatTime

func (m *SyncActivityTaskAttributes) GetLastHeartbeatTime() *types.Timestamp

func (*SyncActivityTaskAttributes) GetLastWorkerIdentity

func (m *SyncActivityTaskAttributes) GetLastWorkerIdentity() string

func (*SyncActivityTaskAttributes) GetScheduledId

func (m *SyncActivityTaskAttributes) GetScheduledId() int64

func (*SyncActivityTaskAttributes) GetScheduledTime

func (m *SyncActivityTaskAttributes) GetScheduledTime() *types.Timestamp

func (*SyncActivityTaskAttributes) GetStartedId

func (m *SyncActivityTaskAttributes) GetStartedId() int64

func (*SyncActivityTaskAttributes) GetStartedTime

func (m *SyncActivityTaskAttributes) GetStartedTime() *types.Timestamp

func (*SyncActivityTaskAttributes) GetVersion

func (m *SyncActivityTaskAttributes) GetVersion() int64

func (*SyncActivityTaskAttributes) GetVersionHistory

func (m *SyncActivityTaskAttributes) GetVersionHistory() *VersionHistory

func (*SyncActivityTaskAttributes) GetWorkflowExecution

func (m *SyncActivityTaskAttributes) GetWorkflowExecution() *v1.WorkflowExecution

func (*SyncActivityTaskAttributes) Marshal

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

func (*SyncActivityTaskAttributes) MarshalTo

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

func (*SyncActivityTaskAttributes) MarshalToSizedBuffer

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

func (*SyncActivityTaskAttributes) ProtoMessage

func (*SyncActivityTaskAttributes) ProtoMessage()

func (*SyncActivityTaskAttributes) Reset

func (m *SyncActivityTaskAttributes) Reset()

func (*SyncActivityTaskAttributes) Size

func (m *SyncActivityTaskAttributes) Size() (n int)

func (*SyncActivityTaskAttributes) String

func (m *SyncActivityTaskAttributes) String() string

func (*SyncActivityTaskAttributes) Unmarshal

func (m *SyncActivityTaskAttributes) Unmarshal(dAtA []byte) error

func (*SyncActivityTaskAttributes) XXX_DiscardUnknown

func (m *SyncActivityTaskAttributes) XXX_DiscardUnknown()

func (*SyncActivityTaskAttributes) XXX_Marshal

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

func (*SyncActivityTaskAttributes) XXX_Merge

func (m *SyncActivityTaskAttributes) XXX_Merge(src proto.Message)

func (*SyncActivityTaskAttributes) XXX_Size

func (m *SyncActivityTaskAttributes) XXX_Size() int

func (*SyncActivityTaskAttributes) XXX_Unmarshal

func (m *SyncActivityTaskAttributes) XXX_Unmarshal(b []byte) error

type SyncShardStatus

type SyncShardStatus struct {
	Timestamp            *types.Timestamp `protobuf:"bytes,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*SyncShardStatus) Descriptor

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

func (*SyncShardStatus) GetTimestamp

func (m *SyncShardStatus) GetTimestamp() *types.Timestamp

func (*SyncShardStatus) Marshal

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

func (*SyncShardStatus) MarshalTo

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

func (*SyncShardStatus) MarshalToSizedBuffer

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

func (*SyncShardStatus) ProtoMessage

func (*SyncShardStatus) ProtoMessage()

func (*SyncShardStatus) Reset

func (m *SyncShardStatus) Reset()

func (*SyncShardStatus) Size

func (m *SyncShardStatus) Size() (n int)

func (*SyncShardStatus) String

func (m *SyncShardStatus) String() string

func (*SyncShardStatus) Unmarshal

func (m *SyncShardStatus) Unmarshal(dAtA []byte) error

func (*SyncShardStatus) XXX_DiscardUnknown

func (m *SyncShardStatus) XXX_DiscardUnknown()

func (*SyncShardStatus) XXX_Marshal

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

func (*SyncShardStatus) XXX_Merge

func (m *SyncShardStatus) XXX_Merge(src proto.Message)

func (*SyncShardStatus) XXX_Size

func (m *SyncShardStatus) XXX_Size() int

func (*SyncShardStatus) XXX_Unmarshal

func (m *SyncShardStatus) XXX_Unmarshal(b []byte) error

type SyncShardStatusTaskAttributes

type SyncShardStatusTaskAttributes struct {
	SourceCluster        string           `protobuf:"bytes,1,opt,name=source_cluster,json=sourceCluster,proto3" json:"source_cluster,omitempty"`
	ShardId              int32            `protobuf:"varint,2,opt,name=shard_id,json=shardId,proto3" json:"shard_id,omitempty"`
	Timestamp            *types.Timestamp `protobuf:"bytes,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*SyncShardStatusTaskAttributes) Descriptor

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

func (*SyncShardStatusTaskAttributes) GetShardId

func (m *SyncShardStatusTaskAttributes) GetShardId() int32

func (*SyncShardStatusTaskAttributes) GetSourceCluster

func (m *SyncShardStatusTaskAttributes) GetSourceCluster() string

func (*SyncShardStatusTaskAttributes) GetTimestamp

func (m *SyncShardStatusTaskAttributes) GetTimestamp() *types.Timestamp

func (*SyncShardStatusTaskAttributes) Marshal

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

func (*SyncShardStatusTaskAttributes) MarshalTo

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

func (*SyncShardStatusTaskAttributes) MarshalToSizedBuffer

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

func (*SyncShardStatusTaskAttributes) ProtoMessage

func (*SyncShardStatusTaskAttributes) ProtoMessage()

func (*SyncShardStatusTaskAttributes) Reset

func (m *SyncShardStatusTaskAttributes) Reset()

func (*SyncShardStatusTaskAttributes) Size

func (m *SyncShardStatusTaskAttributes) Size() (n int)

func (*SyncShardStatusTaskAttributes) String

func (*SyncShardStatusTaskAttributes) Unmarshal

func (m *SyncShardStatusTaskAttributes) Unmarshal(dAtA []byte) error

func (*SyncShardStatusTaskAttributes) XXX_DiscardUnknown

func (m *SyncShardStatusTaskAttributes) XXX_DiscardUnknown()

func (*SyncShardStatusTaskAttributes) XXX_Marshal

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

func (*SyncShardStatusTaskAttributes) XXX_Merge

func (m *SyncShardStatusTaskAttributes) XXX_Merge(src proto.Message)

func (*SyncShardStatusTaskAttributes) XXX_Size

func (m *SyncShardStatusTaskAttributes) XXX_Size() int

func (*SyncShardStatusTaskAttributes) XXX_Unmarshal

func (m *SyncShardStatusTaskAttributes) XXX_Unmarshal(b []byte) error

type TaskType

type TaskType int32
const (
	TaskType_TASK_TYPE_INVALID       TaskType = 0
	TaskType_TASK_TYPE_TRANSFER      TaskType = 1
	TaskType_TASK_TYPE_TIMER         TaskType = 2
	TaskType_TASK_TYPE_REPLICATION   TaskType = 3
	TaskType_TASK_TYPE_CROSS_CLUSTER TaskType = 4
)

func (TaskType) EnumDescriptor

func (TaskType) EnumDescriptor() ([]byte, []int)

func (TaskType) String

func (x TaskType) String() string

type UpdateDomainAsyncWorkflowConfiguratonRequest

type UpdateDomainAsyncWorkflowConfiguratonRequest struct {
	Domain               string                         `protobuf:"bytes,1,opt,name=domain,proto3" json:"domain,omitempty"`
	Configuration        *v1.AsyncWorkflowConfiguration `protobuf:"bytes,2,opt,name=configuration,proto3" json:"configuration,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                       `json:"-"`
	XXX_unrecognized     []byte                         `json:"-"`
	XXX_sizecache        int32                          `json:"-"`
}

func (*UpdateDomainAsyncWorkflowConfiguratonRequest) Descriptor

func (*UpdateDomainAsyncWorkflowConfiguratonRequest) GetConfiguration

func (*UpdateDomainAsyncWorkflowConfiguratonRequest) GetDomain

func (*UpdateDomainAsyncWorkflowConfiguratonRequest) Marshal

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

func (*UpdateDomainAsyncWorkflowConfiguratonRequest) MarshalTo

func (*UpdateDomainAsyncWorkflowConfiguratonRequest) MarshalToSizedBuffer

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

func (*UpdateDomainAsyncWorkflowConfiguratonRequest) ProtoMessage

func (*UpdateDomainAsyncWorkflowConfiguratonRequest) Reset

func (*UpdateDomainAsyncWorkflowConfiguratonRequest) Size

func (*UpdateDomainAsyncWorkflowConfiguratonRequest) String

func (*UpdateDomainAsyncWorkflowConfiguratonRequest) Unmarshal

func (*UpdateDomainAsyncWorkflowConfiguratonRequest) XXX_DiscardUnknown

func (m *UpdateDomainAsyncWorkflowConfiguratonRequest) XXX_DiscardUnknown()

func (*UpdateDomainAsyncWorkflowConfiguratonRequest) XXX_Marshal

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

func (*UpdateDomainAsyncWorkflowConfiguratonRequest) XXX_Merge

func (*UpdateDomainAsyncWorkflowConfiguratonRequest) XXX_Size

func (*UpdateDomainAsyncWorkflowConfiguratonRequest) XXX_Unmarshal

type UpdateDomainAsyncWorkflowConfiguratonResponse

type UpdateDomainAsyncWorkflowConfiguratonResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*UpdateDomainAsyncWorkflowConfiguratonResponse) Descriptor

func (*UpdateDomainAsyncWorkflowConfiguratonResponse) Marshal

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

func (*UpdateDomainAsyncWorkflowConfiguratonResponse) MarshalTo

func (*UpdateDomainAsyncWorkflowConfiguratonResponse) MarshalToSizedBuffer

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

func (*UpdateDomainAsyncWorkflowConfiguratonResponse) ProtoMessage

func (*UpdateDomainAsyncWorkflowConfiguratonResponse) Reset

func (*UpdateDomainAsyncWorkflowConfiguratonResponse) Size

func (*UpdateDomainAsyncWorkflowConfiguratonResponse) String

func (*UpdateDomainAsyncWorkflowConfiguratonResponse) Unmarshal

func (*UpdateDomainAsyncWorkflowConfiguratonResponse) XXX_DiscardUnknown

func (m *UpdateDomainAsyncWorkflowConfiguratonResponse) XXX_DiscardUnknown()

func (*UpdateDomainAsyncWorkflowConfiguratonResponse) XXX_Marshal

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

func (*UpdateDomainAsyncWorkflowConfiguratonResponse) XXX_Merge

func (*UpdateDomainAsyncWorkflowConfiguratonResponse) XXX_Size

func (*UpdateDomainAsyncWorkflowConfiguratonResponse) XXX_Unmarshal

type UpdateDomainIsolationGroupsRequest

type UpdateDomainIsolationGroupsRequest struct {
	Domain               string                          `protobuf:"bytes,1,opt,name=domain,proto3" json:"domain,omitempty"`
	IsolationGroups      *v1.IsolationGroupConfiguration `protobuf:"bytes,2,opt,name=isolation_groups,json=isolationGroups,proto3" json:"isolation_groups,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                        `json:"-"`
	XXX_unrecognized     []byte                          `json:"-"`
	XXX_sizecache        int32                           `json:"-"`
}

func (*UpdateDomainIsolationGroupsRequest) Descriptor

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

func (*UpdateDomainIsolationGroupsRequest) GetDomain

func (*UpdateDomainIsolationGroupsRequest) GetIsolationGroups

func (*UpdateDomainIsolationGroupsRequest) Marshal

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

func (*UpdateDomainIsolationGroupsRequest) MarshalTo

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

func (*UpdateDomainIsolationGroupsRequest) MarshalToSizedBuffer

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

func (*UpdateDomainIsolationGroupsRequest) ProtoMessage

func (*UpdateDomainIsolationGroupsRequest) ProtoMessage()

func (*UpdateDomainIsolationGroupsRequest) Reset

func (*UpdateDomainIsolationGroupsRequest) Size

func (*UpdateDomainIsolationGroupsRequest) String

func (*UpdateDomainIsolationGroupsRequest) Unmarshal

func (m *UpdateDomainIsolationGroupsRequest) Unmarshal(dAtA []byte) error

func (*UpdateDomainIsolationGroupsRequest) XXX_DiscardUnknown

func (m *UpdateDomainIsolationGroupsRequest) XXX_DiscardUnknown()

func (*UpdateDomainIsolationGroupsRequest) XXX_Marshal

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

func (*UpdateDomainIsolationGroupsRequest) XXX_Merge

func (*UpdateDomainIsolationGroupsRequest) XXX_Size

func (*UpdateDomainIsolationGroupsRequest) XXX_Unmarshal

func (m *UpdateDomainIsolationGroupsRequest) XXX_Unmarshal(b []byte) error

type UpdateDomainIsolationGroupsResponse

type UpdateDomainIsolationGroupsResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*UpdateDomainIsolationGroupsResponse) Descriptor

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

func (*UpdateDomainIsolationGroupsResponse) Marshal

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

func (*UpdateDomainIsolationGroupsResponse) MarshalTo

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

func (*UpdateDomainIsolationGroupsResponse) MarshalToSizedBuffer

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

func (*UpdateDomainIsolationGroupsResponse) ProtoMessage

func (*UpdateDomainIsolationGroupsResponse) ProtoMessage()

func (*UpdateDomainIsolationGroupsResponse) Reset

func (*UpdateDomainIsolationGroupsResponse) Size

func (*UpdateDomainIsolationGroupsResponse) String

func (*UpdateDomainIsolationGroupsResponse) Unmarshal

func (m *UpdateDomainIsolationGroupsResponse) Unmarshal(dAtA []byte) error

func (*UpdateDomainIsolationGroupsResponse) XXX_DiscardUnknown

func (m *UpdateDomainIsolationGroupsResponse) XXX_DiscardUnknown()

func (*UpdateDomainIsolationGroupsResponse) XXX_Marshal

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

func (*UpdateDomainIsolationGroupsResponse) XXX_Merge

func (*UpdateDomainIsolationGroupsResponse) XXX_Size

func (*UpdateDomainIsolationGroupsResponse) XXX_Unmarshal

func (m *UpdateDomainIsolationGroupsResponse) XXX_Unmarshal(b []byte) error

type UpdateDynamicConfigRequest

type UpdateDynamicConfigRequest struct {
	ConfigName           string                `protobuf:"bytes,1,opt,name=config_name,json=configName,proto3" json:"config_name,omitempty"`
	ConfigValues         []*DynamicConfigValue `protobuf:"bytes,2,rep,name=config_values,json=configValues,proto3" json:"config_values,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

If filters field is not specified in DynamicConfigValue, value will update fallback value which supersedes the default value defined in codebase.

func (*UpdateDynamicConfigRequest) Descriptor

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

func (*UpdateDynamicConfigRequest) GetConfigName

func (m *UpdateDynamicConfigRequest) GetConfigName() string

func (*UpdateDynamicConfigRequest) GetConfigValues

func (m *UpdateDynamicConfigRequest) GetConfigValues() []*DynamicConfigValue

func (*UpdateDynamicConfigRequest) Marshal

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

func (*UpdateDynamicConfigRequest) MarshalTo

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

func (*UpdateDynamicConfigRequest) MarshalToSizedBuffer

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

func (*UpdateDynamicConfigRequest) ProtoMessage

func (*UpdateDynamicConfigRequest) ProtoMessage()

func (*UpdateDynamicConfigRequest) Reset

func (m *UpdateDynamicConfigRequest) Reset()

func (*UpdateDynamicConfigRequest) Size

func (m *UpdateDynamicConfigRequest) Size() (n int)

func (*UpdateDynamicConfigRequest) String

func (m *UpdateDynamicConfigRequest) String() string

func (*UpdateDynamicConfigRequest) Unmarshal

func (m *UpdateDynamicConfigRequest) Unmarshal(dAtA []byte) error

func (*UpdateDynamicConfigRequest) XXX_DiscardUnknown

func (m *UpdateDynamicConfigRequest) XXX_DiscardUnknown()

func (*UpdateDynamicConfigRequest) XXX_Marshal

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

func (*UpdateDynamicConfigRequest) XXX_Merge

func (m *UpdateDynamicConfigRequest) XXX_Merge(src proto.Message)

func (*UpdateDynamicConfigRequest) XXX_Size

func (m *UpdateDynamicConfigRequest) XXX_Size() int

func (*UpdateDynamicConfigRequest) XXX_Unmarshal

func (m *UpdateDynamicConfigRequest) XXX_Unmarshal(b []byte) error

type UpdateDynamicConfigResponse

type UpdateDynamicConfigResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*UpdateDynamicConfigResponse) Descriptor

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

func (*UpdateDynamicConfigResponse) Marshal

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

func (*UpdateDynamicConfigResponse) MarshalTo

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

func (*UpdateDynamicConfigResponse) MarshalToSizedBuffer

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

func (*UpdateDynamicConfigResponse) ProtoMessage

func (*UpdateDynamicConfigResponse) ProtoMessage()

func (*UpdateDynamicConfigResponse) Reset

func (m *UpdateDynamicConfigResponse) Reset()

func (*UpdateDynamicConfigResponse) Size

func (m *UpdateDynamicConfigResponse) Size() (n int)

func (*UpdateDynamicConfigResponse) String

func (m *UpdateDynamicConfigResponse) String() string

func (*UpdateDynamicConfigResponse) Unmarshal

func (m *UpdateDynamicConfigResponse) Unmarshal(dAtA []byte) error

func (*UpdateDynamicConfigResponse) XXX_DiscardUnknown

func (m *UpdateDynamicConfigResponse) XXX_DiscardUnknown()

func (*UpdateDynamicConfigResponse) XXX_Marshal

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

func (*UpdateDynamicConfigResponse) XXX_Merge

func (m *UpdateDynamicConfigResponse) XXX_Merge(src proto.Message)

func (*UpdateDynamicConfigResponse) XXX_Size

func (m *UpdateDynamicConfigResponse) XXX_Size() int

func (*UpdateDynamicConfigResponse) XXX_Unmarshal

func (m *UpdateDynamicConfigResponse) XXX_Unmarshal(b []byte) error

type UpdateGlobalIsolationGroupsRequest

type UpdateGlobalIsolationGroupsRequest struct {
	IsolationGroups      *v1.IsolationGroupConfiguration `protobuf:"bytes,1,opt,name=isolation_groups,json=isolationGroups,proto3" json:"isolation_groups,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                        `json:"-"`
	XXX_unrecognized     []byte                          `json:"-"`
	XXX_sizecache        int32                           `json:"-"`
}

func (*UpdateGlobalIsolationGroupsRequest) Descriptor

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

func (*UpdateGlobalIsolationGroupsRequest) GetIsolationGroups

func (*UpdateGlobalIsolationGroupsRequest) Marshal

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

func (*UpdateGlobalIsolationGroupsRequest) MarshalTo

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

func (*UpdateGlobalIsolationGroupsRequest) MarshalToSizedBuffer

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

func (*UpdateGlobalIsolationGroupsRequest) ProtoMessage

func (*UpdateGlobalIsolationGroupsRequest) ProtoMessage()

func (*UpdateGlobalIsolationGroupsRequest) Reset

func (*UpdateGlobalIsolationGroupsRequest) Size

func (*UpdateGlobalIsolationGroupsRequest) String

func (*UpdateGlobalIsolationGroupsRequest) Unmarshal

func (m *UpdateGlobalIsolationGroupsRequest) Unmarshal(dAtA []byte) error

func (*UpdateGlobalIsolationGroupsRequest) XXX_DiscardUnknown

func (m *UpdateGlobalIsolationGroupsRequest) XXX_DiscardUnknown()

func (*UpdateGlobalIsolationGroupsRequest) XXX_Marshal

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

func (*UpdateGlobalIsolationGroupsRequest) XXX_Merge

func (*UpdateGlobalIsolationGroupsRequest) XXX_Size

func (*UpdateGlobalIsolationGroupsRequest) XXX_Unmarshal

func (m *UpdateGlobalIsolationGroupsRequest) XXX_Unmarshal(b []byte) error

type UpdateGlobalIsolationGroupsResponse

type UpdateGlobalIsolationGroupsResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*UpdateGlobalIsolationGroupsResponse) Descriptor

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

func (*UpdateGlobalIsolationGroupsResponse) Marshal

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

func (*UpdateGlobalIsolationGroupsResponse) MarshalTo

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

func (*UpdateGlobalIsolationGroupsResponse) MarshalToSizedBuffer

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

func (*UpdateGlobalIsolationGroupsResponse) ProtoMessage

func (*UpdateGlobalIsolationGroupsResponse) ProtoMessage()

func (*UpdateGlobalIsolationGroupsResponse) Reset

func (*UpdateGlobalIsolationGroupsResponse) Size

func (*UpdateGlobalIsolationGroupsResponse) String

func (*UpdateGlobalIsolationGroupsResponse) Unmarshal

func (m *UpdateGlobalIsolationGroupsResponse) Unmarshal(dAtA []byte) error

func (*UpdateGlobalIsolationGroupsResponse) XXX_DiscardUnknown

func (m *UpdateGlobalIsolationGroupsResponse) XXX_DiscardUnknown()

func (*UpdateGlobalIsolationGroupsResponse) XXX_Marshal

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

func (*UpdateGlobalIsolationGroupsResponse) XXX_Merge

func (*UpdateGlobalIsolationGroupsResponse) XXX_Size

func (*UpdateGlobalIsolationGroupsResponse) XXX_Unmarshal

func (m *UpdateGlobalIsolationGroupsResponse) XXX_Unmarshal(b []byte) error

type VersionHistory

type VersionHistory struct {
	BranchToken          []byte                `protobuf:"bytes,1,opt,name=branch_token,json=branchToken,proto3" json:"branch_token,omitempty"`
	Items                []*VersionHistoryItem `protobuf:"bytes,2,rep,name=items,proto3" json:"items,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

VersionHistory contains the version history of a branch.

func (*VersionHistory) Descriptor

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

func (*VersionHistory) GetBranchToken

func (m *VersionHistory) GetBranchToken() []byte

func (*VersionHistory) GetItems

func (m *VersionHistory) GetItems() []*VersionHistoryItem

func (*VersionHistory) Marshal

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

func (*VersionHistory) MarshalTo

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

func (*VersionHistory) MarshalToSizedBuffer

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

func (*VersionHistory) ProtoMessage

func (*VersionHistory) ProtoMessage()

func (*VersionHistory) Reset

func (m *VersionHistory) Reset()

func (*VersionHistory) Size

func (m *VersionHistory) Size() (n int)

func (*VersionHistory) String

func (m *VersionHistory) String() string

func (*VersionHistory) Unmarshal

func (m *VersionHistory) Unmarshal(dAtA []byte) error

func (*VersionHistory) XXX_DiscardUnknown

func (m *VersionHistory) XXX_DiscardUnknown()

func (*VersionHistory) XXX_Marshal

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

func (*VersionHistory) XXX_Merge

func (m *VersionHistory) XXX_Merge(src proto.Message)

func (*VersionHistory) XXX_Size

func (m *VersionHistory) XXX_Size() int

func (*VersionHistory) XXX_Unmarshal

func (m *VersionHistory) XXX_Unmarshal(b []byte) error

type VersionHistoryItem

type VersionHistoryItem struct {
	EventId              int64    `protobuf:"varint,1,opt,name=event_id,json=eventId,proto3" json:"event_id,omitempty"`
	Version              int64    `protobuf:"varint,2,opt,name=version,proto3" json:"version,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

VersionHistoryItem contains signal eventId and the corresponding version.

func (*VersionHistoryItem) Descriptor

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

func (*VersionHistoryItem) GetEventId

func (m *VersionHistoryItem) GetEventId() int64

func (*VersionHistoryItem) GetVersion

func (m *VersionHistoryItem) GetVersion() int64

func (*VersionHistoryItem) Marshal

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

func (*VersionHistoryItem) MarshalTo

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

func (*VersionHistoryItem) MarshalToSizedBuffer

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

func (*VersionHistoryItem) ProtoMessage

func (*VersionHistoryItem) ProtoMessage()

func (*VersionHistoryItem) Reset

func (m *VersionHistoryItem) Reset()

func (*VersionHistoryItem) Size

func (m *VersionHistoryItem) Size() (n int)

func (*VersionHistoryItem) String

func (m *VersionHistoryItem) String() string

func (*VersionHistoryItem) Unmarshal

func (m *VersionHistoryItem) Unmarshal(dAtA []byte) error

func (*VersionHistoryItem) XXX_DiscardUnknown

func (m *VersionHistoryItem) XXX_DiscardUnknown()

func (*VersionHistoryItem) XXX_Marshal

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

func (*VersionHistoryItem) XXX_Merge

func (m *VersionHistoryItem) XXX_Merge(src proto.Message)

func (*VersionHistoryItem) XXX_Size

func (m *VersionHistoryItem) XXX_Size() int

func (*VersionHistoryItem) XXX_Unmarshal

func (m *VersionHistoryItem) XXX_Unmarshal(b []byte) error

Jump to

Keyboard shortcuts

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