worker

Documentation

Index

• func NewConsumer(config *ConsumerConfig) (*nsqConsumer, error)
• type CheckWorker
  • func NewCheckWorker(db *sqlx.DB, rStore results.Store, result *schema.CheckResult) *CheckWorker
  • func (w *CheckWorker) Context() context.Context
  • func (w *CheckWorker) Execute() (interface{}, error)
• type ConsumerConfig

Functions

func NewConsumer

func NewConsumer(config *ConsumerConfig) (*nsqConsumer, error)

Types

type CheckWorker

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

func NewCheckWorker

func NewCheckWorker(db *sqlx.DB, rStore results.Store, result *schema.CheckResult) *CheckWorker

func (*CheckWorker) Context

func (w *CheckWorker) Context() context.Context

func (*CheckWorker) Execute

func (w *CheckWorker) Execute() (interface{}, error)

type ConsumerConfig

type ConsumerConfig struct {
	Topic            string
	Channel          string
	LookupdAddresses []string
	NSQConfig        *nsq.Config
	HandlerCount     int
}