queueing

Documentation

Index

• func RandomInt() (string, error)
• func TopicFromServiceRound(roundID uint64) (string, error)
• type Config
• type IndexedQueue
• type MasterConfig
• type QCheck
  • func CommonExecute(sd *ScoringData, execDeadline time.Time) QCheck
• type QService
• type RoundTookTooLongToExecute
  • func (e *RoundTookTooLongToExecute) Error() string
• type ScoringData

Functions

func RandomInt

func RandomInt() (string, error)

func TopicFromServiceRound

func TopicFromServiceRound(roundID uint64) (string, error)

Types

type Config

type Config struct {
	Use   string
	Kafka struct {
	}
	NSQ struct {
		ProducerNSQD                 string
		IgnoreAllScoresIfWorkerFails bool
		Topic                        string
		MaxInFlight                  int
		AuthSecret                   string
		ClientRootCA                 string
		ClientSSLKey                 string
		ClientSSLCert                string
		ConcurrentHandlers           int
		NSQLookupd                   []string
		ConsumerNSQDPool             []string
	}
}

type IndexedQueue

type IndexedQueue struct {
	Q *QCheck
	I int
}

type MasterConfig

type MasterConfig struct {
	ReportForceRefreshSeconds uint
	ChannelPrefix             string
}

type QCheck

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

func CommonExecute

func CommonExecute(sd *ScoringData, execDeadline time.Time) QCheck

type QService

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

type RoundTookTooLongToExecute

type RoundTookTooLongToExecute struct {
	Msg string
}

func (*RoundTookTooLongToExecute) Error

func (e *RoundTookTooLongToExecute) Error() string

type ScoringData

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