google

Documentation

Index

• Variables
• type Google
  • func New(source *datastore.Source, handler datastore.PubSubHandler, log log.StdLogger) *Google
  • func (g *Google) Consume()
  • func (g *Google) Start()
  • func (g *Google) Stop()
  • func (g *Google) Verify() error

Variables

var ErrInvalidCredentials = errors.New("your google pub/sub credentials are invalid. please verify you're providing the correct credentials")

Types

type Google

type Google struct {
	Cfg *datastore.GooglePubSubConfig
	// contains filtered or unexported fields
}

func New

func New(source *datastore.Source, handler datastore.PubSubHandler, log log.StdLogger) *Google

func (*Google) Consume

func (g *Google) Consume()

func (*Google) Start

func (g *Google) Start()

func (*Google) Stop

func (g *Google) Stop()

func (*Google) Verify

func (g *Google) Verify() error

Verify ensures the pub sub credentials are valid