Versions in this module Expand all Collapse all v0 v0.2.3 Jan 15, 2016 v0.2.2 Jan 12, 2016 Changes in this version + type FanoutMode int + const Parallel + const SerialBalanced + const SerialSequential + type Options struct + FanoutMode FanoutMode + NValue int + RValue int + WValue int + type Replicator struct + func NewReplicator(s Sender, channel shared.SubChannel, logger log.Logger, opts *Options) *Replicator + func (r *Replicator) Read(keys []string, request []byte, operation string, fopts *forward.Options, ...) (responses []Response, err error) + func (r *Replicator) Write(keys []string, request []byte, operation string, fopts *forward.Options, ...) (responses []Response, err error) + type Response struct + Body []byte + Destination string + Keys []string + type Sender interface + Lookup func(string) (string, error) + LookupN func(string, int) ([]string, error) + WhoAmI func() (string, error)
Go to main page