Versions in this module Expand all Collapse all v0 v0.2.1 Jan 29, 2020 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 + func (s *Server) SetReportEncoder(enc *json.Encoder) + type Shuffler interface + Shuffle func()
Go to main page