queueing

package
v0.3.0-alpha1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Nov 21, 2021 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RandomInt

func RandomInt() (string, error)

func TopicFromServiceRound

func TopicFromServiceRound(roundID uint64) (string, error)

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 IndexedQueue struct {
	Q *QCheck
	I int
}

type MasterConfig

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

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
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL