cloudcompute

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

type DockerComputeManagerConfig struct {
	Concurrency int
}

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

type DockerComputeProviderConfig struct {
	//number of concurrent containers to allow on the host
	Concurrency int

	//starts a monitor job which provides job summary counts similar to the AWS Batch dashboard.
	//If the value provided is greater than 0, the monitor will start using the value as a monitoring interval in seconds
	StartMonitor int

	//optional monitor function.  The default monitor will print the status counts to StdOut
	MonitorFunction MonitorFunction

	//optional in memory secrets manager if a secrets mock is necessary
	SecretsManager SecretsManager
}

type DockerEvent struct {
	Status         string `json:"status"`
	Error          string `json:"error"`
	Progress       string `json:"progress"`
	ProgressDetail struct {
		Current int `json:"current"`
		Total   int `json:"total"`
	} `json:"progressDetail"`
}

type DockerJob struct {
	Job    *Job
	Plugin *Plugin
	Status JobStatus
	Log    string

	SecretsManager SecretsManager
	// contains filtered or unexported fields
}

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

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

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

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

type InMemoryJobQueue struct {
	sync.Mutex
	// contains filtered or unexported fields
}

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

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

type JobDeps []*DockerJob

type JobQueue interface {
	Add(job *DockerJob)

	//Gets the next runable job and sets the status to Starting
	GetNextRunnable() *DockerJob

	//Gets all jobs matching the set of statuses
	//Calling with no status argument will return all jobs
	Jobs(statuses ...JobStatus) []*DockerJob

	//Get a job by ID
	GetJob(jobId uuid.UUID) *DockerJob

	UpdateJobs() []uuid.UUID
}

type JobStatus string

type MonitorFunction func(statuses map[JobStatus]int)

type PluginRegistry interface {
	Register(plugin *Plugin) error
	Deregister(name string) error
	Get(name string) (*Plugin, error)
}

type SecretsManager interface {
	AddSecret(key string, val string)
	GetSecret(key string) string
}