Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type FullnessSynchronizer ¶
type FullnessSynchronizer struct {
// contains filtered or unexported fields
}
func NewFullnessSynchronizer ¶
func NewFullnessSynchronizer(items, depth int) *FullnessSynchronizer
NewFullnessSynchronizer creates a synchronizer that emits data on fullness
type IntervalSynchronizer ¶
type IntervalSynchronizer struct {
// contains filtered or unexported fields
}
func NewIntervalSynchronizer ¶
func NewIntervalSynchronizer(items, depth int, interval time.Duration) *IntervalSynchronizer
NewIntervalSynchronizer creates a synchronizer that emits data after elapsed interval unless it is empty
type Node ¶
type Node[T any] struct { // contains filtered or unexported fields }
func (*Node[T]) Connect ¶
func (n *Node[T]) Connect(in ...graco.SourceEdge[T]) (graco.SourceEdge[[]T], error)
type PairMakerFunc ¶
type PairNode ¶
type PairNode[A, B, Res any] struct { // contains filtered or unexported fields }
func NewPair ¶
func NewPair[A, B, Res any](name string, make PairMakerFunc[A, B, Res]) *PairNode[A, B, Res]
func (*PairNode[A, B, Res]) Connect ¶
func (n *PairNode[A, B, Res]) Connect(a graco.SourceEdge[A], b graco.SourceEdge[B]) (graco.SourceEdge[Res], error)
type SynchronizerBuilder ¶
type SynchronizerBuilder func(items int) (Synchronizer, error)
type TimestampSynchronizer ¶
type TimestampSynchronizer struct {
// contains filtered or unexported fields
}
func NewTimestampSynchronizer ¶
func NewTimestampSynchronizer(items, depth int, delta time.Duration) *TimestampSynchronizer
type TripletMakerFunc ¶
type TripletNode ¶
type TripletNode[A, B, C, Res any] struct { // contains filtered or unexported fields }
func NewTriplet ¶
func NewTriplet[A, B, C, Res any](name string, make TripletMakerFunc[A, B, C, Res]) *TripletNode[A, B, C, Res]
func (*TripletNode[A, B, C, Res]) Close ¶
func (n *TripletNode[A, B, C, Res]) Close() error
func (*TripletNode[A, B, C, Res]) Connect ¶
func (n *TripletNode[A, B, C, Res]) Connect(a graco.SourceEdge[A], b graco.SourceEdge[B]) (graco.SourceEdge[Res], error)
func (*TripletNode[A, B, C, Res]) Name ¶
func (n *TripletNode[A, B, C, Res]) Name() string
type WithTimestamp ¶
Click to show internal directories.
Click to hide internal directories.