steps

Documentation

Index

• Variables
• type Step
• type StepResult
  • func Bind[T any, U any](ctx context.Context, m *StepResult[T], step Step[T, U]) *StepResult[U]
  • func NewStepResult[T any](value <-chan helpers.Result[T]) *StepResult[T]
  • func Reject[T any](err error) *StepResult[T]
  • func Resolve[T any](value T) *StepResult[T]
  • func ResolveNone[T any]() *StepResult[T]
  • func (m *StepResult[T]) GetChannel() <-chan helpers.Result[T]
  • func (m *StepResult[T]) Return() []helpers.Result[T]

Variables

var ErrMissingClientAPIKey = errors.Newf("missing client settings api key")

var ErrMissingClientSettings = errors.Newf("missing client settings")

Types

type Step

type Step[T any, U any] interface {
	// Start gets called multiple times for the same Step, once per incoming value,
	// since StepResult is also the list monad (ie., supports multiple values)
	Start(ctx context.Context, input T) (*StepResult[U], error)
	Close(ctx context.Context) error
}

Step is the generalization of a lambda function, with cancellation and closing to allow it to own resources.

type StepResult

type StepResult[T any] struct {
	// contains filtered or unexported fields
}

func Bind

func Bind[T any, U any](
	ctx context.Context,
	m *StepResult[T],
	step Step[T, U],
) *StepResult[U]

Bind is the monadic bind operator for StepResult. It takes a step result, a step (which is just a lambda turned into a struct) iterates over the results in the StepResult, and starts the Step for each value.

func NewStepResult

func NewStepResult[T any](value <-chan helpers.Result[T]) *StepResult[T]

func Reject

func Reject[T any](err error) *StepResult[T]

func Resolve

func Resolve[T any](value T) *StepResult[T]

func ResolveNone

func ResolveNone[T any]() *StepResult[T]

func (*StepResult[T]) GetChannel

func (m *StepResult[T]) GetChannel() <-chan helpers.Result[T]

func (*StepResult[T]) Return

func (m *StepResult[T]) Return() []helpers.Result[T]