Documentation ¶
Index ¶
- 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
- type CedanaStore
- type CheckpointMeta
- type Client
- type Config
- type ConfigClient
- type Connection
- type Docker
- type MockStore
- type NATSStore
- type Notify
- 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
- type SharedStorage
- type Store
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GetProcessName ¶
func GetProcessSimilarity ¶
func UnzipFolder ¶
Types ¶
type ActionScripts ¶
type CedanaStore ¶
type CedanaStore struct {
// contains filtered or unexported fields
}
For pushing and pulling from a cedana managed endpoint
func (*CedanaStore) GetCheckpoint ¶
func (cs *CedanaStore) GetCheckpoint(id string) (*string, error)
ID to GetCheckpoint gets populated from the data sent over as part of a ServerCommand
func (*CedanaStore) ListCheckpoints ¶
func (cs *CedanaStore) ListCheckpoints() (*[]CheckpointMeta, error)
func (*CedanaStore) PushCheckpoint ¶
func (cs *CedanaStore) PushCheckpoint(filepath string) error
TODO NR - multipart uploads & downloads
type CheckpointMeta ¶
type Client ¶
type Client struct { ProcessName string `json:"process_name" mapstructure:"process_name"` LeaveRunning bool `json:"leave_running" mapstructure:"leave_running"` SignalProcessPreDump bool `json:"signal_process_pre_dump" mapstructure:"signal_process_pre_dump"` SignalProcessTimeout int `json:"signal_process_timeout" mapstructure:"signal_process_timeout"` }
type Config ¶
type Config struct { CedanaManaged bool `json:"cedana_managed" mapstructure:"cedana_managed"` Client Client `json:"client" mapstructure:"client"` ActionScripts ActionScripts `json:"action_scripts" mapstructure:"action_scripts"` Connection Connection `json:"connection" mapstructure:"connection"` Docker Docker `json:"docker" mapstructure:"docker"` }
func InitConfig ¶
type ConfigClient ¶
type ConfigClient struct { CedanaManaged bool `json:"cedana_managed"` Client Client `json:"client"` ActionScripts ActionScripts `json:"action_scripts"` Connection Connection `json:"connection"` }
func LoadOverrides ¶
func LoadOverrides(cdir string) (*ConfigClient, error)
type Connection ¶
type Connection struct { NATSUrl string `json:"nats_url" mapstructure:"nats_url"` NATSPort int `json:"nats_port" mapstructure:"nats_port"` NATSAuthToken string `json:"nats_auth_token" mapstructure:"nats_auth_token"` // for cedana managed systems CedanaUrl string `json:"cedana_url" mapstructure:"cedana_url"` CedanaPort int `json:"cedana_port" mapstructure:"cedana_port"` CedanaAuthToken string `json:"cedana_auth_token" mapstructure:"cedana_auth_token"` }
type MockStore ¶
type MockStore struct {
// contains filtered or unexported fields
}
func (*MockStore) GetCheckpoint ¶
func (*MockStore) ListCheckpoints ¶
func (ms *MockStore) ListCheckpoints() (*[]CheckpointMeta, error)
func (*MockStore) PushCheckpoint ¶
type NATSStore ¶
type NATSStore struct {
// contains filtered or unexported fields
}
NATS stores are tied to a job id
func NewNATSStore ¶
func (*NATSStore) GetCheckpoint ¶
func (*NATSStore) ListCheckpoints ¶
func (ns *NATSStore) ListCheckpoints() (*[]CheckpointMeta, error)
func (*NATSStore) PushCheckpoint ¶
type Notify ¶
type Notify struct { Config *Config Logger *zerolog.Logger PreDumpAvail bool PostDumpAvail bool PreRestoreAvail bool }
func (Notify) PostSetupNamespaces ¶
PostSetupNamespaces NoNotify
func (Notify) SetupNamespaces ¶
SetupNamespaces NoNotify
type S3Store ¶
type S3Store struct {
// contains filtered or unexported fields
}
func (*S3Store) GetCheckpoint ¶
func (*S3Store) PushCheckpoint ¶
type SharedStorage ¶
type SharedStorage struct {}
Click to show internal directories.
Click to hide internal directories.