publisher

Documentation

Index

• func LogPublish(logger log.Logger, event interface{}, subjects []string, err error)
• func ResourceTypeToUUID(resourceType string) string
• type FlusherTimeoutOpt
  • func WithFlusherTimeout(flusherTimeout time.Duration) FlusherTimeoutOpt
• type LeadResourceTypeOpt
  • func WithLeadResourceType(regexFilter []*regexp.Regexp, filter client.LeadResourceTypeFilter, ...) LeadResourceTypeOpt
• 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) GetLeadResourceType(event eventbus.Event) string
  • func (p *Publisher) GetPublishSubject(owner string, event eventbus.Event) []string
  • 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)

func ResourceTypeToUUID

func ResourceTypeToUUID(resourceType string) string

Types

type FlusherTimeoutOpt

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

func WithFlusherTimeout

func WithFlusherTimeout(flusherTimeout time.Duration) FlusherTimeoutOpt

type LeadResourceTypeOpt

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

func WithLeadResourceType

func WithLeadResourceType(regexFilter []*regexp.Regexp, filter client.LeadResourceTypeFilter, useUUID bool) LeadResourceTypeOpt

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) GetLeadResourceType

func (p *Publisher) GetLeadResourceType(event eventbus.Event) string

func (*Publisher) GetPublishSubject

func (p *Publisher) GetPublishSubject(owner string, event eventbus.Event) []string

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