replica

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)