cloud

type FileInfo struct {
	// Name of the file, which means the base name.
	Name string
	// URL of the file. The scheme should be roadie://.
	URL *url.URL
	// TimeCreated is the time when the file was created.
	TimeCreated time.Time
	// Size of the file.
	Size int64
}

type FileInfoHandler func(*FileInfo) error

type InstanceHandler func(name, status string) error

type InstanceManager interface {
	// CreateInstance creates an instance which has a given name.
	CreateInstance(ctx context.Context, script *script.Script) error
	// DeleteInstance deletes the given named instance.
	DeleteInstance(ctx context.Context, name string) error
	// Instances returns a list of running instances
	Instances(ctx context.Context, handler InstanceHandler) error
}

type LogHandler func(timestamp time.Time, line string, stderr bool) error

type LogManager interface {
	// Get instance log.
	Get(ctx context.Context, instanceName string, after time.Time, handler LogHandler) error
	// Delete instance log.
	Delete(ctx context.Context, instanceName string) error
	// GetQueueLog retrievs log entries from a given queue.
	GetQueueLog(ctx context.Context, queue string, handler LogHandler) error
	// GetTaskLog retrieves log entries from a task in a queue.
	GetTaskLog(ctx context.Context, queue, task string, handler LogHandler) error
}

type MachineType struct {
	Name        string
	Description string
}

type MetadataItem struct {
	Key   string
	Value string
}

type Provider interface {
	// InstanceManager returns an instance manager interface.
	InstanceManager(context.Context) (InstanceManager, error)
	// QueueManager returns a queue manager interface.
	QueueManager(context.Context) (QueueManager, error)
	// StorageManager returns a storage manager interface.
	StorageManager(context.Context) (StorageManager, error)
	// LogManager returns a log manager interface.
	LogManager(context.Context) (LogManager, error)
	// ResourceManager returns a resource manager interface.
	ResourceManager(context.Context) (ResourceManager, error)
}

type QueueManager interface {
	// Enqueue a new task to a given named queue.
	Enqueue(ctx context.Context, queue string, task *script.Script) error
	// Tasks retrieves tasks in a given names queue.
	Tasks(ctx context.Context, queue string, handler QueueManagerTaskHandler) error
	// Queues retrieves existing queue names.
	Queues(ctx context.Context, handler QueueStatusHandler) error
	// Stop executing tasks in a given named queue.
	Stop(ctx context.Context, queue string) error
	// Restart executing tasks in a given names queue.
	Restart(ctx context.Context, queue string) error
	// CreateWorkers creates worker instances working for a given named queue.
	CreateWorkers(ctx context.Context, queue string, n int, handler QueueManagerNameHandler) error
	// Workers retrieves worker instance names for a given queue.
	Workers(ctx context.Context, queue string, handler QueueManagerNameHandler) error
	// DeleteQueue deletes a given named queue.
	DeleteQueue(ctx context.Context, queue string) error
	// DeleteTask deletes a given named task in a given named queue.
	DeleteTask(ctx context.Context, queue, task string) error
}

type QueueManagerNameHandler func(string) error

type QueueManagerTaskHandler func(name string, status string) error

type QueueStatus struct {
	// The number of waiting tasks.
	Waiting int
	// The number of pending tasks.
	Pending int
	// The number of running tasks.
	Running int
	// The number of worker instances.
	Worker int
}

type QueueStatusHandler func(name string, status QueueStatus) error

type Region struct {
	Name   string
	Status string
}

type ResourceManager interface {
	// GetProjectID returns an ID of the current project.
	GetProjectID() string
	// SetProjectID sets an ID to the current project.
	SetProjectID(string)
	// GetMachineType returns a machine type the current project uses by default.
	GetMachineType() string
	// SetMachineType sets a machine type as the default one.
	SetMachineType(string)
	// MachineTypes returns a set of available machine types.
	MachineTypes(context.Context) ([]MachineType, error)
	// GetRegion returns a region name the current project working on.
	GetRegion() string
	// SetRegion sets a region to the current project.
	SetRegion(string)
	// Regions returns a set of available regions.
	Regions(context.Context) ([]Region, error)
}

type Storage struct {

	// TODO: Delete or update this.
	// Writer logs to be printed.
	Log io.Writer
	// contains filtered or unexported fields
}

type StorageManager interface {

	// Upload a given stream to a given URL.
	Upload(ctx context.Context, loc *url.URL, in io.Reader) error

	// Download a file pointed by a given URL and write it to a given stream.
	Download(ctx context.Context, loc *url.URL, out io.Writer) error

	// GetFileInfo retrieves information of a file pointed by a given URL.
	GetFileInfo(ctx context.Context, loc *url.URL) (*FileInfo, error)

	// List up files of which URLs start with a given URL.
	// It takes a handler; information of found files are sent to it.
	List(ctx context.Context, loc *url.URL, handler FileInfoHandler) error

	// Delete a file pointed by a given URL.
	Delete(ctx context.Context, loc *url.URL) error
}