matcher

type DeadlineMatcher struct {
	Matcher
	// contains filtered or unexported fields
}

type JobsManager interface {
	// Create prepares a new job for the worker.
	Create(boruta.ReqID, boruta.WorkerUUID) error
	// Get returns pointer to a Job from JobsManager or error if no job for
	// the worker is found.
	Get(boruta.WorkerUUID) (*workers.Job, error)
	// Finish cleans up after job is done. The second parameter defines
	// if worker should be prepared for next job.
	Finish(boruta.WorkerUUID, bool) error
}

type JobsManagerImpl struct {
	JobsManager
	// contains filtered or unexported fields
}

type Matcher interface {
	// Notify triggers action in the matcher. The ReqID slice contain set
	// of requests' IDs related to the event. The slice can be empty if the event
	// requires generic actions on all requests.
	Notify([]boruta.ReqID)
}

type RequestsManager interface {
	// InitIteration starts iteration over requests pending in queue.
	// Method returns error if iterations are already started and have not been
	// terminated with TerminateIteration()
	InitIteration() error
	// TerminateIteration finishes iterating over requests formerly started with InitIteration.
	TerminateIteration()
	// Next gets next ID from request queue.
	// Method returns {ID, true} if there is pending request
	// or {ReqID(0), false} if queue's end has been reached.
	Next() (boruta.ReqID, bool)
	// VerifyIfReady checks if the request is ready to be run on worker.
	VerifyIfReady(boruta.ReqID, time.Time) bool
	// Get retrieves full request information or error if no request is found.
	Get(boruta.ReqID) (boruta.ReqInfo, error)
	// Timeout sets request to TIMEOUT state after Deadline time is exceeded.
	Timeout(boruta.ReqID) error
	// Close closes request setting it in DONE state, closing job
	// and releasing worker after run time of the request has been exceeded.
	Close(boruta.ReqID) error
	// Run starts job performing the request on the worker.
	Run(boruta.ReqID, boruta.WorkerUUID) error
}

type TimeoutMatcher struct {
	Matcher
	// contains filtered or unexported fields
}

type ValidMatcher struct {
	Matcher
	// contains filtered or unexported fields
}

type WorkersManager interface {
	// TakeBestMatchingWorker returns best matching worker that meets a criteria.
	// An error is returned if no matching worker is found.
	TakeBestMatchingWorker(boruta.Groups, boruta.Capabilities) (boruta.WorkerUUID, error)

	// PrepareWorker makes it ready for running a job.
	// Caller of this method can decide (with 2nd parameter) if key generation
	// is required for preparing worker.
	PrepareWorker(worker boruta.WorkerUUID, withKeyGeneration bool) error

	// GetWorkerSSHAddr returns address of the ssh daemon on the worker that can
	// be used for setting up tunnel to the worker. If there is no worker with
	// given WorkerUUID an error is returned.
	GetWorkerSSHAddr(boruta.WorkerUUID) (net.TCPAddr, error)

	// GetWorkerKey returns private RSA key of the worker that can be used for
	// accessing the worker. If there is no worker with given WorkerUUID an error
	// is returned.
	GetWorkerKey(boruta.WorkerUUID) (rsa.PrivateKey, error)

	// SetChangeListener stores reference to object, which should be notified
	// in case of changes of workers' states.
	SetChangeListener(workers.WorkerChange)
}