Versions in this module Expand all Collapse all v1 v1.32.0 Mar 21, 2022 v1.30.0 Mar 20, 2022 Changes in this version + type AlertFunc func(missed int) + func (f AlertFunc) Alert(missed int) + type Alerter interface + Alert func(missed int) + type Diode interface + Set func(GenericDataType) + TryNext func() (GenericDataType, bool) + type GenericDataType unsafe.Pointer + type ManyToOne struct + func NewManyToOne(size int, alerter Alerter) *ManyToOne + func (d *ManyToOne) Set(data GenericDataType) + func (d *ManyToOne) TryNext() (data GenericDataType, ok bool) + type OneToOne struct + func NewOneToOne(size int, alerter Alerter) *OneToOne + func (d *OneToOne) Set(data GenericDataType) + func (d *OneToOne) TryNext() (data GenericDataType, ok bool) + type Poller struct + func NewPoller(d Diode, opts ...PollerConfigOption) *Poller + func (p *Poller) Next() GenericDataType + type PollerConfigOption func(*Poller) + func WithPollingContext(ctx context.Context) PollerConfigOption + func WithPollingInterval(interval time.Duration) PollerConfigOption + type Waiter struct + func NewWaiter(d Diode, opts ...WaiterConfigOption) *Waiter + func (w *Waiter) Next() GenericDataType + func (w *Waiter) Set(data GenericDataType) + type WaiterConfigOption func(*Waiter) + func WithWaiterContext(ctx context.Context) WaiterConfigOption
Go to main page