core

type BlockPolicy struct {
	Name   string
	Record utils.Record
	Config utils.Record
}

type Dispatcher struct {
	// A pool of workers channels that are registered with the dispatcher
	JobPool    chan chan Job
	MaxWorkers int
}

type Job struct {
	Request utils.Record
	Type    string
}

type Mask struct {
	InclusiveMask bool
	FirstEvent    int64
	LastEvent     int64
	FirstLumi     int
	LastLumi      int
	FirstRun      int
	LstRun        int
	RunAndLumis   map[int][]int
}

type Metrics struct {
	Jobs metrics.Counter // number of jobs
}

type MonteCarloPolicy struct {
	Name   string
	Record utils.Record
	Config utils.Record
}

type Policy interface {
	Split() []WorkQueueElement
	Validate() bool
}

type ResubmitBlockPolicy struct {
	Name   string
	Record utils.Record
	Config utils.Record
}

type WorkQueueElement struct {
	couchdb.Document
	Inputs          map[string][]string // {blockName:sites}
	ParentData      map[string][]string // {blockName:sites}
	PileupData      map[string][]string // {blockName:sites}
	ParentFlag      bool
	NumberOfLumis   int
	NumberOfFiles   int
	NumberOfEvents  int
	Jobs            int
	OpenForNewData  bool
	NoInputUpdate   bool
	NoPileupUpdate  bool
	WMSpec          string
	Mask            map[string]int
	BlowupFactor    int
	ACDC            string
	RequestName     string
	TaskName        string
	Dbs             string
	SiteWhiteList   []string
	SiteBlackList   []string
	Priority        int
	ParentQueueUrl  string
	ChildQueueUrl   string
	PercentSuccess  float32
	PercentComplete float32
	WMBSUrl         string
	FilesProcessed  int
	StartPolicy     string
	EndPolicy       string
}

type Worker struct {
	Id         int
	JobPool    chan chan Job
	JobChannel chan Job
	// contains filtered or unexported fields
}

type WorkqueueStatus struct {
	Addrs            []string         `json:"addrs"`     // list of all IP addresses
	TimeStamp        int64            `json:"ts"`        // time stamp
	Metrics          map[string]int64 `json:"metrics"`   // workqueue metrics
	NumberOfRequests int              `json:"nRequests"` // number of requests in workqueue
}