utils

May 14, 2024

Changes in this version

+ const DEFAULT_LOG_LEVEL

+ const LOG_CALLER_SKIP

+ const LOG_TIME_FORMAT_FULL

type Config

+ func GetConfig() (*Config, error)

+ type LineInfoHook struct

+ func (h LineInfoHook) Run(e *zerolog.Event, l zerolog.Level, msg string)

Feb 22, 2024

Changes in this version

+ func InitOtel(ctx context.Context, version string) (shutdown func(context.Context) error, err error)

Jan 23, 2024

Changes in this version

+ const MaxNameLen

+ func SendFile(socket *os.File, file *os.File) error

+ func SendRawFd(socket *os.File, msg string, fd uintptr) error

+ func WriteJSON(w io.Writer, v interface{}) error

type CedanaStore

+ func (cs *CedanaStore) FullMultipartUpload(checkpointPath string) (*UploadResponse, error)

type Notify

+ PostDumpFunc NotifyFunc

+ PreDumpFunc NotifyFunc

+ PreRestoreFunc NotifyFunc

+ PreResumeFunc NotifyFunc

+ func (n Notify) PreResume() error

+ type NotifyFunc struct

+ Avail bool

+ Callback func() error

Dec 6, 2023

Changes in this version

+ type OperationType string

+ const CompressOp

+ const CriuCheckpointOp

+ const CriuRestoreOp

+ const DecompressOp

+ const DownloadOp

+ const UploadOp

+ type Timings struct

+ func NewTimings() *Timings

+ func (t *Timings) Flush() error

+ func (t *Timings) Start(name OperationType)

+ func (t *Timings) Stop(name OperationType)

Dec 5, 2023

Changes in this version

+ func TarFolder(srcFolder, destTar string) error

+ func TarGzFolder(srcFolder, destTar string) error

+ func TarLZ4Folder(srcFolder, destTar string) error

+ func UntarFolder(srcTar, destFolder string) error

+ func UntarGzFolder(srcTarGz, destFolder string) error

Nov 30, 2023

Changes in this version

+ func GenSampleConfig() string

type Connection

+ CedanaUser string

Nov 13, 2023

Changes in this version

+ const StorePath

+ func StartPprofServer()

Oct 24, 2023

Changes in this version

+ var AliasesBkt = []byte(aliasesName)

+ var AllCtrsBkt = []byte(allCtrsName)

+ var AllPodsBkt = []byte(allPodsName)

+ var AllVolsBkt = []byte(allVolsName)

+ var ConfigKey = []byte(configName)

+ var ContainersBkt = []byte(containersName)

+ var CtrBkt = []byte(ctrName)

+ var DependenciesBkt = []byte(dependenciesName)

+ var ExecBkt = []byte(execName)

+ var ExitCodeBkt = []byte(exitCodeName)

+ var ExitCodeTimeStampBkt = []byte(exitCodeTimeStampName)

+ var GraphDriverKey = []byte(graphDriverName)

+ var GraphRootKey = []byte(graphRootName)

+ var IDRegistryBkt = []byte(idRegistryName)

+ var NameRegistryBkt = []byte(nameRegistryName)

+ var NetNSKey = []byte(netNSName)

+ var NetworksBkt = []byte(networksName)

+ var OsKey = []byte(osName)

+ var PodBkt = []byte(podName)

+ var PodIDKey = []byte(podIDName)

+ var RunRootKey = []byte(runRootName)

+ var RuntimeConfigBkt = []byte(runtimeConfigName)

+ var StateKey = []byte(stateName)

+ var StaticDirKey = []byte(staticDirName)

+ var TmpDirKey = []byte(tmpDirName)

+ var VolBkt = []byte(volName)

+ var VolCtrsBkt = []byte(volumeCtrsName)

+ var VolDependenciesBkt = []byte(volCtrDependencies)

+ var VolPathKey = []byte(volPathName)

+ func CRImportCheckpoint(ctx context.Context, dir, containerId string) error

+ func CreateContainer(ctrState *map[string]interface{}, ctrConfig *types.ContainerConfig, db *DB, ...) error

