Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ErrPanic = errors.New("panic")
View Source
var ErrUnknownPanic = errors.New("unknown panic")
Functions ¶
func TopicFromServiceRound ¶
Types ¶
type Config ¶
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:4161\"]"` ConsumerNSQDPool []string `default:"[\"\"]"` // "[\"nsqd:4150\"]"` } }
type IndexedQueue ¶
type MasterConfig ¶
type QCheck ¶
func CommonExecute ¶
func CommonExecute(sd *ScoringData, execDeadline time.Time) QCheck
type RoundTookTooLongToExecuteError ¶ added in v0.3.6
type RoundTookTooLongToExecuteError struct {
Msg string
}
func (*RoundTookTooLongToExecuteError) Error ¶ added in v0.3.6
func (e *RoundTookTooLongToExecuteError) Error() string
Click to show internal directories.
Click to hide internal directories.