consumer

Documentation

Index

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

New to create new consumer.

func (*Consumer) Close

func (c *Consumer) Close() error

Close to stop consumer connection.

func (*Consumer) SubscribeParseAgency

func (c *Consumer) SubscribeParseAgency() error

SubscribeParseAgency to subscribe parse agency.

func (*Consumer) SubscribeParseVtuber

func (c *Consumer) SubscribeParseVtuber() error

SubscribeParseVtuber to subscribe parse vtuber.