leadercast

Mar 30, 2022

Changes in this version

+ func NewMemTransportFunc(ctx context.Context) func() Transport

+ type LeaderCast struct

+ func New(transport Transport, peerIdx, peers int) *LeaderCast

+ func (l *LeaderCast) Propose(ctx context.Context, duty core.Duty, data core.UnsignedDataSet) error

+ func (l *LeaderCast) Run(ctx context.Context) error

+ func (l *LeaderCast) Subscribe(fn func(ctx context.Context, duty core.Duty, set core.UnsignedDataSet) error)

+ type Transport interface

+ AwaitNext func(ctx context.Context) (fromIdx int, d core.Duty, data core.UnsignedDataSet, err error)

+ Broadcast func(ctx context.Context, fromIdx int, d core.Duty, data core.UnsignedDataSet) error

+ func NewP2PTransport(tcpNode host.Host, peerIDx int, peers []peer.ID) Transport