containerkeepaliver

Documentation

Index

• type ContainerKeepAliver
  • func NewContainerKeepAliver(logger lager.Logger, workerClient worker.Client, db ContainerKeepAliverDB, ...) ContainerKeepAliver
• type ContainerKeepAliverDB

Types

type ContainerKeepAliver

type ContainerKeepAliver interface {
	Run() error
}

func NewContainerKeepAliver

func NewContainerKeepAliver(
	logger lager.Logger,
	workerClient worker.Client,
	db ContainerKeepAliverDB,
	pipelineDBFactory db.PipelineDBFactory,
) ContainerKeepAliver

type ContainerKeepAliverDB

type ContainerKeepAliverDB interface {
	FindJobIDForBuild(buildID int) (int, bool, error)
	FindLatestSuccessfulBuildsPerJob() (map[int]int, error)
	FindJobContainersFromUnsuccessfulBuilds() ([]db.SavedContainer, error)
	UpdateExpiresAtOnContainer(handle string, ttl time.Duration) error
	GetPipelineByID(pipelineID int) (db.SavedPipeline, error)
}