publisher

Documentation

Index

• func LogPublish(logger log.Logger, event interface{}, subjects []string, err error)
• type FlusherTimeoutOpt
  • func WithFlusherTimeout(flusherTimeout time.Duration) FlusherTimeoutOpt
• type MarshalerFunc
• type MarshalerOpt
  • func WithMarshaler(dataMarshaler MarshalerFunc) MarshalerOpt
• type Option
• type Publisher
  • func New(conn *nats.Conn, jetstream bool, opts ...Option) (*Publisher, error)
  • func (p *Publisher) AddCloseFunc(f func())
  • func (p *Publisher) Close()
  • func (p *Publisher) Flush(ctx context.Context) error
  • func (p *Publisher) Publish(ctx context.Context, topics []string, groupID, aggregateID string, ...) error
  • func (p *Publisher) PublishData(subj string, data []byte) error

Functions

func LogPublish

func LogPublish(logger log.Logger, event interface{}, subjects []string, err error)

Types

type FlusherTimeoutOpt

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

func WithFlusherTimeout

func WithFlusherTimeout(flusherTimeout time.Duration) FlusherTimeoutOpt

type MarshalerFunc

type MarshalerFunc = func(v interface{}) ([]byte, error)

MarshalerFunc marshal struct to bytes.

type MarshalerOpt

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

func WithMarshaler

func WithMarshaler(dataMarshaler MarshalerFunc) MarshalerOpt

type Option

type Option interface {
	// contains filtered or unexported methods
}

type Publisher

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

Publisher implements a eventbus.Publisher interface.

func New

func New(conn *nats.Conn, jetstream bool, opts ...Option) (*Publisher, error)

Create publisher with existing NATS connection and proto marshaller

func (*Publisher) AddCloseFunc

func (p *Publisher) AddCloseFunc(f func())

func (*Publisher) Close

func (p *Publisher) Close()

func (*Publisher) Flush

func (p *Publisher) Flush(ctx context.Context) error

func (*Publisher) Publish

func (p *Publisher) Publish(ctx context.Context, topics []string, groupID, aggregateID string, event eventbus.Event) error

Publish publishes an event to topics.

func (*Publisher) PublishData

func (p *Publisher) PublishData(subj string, data []byte) error