orchestrator

type AndroidBuild struct {
	ID     string
	Target string
}

type CVDSelector struct {
	Group string
	Name  string
}

type Config struct {
	Paths                  IMPaths
	AndroidBuildServiceURL string
	CVDCreationTimeout     time.Duration
	CVDUser                string
}

type Controller struct {
	Config                Config
	OperationManager      OperationManager
	WaitOperationDuration time.Duration
	UserArtifactsManager  UserArtifactsManager
	DebugVariablesManager *debug.VariablesManager
}

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

type CreateCVDActionOpts struct {
	Request                  *apiv1.CreateCVDRequest
	HostValidator            Validator
	Paths                    IMPaths
	OperationManager         OperationManager
	ExecContext              ExecContext
	BuildAPI                 artifacts.BuildAPI
	ArtifactsFetcher         artifacts.Fetcher
	CVDBundleFetcher         artifacts.CVDBundleFetcher
	UUIDGen                  func() string
	CVDUser                  string
	CVDStartTimeout          time.Duration
	UserArtifactsDirResolver UserArtifactsDirResolver
	BuildAPICredentials      string
}

type EmptyFieldError string

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

type ExecCVDCommandActionOpts struct {
	Command          string
	Selector         CVDSelector
	Paths            IMPaths
	OperationManager OperationManager
	ExecContext      ExecContext
	CVDUser          string
}

type ExecContext = func(ctx context.Context, name string, arg ...string) *exec.Cmd

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

type FetchArtifactsActionOpts struct {
	Request          *apiv1.FetchArtifactsRequest
	Paths            IMPaths
	OperationManager OperationManager
	BuildAPI         artifacts.BuildAPI
	CVDBundleFetcher artifacts.CVDBundleFetcher
	ArtifactsFetcher artifacts.Fetcher
	UUIDGen          func() string
}

type HostValidator struct {
	ExecContext ExecContext
}

type IMPaths struct {
	RootDir          string
	ArtifactsRootDir string
}

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

type ListCVDsActionOpts struct {
	Paths       IMPaths
	ExecContext ExecContext
	CVDUser     string
}

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

type NotFoundOperationError string

type OperationManager interface {
	New() apiv1.Operation

	Get(name string) (apiv1.Operation, error)

	GetResult(name string) (*OperationResult, error)

	Complete(name string, result *OperationResult) error

	// Waits for the specified operation to be DONE within the passed deadline. If the deadline
	// is reached `OperationWaitTimeoutError` will be returned.
	// NOTE: if dt is zero there's no timeout.
	Wait(name string, dt time.Duration) (*OperationResult, error)
}

type OperationNotDoneError string

type OperationResult struct {
	Error error
	Value interface{}
}

type OperationWaitTimeoutError struct{}

type UserArtifactChunk struct {
	Name           string
	ChunkNumber    int
	ChunkTotal     int
	ChunkSizeBytes int64
	File           io.Reader
}

type UserArtifactsDirResolver interface {
	// Given a directory name returns its full path.
	GetDirPath(name string) string
}

type UserArtifactsManager interface {
	UserArtifactsDirResolver
	// Creates a new directory for uploading user artifacts in the future.
	NewDir() (*apiv1.UploadDirectory, error)
	// List existing directories
	ListDirs() (*apiv1.ListUploadDirectoriesResponse, error)
	// Update artifact with the passed chunk.
	UpdateArtifact(dir string, chunk UserArtifactChunk) error
	// Extract artifact
	ExtractArtifact(dir, name string) error
}

type UserArtifactsManagerImpl struct {
	UserArtifactsManagerOpts
}

type UserArtifactsManagerOpts struct {
	// The root directory where to store the artifacts.
	RootDir string
	// Factory of name values
	NameFactory func() string
}

type Validator interface {
	Validate() error
}