+ func GetAllCtrsBucket(tx *bolt.Tx) (*bolt.Bucket, error)

+ func GetCtrBucket(tx *bolt.Tx) (*bolt.Bucket, error)

+ func GetIDBucket(tx *bolt.Tx) (*bolt.Bucket, error)

+ func GetNamesBucket(tx *bolt.Tx) (*bolt.Bucket, error)

+ func GetVolBucket(tx *bolt.Tx) (*bolt.Bucket, error)

+ func JSONDeepCopy(from, to interface{}) error

+ func NewFromFile(path string) (*rspec.Spec, envCache, error)

+ func NewFromTemplate(r io.Reader) (*rspec.Spec, envCache, error)

+ func ReadJSONFile(v interface{}, dir, file string) (string, error)

+ func WriteJSONFile(v interface{}, dir, file string) (string, error)

type CedanaStore

+ func NewCedanaStore(cfg *Config) *CedanaStore

+ func (cs *CedanaStore) CompleteMultiPartUpload(uploadResp UploadResponse, cid string) error

+ func (cs *CedanaStore) CreateMultiPartUpload(fullSize int64) (UploadResponse, string, error)

+ func (cs *CedanaStore) StartMultiPartUpload(cid string, uploadResp *UploadResponse, checkpointPath string) error

type Client

+ ForwardLogs bool

+ type Criu struct

+ func MakeCriu() *Criu

+ func (c *Criu) Cleanup()

+ func (c *Criu) Dump(opts *rpc.CriuOpts, nfy *Notify) (*rpc.CriuResp, error)

+ func (c *Criu) GetCriuVersion() (int, error)

+ func (c *Criu) IsCriuAtLeast(version int) (bool, error)

+ func (c *Criu) PreDump(opts *rpc.CriuOpts, nfy *Notify) (*rpc.CriuResp, error)

+ func (c *Criu) Prepare() error

+ func (c *Criu) Restore(opts *rpc.CriuOpts, nfy *Notify) (*rpc.CriuResp, error)

+ func (c *Criu) SetCriuPath(path string)

+ type DB struct

+ Conn *bolt.DB

+ DbLock sync.Mutex

+ DbPath string

+ func (db *DB) SetNewDbConn() error

+ func (s *DB) GetContainerConfigFromDB(id []byte, config *map[string]interface{}, ctrsBkt *bolt.Bucket) error

+ func (s *DB) GetContainerStateDB(id []byte, state *map[string]interface{}, ctrsBkt *bolt.Bucket) error

+ type UploadResponse struct

+ PartCount int

+ PartSize int

+ UploadID string

Aug 29, 2023

Changes in this version

+ var File_profile_proto protoreflect.FileDescriptor

+ func CreateTestConn(t *testing.T) *nats.Conn

+ func CreateTestJetstream(t *testing.T) jetstream.JetStream

+ func RunDefaultServer(t *testing.T) *server.Server

type Client

+ Task string

+ type Function struct

+ Filename int64

+ Id uint64

+ Name int64

+ StartLine int64

+ SystemName int64

+ func (*Function) Descriptor() ([]byte, []int)

+ func (*Function) ProtoMessage()

+ func (x *Function) GetFilename() int64

+ func (x *Function) GetId() uint64

+ func (x *Function) GetName() int64

+ func (x *Function) GetStartLine() int64

+ func (x *Function) GetSystemName() int64

+ func (x *Function) ProtoReflect() protoreflect.Message

+ func (x *Function) Reset()

+ func (x *Function) String() string

+ type Label struct

+ Key int64

+ Num int64

+ NumUnit int64

+ Str int64

+ func (*Label) Descriptor() ([]byte, []int)

+ func (*Label) ProtoMessage()

+ func (x *Label) GetKey() int64

+ func (x *Label) GetNum() int64

+ func (x *Label) GetNumUnit() int64

+ func (x *Label) GetStr() int64

+ func (x *Label) ProtoReflect() protoreflect.Message

+ func (x *Label) Reset()

+ func (x *Label) String() string

+ type Line struct

