nats

Documentation

Index

• 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 WithMsgCodec(codec sink.Codec) SubOption
• type Subscriber
  • 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)

Functions

func NewProjector

func NewProjector(
	ctx context.Context,
	logger log.Logger,
	url string,
	lockerFactory projection.LockerFactory,
	catchUpLockerFactory projection.WaitLockerFactory,
	resumeStore projection.ResumeStore,
	resumeKey projection.ResumeKey,
	projectionName string,
	topic string,
	esRepo projection.Repository,
	handler projection.MessageHandlerFunc,
	options projection.ProjectorOptions,
) (*worker.RunWorker, error)

func NewProjectorWithConn

func NewProjectorWithConn(
	ctx context.Context,
	logger log.Logger,
	nc *nats.Conn,
	lockerFactory projection.LockerFactory,
	catchUpLockerFactory projection.WaitLockerFactory,
	resumeStore projection.ResumeStore,
	resumeKey projection.ResumeKey,
	projectionName string,
	topic string,
	esRepo projection.Repository,
	handler projection.MessageHandlerFunc,
	options projection.ProjectorOptions,
) (*worker.RunWorker, error)

Types

type SubOption

type SubOption func(*Subscriber)

func WithMsgCodec

func WithMsgCodec(codec sink.Codec) SubOption

type Subscriber

type Subscriber struct {
	// contains filtered or unexported fields
}

func NewSubscriber

func NewSubscriber(
	logger log.Logger,
	jetStream nats.JetStreamContext,
	resumeStore projection.ResumeStore,
	resumeKey projection.ResumeKey,
	options ...SubOption,
) *Subscriber

func (*Subscriber) ResumeKey

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

func (*Subscriber) RetrieveLastSequence

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

func (*Subscriber) SaveLastSequence

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

func (*Subscriber) StartConsumer

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

func (*Subscriber) StopConsumer

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