adminv1

package
Version: v0.0.0-...-6c250ae Latest Latest
Warning

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

Go to latest
Published: Nov 19, 2022 License: MIT Imports: 17 Imported by: 0

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

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

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