dispatch

type AgentExecution struct {
	// contains filtered or unexported fields
}

type AgentMonitor struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

type AgentUpdate interface {
	AgentUp(node string, tags []string)
	AgentDown(node string, tags []string)
}

type Agents interface {
	Get(tag string) map[string]string
	Check(agent string) bool
}

type Dispatcher interface {
	// agent node up/down notification
	AgentUp(string)
	AgentDown(string)

	// dispatcher properties Name() string
	Name() string
	Concurrency() int

	// operations
	Serve()
	Stop()

	// agent/job results notification
	DependencyCompleted(*JobExecutionResult)
	AgentsCompleted(*JobExecutionResult)
}

type DispatcherEvent struct {
	EventType int
	EventData interface{}
}

type Execution interface {
	// Get jobs execution group id
	GetMaxGroupIds([]string) map[string]int64
	// Job complete notify
	JobCompleted(*JobExecutionResult)

	JobDeleted(string)

	// Subscribe/Unsubscribe job complete events
	Subscribe(Dispatcher, []string)
	Unsubscribe(Dispatcher, []string)
}

type JobDispatchState struct {
	// job dependents state
	Dependents map[string]int64 `json:"dependents"`

	// job running agents state
	// map[node]map[dispatch id]ok
	RunningAgents map[string]map[string]bool `json:"running_agents"`

	// job all completed state
	// will not dispatch again
	JobCompleted bool `json:"job_completed"`
}

type JobDispatcher struct {
	// contains filtered or unexported fields
}

type JobDispatcherManager struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

type JobExecution struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

type JobExecutionResult struct {
	logic.ExecutionResult

	DispatchIDs []string `json:"dispatch_ids"`

	// Number of successful executions of this job.
	SuccessCount int `json:"success_count"`

	// Number of errors running this job.
	ErrorCount int `json:"error_count"`

	// Last time this job executed successful.
	LastSuccess time.Time `json:"last_success"`

	// Last time this job failed.
	LastError time.Time `json:"last_error"`
}