Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Interface ¶
type Interface interface { CountWorkflowExecutions( ctx context.Context, CountRequest *shared.CountWorkflowExecutionsRequest, opts ...yarpc.CallOption, ) (*shared.CountWorkflowExecutionsResponse, error) DeprecateDomain( ctx context.Context, DeprecateRequest *shared.DeprecateDomainRequest, opts ...yarpc.CallOption, ) error DescribeDomain( ctx context.Context, DescribeRequest *shared.DescribeDomainRequest, opts ...yarpc.CallOption, ) (*shared.DescribeDomainResponse, error) DescribeTaskList( ctx context.Context, Request *shared.DescribeTaskListRequest, opts ...yarpc.CallOption, ) (*shared.DescribeTaskListResponse, error) DescribeWorkflowExecution( ctx context.Context, DescribeRequest *shared.DescribeWorkflowExecutionRequest, opts ...yarpc.CallOption, ) (*shared.DescribeWorkflowExecutionResponse, error) GetSearchAttributes( ctx context.Context, opts ...yarpc.CallOption, ) (*shared.GetSearchAttributesResponse, error) GetWorkflowExecutionHistory( ctx context.Context, GetRequest *shared.GetWorkflowExecutionHistoryRequest, opts ...yarpc.CallOption, ) (*shared.GetWorkflowExecutionHistoryResponse, error) ListArchivedWorkflowExecutions( ctx context.Context, ListRequest *shared.ListArchivedWorkflowExecutionsRequest, opts ...yarpc.CallOption, ) (*shared.ListArchivedWorkflowExecutionsResponse, error) ListClosedWorkflowExecutions( ctx context.Context, ListRequest *shared.ListClosedWorkflowExecutionsRequest, opts ...yarpc.CallOption, ) (*shared.ListClosedWorkflowExecutionsResponse, error) ListDomains( ctx context.Context, ListRequest *shared.ListDomainsRequest, opts ...yarpc.CallOption, ) (*shared.ListDomainsResponse, error) ListOpenWorkflowExecutions( ctx context.Context, ListRequest *shared.ListOpenWorkflowExecutionsRequest, opts ...yarpc.CallOption, ) (*shared.ListOpenWorkflowExecutionsResponse, error) ListWorkflowExecutions( ctx context.Context, ListRequest *shared.ListWorkflowExecutionsRequest, opts ...yarpc.CallOption, ) (*shared.ListWorkflowExecutionsResponse, error) PollForActivityTask( ctx context.Context, PollRequest *shared.PollForActivityTaskRequest, opts ...yarpc.CallOption, ) (*shared.PollForActivityTaskResponse, error) PollForDecisionTask( ctx context.Context, PollRequest *shared.PollForDecisionTaskRequest, opts ...yarpc.CallOption, ) (*shared.PollForDecisionTaskResponse, error) QueryWorkflow( ctx context.Context, QueryRequest *shared.QueryWorkflowRequest, opts ...yarpc.CallOption, ) (*shared.QueryWorkflowResponse, error) RecordActivityTaskHeartbeat( ctx context.Context, HeartbeatRequest *shared.RecordActivityTaskHeartbeatRequest, opts ...yarpc.CallOption, ) (*shared.RecordActivityTaskHeartbeatResponse, error) RecordActivityTaskHeartbeatByID( ctx context.Context, HeartbeatRequest *shared.RecordActivityTaskHeartbeatByIDRequest, opts ...yarpc.CallOption, ) (*shared.RecordActivityTaskHeartbeatResponse, error) RegisterDomain( ctx context.Context, RegisterRequest *shared.RegisterDomainRequest, opts ...yarpc.CallOption, ) error RequestCancelWorkflowExecution( ctx context.Context, CancelRequest *shared.RequestCancelWorkflowExecutionRequest, opts ...yarpc.CallOption, ) error ResetStickyTaskList( ctx context.Context, ResetRequest *shared.ResetStickyTaskListRequest, opts ...yarpc.CallOption, ) (*shared.ResetStickyTaskListResponse, error) ResetWorkflowExecution( ctx context.Context, ResetRequest *shared.ResetWorkflowExecutionRequest, opts ...yarpc.CallOption, ) (*shared.ResetWorkflowExecutionResponse, error) RespondActivityTaskCanceled( ctx context.Context, CanceledRequest *shared.RespondActivityTaskCanceledRequest, opts ...yarpc.CallOption, ) error RespondActivityTaskCanceledByID( ctx context.Context, CanceledRequest *shared.RespondActivityTaskCanceledByIDRequest, opts ...yarpc.CallOption, ) error RespondActivityTaskCompleted( ctx context.Context, CompleteRequest *shared.RespondActivityTaskCompletedRequest, opts ...yarpc.CallOption, ) error RespondActivityTaskCompletedByID( ctx context.Context, CompleteRequest *shared.RespondActivityTaskCompletedByIDRequest, opts ...yarpc.CallOption, ) error RespondActivityTaskFailed( ctx context.Context, FailRequest *shared.RespondActivityTaskFailedRequest, opts ...yarpc.CallOption, ) error RespondActivityTaskFailedByID( ctx context.Context, FailRequest *shared.RespondActivityTaskFailedByIDRequest, opts ...yarpc.CallOption, ) error RespondDecisionTaskCompleted( ctx context.Context, CompleteRequest *shared.RespondDecisionTaskCompletedRequest, opts ...yarpc.CallOption, ) (*shared.RespondDecisionTaskCompletedResponse, error) RespondDecisionTaskFailed( ctx context.Context, FailedRequest *shared.RespondDecisionTaskFailedRequest, opts ...yarpc.CallOption, ) error RespondQueryTaskCompleted( ctx context.Context, CompleteRequest *shared.RespondQueryTaskCompletedRequest, opts ...yarpc.CallOption, ) error ScanWorkflowExecutions( ctx context.Context, ListRequest *shared.ListWorkflowExecutionsRequest, opts ...yarpc.CallOption, ) (*shared.ListWorkflowExecutionsResponse, error) SignalWithStartWorkflowExecution( ctx context.Context, SignalWithStartRequest *shared.SignalWithStartWorkflowExecutionRequest, opts ...yarpc.CallOption, ) (*shared.StartWorkflowExecutionResponse, error) SignalWorkflowExecution( ctx context.Context, SignalRequest *shared.SignalWorkflowExecutionRequest, opts ...yarpc.CallOption, ) error StartWorkflowExecution( ctx context.Context, StartRequest *shared.StartWorkflowExecutionRequest, opts ...yarpc.CallOption, ) (*shared.StartWorkflowExecutionResponse, error) TerminateWorkflowExecution( ctx context.Context, TerminateRequest *shared.TerminateWorkflowExecutionRequest, opts ...yarpc.CallOption, ) error UpdateDomain( ctx context.Context, UpdateRequest *shared.UpdateDomainRequest, opts ...yarpc.CallOption, ) (*shared.UpdateDomainResponse, error) }
Interface is a client for the WorkflowService service.
func New ¶
func New(c transport.ClientConfig, opts ...thrift.ClientOption) Interface
New builds a new client for the WorkflowService service.
client := workflowserviceclient.New(dispatcher.ClientConfig("workflowservice"))
Click to show internal directories.
Click to hide internal directories.