+ FunctionId uint64

+ Line int64

+ func (*Line) Descriptor() ([]byte, []int)

+ func (*Line) ProtoMessage()

+ func (x *Line) GetFunctionId() uint64

+ func (x *Line) GetLine() int64

+ func (x *Line) ProtoReflect() protoreflect.Message

+ func (x *Line) Reset()

+ func (x *Line) String() string

+ type Location struct

+ Address uint64

+ Id uint64

+ IsFolded bool

+ Line []*Line

+ MappingId uint64

+ func (*Location) Descriptor() ([]byte, []int)

+ func (*Location) ProtoMessage()

+ func (x *Location) GetAddress() uint64

+ func (x *Location) GetId() uint64

+ func (x *Location) GetIsFolded() bool

+ func (x *Location) GetLine() []*Line

+ func (x *Location) GetMappingId() uint64

+ func (x *Location) ProtoReflect() protoreflect.Message

+ func (x *Location) Reset()

+ func (x *Location) String() string

+ type Mapping struct

+ BuildId int64

+ FileOffset uint64

+ Filename int64

+ HasFilenames bool

+ HasFunctions bool

+ HasInlineFrames bool

+ HasLineNumbers bool

+ Id uint64

+ MemoryLimit uint64

+ MemoryStart uint64

+ func (*Mapping) Descriptor() ([]byte, []int)

+ func (*Mapping) ProtoMessage()

+ func (x *Mapping) GetBuildId() int64

+ func (x *Mapping) GetFileOffset() uint64

+ func (x *Mapping) GetFilename() int64

+ func (x *Mapping) GetHasFilenames() bool

+ func (x *Mapping) GetHasFunctions() bool

+ func (x *Mapping) GetHasInlineFrames() bool

+ func (x *Mapping) GetHasLineNumbers() bool

+ func (x *Mapping) GetId() uint64

+ func (x *Mapping) GetMemoryLimit() uint64

+ func (x *Mapping) GetMemoryStart() uint64

+ func (x *Mapping) ProtoReflect() protoreflect.Message

+ func (x *Mapping) Reset()

+ func (x *Mapping) String() string

+ type Profile struct

+ Comment []int64

+ DefaultSampleType int64

+ DropFrames int64

+ DurationNanos int64

+ Function []*Function

+ KeepFrames int64

+ Location []*Location

+ Mapping []*Mapping

+ Period int64

+ PeriodType *ValueType

+ Sample []*Sample

+ SampleType []*ValueType

+ StringTable []string

+ TimeNanos int64

+ func (*Profile) Descriptor() ([]byte, []int)

+ func (*Profile) ProtoMessage()

+ func (x *Profile) GetComment() []int64

+ func (x *Profile) GetDefaultSampleType() int64

+ func (x *Profile) GetDropFrames() int64

+ func (x *Profile) GetDurationNanos() int64

+ func (x *Profile) GetFunction() []*Function

+ func (x *Profile) GetKeepFrames() int64

+ func (x *Profile) GetLocation() []*Location

+ func (x *Profile) GetMapping() []*Mapping

+ func (x *Profile) GetPeriod() int64

+ func (x *Profile) GetPeriodType() *ValueType

+ func (x *Profile) GetSample() []*Sample

+ func (x *Profile) GetSampleType() []*ValueType

+ func (x *Profile) GetStringTable() []string

+ func (x *Profile) GetTimeNanos() int64

+ func (x *Profile) ProtoReflect() protoreflect.Message

+ func (x *Profile) Reset()

+ func (x *Profile) String() string

+ type Sample struct

+ Label []*Label

+ LocationId []uint64

+ Value []int64

+ func (*Sample) Descriptor() ([]byte, []int)

+ func (*Sample) ProtoMessage()

+ func (x *Sample) GetLabel() []*Label

+ func (x *Sample) GetLocationId() []uint64

+ func (x *Sample) GetValue() []int64

+ func (x *Sample) ProtoReflect() protoreflect.Message

+ func (x *Sample) Reset()

+ func (x *Sample) String() string

+ type ValueType struct

