sfn

Documentation

Index

• type Activities
  • func NewActivities(sess *session.Session, config ...*aws.Config) *Activities
  • func NewActivitiesWithSessionFactory(sessionFactory SessionFactory) *Activities
  • func (a *Activities) CreateActivity(ctx context.Context, input *sfn.CreateActivityInput) (*sfn.CreateActivityOutput, error)
  • func (a *Activities) CreateStateMachine(ctx context.Context, input *sfn.CreateStateMachineInput) (*sfn.CreateStateMachineOutput, error)
  • func (a *Activities) DeleteActivity(ctx context.Context, input *sfn.DeleteActivityInput) (*sfn.DeleteActivityOutput, error)
  • func (a *Activities) DeleteStateMachine(ctx context.Context, input *sfn.DeleteStateMachineInput) (*sfn.DeleteStateMachineOutput, error)
  • func (a *Activities) DescribeActivity(ctx context.Context, input *sfn.DescribeActivityInput) (*sfn.DescribeActivityOutput, error)
  • func (a *Activities) DescribeExecution(ctx context.Context, input *sfn.DescribeExecutionInput) (*sfn.DescribeExecutionOutput, error)
  • func (a *Activities) DescribeStateMachine(ctx context.Context, input *sfn.DescribeStateMachineInput) (*sfn.DescribeStateMachineOutput, error)
  • func (a *Activities) DescribeStateMachineForExecution(ctx context.Context, input *sfn.DescribeStateMachineForExecutionInput) (*sfn.DescribeStateMachineForExecutionOutput, error)
  • func (a *Activities) GetActivityTask(ctx context.Context, input *sfn.GetActivityTaskInput) (*sfn.GetActivityTaskOutput, error)
  • func (a *Activities) GetExecutionHistory(ctx context.Context, input *sfn.GetExecutionHistoryInput) (*sfn.GetExecutionHistoryOutput, error)
  • func (a *Activities) ListActivities(ctx context.Context, input *sfn.ListActivitiesInput) (*sfn.ListActivitiesOutput, error)
  • func (a *Activities) ListExecutions(ctx context.Context, input *sfn.ListExecutionsInput) (*sfn.ListExecutionsOutput, error)
  • func (a *Activities) ListStateMachines(ctx context.Context, input *sfn.ListStateMachinesInput) (*sfn.ListStateMachinesOutput, error)
  • func (a *Activities) ListTagsForResource(ctx context.Context, input *sfn.ListTagsForResourceInput) (*sfn.ListTagsForResourceOutput, error)
  • func (a *Activities) SendTaskFailure(ctx context.Context, input *sfn.SendTaskFailureInput) (*sfn.SendTaskFailureOutput, error)
  • func (a *Activities) SendTaskHeartbeat(ctx context.Context, input *sfn.SendTaskHeartbeatInput) (*sfn.SendTaskHeartbeatOutput, error)
  • func (a *Activities) SendTaskSuccess(ctx context.Context, input *sfn.SendTaskSuccessInput) (*sfn.SendTaskSuccessOutput, error)
  • func (a *Activities) StartExecution(ctx context.Context, input *sfn.StartExecutionInput) (*sfn.StartExecutionOutput, error)
  • func (a *Activities) StartSyncExecution(ctx context.Context, input *sfn.StartSyncExecutionInput) (*sfn.StartSyncExecutionOutput, error)
  • func (a *Activities) StopExecution(ctx context.Context, input *sfn.StopExecutionInput) (*sfn.StopExecutionOutput, error)
  • func (a *Activities) TagResource(ctx context.Context, input *sfn.TagResourceInput) (*sfn.TagResourceOutput, error)
  • func (a *Activities) UntagResource(ctx context.Context, input *sfn.UntagResourceInput) (*sfn.UntagResourceOutput, error)
  • func (a *Activities) UpdateStateMachine(ctx context.Context, input *sfn.UpdateStateMachineInput) (*sfn.UpdateStateMachineOutput, error)
• type SessionFactory

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) CreateActivity

