execution

package
v1.1.1 Latest Latest
Warning

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

Go to latest
Published: Oct 7, 2020 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

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
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL