once

Documentation

Index

• type Checker
• type PublisherWrapper
  • func MewPublisherWrapper(pub nc.Publisher, checker Checker) *PublisherWrapper
  • func (wr *PublisherWrapper) Close() error
  • func (wr *PublisherWrapper) Publish(ctx context.Context, messages ...any) error

Types

type Checker

type Checker interface {
	IsSkip(msg any) bool
	MarkAsSent(msg any) error
}

Checker provides test interface of messages

type PublisherWrapper

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

PublisherWrapper provides additional check before send message to the stream

func MewPublisherWrapper

func MewPublisherWrapper(pub nc.Publisher, checker Checker) *PublisherWrapper

MewPublisherWrapper with checker

func (*PublisherWrapper) Close

func (wr *PublisherWrapper) Close() error

Close publisher if supported

func (*PublisherWrapper) Publish

func (wr *PublisherWrapper) Publish(ctx context.Context, messages ...any) error

Publish one or more messages to the pub-service if will pass conditions