+ Type int64

+ Unit int64

+ func (*ValueType) Descriptor() ([]byte, []int)

+ func (*ValueType) ProtoMessage()

+ func (x *ValueType) GetType() int64

+ func (x *ValueType) GetUnit() int64

+ func (x *ValueType) ProtoReflect() protoreflect.Message

+ func (x *ValueType) Reset()

+ func (x *ValueType) String() string

Aug 14, 2023

Changes in this version

+ func CopyFile(src, dstFolder string) error

+ func GenerateJWT(id string, skey string) (*string, error)

+ func GetLogger() zerolog.Logger

+ func GetPid(processName string) (int32, error)

+ func GetProcessName(pid int32) (*string, error)

+ func GetProcessSimilarity(processName string, processes []*ps.Process) (int32, error)

+ func UnzipFolder(src, dest string) error

+ func ZipFolder(folderPath, zipFilePath string) error

+ type ActionScripts struct

+ PostDump string

+ PreDump string

+ PreRestore string

+ type CedanaStore struct

+ func (cs *CedanaStore) GetCheckpoint(id string) (*string, error)

+ func (cs *CedanaStore) ListCheckpoints() (*[]CheckpointMeta, error)

+ func (cs *CedanaStore) PushCheckpoint(filepath string) error

+ type CheckpointMeta struct

+ Bucket string

+ Checksum string

+ ID string

+ ModTime time.Time

+ Name string

+ Size uint64

+ type Client struct

+ LeaveRunning bool

+ ProcessName string

+ SignalProcessPreDump bool

+ SignalProcessTimeout int

+ type Config struct

+ ActionScripts ActionScripts

+ CedanaManaged bool

+ Client Client

+ Connection Connection

+ Docker Docker

+ SharedStorage SharedStorage

+ func InitConfig() (*Config, error)

+ type ConfigClient struct

+ ActionScripts ActionScripts

+ CedanaManaged bool

+ Client Client

+ Connection Connection

+ SharedStorage SharedStorage

+ func LoadOverrides(cdir string) (*ConfigClient, error)

+ type Connection struct

+ CedanaAuthToken string

+ CedanaPort int

+ CedanaUrl string

+ NATSAuthToken string

+ NATSPort int

+ NATSUrl string

+ type Docker struct

+ CheckpointID string

+ ContainerName string

+ LeaveRunning bool

+ type MockStore struct

+ func (ms *MockStore) GetCheckpoint() (*string, error)

+ func (ms *MockStore) ListCheckpoints() (*[]CheckpointMeta, error)

+ func (ms *MockStore) PushCheckpoint(filepath string) error

+ type NATSStore struct

+ func NewNATSStore(logger *zerolog.Logger, jsc nats.JetStreamContext, jobID string) *NATSStore

+ func (ns *NATSStore) GetCheckpoint(checkpointFilePath string) (*string, error)

+ func (ns *NATSStore) ListCheckpoints() (*[]CheckpointMeta, error)

+ func (ns *NATSStore) PushCheckpoint(filepath string) error

+ type Notify struct

+ Config *Config

+ Logger *zerolog.Logger

+ PostDumpAvail bool

+ PreDumpAvail bool

+ PreRestoreAvail bool

+ func (n Notify) NetworkLock() error

+ func (n Notify) NetworkUnlock() error

+ func (n Notify) PostDump() error

+ func (n Notify) PostRestore(pid int32) error

+ func (n Notify) PostResume() error

+ func (n Notify) PostSetupNamespaces() error

+ func (n Notify) PreDump() error

+ func (n Notify) PreRestore() error

+ func (n Notify) SetupNamespaces(pid int32) error

+ type S3Store struct

+ func (s *S3Store) GetCheckpoint() (*string, error)

+ func (s *S3Store) PushCheckpoint(filepath string) error

+ type SharedStorage struct

+ DumpStorageDir string

+ MountPoint string

+ type Store interface

+ GetCheckpoint func(string) (*string, error)

+ ListCheckpoints func() (*[]CheckpointMeta, error)

+ PushCheckpoint func(filepath string) error