pubsub

Documentation

Index

• Constants
• type Publisher
  • func (p *Publisher) Boot(ctx context.Context, config config.Config, ...) error
  • func (p Publisher) Dispatch() error
  • func (p *Publisher) Push(msg message.Message) error
  • func (p *Publisher) SetPubsubClient(client *pubsub.Client)

Constants

const DispatcherThreads = 5

Types

type Publisher

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

func (*Publisher) Boot

func (p *Publisher) Boot(ctx context.Context, config config.Config, outboundPool *goconcurrentqueue.FIFO) error

func (Publisher) Dispatch

func (p Publisher) Dispatch() error

func (*Publisher) Push

func (p *Publisher) Push(msg message.Message) error

func (*Publisher) SetPubsubClient

func (p *Publisher) SetPubsubClient(client *pubsub.Client)