publisher

Documentation

Index

• func GetClient(projectid string) (*gpubsub.Client, error)
• type Publisher
  • func NewPublisher(logger *zap.Logger, bqEvents <-chan types.EventMsg, config *cfg.Config, ...) (*Publisher, error)
  • func (c *Publisher) Publish(messages []gpubsub.Message, t *time.Timer, maxDelay time.Duration)
  • func (c *Publisher) Run()
  • func (c *Publisher) Stop()

Functions

func GetClient

func GetClient(projectid string) (*gpubsub.Client, error)

Types

type Publisher

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

func NewPublisher

func NewPublisher(logger *zap.Logger, bqEvents <-chan types.EventMsg, config *cfg.Config, collectorPool *sync.Pool, client *gpubsub.Client, id int) (*Publisher, error)

func (*Publisher) Publish

func (c *Publisher) Publish(messages []gpubsub.Message, t *time.Timer, maxDelay time.Duration)

func (*Publisher) Run

func (c *Publisher) Run()

func (*Publisher) Stop

func (c *Publisher) Stop()