swf

package
v0.4.0 Latest Latest
Warning

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

 Go to latest Published: May 5, 2021 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Activities 

type Activities struct {
	// contains filtered or unexported fields
}

func NewActivities 

func NewActivities(sess *session.Session, config ...*aws.Config) *Activities

func NewActivitiesWithSessionFactory 

func NewActivitiesWithSessionFactory(sessionFactory SessionFactory) *Activities

func (*Activities) CountClosedWorkflowExecutions 

func (a *Activities) CountClosedWorkflowExecutions(ctx context.Context, input *swf.CountClosedWorkflowExecutionsInput) (*swf.WorkflowExecutionCount, error)

func (*Activities) CountOpenWorkflowExecutions 

func (a *Activities) CountOpenWorkflowExecutions(ctx context.Context, input *swf.CountOpenWorkflowExecutionsInput) (*swf.WorkflowExecutionCount, error)

func (*Activities) CountPendingActivityTasks 

func (a *Activities) CountPendingActivityTasks(ctx context.Context, input *swf.CountPendingActivityTasksInput) (*swf.PendingTaskCount, error)

func (*Activities) CountPendingDecisionTasks 

func (a *Activities) CountPendingDecisionTasks(ctx context.Context, input *swf.CountPendingDecisionTasksInput) (*swf.PendingTaskCount, error)

func (*Activities) DeprecateActivityType 

func (a *Activities) DeprecateActivityType(ctx context.Context, input *swf.DeprecateActivityTypeInput) (*swf.DeprecateActivityTypeOutput, error)

func (*Activities) DeprecateDomain 

func (a *Activities) DeprecateDomain(ctx context.Context, input *swf.DeprecateDomainInput) (*swf.DeprecateDomainOutput, error)

func (*Activities) DeprecateWorkflowType 

func (a *Activities) DeprecateWorkflowType(ctx context.Context, input *swf.DeprecateWorkflowTypeInput) (*swf.DeprecateWorkflowTypeOutput, error)

func (*Activities) DescribeActivityType 

func (a *Activities) DescribeActivityType(ctx context.Context, input *swf.DescribeActivityTypeInput) (*swf.DescribeActivityTypeOutput, error)

func (*Activities) DescribeDomain 

func (a *Activities) DescribeDomain(ctx context.Context, input *swf.DescribeDomainInput) (*swf.DescribeDomainOutput, error)

func (*Activities) DescribeWorkflowExecution 

func (a *Activities) DescribeWorkflowExecution(ctx context.Context, input *swf.DescribeWorkflowExecutionInput) (*swf.DescribeWorkflowExecutionOutput, error)

func (*Activities) DescribeWorkflowType 

func (a *Activities) DescribeWorkflowType(ctx context.Context, input *swf.DescribeWorkflowTypeInput) (*swf.DescribeWorkflowTypeOutput, error)

func (*Activities) GetWorkflowExecutionHistory 

func (a *Activities) GetWorkflowExecutionHistory(ctx context.Context, input *swf.GetWorkflowExecutionHistoryInput) (*swf.GetWorkflowExecutionHistoryOutput, error)

func (*Activities) ListActivityTypes 

func (a *Activities) ListActivityTypes(ctx context.Context, input *swf.ListActivityTypesInput) (*swf.ListActivityTypesOutput, error)

func (*Activities) ListClosedWorkflowExecutions 

func (a *Activities) ListClosedWorkflowExecutions(ctx context.Context, input *swf.ListClosedWorkflowExecutionsInput) (*swf.WorkflowExecutionInfos, error)

func (*Activities) ListDomains 

func (a *Activities) ListDomains(ctx context.Context, input *swf.ListDomainsInput) (*swf.ListDomainsOutput, error)

func (*Activities) ListOpenWorkflowExecutions 

func (a *Activities) ListOpenWorkflowExecutions(ctx context.Context, input *swf.ListOpenWorkflowExecutionsInput) (*swf.WorkflowExecutionInfos, error)

func (*Activities) ListTagsForResource 

func (a *Activities) ListTagsForResource(ctx context.Context, input *swf.ListTagsForResourceInput) (*swf.ListTagsForResourceOutput, error)

func (*Activities) ListWorkflowTypes 

func (a *Activities) ListWorkflowTypes(ctx context.Context, input *swf.ListWorkflowTypesInput) (*swf.ListWorkflowTypesOutput, error)

