pipeline

package
v1.0.10 Latest Latest
Warning

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

Go to latest
Published: Aug 8, 2022 License: MIT Imports: 2 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Pipeline

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

func New

func New[T any]() *Pipeline[T]

func (*Pipeline[T]) Run

func (t *Pipeline[T]) Run(in T) (T, error)

func (*Pipeline[T]) Step

func (t *Pipeline[T]) Step(fn StepFn[T]) *Pipeline[T]

type PipelineTry

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

func NewTry

func NewTry[T any]() *PipelineTry[T]

func (*PipelineTry[T]) Run

func (t *PipelineTry[T]) Run(in T) trier.Try[T]

func (*PipelineTry[T]) Step

func (t *PipelineTry[T]) Step(fn StepTryFn[T]) *PipelineTry[T]

type StepFn

type StepFn[T any] func(T) (T, error)

type StepTryFn

type StepTryFn[T any] func(T) trier.Try[T]

Jump to

Keyboard shortcuts

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