sfn

package

v0.0.0-...-c92edef Latest Latest Go to latest Published: May 19, 2022 License: Apache-2.0 Imports: 14 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/jordipuigbou/step-functions-test

Links

Open Source Insights

Documentation ¶

Index ¶

func InitializeContext(ctx context.Context) context.Context
type ConsumedCapacity
type ContextKey
type Logger
- func GetLogger() *Logger
- func NewLogger(logsPath string) (*Logger, error)
- func (l Logger) LogMessage(message string)
type Session
- func GetSession(ctx context.Context) *Session
type Steps
- func (s Steps) InitializeSteps(ctx context.Context, scenCtx *godog.ScenarioContext) context.Context

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func InitializeContext ¶

func InitializeContext(ctx context.Context) context.Context

Types ¶

type ConsumedCapacity ¶

type ConsumedCapacity struct {
	TableName     string  `json:"TableName"`
	CapacityUnits float64 `json:"CapacityUnits"`
}

type ContextKey ¶

type ContextKey string

ContextKey defines a type to store the integration HTTP session in context.Context.

type Logger ¶

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

Logger logs the sfn operations in a configurable file.

func GetLogger ¶

func GetLogger() *Logger

GetLogger returns the logger for sfn operations. If the logger is not created yet, it creates a new instance of Logger.

func NewLogger ¶

func NewLogger(logsPath string) (*Logger, error)

NewLogger creates an instance of the logger. It configures the file path where the sfn operations are logged.

func (Logger) LogMessage ¶

func (l Logger) LogMessage(message string)

Log a sfn message

type Session ¶

type Session struct {
	AwsSession *aws_s.Session
	// contains filtered or unexported fields
}

func GetSession ¶

func GetSession(ctx context.Context) *Session

GetSession returns the integration HTTP session stored in context. Note that the context should be previously initialized with InitializeContext function.

func (*Session) CreateStepFunctionMachine ¶

func (s *Session) CreateStepFunctionMachine(
	ctx context.Context, sfnStateMachineName, sfnDefinition string,
) error

func (*Session) DeleteSfnStateMachine ¶

func (s *Session) DeleteSfnStateMachine() error

func (*Session) DescribeSfnStateExecution ¶

func (s *Session) DescribeSfnStateExecution(ctx context.Context, key string) error

func (*Session) SetAwsSfnClient ¶

func (s *Session) SetAwsSfnClient()

func (*Session) StartSfnExecution ¶

func (s *Session) StartSfnExecution(executionName string) error

func (*Session) ValidateSfnOutput ¶

func (s *Session) ValidateSfnOutput(ctx context.Context, key, expectedOutput string) error

type Steps ¶

type Steps struct {
}

func (Steps) InitializeSteps ¶

func (s Steps) InitializeSteps(
	ctx context.Context,
	scenCtx *godog.ScenarioContext,
) context.Context

Source Files ¶

View all Source files

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