func (*Activities) PollForActivityTask 

func (a *Activities) PollForActivityTask(ctx context.Context, input *swf.PollForActivityTaskInput) (*swf.PollForActivityTaskOutput, error)

func (*Activities) PollForDecisionTask 

func (a *Activities) PollForDecisionTask(ctx context.Context, input *swf.PollForDecisionTaskInput) (*swf.PollForDecisionTaskOutput, error)

func (*Activities) RecordActivityTaskHeartbeat 

func (a *Activities) RecordActivityTaskHeartbeat(ctx context.Context, input *swf.RecordActivityTaskHeartbeatInput) (*swf.RecordActivityTaskHeartbeatOutput, error)

func (*Activities) RegisterActivityType 

func (a *Activities) RegisterActivityType(ctx context.Context, input *swf.RegisterActivityTypeInput) (*swf.RegisterActivityTypeOutput, error)

func (*Activities) RegisterDomain 

func (a *Activities) RegisterDomain(ctx context.Context, input *swf.RegisterDomainInput) (*swf.RegisterDomainOutput, error)

func (*Activities) RegisterWorkflowType 

func (a *Activities) RegisterWorkflowType(ctx context.Context, input *swf.RegisterWorkflowTypeInput) (*swf.RegisterWorkflowTypeOutput, error)

func (*Activities) RequestCancelWorkflowExecution 

func (a *Activities) RequestCancelWorkflowExecution(ctx context.Context, input *swf.RequestCancelWorkflowExecutionInput) (*swf.RequestCancelWorkflowExecutionOutput, error)

func (*Activities) RespondActivityTaskCanceled 

func (a *Activities) RespondActivityTaskCanceled(ctx context.Context, input *swf.RespondActivityTaskCanceledInput) (*swf.RespondActivityTaskCanceledOutput, error)

func (*Activities) RespondActivityTaskCompleted 

func (a *Activities) RespondActivityTaskCompleted(ctx context.Context, input *swf.RespondActivityTaskCompletedInput) (*swf.RespondActivityTaskCompletedOutput, error)

func (*Activities) RespondActivityTaskFailed 

func (a *Activities) RespondActivityTaskFailed(ctx context.Context, input *swf.RespondActivityTaskFailedInput) (*swf.RespondActivityTaskFailedOutput, error)

func (*Activities) RespondDecisionTaskCompleted 

func (a *Activities) RespondDecisionTaskCompleted(ctx context.Context, input *swf.RespondDecisionTaskCompletedInput) (*swf.RespondDecisionTaskCompletedOutput, error)

func (*Activities) SignalWorkflowExecution 

func (a *Activities) SignalWorkflowExecution(ctx context.Context, input *swf.SignalWorkflowExecutionInput) (*swf.SignalWorkflowExecutionOutput, error)

func (*Activities) StartWorkflowExecution 

func (a *Activities) StartWorkflowExecution(ctx context.Context, input *swf.StartWorkflowExecutionInput) (*swf.StartWorkflowExecutionOutput, error)

func (*Activities) TagResource 

func (a *Activities) TagResource(ctx context.Context, input *swf.TagResourceInput) (*swf.TagResourceOutput, error)

func (*Activities) TerminateWorkflowExecution 

func (a *Activities) TerminateWorkflowExecution(ctx context.Context, input *swf.TerminateWorkflowExecutionInput) (*swf.TerminateWorkflowExecutionOutput, error)

func (*Activities) UndeprecateActivityType 

func (a *Activities) UndeprecateActivityType(ctx context.Context, input *swf.UndeprecateActivityTypeInput) (*swf.UndeprecateActivityTypeOutput, error)

func (*Activities) UndeprecateDomain 

func (a *Activities) UndeprecateDomain(ctx context.Context, input *swf.UndeprecateDomainInput) (*swf.UndeprecateDomainOutput, error)

func (*Activities) UndeprecateWorkflowType 

func (a *Activities) UndeprecateWorkflowType(ctx context.Context, input *swf.UndeprecateWorkflowTypeInput) (*swf.UndeprecateWorkflowTypeOutput, error)

func (*Activities) UntagResource 

func (a *Activities) UntagResource(ctx context.Context, input *swf.UntagResourceInput) (*swf.UntagResourceOutput, error)

type SessionFactory 

type SessionFactory interface {
	Session(ctx context.Context) (*session.Session, error)
}

SessionFactory returns an aws.Session based on the activity context.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.