nats

Sep 4, 2023

Changes in this version

type Subscriber

+ func (s *Subscriber) Positions(ctx context.Context) (map[uint32]projection.SubscriberPosition, error)

+ func (s *Subscriber) TopicPartitions() (string, []uint32)

Jul 25, 2023

Changes in this version

type Subscriber

+ func NewSubscriberWithConn(logger log.Logger, nc *nats.Conn, topic string) (*Subscriber, error)

+ func NewSubscriberWithURL(ctx context.Context, logger log.Logger, url string, topic string) (*Subscriber, error)

+ func (s *Subscriber) Topic() util.Topic

Jul 2, 2023

Changes in this version

+ func NewProjector(ctx context.Context, logger log.Logger, url string, ...) (*worker.RunWorker, error)

+ func NewProjectorWithConn(ctx context.Context, logger log.Logger, nc *nats.Conn, ...) (*worker.RunWorker, error)

+ type SubOption func(*Subscriber)

+ func WithMsgCodec(codec sink.Codec) SubOption

+ type Subscriber struct

+ func NewSubscriber(logger log.Logger, jetStream nats.JetStreamContext, ...) *Subscriber

+ func (s *Subscriber) ResumeKey() projection.ResumeKey

+ func (s *Subscriber) RetrieveLastSequence(ctx context.Context) (uint64, error)

+ func (s *Subscriber) SaveLastSequence(ctx context.Context, token uint64) error

+ func (s *Subscriber) StartConsumer(ctx context.Context, handler projection.MessageHandlerFunc, ...) error

+ func (s *Subscriber) StopConsumer(ctx context.Context)