aggregator

Documentation

Index

• type Config
• type Service
  • func New(cfg Config, logger log.Logger) (Service, error)
  • func (s *Service) HandleMessage(m *gonsq.Message) error
  • func (s *Service) Start() error

Types

type Config

type Config struct {
	LogLevel string             `mapstructure:"log_level"`
	Consumer config.ConsumerCfg `mapstructure:"consumer"`
	DB       store.Config       `mapstructure:"db"`
	Storage  config.StorageCfg  `mapstructure:"storage"`
}

Config represents our application config.

type Service

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

Service represents the PE scan service. It adheres to the nsq.Handler interface. This allows us to define our own custom handlers for our messages. Think of these handlers much like you would an http handler.

func New

func New(cfg Config, logger log.Logger) (Service, error)

New create a new aggregator scanner service.

func (*Service) HandleMessage

func (s *Service) HandleMessage(m *gonsq.Message) error

HandleMessage is the only requirement needed to fulfill the nsq.Handler.

func (*Service) Start

func (s *Service) Start() error

Start kicks in the service to start consuming events.