bus

Documentation

Index

• Constants
• type Bus
  • func New() (Bus, error)
  • func (b Bus) EnvelopeCreated(ctx context.Context, id int64)
  • func (b Bus) EnvelopeDeleted(ctx context.Context)
  • func (b Bus) MailmanEnqueued(ctx context.Context)
  • func (b Bus) OnEnvelopeCreated(h func(ctx context.Context, evt models.EventEnvelopeCreated) error) func()
  • func (b Bus) OnEnvelopeDeleted(h func(ctx context.Context, evt models.EventEnvelopeDeleted) error) func()
  • func (b Bus) OnMailmanEnqueued(h func(ctx context.Context, evt models.EventMailmanEnqueued) error) func()

Constants

const (
	TopicEnvelopeCreated = "envelope.created"
	TopicEnvelopeDeleted = "envelope.deleted"
	TopicMailmanEnqueued = "mailman.enqueued"
)

Types

type Bus

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

func New

func New() (Bus, error)

func (Bus) EnvelopeCreated

func (b Bus) EnvelopeCreated(ctx context.Context, id int64)

EnvelopeCreated implements core.Bus.

func (Bus) EnvelopeDeleted

func (b Bus) EnvelopeDeleted(ctx context.Context)

EnvelopeDeleted implements core.Bus.

func (Bus) MailmanEnqueued

func (b Bus) MailmanEnqueued(ctx context.Context)

MailmanEnqueued implements core.Bus.

func (Bus) OnEnvelopeCreated

func (b Bus) OnEnvelopeCreated(h func(ctx context.Context, evt models.EventEnvelopeCreated) error) func()

OnEnvelopeCreated implements core.Bus.

func (Bus) OnEnvelopeDeleted

func (b Bus) OnEnvelopeDeleted(h func(ctx context.Context, evt models.EventEnvelopeDeleted) error) func()

OnEnvelopeDeleted implements core.Bus.

func (Bus) OnMailmanEnqueued

func (b Bus) OnMailmanEnqueued(h func(ctx context.Context, evt models.EventMailmanEnqueued) error) func()

OnMailmanEnqueued implements core.Bus.