queueing

package
v0.3.0-alpha7 Latest Latest
Warning

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

Go to latest
Published: Nov 25, 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
	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
}

Jump to

Keyboard shortcuts

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