rpc

Dec 26, 2020

Changes in this version

+ var ErrEngineClosed = xerrors.New("engine was closed")

type Engine

+ func (e *Engine) Close()

Dec 23, 2020

Changes in this version

+ type Clock interface

+ After func(d time.Duration) <-chan time.Time

type Config

+ Clock Clock

+ type RetryLimitReachedErr struct

+ Retries int

+ func (r *RetryLimitReachedErr) Error() string

+ func (r *RetryLimitReachedErr) Is(err error) bool

Dec 22, 2020

Changes in this version

+ func NopSend(ctx context.Context, msgID int64, seqNo int32, in bin.Encoder) error

+ type Config struct

+ Logger *zap.Logger

+ MaxRetries int

+ RetryInterval time.Duration

+ type Engine struct

+ func New(send Send, cfg Config) *Engine

+ func (e *Engine) Do(ctx context.Context, req Request) error

+ func (e *Engine) NotifyAcks(ids []int64)

+ func (e *Engine) NotifyError(msgID int64, rpcErr error)

+ func (e *Engine) NotifyResult(msgID int64, b *bin.Buffer) error

+ type Request struct

+ ID int64

+ Input bin.Encoder

+ Output bin.Decoder

+ Sequence int32

+ type Send func(ctx context.Context, msgID int64, seqNo int32, in bin.Encoder) error