network

Documentation

Index

• func New(cc types.ConnectionConfig, logger log.Logger, statshub types.StatsHub, ...) (types.NetworkClient, error)
• func NewPending(shards int, defaultCapacity int) *pending

Functions

func New

func New(cc types.ConnectionConfig, logger log.Logger, statshub types.StatsHub, requestSignalsFromFileQueue chan types.RequestMoreSignals[types.Datum]) (types.NetworkClient, error)

func NewPending

func NewPending(shards int, defaultCapacity int) *pending