pubsub

Documentation

Index

• type Options
  • func NewOptions() *Options
• type PubSub
  • func (rcv *PubSub) InitPrometheus(reg prometheus.Registerer)
  • func (rcv *PubSub) Stat(send helper.StatCallback)
  • func (rcv *PubSub) Stop()

Types

type Options

type Options struct {
	Project             string `toml:"project"`
	Subscription        string `toml:"subscription"`
	ReceiverGoRoutines  int    `toml:"receiver_go_routines"`
	ReceiverMaxMessages int    `toml:"receiver_max_messages"`
	ReceiverMaxBytes    int    `toml:"receiver_max_bytes"`
}

Options contains all receiver's options that can be changed by user

func NewOptions

func NewOptions() *Options

NewOptions returns Options struct filled with default values.

type PubSub

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

PubSub receive metrics from a google pubsub subscription

func (*PubSub) InitPrometheus

func (rcv *PubSub) InitPrometheus(reg prometheus.Registerer)

InitPrometheus is a stub for the receiver prom metrics. Required to satisfy Receiver interface.

func (*PubSub) Stat

func (rcv *PubSub) Stat(send helper.StatCallback)

Stat sends pubsub receiver's internal stats to specified callback

func (*PubSub) Stop

func (rcv *PubSub) Stop()

Stop shuts down the pubsub receiver and waits until all message processing is completed before returning