func (a *Activities) CreateActivity(ctx context.Context, input *sfn.CreateActivityInput) (*sfn.CreateActivityOutput, error)

func (*Activities) CreateStateMachine

func (a *Activities) CreateStateMachine(ctx context.Context, input *sfn.CreateStateMachineInput) (*sfn.CreateStateMachineOutput, error)

func (*Activities) DeleteActivity

func (a *Activities) DeleteActivity(ctx context.Context, input *sfn.DeleteActivityInput) (*sfn.DeleteActivityOutput, error)

func (*Activities) DeleteStateMachine

func (a *Activities) DeleteStateMachine(ctx context.Context, input *sfn.DeleteStateMachineInput) (*sfn.DeleteStateMachineOutput, error)

func (*Activities) DescribeActivity

func (a *Activities) DescribeActivity(ctx context.Context, input *sfn.DescribeActivityInput) (*sfn.DescribeActivityOutput, error)

func (*Activities) DescribeExecution

func (a *Activities) DescribeExecution(ctx context.Context, input *sfn.DescribeExecutionInput) (*sfn.DescribeExecutionOutput, error)

func (*Activities) DescribeStateMachine

func (a *Activities) DescribeStateMachine(ctx context.Context, input *sfn.DescribeStateMachineInput) (*sfn.DescribeStateMachineOutput, error)

func (*Activities) DescribeStateMachineForExecution

func (a *Activities) DescribeStateMachineForExecution(ctx context.Context, input *sfn.DescribeStateMachineForExecutionInput) (*sfn.DescribeStateMachineForExecutionOutput, error)

func (*Activities) GetActivityTask

func (a *Activities) GetActivityTask(ctx context.Context, input *sfn.GetActivityTaskInput) (*sfn.GetActivityTaskOutput, error)

func (*Activities) GetExecutionHistory

func (a *Activities) GetExecutionHistory(ctx context.Context, input *sfn.GetExecutionHistoryInput) (*sfn.GetExecutionHistoryOutput, error)

func (*Activities) ListActivities

func (a *Activities) ListActivities(ctx context.Context, input *sfn.ListActivitiesInput) (*sfn.ListActivitiesOutput, error)

func (*Activities) ListExecutions

func (a *Activities) ListExecutions(ctx context.Context, input *sfn.ListExecutionsInput) (*sfn.ListExecutionsOutput, error)

func (*Activities) ListStateMachines

func (a *Activities) ListStateMachines(ctx context.Context, input *sfn.ListStateMachinesInput) (*sfn.ListStateMachinesOutput, error)

func (*Activities) ListTagsForResource

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

func (*Activities) SendTaskFailure

func (a *Activities) SendTaskFailure(ctx context.Context, input *sfn.SendTaskFailureInput) (*sfn.SendTaskFailureOutput, error)

func (*Activities) SendTaskHeartbeat

func (a *Activities) SendTaskHeartbeat(ctx context.Context, input *sfn.SendTaskHeartbeatInput) (*sfn.SendTaskHeartbeatOutput, error)

func (*Activities) SendTaskSuccess

func (a *Activities) SendTaskSuccess(ctx context.Context, input *sfn.SendTaskSuccessInput) (*sfn.SendTaskSuccessOutput, error)

func (*Activities) StartExecution

func (a *Activities) StartExecution(ctx context.Context, input *sfn.StartExecutionInput) (*sfn.StartExecutionOutput, error)

func (*Activities) StartSyncExecution

func (a *Activities) StartSyncExecution(ctx context.Context, input *sfn.StartSyncExecutionInput) (*sfn.StartSyncExecutionOutput, error)

func (*Activities) StopExecution

func (a *Activities) StopExecution(ctx context.Context, input *sfn.StopExecutionInput) (*sfn.StopExecutionOutput, error)

func (*Activities) TagResource

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

func (*Activities) UntagResource

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

func (*Activities) UpdateStateMachine

func (a *Activities) UpdateStateMachine(ctx context.Context, input *sfn.UpdateStateMachineInput) (*sfn.UpdateStateMachineOutput, error)

type SessionFactory

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

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