interfaces.go

package director

import (
	"io"
	"os"
	"time"

	semver "github.com/cppforlife/go-semi-semantic/version"
)

//go:generate counterfeiter . Director

type Director interface {
	IsAuthenticated() (bool, error)
	Info() (Info, error)

	Locks() ([]Lock, error)

	CurrentTasks(TasksFilter) ([]Task, error)
	RecentTasks(int, TasksFilter) ([]Task, error)
	FindTask(int) (Task, error)

	Events(EventsFilter) ([]Event, error)

	Deployments() ([]Deployment, error)
	FindDeployment(string) (Deployment, error)

	Releases() ([]Release, error)
	HasRelease(name, version string) (bool, error)
	FindRelease(ReleaseSlug) (Release, error)
	FindReleaseSeries(ReleaseSeriesSlug) (ReleaseSeries, error)
	UploadReleaseURL(url, sha1 string, rebase, fix bool) error
	UploadReleaseFile(file UploadFile, rebase, fix bool) error
	MatchPackages(manifest interface{}, compiled bool) ([]string, error)

	Stemcells() ([]Stemcell, error)
	HasStemcell(name, version string) (bool, error)
	FindStemcell(StemcellSlug) (Stemcell, error)
	UploadStemcellURL(url, sha1 string, fix bool) error
	UploadStemcellFile(file UploadFile, fix bool) error

	LatestCloudConfig() (CloudConfig, error)
	UpdateCloudConfig([]byte) error

	LatestRuntimeConfig() (RuntimeConfig, error)
	UpdateRuntimeConfig([]byte) error

	FindOrphanedDisk(string) (OrphanedDisk, error)
	OrphanedDisks() ([]OrphanedDisk, error)

	EnableResurrection(bool) error
	CleanUp(bool) error
	DownloadResourceUnchecked(blobstoreID string, out io.Writer) error
}

type UploadFile interface {
	io.ReadCloser
	Stat() (os.FileInfo, error)
}

//go:generate counterfeiter . ReleaseArchive

type ReleaseArchive interface {
	Info() (string, string, error)
	File() (UploadFile, error)
}

//go:generate counterfeiter . StemcellArchive

type StemcellArchive interface {
	Info() (string, string, error)
	File() (UploadFile, error)
}

//go:generate counterfeiter . FileReporter

type FileReporter interface {
	TrackUpload(int64, io.ReadCloser) io.ReadCloser
	TrackDownload(int64, io.Writer) io.Writer
}

//go:generate counterfeiter . Deployment

type Deployment interface {
	Name() string
	Manifest() (string, error)
	CloudConfig() (string, error)
	Diff([]byte, bool) (DiffLines, error)

	Releases() ([]Release, error)
	ExportRelease(ReleaseSlug, OSVersionSlug) (ExportReleaseResult, error)

	Stemcells() ([]Stemcell, error)
	VMInfos() ([]VMInfo, error)
	InstanceInfos() ([]VMInfo, error)

	Errands() ([]Errand, error)
	RunErrand(string, bool) (ErrandResult, error)

	ScanForProblems() ([]Problem, error)
	ResolveProblems([]ProblemAnswer) error

	Snapshots() ([]Snapshot, error)
	TakeSnapshots() error
	DeleteSnapshot(string) error
	DeleteSnapshots() error

	// Deployment, pool or instance specifics
	Start(slug AllOrPoolOrInstanceSlug) error
	Stop(slug AllOrPoolOrInstanceSlug, hard bool, sd SkipDrain, force bool) error
	Restart(slug AllOrPoolOrInstanceSlug, sd SkipDrain, force bool) error
	Recreate(slug AllOrPoolOrInstanceSlug, sd SkipDrain, force bool) error

	SetUpSSH(AllOrPoolOrInstanceSlug, SSHOpts) (SSHResult, error)
	CleanUpSSH(AllOrPoolOrInstanceSlug, SSHOpts) error

	// Instance specifics
	FetchLogs(InstanceSlug, []string, bool) (LogsResult, error)
	TakeSnapshot(InstanceSlug) error
	EnableResurrection(InstanceSlug, bool) error

	Update(manifest []byte, opts UpdateOpts) error
	Delete(force bool) error
}

type UpdateOpts struct {
	Recreate  bool
	Fix       bool
	SkipDrain SkipDrain
}

//go:generate counterfeiter . ReleaseSeries

type ReleaseSeries interface {
	Name() string
	Delete(force bool) error
}

//go:generate counterfeiter . Release

type Release interface {
	Name() string
	Version() semver.Version
	VersionMark(mark string) string
	CommitHashWithMark(mark string) string

	Jobs() ([]Job, error)
	Packages() ([]Package, error)

	Delete(force bool) error
}

//go:generate counterfeiter . Stemcell

type Stemcell interface {
	Name() string
	Version() semver.Version
	VersionMark(mark string) string

	OSName() string
	CID() string

	Delete(force bool) error
}

type TasksFilter struct {
	All        bool
	Deployment string
}

type Task interface {
	ID() int
	StartedAt() time.Time
	LastActivityAt() time.Time

	State() string
	IsError() bool
	User() string
	DeploymentName() string

	Description() string
	Result() string

	EventOutput(TaskReporter) error
	CPIOutput(TaskReporter) error
	DebugOutput(TaskReporter) error
	ResultOutput(TaskReporter) error
	RawOutput(TaskReporter) error

	Cancel() error
}

//go:generate counterfeiter . TaskReporter

type TaskReporter interface {
	TaskStarted(int)
	TaskFinished(int, string)
	TaskOutputChunk(int, []byte)
}

//go:generate counterfeiter . OrphanedDisk

type OrphanedDisk interface {
	CID() string
	Size() uint64

	Deployment() Deployment
	InstanceName() string
	AZName() string

	OrphanedAt() time.Time

	Delete() error
}

type EventsFilter struct {
	BeforeID   string
	Before     string
	After      string
	Deployment string
	Task       string
	Instance   string
}

//go:generate counterfeiter . Event

type Event interface {
	ID() string
	ParentID() string
	Timestamp() time.Time
	User() string
	Action() string
	ObjectType() string
	ObjectName() string
	TaskID() string
	DeploymentName() string
	Instance() string
	Context() map[string]interface{}
}