consumer

Documentation

Index

• type Consumer
  • func New(service service.Service, ps pubsub.PubSub, topic string) *Consumer
  • func (c *Consumer) Close() error
  • func (c *Consumer) Subscribe() 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

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() error

Subscribe to subscribe.