Documentation ¶
Index ¶
- func NewStream[Msg any](source stream.Processor[stream.Source, Msg], ...) stream.Stream
- func NewTable[Key comparable, Value any](c ...table.ColumnName) (table.Table[Key, Value], error)
- func NewTableUpdater[Msg any, Key comparable, Value any](t table.Table[Key, Value], k table.KeySelector[Msg, Key], ...) (table.Updater[Msg, Key, Value], error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewStream ¶
func NewStream[Msg any]( source stream.Processor[stream.Source, Msg], rest ...stream.Processor[Msg, Msg], ) stream.Stream
NewStream instantiates a new stream, given a set of Processors
func NewTable ¶
func NewTable[Key comparable, Value any]( c ...table.ColumnName, ) (table.Table[Key, Value], error)
NewTable instantiates a new Table given a set of column names
func NewTableUpdater ¶
func NewTableUpdater[Msg any, Key comparable, Value any]( t table.Table[Key, Value], k table.KeySelector[Msg, Key], c ...table.Column[Msg, Value], ) (table.Updater[Msg, Key, Value], error)
NewTableUpdater instantiates a new table Updater given a Table and a set of Key and Column Selectors
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.