machine

Nov 14, 2023

Changes in this version

type Option

+ func OptionFlush(gracePeriod time.Duration, flushFN func(vertexName string, payload any)) Option

Nov 12, 2023

Changes in this version

type Option

+ func OptionAttributes(attributes ...slog.Attr) Option

Nov 9, 2023

Changes in this version

+ func DebugSlogHandler(handler slog.Handler)

+ type Edge interface

+ Output func() chan T

+ Send func(data T)

+ type Filter func(d T) bool

+ type Machine interface

+ And func(x ...Filter[T]) (Machine[T], Machine[T])

+ Distribute func(Edge[T]) Machine[T]

+ Drop func()

+ If func(f Filter[T]) (Machine[T], Machine[T])

+ Memoize func(x Monad[Monad[T]], index func(T) string) Machine[T]

+ Name func() string

+ Or func(x ...Filter[T]) (Machine[T], Machine[T])

+ Output func() chan T

+ Recurse func(x Monad[Monad[T]]) Machine[T]

+ Select func(fns ...Filter[T]) []Machine[T]

+ Tee func(func(T) (a, b T)) (Machine[T], Machine[T])

+ Then func(a Monad[T]) Machine[T]

+ While func(x Filter[T]) (loop, out Machine[T])

+ func New[T any](name string, input chan T, options ...Option) (startFn func(context.Context), x Machine[T])

+ func Transform[T, U any](m Machine[T], fn func(d T) U) (Machine[U], error)

+ type Monad func(d T) T

+ type Option interface

+ var OptionDebug Option = &option{ ... }

+ var OptionFIF0 Option = &option{ ... }

+ func OptionBufferSize(size int) Option