utils

Documentation

Index

• type BackgroundLambdaStep
  • func (l *BackgroundLambdaStep[Input, Output]) Close(ctx context.Context) error
  • func (l *BackgroundLambdaStep[Input, Output]) Start(ctx context.Context, input Input) (*steps.StepResult[Output], error)
• type BackgroundMapLambdaStep
  • func (l *BackgroundMapLambdaStep[Input, Output]) Close(ctx context.Context) error
  • func (l *BackgroundMapLambdaStep[Input, Output]) Start(ctx context.Context, input []Input) (*steps.StepResult[Output], error)
• type LambdaStep
  • func (l *LambdaStep[Input, Output]) Close(ctx context.Context) error
  • func (l *LambdaStep[Input, Output]) Start(ctx context.Context, input Input) (*steps.StepResult[Output], error)
• type MapLambdaStep
  • func (l *MapLambdaStep[Input, Output]) Close(ctx context.Context) error
  • func (l *MapLambdaStep[Input, Output]) Start(ctx context.Context, input []Input) (*steps.StepResult[Output], error)

Types

type BackgroundLambdaStep

type BackgroundLambdaStep[Input any, Output any] struct {
	Function func(context.Context, Input) helpers.Result[Output]
	// contains filtered or unexported fields
}

BackgroundLambdaStep is a struct that wraps a function to be used as a step in a pipeline. The function takes a context and an input, and returns a Result. The function is executed in a separate goroutine.

func (*BackgroundLambdaStep[Input, Output]) Close

func (l *BackgroundLambdaStep[Input, Output]) Close(ctx context.Context) error

func (*BackgroundLambdaStep[Input, Output]) Start

func (l *BackgroundLambdaStep[Input, Output]) Start(ctx context.Context, input Input) (*steps.StepResult[Output], error)

type BackgroundMapLambdaStep

type BackgroundMapLambdaStep[Input any, Output any] struct {
	Function func(context.Context, Input) helpers.Result[Output]
	// contains filtered or unexported fields
}

BackgroundMapLambdaStep is a struct that wraps a function to be used as a step in a pipeline. The function takes a context and an input, and returns a Result. The function is applied to each element of an input slice in a separate goroutine.

func (*BackgroundMapLambdaStep[Input, Output]) Close

func (l *BackgroundMapLambdaStep[Input, Output]) Close(ctx context.Context) error

func (*BackgroundMapLambdaStep[Input, Output]) Start

func (l *BackgroundMapLambdaStep[Input, Output]) Start(ctx context.Context, input []Input) (*steps.StepResult[Output], error)

type LambdaStep

type LambdaStep[Input any, Output any] struct {
	Function func(Input) helpers.Result[Output]
}

LambdaStep is a struct that wraps a function to be used as a step in a pipeline. The function takes an input and returns a Result.

func (*LambdaStep[Input, Output]) Close

func (l *LambdaStep[Input, Output]) Close(ctx context.Context) error

func (*LambdaStep[Input, Output]) Start

func (l *LambdaStep[Input, Output]) Start(ctx context.Context, input Input) (*steps.StepResult[Output], error)

type MapLambdaStep

type MapLambdaStep[Input any, Output any] struct {
	Function func(Input) helpers.Result[Output]
}

MapLambdaStep is a struct that wraps a function to be used as a step in a pipeline. The function takes an input and returns a Result. The function is applied to each element of an input slice.

func (*MapLambdaStep[Input, Output]) Close

func (l *MapLambdaStep[Input, Output]) Close(ctx context.Context) error

func (*MapLambdaStep[Input, Output]) Start

func (l *MapLambdaStep[Input, Output]) Start(ctx context.Context, input []Input) (*steps.StepResult[Output], error)