Versions in this module Expand all Collapse all v1 v1.0.6 Sep 20, 2020 v1.0.5 Aug 25, 2020 Changes in this version + const EXPIRED_TIME + const TIMEOUT + var IMAGE_MANIFESTS_PATTERN = regexp.Compile("^(.*)://(.*)/v2/(.*)/manifests/(.*)") + func NewManager(cfg *config.Config) (mgr.PreheatManager, error) + func RegisterPreheater(typ string, preheater Preheater) + type BasePreheater struct + func (p *BasePreheater) Cancel(id string) + func (p *BasePreheater) NewWorker(task *mgr.PreheatTask, service *PreheatService) IWorker + func (p *BasePreheater) Remove(id string) + func (p *BasePreheater) Type() string + type BaseWorker struct + PreheatService *PreheatService + Preheater Preheater + Task *mgr.PreheatTask + func (w *BaseWorker) Run() + func (w *BaseWorker) Stop() + type FilePreheat struct + func (p *FilePreheat) NewWorker(task *mgr.PreheatTask, service *PreheatService) IWorker + func (p *FilePreheat) Type() string + type FileWorker struct + type IWorker interface + Run func() + Stop func() + type ImagePreheat struct + func (p *ImagePreheat) NewWorker(task *mgr.PreheatTask, service *PreheatService) IWorker + func (p *ImagePreheat) Type() string + type ImageWorker struct + type Layer struct + type Manager struct + func (m *Manager) Create(ctx context.Context, task *types.PreheatCreateRequest) (preheatID string, err error) + func (m *Manager) Delete(ctx context.Context, preheatID string) (err error) + func (m *Manager) Get(ctx context.Context, preheatID string) (preheatTask *mgr.PreheatTask, err error) + func (m *Manager) GetAll(ctx context.Context) (preheatTasks []*mgr.PreheatTask, err error) + type PreheatProgress struct + func NewPreheatProgress(output string, cmd *exec.Cmd) *PreheatProgress + type PreheatService struct + PreheatPath string + func NewPreheatService(homeDir string) *PreheatService + func (svc *PreheatService) Create(task *mgr.PreheatTask) (string, error) + func (svc *PreheatService) Delete(id string) + func (svc *PreheatService) ExecutePreheat(task *mgr.PreheatTask) (progress *PreheatProgress, err error) + func (svc *PreheatService) Get(id string) *mgr.PreheatTask + func (svc *PreheatService) GetAll() []*mgr.PreheatTask + func (svc *PreheatService) Update(id string, task *mgr.PreheatTask) bool + type PreheatTaskRepository struct + func NewPreheatTaskRepository() *PreheatTaskRepository + func (r *PreheatTaskRepository) Add(task *mgr.PreheatTask) (*mgr.PreheatTask, error) + func (r *PreheatTaskRepository) Delete(id string) bool + func (r *PreheatTaskRepository) Get(id string) *mgr.PreheatTask + func (r *PreheatTaskRepository) GetAll() []*mgr.PreheatTask + func (r *PreheatTaskRepository) GetAllIds() []string + func (r *PreheatTaskRepository) IsExpired(id string) bool + func (r *PreheatTaskRepository) Update(id string, task *mgr.PreheatTask) bool + type Preheater interface + Cancel func(id string) + NewWorker func(task *mgr.PreheatTask, service *PreheatService) IWorker + Remove func(id string) + Type func() string + func GetPreheater(typ string) Preheater