replicator

Jun 13, 2022

Changes in this version

+ type Limiter interface

+ ProcessAndRecord func(msg *nats.Msg, f func(msg *nats.Msg, process bool) error) error

+ Tracker func() *idtrack.Tracker

+ type Stream struct

+ func NewStream(stream *config.Stream, sr *config.Config, log *logrus.Entry) (*Stream, error)

+ func (s *Stream) Run(ctx context.Context, wg *sync.WaitGroup) error

+ type Target struct

+ func (t *Target) Close() error