memdb

type GaiaMemDB interface {
	// SyncStore syncs the memdb with the store.
	SyncStore() error

	// GetAllWorker returns all worker.
	GetAllWorker() []*gaia.Worker

	// UpsertWorker inserts or updates the given worker in the memdb.
	// If persist is true, the given worker will be persisted in the store.
	UpsertWorker(w *gaia.Worker, persist bool) error

	// GetWorker returns a worker by the given identifier.
	GetWorker(id string) (*gaia.Worker, error)

	// DeleteWorker deletes a worker by the given identifier.
	// If persist is true, the worker will also be deleted from the store.
	DeleteWorker(id string, persist bool) error

	// InsertPipelineRun inserts a pipeline run in the memdb.
	InsertPipelineRun(p *gaia.PipelineRun) error

	// PopPipelineRun gets the oldest pipeline run by tags and removes it immediately
	// from the memdb.
	PopPipelineRun(tags []string) (*gaia.PipelineRun, error)

	// DeletePipelineRun deletes the given pipeline run from the memdb.
	DeletePipelineRun(runID string) error

	// InsertDockerWorker inserts a docker worker into the memdb.
	InsertDockerWorker(w *docker.Worker) error

	// GetDockerWorker gets the docker worker by the given worker id.
	GetDockerWorker(workerID string) (*docker.Worker, error)

	// DeleteDockerWorker deletes the docker worker by then given worker id.
	DeleteDockerWorker(workerID string) error

	// GetAllDockerWorker gets all docker worker.
	GetAllDockerWorker() ([]*docker.Worker, error)
}

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