modules

Jan 13, 2024

Changes in this version

type BaseModule

+ func (m *BaseModule) CreateInputWithCapacity(name string, cap int)

type Input

+ func NewInputWithCapacity(name string, cap int) *Input

Sep 14, 2023

Changes in this version

type BaseModule

+ func (m *BaseModule) MustInput(name string) *Input

+ func (m *BaseModule) MustOutput(name string) *Output

type Module

+ MustInput func(name string) *Input

+ MustOutput func(name string) *Output

Sep 13, 2023

Changes in this version

+ type BaseModule struct

+ G workerpool.Group

+ Log zerolog.Logger

+ func New(name string) BaseModule

+ func (*BaseModule) Close() error

+ func (*BaseModule) Start(_ context.Context)

+ func (m *BaseModule) AttachTo(outputModule Module, outputName, inputName string) error

+ func (m *BaseModule) CreateInput(name string)

+ func (m *BaseModule) CreateOutput(name string)

+ func (m *BaseModule) Input(name string) (*Input, error)

+ func (m *BaseModule) Name() string

+ func (m *BaseModule) Output(name string) (*Output, error)

Aug 24, 2023

Changes in this version

+ var ErrUnknownInput = errors.New("unknown input")

+ var ErrUnknownModule = errors.New("unknown module")

+ var ErrUnknownOutput = errors.New("unknown output")

+ func Connect(outputModule, inputModule Module, outputName, inputName string) error

+ type Input struct

+ func NewInput(name string) *Input

+ func (input *Input) Close() error

+ func (input *Input) Listen() <-chan any

+ func (input *Input) Name() string

+ func (input *Input) Push(msg any)

+ type Module interface

+ AttachTo func(outputName string, input *Input) error

+ Input func(name string) (*Input, error)

+ Name func() string

+ Output func(name string) (*Output, error)

+ Start func(ctx context.Context)

+ type Output struct

+ func NewOutput(name string) *Output

+ func (output *Output) Attach(input *Input)

+ func (output *Output) ConnectedInputs() []*Input

+ func (output *Output) Name() string

+ func (output *Output) Push(msg any)

+ type Workflow struct

+ func NewWorkflow(modules ...Module) *Workflow

+ func (wf *Workflow) Add(module Module) error

+ func (wf *Workflow) AddWithName(module Module, name string) error

+ func (wf *Workflow) Connect(srcModule, srcOutput, destModule, destInput string) error

+ func (wf *Workflow) Get(name string) (Module, error)

+ func (wf *Workflow) Start(ctx context.Context)