consumer

Documentation

Index

• type Message
• type Service
  • func NewService(opt *config.ConsumerOptions) *Service
  • func (s *Service) Serve() error

Types

type Message

type Message struct {
	Data []struct {
		Name  string `json:"name"`
		Score string `json:"score"`
	} `json:"data"`
}

type Service

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

func NewService

func NewService(opt *config.ConsumerOptions) *Service

func (*Service) Serve

func (s *Service) Serve() error