in go/proto/admin/v1/service.pb.yarpc.go [142:493]
func buildAdminAPIYARPCProcedures(params buildAdminAPIYARPCProceduresParams) []transport.Procedure {
handler := &_AdminAPIYARPCHandler{params.Server}
return protobuf.BuildProcedures(
protobuf.BuildProceduresParams{
ServiceName: "uber.cadence.admin.v1.AdminAPI",
UnaryHandlerParams: []protobuf.BuildProceduresUnaryHandlerParams{
{
MethodName: "DescribeWorkflowExecution",
Handler: protobuf.NewUnaryHandler(
protobuf.UnaryHandlerParams{
Handle: handler.DescribeWorkflowExecution,
NewRequest: newAdminAPIServiceDescribeWorkflowExecutionYARPCRequest,
AnyResolver: params.AnyResolver,
},
),
},
{
MethodName: "DescribeHistoryHost",
Handler: protobuf.NewUnaryHandler(
protobuf.UnaryHandlerParams{
Handle: handler.DescribeHistoryHost,
NewRequest: newAdminAPIServiceDescribeHistoryHostYARPCRequest,
AnyResolver: params.AnyResolver,
},
),
},
{
MethodName: "DescribeShardDistribution",
Handler: protobuf.NewUnaryHandler(
protobuf.UnaryHandlerParams{
Handle: handler.DescribeShardDistribution,
NewRequest: newAdminAPIServiceDescribeShardDistributionYARPCRequest,
AnyResolver: params.AnyResolver,
},
),
},
{
MethodName: "CloseShard",
Handler: protobuf.NewUnaryHandler(
protobuf.UnaryHandlerParams{
Handle: handler.CloseShard,
NewRequest: newAdminAPIServiceCloseShardYARPCRequest,
AnyResolver: params.AnyResolver,
},
),
},
{
MethodName: "RemoveTask",
Handler: protobuf.NewUnaryHandler(
protobuf.UnaryHandlerParams{
Handle: handler.RemoveTask,
NewRequest: newAdminAPIServiceRemoveTaskYARPCRequest,
AnyResolver: params.AnyResolver,
},
),
},
{
MethodName: "ResetQueue",
Handler: protobuf.NewUnaryHandler(
protobuf.UnaryHandlerParams{
Handle: handler.ResetQueue,
NewRequest: newAdminAPIServiceResetQueueYARPCRequest,
AnyResolver: params.AnyResolver,
},
),
},
{
MethodName: "DescribeQueue",
Handler: protobuf.NewUnaryHandler(
protobuf.UnaryHandlerParams{
Handle: handler.DescribeQueue,
NewRequest: newAdminAPIServiceDescribeQueueYARPCRequest,
AnyResolver: params.AnyResolver,
},
),
},
{
MethodName: "GetWorkflowExecutionRawHistoryV2",
Handler: protobuf.NewUnaryHandler(
protobuf.UnaryHandlerParams{
Handle: handler.GetWorkflowExecutionRawHistoryV2,
NewRequest: newAdminAPIServiceGetWorkflowExecutionRawHistoryV2YARPCRequest,
AnyResolver: params.AnyResolver,
},
),
},
{
MethodName: "GetReplicationMessages",
Handler: protobuf.NewUnaryHandler(
protobuf.UnaryHandlerParams{
Handle: handler.GetReplicationMessages,
NewRequest: newAdminAPIServiceGetReplicationMessagesYARPCRequest,
AnyResolver: params.AnyResolver,
},
),
},
{
MethodName: "GetDLQReplicationMessages",
Handler: protobuf.NewUnaryHandler(
protobuf.UnaryHandlerParams{
Handle: handler.GetDLQReplicationMessages,
NewRequest: newAdminAPIServiceGetDLQReplicationMessagesYARPCRequest,
AnyResolver: params.AnyResolver,
},
),
},
{
MethodName: "GetDomainReplicationMessages",
Handler: protobuf.NewUnaryHandler(
protobuf.UnaryHandlerParams{
Handle: handler.GetDomainReplicationMessages,
NewRequest: newAdminAPIServiceGetDomainReplicationMessagesYARPCRequest,
AnyResolver: params.AnyResolver,
},
),
},
{
MethodName: "ReapplyEvents",
Handler: protobuf.NewUnaryHandler(
protobuf.UnaryHandlerParams{
Handle: handler.ReapplyEvents,
NewRequest: newAdminAPIServiceReapplyEventsYARPCRequest,
AnyResolver: params.AnyResolver,
},
),
},
{
MethodName: "AddSearchAttribute",
Handler: protobuf.NewUnaryHandler(
protobuf.UnaryHandlerParams{
Handle: handler.AddSearchAttribute,
NewRequest: newAdminAPIServiceAddSearchAttributeYARPCRequest,
AnyResolver: params.AnyResolver,
},
),
},
{
MethodName: "DescribeCluster",
Handler: protobuf.NewUnaryHandler(
protobuf.UnaryHandlerParams{
Handle: handler.DescribeCluster,
NewRequest: newAdminAPIServiceDescribeClusterYARPCRequest,
AnyResolver: params.AnyResolver,
},
),
},
{
MethodName: "CountDLQMessages",
Handler: protobuf.NewUnaryHandler(
protobuf.UnaryHandlerParams{
Handle: handler.CountDLQMessages,
NewRequest: newAdminAPIServiceCountDLQMessagesYARPCRequest,
AnyResolver: params.AnyResolver,
},
),
},
{
MethodName: "ReadDLQMessages",
Handler: protobuf.NewUnaryHandler(
protobuf.UnaryHandlerParams{
Handle: handler.ReadDLQMessages,
NewRequest: newAdminAPIServiceReadDLQMessagesYARPCRequest,
AnyResolver: params.AnyResolver,
},
),
},
{
MethodName: "PurgeDLQMessages",
Handler: protobuf.NewUnaryHandler(
protobuf.UnaryHandlerParams{
Handle: handler.PurgeDLQMessages,
NewRequest: newAdminAPIServicePurgeDLQMessagesYARPCRequest,
AnyResolver: params.AnyResolver,
},
),
},
{
MethodName: "MergeDLQMessages",
Handler: protobuf.NewUnaryHandler(
protobuf.UnaryHandlerParams{
Handle: handler.MergeDLQMessages,
NewRequest: newAdminAPIServiceMergeDLQMessagesYARPCRequest,
AnyResolver: params.AnyResolver,
},
),
},
{
MethodName: "RefreshWorkflowTasks",
Handler: protobuf.NewUnaryHandler(
protobuf.UnaryHandlerParams{
Handle: handler.RefreshWorkflowTasks,
NewRequest: newAdminAPIServiceRefreshWorkflowTasksYARPCRequest,
AnyResolver: params.AnyResolver,
},
),
},
{
MethodName: "ResendReplicationTasks",
Handler: protobuf.NewUnaryHandler(
protobuf.UnaryHandlerParams{
Handle: handler.ResendReplicationTasks,
NewRequest: newAdminAPIServiceResendReplicationTasksYARPCRequest,
AnyResolver: params.AnyResolver,
},
),
},
{
MethodName: "GetCrossClusterTasks",
Handler: protobuf.NewUnaryHandler(
protobuf.UnaryHandlerParams{
Handle: handler.GetCrossClusterTasks,
NewRequest: newAdminAPIServiceGetCrossClusterTasksYARPCRequest,
AnyResolver: params.AnyResolver,
},
),
},
{
MethodName: "RespondCrossClusterTasksCompleted",
Handler: protobuf.NewUnaryHandler(
protobuf.UnaryHandlerParams{
Handle: handler.RespondCrossClusterTasksCompleted,
NewRequest: newAdminAPIServiceRespondCrossClusterTasksCompletedYARPCRequest,
AnyResolver: params.AnyResolver,
},
),
},
{
MethodName: "GetDynamicConfig",
Handler: protobuf.NewUnaryHandler(
protobuf.UnaryHandlerParams{
Handle: handler.GetDynamicConfig,
NewRequest: newAdminAPIServiceGetDynamicConfigYARPCRequest,
AnyResolver: params.AnyResolver,
},
),
},
{
MethodName: "UpdateDynamicConfig",
Handler: protobuf.NewUnaryHandler(
protobuf.UnaryHandlerParams{
Handle: handler.UpdateDynamicConfig,
NewRequest: newAdminAPIServiceUpdateDynamicConfigYARPCRequest,
AnyResolver: params.AnyResolver,
},
),
},
{
MethodName: "RestoreDynamicConfig",
Handler: protobuf.NewUnaryHandler(
protobuf.UnaryHandlerParams{
Handle: handler.RestoreDynamicConfig,
NewRequest: newAdminAPIServiceRestoreDynamicConfigYARPCRequest,
AnyResolver: params.AnyResolver,
},
),
},
{
MethodName: "ListDynamicConfig",
Handler: protobuf.NewUnaryHandler(
protobuf.UnaryHandlerParams{
Handle: handler.ListDynamicConfig,
NewRequest: newAdminAPIServiceListDynamicConfigYARPCRequest,
AnyResolver: params.AnyResolver,
},
),
},
{
MethodName: "DeleteWorkflow",
Handler: protobuf.NewUnaryHandler(
protobuf.UnaryHandlerParams{
Handle: handler.DeleteWorkflow,
NewRequest: newAdminAPIServiceDeleteWorkflowYARPCRequest,
AnyResolver: params.AnyResolver,
},
),
},
{
MethodName: "MaintainCorruptWorkflow",
Handler: protobuf.NewUnaryHandler(
protobuf.UnaryHandlerParams{
Handle: handler.MaintainCorruptWorkflow,
NewRequest: newAdminAPIServiceMaintainCorruptWorkflowYARPCRequest,
AnyResolver: params.AnyResolver,
},
),
},
{
MethodName: "GetGlobalIsolationGroups",
Handler: protobuf.NewUnaryHandler(
protobuf.UnaryHandlerParams{
Handle: handler.GetGlobalIsolationGroups,
NewRequest: newAdminAPIServiceGetGlobalIsolationGroupsYARPCRequest,
AnyResolver: params.AnyResolver,
},
),
},
{
MethodName: "UpdateGlobalIsolationGroups",
Handler: protobuf.NewUnaryHandler(
protobuf.UnaryHandlerParams{
Handle: handler.UpdateGlobalIsolationGroups,
NewRequest: newAdminAPIServiceUpdateGlobalIsolationGroupsYARPCRequest,
AnyResolver: params.AnyResolver,
},
),
},
{
MethodName: "GetDomainIsolationGroups",
Handler: protobuf.NewUnaryHandler(
protobuf.UnaryHandlerParams{
Handle: handler.GetDomainIsolationGroups,
NewRequest: newAdminAPIServiceGetDomainIsolationGroupsYARPCRequest,
AnyResolver: params.AnyResolver,
},
),
},
{
MethodName: "UpdateDomainIsolationGroups",
Handler: protobuf.NewUnaryHandler(
protobuf.UnaryHandlerParams{
Handle: handler.UpdateDomainIsolationGroups,
NewRequest: newAdminAPIServiceUpdateDomainIsolationGroupsYARPCRequest,
AnyResolver: params.AnyResolver,
},
),
},
{
MethodName: "GetDomainAsyncWorkflowConfiguraton",
Handler: protobuf.NewUnaryHandler(
protobuf.UnaryHandlerParams{
Handle: handler.GetDomainAsyncWorkflowConfiguraton,
NewRequest: newAdminAPIServiceGetDomainAsyncWorkflowConfiguratonYARPCRequest,
AnyResolver: params.AnyResolver,
},
),
},
{
MethodName: "UpdateDomainAsyncWorkflowConfiguraton",
Handler: protobuf.NewUnaryHandler(
protobuf.UnaryHandlerParams{
Handle: handler.UpdateDomainAsyncWorkflowConfiguraton,
NewRequest: newAdminAPIServiceUpdateDomainAsyncWorkflowConfiguratonYARPCRequest,
AnyResolver: params.AnyResolver,
},
),
},
},
OnewayHandlerParams: []protobuf.BuildProceduresOnewayHandlerParams{},
StreamHandlerParams: []protobuf.BuildProceduresStreamHandlerParams{},
},
)
}