Versions in this module Expand all Collapse all v0 v0.0.3 Mar 23, 2021 v0.0.2 Mar 23, 2021 Changes in this version + type ConveyorBelt struct + Ctx context.Context + DataDomain interface{} + LogInfoGen func(*ConveyorBelt) string + Logger log.Logger + S *Streamline + func NewConveyorBelt(s *Streamline, c context.Context, dataDomainRef interface{}, ...) *ConveyorBelt + func (c *ConveyorBelt) Debugw(args ...interface{}) + func (c *ConveyorBelt) Errorw(args ...interface{}) + func (c *ConveyorBelt) Infow(args ...interface{}) + func (c *ConveyorBelt) Run() (int, error) + func (c *ConveyorBelt) Warnw(args ...interface{}) + type Factory struct + func New() *Factory + func (f *Factory) Get(name string) *Streamline + func (f *Factory) GetAllStreamlines() map[string]*Streamline + func (f *Factory) NewStreamline(name, action, resource string) *Streamline + func (f *Factory) Plot() string + type Proc struct + F ProcFunc + Name string + type ProcFunc func(*ConveyorBelt) int + type Streamline struct + Action string + Name string + Resource string + Tags []string + func (s *Streamline) Add(procName string, f ProcFunc) + func (s *Streamline) AddTag(tag string) + func (s *Streamline) Describe() []string + func (s *Streamline) Insert(target string, procName string, f ProcFunc, insertBefore bool) error + func (s *Streamline) InsertFront(procName string, f ProcFunc) error