server

Nov 5, 2019

Changes in this version

type Server

+ func (s *Server) SetReportEncoder(enc *json.Encoder)

Aug 28, 2019

Changes in this version

+ type Joiner interface

+ Join func(unmixed []byte, pid int) error

+ ValidateUnmixed func(unmixed []byte) error

+ type Mixer interface

+ Confirm func(confirm interface{}, pid int) error

+ Mix func(m []byte)

+ type NewMixer func(desc []byte) (Mixer, error)

+ type PublishMixer interface

+ PublishMix func(ctx context.Context) error

+ type Server struct

+ func New(msize int, newm NewMixer, epoch time.Duration) (*Server, error)

+ func (s *Server) Run(ctx context.Context, lis net.Listener) error

+ type Shuffler interface

+ Shuffle func()