internal

Documentation

Index

• func ErrDataTypes(id component.ID, from, to pipeline.Signal) error
• type BaseRouter
  • func NewBaseRouter[T any](fanout func([]T) T, cm map[pipeline.ID]T) BaseRouter[T]
  • func (r *BaseRouter[T]) Consumer(pipelineIDs ...pipeline.ID) (T, error)
  • func (r *BaseRouter[T]) PipelineIDs() []pipeline.ID

Functions

func ErrDataTypes

func ErrDataTypes(id component.ID, from, to pipeline.Signal) error

Types

type BaseRouter

type BaseRouter[T any] struct {
	Consumers map[pipeline.ID]T
	// contains filtered or unexported fields
}

func NewBaseRouter

func NewBaseRouter[T any](fanout func([]T) T, cm map[pipeline.ID]T) BaseRouter[T]

func (*BaseRouter[T]) Consumer

func (r *BaseRouter[T]) Consumer(pipelineIDs ...pipeline.ID) (T, error)

func (*BaseRouter[T]) PipelineIDs

func (r *BaseRouter[T]) PipelineIDs() []pipeline.ID