adminv1

package
v0.0.0-...-dcfe462 Latest Latest
Warning

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

 Go to latest Published: Dec 30, 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 AdminAPIReflectionMeta = reflection.ServerMeta{
	ServiceName:     "uber.cadence.admin.v1.AdminAPI",
	FileDescriptors: yarpcFileDescriptorClosurec6fc96d64a8b67fd,
}

AdminAPIReflectionMeta is the reflection server metadata required for using the gRPC reflection protocol with YARPC.

See https://github.com/grpc/grpc/blob/master/doc/server-reflection.md.

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)
	UpdateTaskListPartitionConfig(context.Context, *UpdateTaskListPartitionConfigRequest, ...yarpc.CallOption) (*UpdateTaskListPartitionConfigResponse, 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)
	UpdateTaskListPartitionConfig(context.Context, *UpdateTaskListPartitionConfigRequest) (*UpdateTaskListPartitionConfigResponse, 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 (m *ApplyParentClosePolicyAttributes) Reset()

func (*ApplyParentClosePolicyAttributes) Size 

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

func (*ApplyParentClosePolicyAttributes) String 

func (m *ApplyParentClosePolicyAttributes) String() 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 (m *ApplyParentClosePolicyAttributes) XXX_Merge(src proto.Message)

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 (m *ApplyParentClosePolicyRequest) GetChild() *ApplyParentClosePolicyAttributes

func (*ApplyParentClosePolicyRequest) GetStatus 

func (m *ApplyParentClosePolicyRequest) GetStatus() *ApplyParentClosePolicyStatus

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 (m *ApplyParentClosePolicyRequest) String() string

func (*ApplyParentClosePolicyRequest) Unmarshal 

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

func (*ApplyParentClosePolicyRequest) XXX_DiscardUnknown