Versions in this module Expand all Collapse all v8 v8.0.9 Jun 22, 2022 v8.0.0 Jun 22, 2022 Changes in this version + type Joiner interface + Join func(unmixed []byte, pid int) error + ValidateUnmixed func(unmixed []byte, mcount int) 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) SetMinPeers(min int) + func (s *Server) SetReportEncoder(enc *json.Encoder) + type Shuffler interface + Shuffle func()