pipeline

Documentation

Index

• type Pipeline
  • func New[T any]() *Pipeline[T]
  • func (t *Pipeline[T]) Append(fn StepFn[T]) *Pipeline[T]
  • func (t *Pipeline[T]) Prepend(fn StepFn[T]) *Pipeline[T]
  • func (t *Pipeline[T]) RunList(items []T) []T
  • func (t *Pipeline[T]) RunSingle(item T) T
• type PipelineTry
  • func NewTry[T any]() *PipelineTry[T]
  • func (t *PipelineTry[T]) Append(fn StepWithErrFn[T]) *PipelineTry[T]
  • func (t *PipelineTry[T]) Prepend(fn StepWithErrFn[T]) *PipelineTry[T]
  • func (t *PipelineTry[T]) Run(in T) trier.Try[T]
• type PipelineWithErr
  • func NewWithError[T any]() *PipelineWithErr[T]
  • func (t *PipelineWithErr[T]) Append(fn StepWithErrFn[T]) *PipelineWithErr[T]
  • func (t *PipelineWithErr[T]) Prepend(fn StepWithErrFn[T]) *PipelineWithErr[T]
  • func (t *PipelineWithErr[T]) Run(in T) (T, error)
• type StepFn
  • func StringRemover[T ~string](remove string) StepFn[T]
• type StepWithErrFn
  • func SimpleStep[T any](fn func(T) T) StepWithErrFn[T]

Types

type Pipeline

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

func New

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

func (*Pipeline[T]) Append

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

func (*Pipeline[T]) Prepend

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

func (*Pipeline[T]) RunList

func (t *Pipeline[T]) RunList(items []T) []T

func (*Pipeline[T]) RunSingle

func (t *Pipeline[T]) RunSingle(item T) T

type PipelineTry

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

func NewTry

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

func (*PipelineTry[T]) Append

func (t *PipelineTry[T]) Append(fn StepWithErrFn[T]) *PipelineTry[T]

func (*PipelineTry[T]) Prepend

func (t *PipelineTry[T]) Prepend(fn StepWithErrFn[T]) *PipelineTry[T]

func (*PipelineTry[T]) Run

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

type PipelineWithErr

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

func NewWithError

func NewWithError[T any]() *PipelineWithErr[T]

func (*PipelineWithErr[T]) Append

func (t *PipelineWithErr[T]) Append(fn StepWithErrFn[T]) *PipelineWithErr[T]

func (*PipelineWithErr[T]) Prepend

func (t *PipelineWithErr[T]) Prepend(fn StepWithErrFn[T]) *PipelineWithErr[T]

func (*PipelineWithErr[T]) Run

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

type StepFn

type StepFn[T any] func(T) T

func StringRemover

func StringRemover[T ~string](remove string) StepFn[T]

type StepWithErrFn

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

func SimpleStep

func SimpleStep[T any](fn func(T) T) StepWithErrFn[T]