Versions in this module Expand all Collapse all v1 v1.12.0 Dec 10, 2021 Changes in this version type Client + func (_m *Client) WorkflowService() workflowservice.WorkflowServiceClient v1.11.2 Nov 25, 2021 Changes in this version + type Client struct + func (_m *Client) CancelWorkflow(ctx context.Context, workflowID string, runID string) error + func (_m *Client) Close() + func (_m *Client) CompleteActivity(ctx context.Context, taskToken []byte, result interface{}, err error) error + func (_m *Client) CompleteActivityByID(ctx context.Context, namespace string, workflowID string, runID string, ...) error + func (_m *Client) CountWorkflow(ctx context.Context, request *workflowservice.CountWorkflowExecutionsRequest) (*workflowservice.CountWorkflowExecutionsResponse, error) + func (_m *Client) DescribeTaskQueue(ctx context.Context, taskqueue string, taskqueueType enumspb.TaskQueueType) (*workflowservice.DescribeTaskQueueResponse, error) + func (_m *Client) DescribeWorkflowExecution(ctx context.Context, workflowID string, runID string) (*workflowservice.DescribeWorkflowExecutionResponse, error) + func (_m *Client) ExecuteWorkflow(ctx context.Context, options client.StartWorkflowOptions, workflow interface{}, ...) (client.WorkflowRun, error) + func (_m *Client) GetSearchAttributes(ctx context.Context) (*workflowservice.GetSearchAttributesResponse, error) + func (_m *Client) GetWorkflow(ctx context.Context, workflowID string, runID string) client.WorkflowRun + func (_m *Client) GetWorkflowHistory(ctx context.Context, workflowID string, runID string, isLongPoll bool, ...) client.HistoryEventIterator + func (_m *Client) ListArchivedWorkflow(ctx context.Context, ...) (*workflowservice.ListArchivedWorkflowExecutionsResponse, error) + func (_m *Client) ListClosedWorkflow(ctx context.Context, ...) (*workflowservice.ListClosedWorkflowExecutionsResponse, error) + func (_m *Client) ListOpenWorkflow(ctx context.Context, ...) (*workflowservice.ListOpenWorkflowExecutionsResponse, error) + func (_m *Client) ListWorkflow(ctx context.Context, request *workflowservice.ListWorkflowExecutionsRequest) (*workflowservice.ListWorkflowExecutionsResponse, error) + func (_m *Client) QueryWorkflow(ctx context.Context, workflowID string, runID string, queryType string, ...) (converter.EncodedValue, error) + func (_m *Client) QueryWorkflowWithOptions(ctx context.Context, request *client.QueryWorkflowWithOptionsRequest) (*client.QueryWorkflowWithOptionsResponse, error) + func (_m *Client) RecordActivityHeartbeat(ctx context.Context, taskToken []byte, details ...interface{}) error + func (_m *Client) RecordActivityHeartbeatByID(ctx context.Context, namespace string, workflowID string, runID string, ...) error + func (_m *Client) ResetWorkflowExecution(ctx context.Context, request *workflowservice.ResetWorkflowExecutionRequest) (*workflowservice.ResetWorkflowExecutionResponse, error) + func (_m *Client) ScanWorkflow(ctx context.Context, request *workflowservice.ScanWorkflowExecutionsRequest) (*workflowservice.ScanWorkflowExecutionsResponse, error) + func (_m *Client) SignalWithStartWorkflow(ctx context.Context, workflowID string, signalName string, ...) (client.WorkflowRun, error) + func (_m *Client) SignalWorkflow(ctx context.Context, workflowID string, runID string, signalName string, ...) error + func (_m *Client) TerminateWorkflow(ctx context.Context, workflowID string, runID string, reason string, ...) error + type HistoryEventIterator struct + func (_m *HistoryEventIterator) HasNext() bool + func (_m *HistoryEventIterator) Next() (*historypb.HistoryEvent, error) + type NamespaceClient struct + func (_m *NamespaceClient) Close() + func (_m *NamespaceClient) Describe(ctx context.Context, name string) (*workflowservice.DescribeNamespaceResponse, error) + func (_m *NamespaceClient) Register(ctx context.Context, request *workflowservice.RegisterNamespaceRequest) error + func (_m *NamespaceClient) Update(ctx context.Context, request *workflowservice.UpdateNamespaceRequest) error + type Value struct + func (_m *Value) Get(valuePtr interface{}) error + func (_m *Value) HasValue() bool + type WorkflowRun struct + func (_m *WorkflowRun) Get(ctx context.Context, valuePtr interface{}) error + func (_m *WorkflowRun) GetID() string + func (_m *WorkflowRun) GetRunID() string
Go to main page