queueing

type Config struct {
	Use   string `default:"none"`
	Kafka struct {
	}
	NSQ struct {
		ProducerNSQD                 string   `default:"nsqd:4150"`
		IgnoreAllScoresIfWorkerFails bool     `default:"true"`
		Topic                        string   `default:"default"`
		MaxInFlight                  int      `default:"200"` // This should be more than min(NumberOfChecks, #NSQD Nodes)
		AuthSecret                   string   `default:""`
		ClientRootCA                 string   `default:""`
		ClientSSLKey                 string   `default:""`
		ClientSSLCert                string   `default:""`
		ConcurrentHandlers           int      `default:"200"`
		NSQLookupd                   []string `default:"[\"\"]"` // "[\"nsqlookupd:4160\"]"
		ConsumerNSQDPool             []string `default:"[\"\"]"` // "[\"nsqd:4150\"]"
	}
}

type IndexedQueue struct {
	Q *QCheck
	I int
}

type MasterConfig struct {
	ReportForceRefreshSeconds uint   `default:"60"`
	ChannelPrefix             string `default:"master"`
}

type QCheck struct {
	Service QService
	RoundID uint64
	Passed  bool
	Log     string
	Err     string
}

type QService struct {
	ID             uuid.UUID
	Group          string
	Name           string
	ReturningTopic string
}

type RoundTookTooLongToExecuteError struct {
	Msg string
}

type ScoringData struct {
	Service    QService
	Properties map[string]string
	Deadline   time.Time
	MasterTime time.Time
	Host       string
	RoundID    uint64
}