runtime

Documentation

Index

• Constants
• Variables
• func ErrorEventsHandler(w *Wrkr)
• func NetworkWrkrReconnect(newNxNC rpc.NxNetworkClient)
• func RegisterWrkr(wID int, wOpts ...*WrkrOpt)
• func StartWrkrs()
• func StopWrkrs(wg *sync.WaitGroup)
• type Job
  • func NewJob(id, nodeID, jobType, priority string) *Job
• type JobSpec
• type Jobs
• type Wrkr
• type WrkrOpt
  • func SetWrkrOpt(k int, v interface{}) *WrkrOpt

Constants

const (
	WrkrOptName = iota
	WrkrOptJobQueue
	WrkrOptStartFunc
	WrkrOptExtFunc
	WrkrOptNxNetworkClient
)

const (
	APIVersionV1 = "v1"
	Kind         = "Job"

	JobTypeCommand = "cmdJob"
	JobTypeNetwork = "networkJob"
	JobTypeIPAM    = "ipamJob"
)

const (
	JobPriorityLow    = "LOW"
	JobPriorityMedium = "MEDIUM"
	JobPriorityHigh   = "HIGH"
)

Variables

var ErrorEventsJobQueue = make(chan error, 128)

Functions

func ErrorEventsHandler

func ErrorEventsHandler(w *Wrkr)

func NetworkWrkrReconnect

func NetworkWrkrReconnect(newNxNC rpc.NxNetworkClient)

func RegisterWrkr

func RegisterWrkr(wID int, wOpts ...*WrkrOpt)

func StartWrkrs

func StartWrkrs()

func StopWrkrs

func StopWrkrs(wg *sync.WaitGroup)

Types

type Job

type Job struct {
	APIVersion string  `json:"apiVersion"`
	Kind       string  `json:"kind"`
	Spec       JobSpec `json:"spec"`
}

func NewJob

func NewJob(id, nodeID, jobType, priority string) *Job

type JobSpec

type JobSpec struct {
	ID        string      `json:"eventId"`
	NodeID    string      `json:"nodeId"`
	JobType   string      `json:"jobType"`
	Priority  string      `json:"priority"`
	Timestamp time.Time   `json:"timestamp"`
	Payload   interface{} `json:"payload"`
}

type Jobs

type Jobs []Job

type Wrkr

type Wrkr struct {
	Name     string
	JobQueue interface{}
	QuitChan chan struct{}
	Running  bool
	WG       *sync.WaitGroup
	Ctx      context.Context

	NxNC rpc.NxNetworkClient
	// contains filtered or unexported fields
}

type WrkrOpt

type WrkrOpt struct {
	Key   int
	Value interface{}
}

func SetWrkrOpt

func SetWrkrOpt(k int, v interface{}) *WrkrOpt