natsmailproviderevents

Documentation

Index

• type Listener
  • func NewListener(dependencies *mailing.Dependencies, ...) (*Listener, error)
  • func (l *Listener) Start(ctx context.Context) error
  • func (l *Listener) Stop() error
• type Publisher
  • func NewPublisher(dependencies *mailing.Dependencies) (*Publisher, error)
  • func (p *Publisher) PublishCurrentMailingProviderReplaced(ctx context.Context, in *mailingpb.EventCurrentMailingProviderReplaced) error
  • func (p *Publisher) PublishCurrentMailingProviderUpdated(ctx context.Context, in *mailingpb.EventCurrentMailingProviderUpdated) error

Types

type Listener

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

Listener is a mail provider event listener on NATS.

func NewListener

func NewListener(dependencies *mailing.Dependencies, eventHandler mailproviderevents.EventHandler) (*Listener, error)

NewListener creates a new event Listener.

func (*Listener) Start

func (l *Listener) Start(ctx context.Context) error

Start listening for the NATS mail provider events.

func (*Listener) Stop

func (l *Listener) Stop() error

Stop listening for the NATS mail provider events.

type Publisher

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

func NewPublisher

func NewPublisher(dependencies *mailing.Dependencies) (*Publisher, error)

NewPublisher creates a new event Publisher.

func (*Publisher) PublishCurrentMailingProviderReplaced

func (p *Publisher) PublishCurrentMailingProviderReplaced(ctx context.Context, in *mailingpb.EventCurrentMailingProviderReplaced) error

func (*Publisher) PublishCurrentMailingProviderUpdated

func (p *Publisher) PublishCurrentMailingProviderUpdated(ctx context.Context, in *mailingpb.EventCurrentMailingProviderUpdated) error

PublishCurrentMailingProviderUpdated publishes a provider updated event.