dispatcher

Feb 11, 2022

Changes in this version

+ var ErrBadResponse = errors.New("bad response")

+ var ErrDestUnknown = errors.New("destination unknown")

+ var ErrDuplicateDispatch = errors.New("message already dispatched")

+ var ErrFailedMarshal = errors.New("failed to marshal data")

+ var ErrResponseReadFail = errors.New("failed to read response")

+ var ErrSendFailed = errors.New("sending failed")

+ type Dispatcher struct

+ Replicas *types.ReplicaStore

+ func NewDispatcher(ctx *context.RootContext) *Dispatcher

+ func (d *Dispatcher) DispatchMessage(msg *types.Message) error

+ func (d *Dispatcher) DispatchTimeout(t *types.ReplicaTimeout) error

+ func (d *Dispatcher) RestartAll() error

+ func (d *Dispatcher) RestartReplica(replica types.ReplicaID) error

+ func (d *Dispatcher) StartReplica(replica types.ReplicaID) error

+ func (d *Dispatcher) StopReplica(replica types.ReplicaID) error