consumer

Documentation

Index

• type Consumer
  • func New(service service.Service, ps pubsub.PubSub, topic string) (*Consumer, error)
  • func (c *Consumer) Close() error
  • func (c *Consumer) Subscribe(nrApp *newrelic.Application) error

Types

type Consumer

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

Consumer contains functions for consumer.

func New

func New(service service.Service, ps pubsub.PubSub, topic string) (*Consumer, error)

New to create new consumer.

func (*Consumer) Close

func (c *Consumer) Close() error

Close to stop consumer connection.

func (*Consumer) Subscribe

func (c *Consumer) Subscribe(nrApp *newrelic.Application) error

Subscribe to start subscribing to topic.