execution

Documentation

Index

• func GetDetails(sfnc sfniface.SFNAPI, executionArn *string) (*Execution, *StateDetails, error)
• type Execution
  • func ExecutionsAfter(sfnc aws.SFNAPI, arn *string, status *string, afterTime time.Time) ([]*Execution, error)
  • func FindExecution(sfnc sfniface.SFNAPI, arn *string, name_prefix string) (*Execution, error)
  • func StartExecution(sfnc sfniface.SFNAPI, arn *string, name *string, input interface{}) (*Execution, error)
  • func StartExecutionRaw(sfnc sfniface.SFNAPI, arn *string, name *string, input_json *string) (*Execution, error)
  • func (e *Execution) GetStateDetails(sfnc sfniface.SFNAPI) (*StateDetails, error)
  • func (e *Execution) WaitForExecution(sfnc sfniface.SFNAPI, sleep int, fn ExecutionWaiter)
• type ExecutionWaiter
• type StateDetails

Functions

func GetDetails

func GetDetails(sfnc sfniface.SFNAPI, executionArn *string) (*Execution, *StateDetails, error)

Types

type Execution

type Execution struct {
	ExecutionArn    *string
	Input           *string
	Name            *string
	Output          *string
	StartDate       *time.Time
	StateMachineArn *string
	Status          *string
	StopDate        *time.Time
}

func ExecutionsAfter

func ExecutionsAfter(sfnc aws.SFNAPI, arn *string, status *string, afterTime time.Time) ([]*Execution, error)

executions lists executions with an option to filter

func FindExecution

func FindExecution(sfnc sfniface.SFNAPI, arn *string, name_prefix string) (*Execution, error)

func StartExecution

func StartExecution(sfnc sfniface.SFNAPI, arn *string, name *string, input interface{}) (*Execution, error)

func StartExecutionRaw

func StartExecutionRaw(sfnc sfniface.SFNAPI, arn *string, name *string, input_json *string) (*Execution, error)

func (*Execution) GetStateDetails

func (e *Execution) GetStateDetails(sfnc sfniface.SFNAPI) (*StateDetails, error)

func (*Execution) WaitForExecution

func (e *Execution) WaitForExecution(sfnc sfniface.SFNAPI, sleep int, fn ExecutionWaiter)

WaitForExecution allows another application to wait for the execution to finish and process output as it comes in for usability

type ExecutionWaiter

type ExecutionWaiter func(*Execution, *StateDetails, error) error

type StateDetails

type StateDetails struct {
	LastStateName *string
	LastTaskName  *string
	LastOutput    *string
	Timestamp     *time.Time
}