gcp

Documentation

Index

• func NewWatermillPublisher(config config.Config, logger watermill.LoggerAdapter) (*googlecloud.Publisher, error)
• type NoopPublisher
  • func NewNoopPublisher() *NoopPublisher
  • func (p *NoopPublisher) PublishNewEventReceived(ctx context.Context, event domain.Event) error
• type Publisher
  • func NewPublisher(publisher *googlecloud.Publisher) *Publisher
  • func (p *Publisher) PublishNewEventReceived(ctx context.Context, event domain.Event) error

Functions

func NewWatermillPublisher

func NewWatermillPublisher(config config.Config, logger watermill.LoggerAdapter) (*googlecloud.Publisher, error)

Types

type NoopPublisher

type NoopPublisher struct {
}

func NewNoopPublisher

func NewNoopPublisher() *NoopPublisher

func (*NoopPublisher) PublishNewEventReceived

func (p *NoopPublisher) PublishNewEventReceived(ctx context.Context, event domain.Event) error

type Publisher

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

func NewPublisher

func NewPublisher(publisher *googlecloud.Publisher) *Publisher

func (*Publisher) PublishNewEventReceived

func (p *Publisher) PublishNewEventReceived(ctx context.Context, event domain.Event) error