handler

Sep 1, 2022

Changes in this version

+ func CompsNeedHandleImage(comps map[string]schema.Component) bool

type FsHandler

+ func (fh *FsHandler) IsDir(path string) (bool, error)

type PathTimeMap

+ func (pm *PathTimeMap) LatestTime() (path string, latestTime time.Time)

Jun 1, 2022

Changes in this version

+ const RegistryUrl

+ const TarFile

+ var NewFsHandlerWithServer = func(fsID string, logEntry *log.Entry) (*FsHandler, error)

+ var ReadFileFromFs = func(fsID, filePath string, logEntry *log.Entry) ([]byte, error)

+ func NeedHandleImage(dockerEnv string) bool

+ type FsHandler struct

+ func MockerNewFsHandlerWithServer(fsID string, logEntry *log.Entry) (*FsHandler, error)

+ func (fh *FsHandler) Exist(path string) (bool, error)

+ func (fh *FsHandler) LastModTime(path string) (time.Time, error)

+ func (fh *FsHandler) MkdirAll(path string, perm os.FileMode) error

+ func (fh *FsHandler) ModTime(path string) (time.Time, error)

+ func (fh *FsHandler) ReadFsFile(path string) ([]byte, error)

+ func (fh *FsHandler) RemoveAll(path string) error

+ func (fh *FsHandler) Stat(path string) (os.FileInfo, error)

+ type FsServerEmptyError struct

+ func (e FsServerEmptyError) Error() string

+ type ImageConfig struct

+ Config string

+ Layers []string

+ RepoTags []string

+ type ImageHandler struct

+ UrlMap sync.Map

+ var PFImageHandler *ImageHandler

+ func InitPFImageHandler() (*ImageHandler, error)

+ func (handler *ImageHandler) ExecCBAndRemoveHandleID(logEntry *log.Entry, handleID, imageID, imageUrl string, err error)

+ func (handler *ImageHandler) HandleImage(dockerEnv, runID, fsID string, imageIDs []string, logEntry *log.Entry, ...) error

+ func (handler *ImageHandler) HandleTarImage(dockerEnv, runID, fsID string, imageIDs []string, logEntry *log.Entry, ...) (err error)

+ func (handler *ImageHandler) HandleUrlImage(dockerEnv, runID, fsID string, logEntry *log.Entry, ...) error

+ func (handler *ImageHandler) IsImageExistInRepo(handleInfo imageHandleInfo, imageID string) bool

+ func (handler *ImageHandler) RemoveImage(logEntry *log.Entry, imageID []string)

+ func (handler *ImageHandler) Run()

+ func (handler *ImageHandler) Stop()

+ type ImageHandlerCallBackFunc func(imageInfo ImageInfo, err error) error

+ type ImageHandlerError struct

+ func (e ImageHandlerError) Error() string

+ type ImageInfo struct

+ FsID string

+ ImageID string

+ PFImageID string

+ RunID string

+ Source string

+ Url string

+ UrlUpdated bool

+ type PathTimeMap struct

+ PTMap map[string]time.Time

+ func (pm *PathTimeMap) LatesTime() (path string, latestTime time.Time)

+ func (pm *PathTimeMap) WalkFunc(path string, info iofs.FileInfo, err error) error