store

Documentation

Index

• func GenerationHasToBeBuilt(g *protobuf.Generation) bool
• func GenerationShow(g *protobuf.Generation)
• func IsTesting(d *protobuf.Deployment) bool
• func StatusToString(status Status) string
• type BuildStatus
  • func StringToBuildStatus(statusStr string) BuildStatus
  • func (s BuildStatus) String() string
• type EvalStatus
  • func StringToEvalStatus(statusStr string) EvalStatus
  • func (s EvalStatus) String() string
• type Status
  • func StringToStatus(statusStr string) Status
• type Store
  • func New(broker *broker.Broker, filename, gcRootsDir string, ...) (*Store, error)
  • func (s *Store) Commit()
  • func (s *Store) DeploymentFinished(uuid string, deploymentErr error, cominNeedRestart bool, profilePath string, ...) error
  • func (s *Store) DeploymentList() []*protobuf.Deployment
  • func (s *Store) DeploymentStarted(uuid, bootedStorepath, currentStorepath string) error
  • func (s *Store) GenerationBuildFinished(uuid string, buildErr error) error
  • func (s *Store) GenerationBuildStart(uuid, reason string) error
  • func (s *Store) GenerationEvalFinished(uuid string, drvPath, outPath, machineId string, evalErr error) error
  • func (s *Store) GenerationEvalStarted(uuid string) error
  • func (s *Store) GenerationGet(uuid string) (protobuf.Generation, error)
  • func (s *Store) GetDeploymentLastest() (latest *protobuf.Deployment)
  • func (s *Store) GetDeploymentProfilePaths() []string
  • func (s *Store) GetState() *protobuf.Store
  • func (s *Store) LastDeployment() (ok bool, d *protobuf.Deployment)
  • func (s *Store) Load() (err error)
  • func (s *Store) NewDeployment(g *protobuf.Generation, ...) *protobuf.Deployment
  • func (s *Store) NewGeneration(hostname, repositoryPath, repositoryDir, systemAttr string, ...) (g protobuf.Generation)

Functions

func GenerationHasToBeBuilt

func GenerationHasToBeBuilt(g *protobuf.Generation) bool

func GenerationShow

func GenerationShow(g *protobuf.Generation)

func IsTesting

func IsTesting(d *protobuf.Deployment) bool

func StatusToString

func StatusToString(status Status) string

Types

type BuildStatus

type BuildStatus int64

const (
	BuildInit BuildStatus = iota
	Building
	Built
	BuildFailed
)

func StringToBuildStatus

func StringToBuildStatus(statusStr string) BuildStatus

func (BuildStatus) String

func (s BuildStatus) String() string

type EvalStatus

type EvalStatus int64

const (
	EvalInit EvalStatus = iota
	Evaluating
	Evaluated
	EvalFailed
)

func StringToEvalStatus

func StringToEvalStatus(statusStr string) EvalStatus

func (EvalStatus) String

func (s EvalStatus) String() string

type Status

type Status int64

const (
	Init Status = iota
	Running
	Done
	Failed
)

func StringToStatus

func StringToStatus(statusStr string) Status

type Store

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

func New

func New(broker *broker.Broker, filename, gcRootsDir string, bootEntryCapacity, successfulCapacity, anyCapacity int) (*Store, error)

func (*Store) Commit

func (s *Store) Commit()

func (*Store) DeploymentFinished

func (s *Store) DeploymentFinished(uuid string, deploymentErr error, cominNeedRestart bool, profilePath string, bootedStorepath, currentStorepath string) error

func (*Store) DeploymentList

func (s *Store) DeploymentList() []*protobuf.Deployment

DeploymentAdd inserts a deployment and return an evicted deployment because the capacity has been reached.

func (*Store) DeploymentStarted

func (s *Store) DeploymentStarted(uuid, bootedStorepath, currentStorepath string) error

func (*Store) GenerationBuildFinished

func (s *Store) GenerationBuildFinished(uuid string, buildErr error) error

func (*Store) GenerationBuildStart

func (s *Store) GenerationBuildStart(uuid, reason string) error

func (*Store) GenerationEvalFinished

func (s *Store) GenerationEvalFinished(uuid string, drvPath, outPath, machineId string, evalErr error) error

func (*Store) GenerationEvalStarted

func (s *Store) GenerationEvalStarted(uuid string) error

func (*Store) GenerationGet

func (s *Store) GenerationGet(uuid string) (protobuf.Generation, error)

GenerationGet is thread safe and returns a copy

func (*Store) GetDeploymentLastest

func (s *Store) GetDeploymentLastest() (latest *protobuf.Deployment)

func (*Store) GetDeploymentProfilePaths

func (s *Store) GetDeploymentProfilePaths() []string

func (*Store) GetState

func (s *Store) GetState() *protobuf.Store

func (*Store) LastDeployment

func (s *Store) LastDeployment() (ok bool, d *protobuf.Deployment)

func (*Store) Load

func (s *Store) Load() (err error)

func (*Store) NewDeployment

func (s *Store) NewDeployment(g *protobuf.Generation, operation, reason, bootedStorepath, currentStorepath string) *protobuf.Deployment

func (*Store) NewGeneration

func (s *Store) NewGeneration(hostname, repositoryPath, repositoryDir, systemAttr string, rs *protobuf.RepositoryStatus) (g protobuf.Generation)