common

package

Go to main page

Versions in this module

v0

v0.2.4

Jun 16, 2026

v0.2.3

Jun 11, 2026

v0.2.2

Jun 9, 2026

Changes in this version

+ func ResolveAgentURL(nodeConfig *NodeConfig) (string, error)

v0.2.1

May 7, 2026

Changes in this version

+ type LoadDriverError struct

+ Code LoadDriverErrorCode

+ DriverID LoadDriverID

+ Err error

+ func (e *LoadDriverError) Error() string

+ type LoadDriverErrorCode string

+ const LoadDriverErrAlreadyRegistered

+ const LoadDriverErrBuildFailed

+ const LoadDriverErrNotRegistered

v0.2.0

May 7, 2026

Changes in this version

type Mode

+ const AgentMode

type NodeState

+ func NewNodeState() NodeState

type NodesRepository

+ GetByAgentId func(agentId string) (NodeEntry, error)

v0.1.10

Apr 22, 2026

Changes in this version

+ type NetworkInterface struct

+ Addresses []string

+ HWAddr string

+ Name string

type NodeState

+ NetworkInterfaces []NetworkInterface

v0.1.9

Apr 13, 2026

Changes in this version

+ func CastMetadata[T any](metadataPtr any) (*T, error)

+ func CopyFile(src, dst string) error

v0.1.8

Apr 9, 2026

Changes in this version

+ func ResolveExecPath(execFile string, workingDir *string) (string, error)

+ func UpdateGuestNodeMetadata[T any](guestNodeName string, repo NodesRepository, updateFn func(metadata *T) error) error

+ func UpdateSelfNodeMetadata[T any](repo NodesRepository, updateFn func(metadata *T) error) error

+ type ContainerState struct

+ CPUSystem float64

+ CPUUsage float64

+ CPUUser float64

+ ContainerID string

+ MemoryLimit float64

+ MemoryPercent float64

+ MemoryUsage float64

+ type ContainerStates map[string]ContainerState

type Node

+ CloudInit *cloudinit.CloudInit

type NodeConfig

+ CloudInit *cloudinit.CloudInit

type NodeDriver

+ GetState func() (NodeState, error)

type NodeDriverInfo

+ GuestMode bool

type NodeEntry

+ CloudInit *cloudinit.CloudInit

+ type NodeState struct

+ Containers []ContainerState

+ CpuLoadAvg float32

+ FreeMem uint64

+ FreeMemPercent float64

+ FreeStorage uint64

+ IdleCPU uint64

+ NumCPU int

+ ProcIdleCount uint32

+ ProcRunningCount uint32

+ ProcSleepingCount uint32

+ ProcStoppedCount uint32

+ ProcThreadsCount uint32

+ ProcTotalCount uint32

+ ProcZombieCount uint32

+ SwapFree uint64

+ SwapTotal uint64

+ SwapUsed uint64

+ SystemCPU uint64

+ TotalCPU uint64

+ TotalMem uint64

+ UsageCPUPercent float64

+ UsedMem uint64

+ UserCPU uint64

type NodesRepository

+ GetAllGuestNodes func() ([]NodeEntry, error)

+ UpdateGuestMetadata func(guestNodeName string, updateFn func(metadataPtr any) error) error

+ UpdateSelfMetadata func(updateFn func(metadataPtr any) error) error

v0.1.5

Mar 11, 2026

Changes in this version

type LoadDriver

+ Start func(repository DeploymentsRepository, deployment Deployment) error

type NewNodeDriverInfoOpts

+ func WithStartMode(m Mode) NewNodeDriverInfoOpts

+ func WithStopMode(m Mode) NewNodeDriverInfoOpts

type NodeDriver

+ Start func(nodeName *string, repository NodesRepository) error

+ Stop func(nodeName *string, message string, time uint32, repository NodesRepository, ...) error

type NodeDriverInfo

+ StartMode Mode

+ StopMode Mode

v0.1.4

Mar 2, 2026

v0.1.3

Mar 1, 2026

v0.1.2

Feb 27, 2026

Changes in this version

+ func UpdateDeploymentMetadata[T any](repo DeploymentsRepository, deploymentID DeploymentID, ...) error

+ type Capabilities interface

+ ContainersEngine func() bool

+ ContainersNetworking func() bool

+ VMM func() bool

+ Volumes func() bool

+ VolumesZFS func() bool

type DeploymentStatusCode

+ const DeploymentStatusNotReady

+ const DeploymentStatusReady

type LoadDriver

+ Deprovision func(repository DeploymentsRepository, deployment Deployment) error

+ Kill func(repository DeploymentsRepository, deployment Deployment) error

+ Provision func(node NodeDriver, repository DeploymentsRepository, loadName string) (DeploymentID, error)

+ Run func(repository DeploymentsRepository, deployment Deployment) error

+ Stop func(repository DeploymentsRepository, deployment Deployment) error

+ UpdateStatus func(repository DeploymentsRepository, deployment Deployment) (DeploymentStatus, error)

+ type Mode int

+ const ClientMode

+ const DaemonMode

+ type NewNodeDriverInfoOpts func(i *NodeDriverInfo) error

+ func WithRestartMode(m Mode) NewNodeDriverInfoOpts

+ func WithShutdownMode(m Mode) NewNodeDriverInfoOpts

+ func WithStartupMode(m Mode) NewNodeDriverInfoOpts

type NodeDriver

+ Deprovision func(repository NodesRepository) error

+ GetCapabilities func() (Capabilities, error)

+ Provision func(nodeName string, repository NodesRepository) error

+ UpdateStatus func(nodeName *string, repository NodesRepository) (NodeStatus, error)

+ type NodeDriverBuilder func(config *any) (NodeDriver, error)

type NodeDriverInfo

+ RestartMode Mode

+ ShutdownMode Mode

+ StartupMode Mode

+ func NewNodeDriverInfo(id NodeDriverID, builder NodeDriverBuilder, opts ...NewNodeDriverInfoOpts) (NodeDriverInfo, error)

type NodeStatus

+ Reason string

+ StatusCode NodeStatusCode

+ type NodeStatusCode string

+ const NodeStatusError

+ const NodeStatusOffline

+ const NodeStatusOnline

+ const NodeStatusReady

type NodesRepository

+ DeleteGuestNode func(guestNodeName string, guestDriver NodeDriver, metadata any) error

+ DeleteSelf func() error

+ GetGuestNode func(guestNodeName string) (NodeEntry, error)

+ SetGuestNode func(guestNodeName string, guestDriver NodeDriver, metadata any) error

+ SetSelf func(nodeName string, driver NodeDriver, metadata any) error

v0.1.1

Feb 9, 2026

v0.1.0

Feb 9, 2026

Changes in this version

+ func CreateLogFile(logsPath LogsPath, filename string, perm os.FileMode) (*os.File, error)

+ func ReadFileAt(filepath string, offset int64) ([]byte, int64, error)

+ func RegisterLoadDriver(d LoadDriver) error

+ func RegisterNodeDriver(d NodeDriver) error

+ func SetDeploymentError(repository DeploymentsRepository, deployment Deployment, msg string, ...) error

+ func TailFile(filepath string, w io.Writer) error

+ func UnregisterLoadDriver(id LoadDriverID) error

+ func UnregisterNodeDriver(id NodeDriverID) error

+ func UpdateMetadata[T any](repo DeploymentsRepository, deploymentID DeploymentID, ...) error

+ type Deployment struct

+ ID DeploymentID

+ LoadDriver LoadDriver

+ LoadName string

+ Metadata any

+ Status DeploymentStatus

+ type DeploymentID = uuid.UUID

+ type DeploymentStatus struct

+ Reason string

+ StatusCode DeploymentStatusCode

+ type DeploymentStatusCode string

+ const DeploymentStatusError

+ const DeploymentStatusNotDeployed

+ const DeploymentStatusPlanned

+ const DeploymentStatusRunning

+ const DeploymentStatusStopped

+ type DeploymentsRepository interface

+ Create func(loadName string, driver LoadDriver, status DeploymentStatus, metadata any) (DeploymentID, error)

+ DeleteByLoad func(loadName string) error

+ DeleteDeployment func(deploymentID uuid.UUID) error

+ GetAll func() ([]Deployment, error)

+ GetByLoad func(loadName string) ([]Deployment, error)

+ GetByLoadAndStatus func(loadName string, statusCode DeploymentStatusCode) ([]Deployment, error)

+ GetDeployment func(deploymentID DeploymentID) (*Deployment, error)

+ UpdateMetadata func(deploymentID DeploymentID, updateFn func(metadata any) error) error

+ UpdateStatus func(deploymentID DeploymentID, status DeploymentStatus) error

+ type Hash [32]byte

+ type HashableLoadConfig struct

+ DependsOn []string

+ Driver LoadDriverID

+ DriverConfig any

+ Name string

+ Node string

+ type Load struct

+ DependsOn []*Load

+ Driver LoadDriver

+ Name string

+ Node *NodeConfig

+ StartChain LoadChain

+ StopChain LoadChain

+ func (l *Load) GetDependencies() []string

+ func (l *Load) Hash() [32]byte

+ func (l *Load) MarshalJSON() ([]byte, error)

+ func (l *Load) UnmarshalJSON(data []byte) error

+ func (l *Load) UpdateLoadChains(configGraph graph.Graph[string, string], loadsMap map[string]*Load)

+ type LoadChain []*Load

+ func (chain LoadChain) Hash() Hash

+ type LoadConfig struct

+ DependsOn []string

+ Driver LoadDriverID

+ DriverConfig any

+ Name string

+ Node string

+ StartChainHash string

+ StopChainHash string

+ type LoadDriver interface

+ DriverInfo func() LoadDriverInfo

+ GetDriverConfig func() LoadDriverConfig

+ GetLoadDriverID func() LoadDriverID

+ KillDeployment func(repository DeploymentsRepository, deployment Deployment) error

+ MarshalJSON func() ([]byte, error)

+ PlanDeployment func(repository DeploymentsRepository, loadName string) (DeploymentID, error)

+ ReadStderr func(repository DeploymentsRepository, deployment Deployment, offset int64) ([]byte, int64, error)

+ ReadStdout func(repository DeploymentsRepository, deployment Deployment, offset int64) ([]byte, int64, error)

+ RunDeployment func(repository DeploymentsRepository, deployment Deployment) error

+ StopDeployment func(repository DeploymentsRepository, deployment Deployment) error

+ StreamStderr func(repository DeploymentsRepository, deployment Deployment, w io.Writer) error

+ StreamStdout func(repository DeploymentsRepository, deployment Deployment, w io.Writer) error

+ UnmarshalJSON func(data []byte) error

+ UnplanDeployment func(repository DeploymentsRepository, deployment Deployment) error

+ UpdateDeploymentStatus func(repository DeploymentsRepository, deployment Deployment) (DeploymentStatus, error)

+ Verify func() error

+ func BuildLoadDriver(d LoadDriverConfig) (LoadDriver, error)

+ type LoadDriverConfig struct

+ Driver LoadDriverID

+ DriverConfig any

+ type LoadDriverID string

+ type LoadDriverInfo struct

+ ID LoadDriverID

+ New func(config any) (LoadDriver, error)

+ type LogsPath string

+ type Node struct

+ Driver NodeDriver

+ Name string

+ Url string

+ func NewNodeFromConfig(config *NodeConfig) (*Node, error)

+ func (n *Node) Hash() [32]byte

+ func (n *Node) MarshalJSON() ([]byte, error)

+ func (n *Node) UnmarshalJSON(data []byte) error

+ type NodeConfig struct

+ Driver NodeDriverID

+ DriverConfig *any

+ Name string

+ Url string

+ type NodeDriver interface

+ DriverInfo func() NodeDriverInfo

+ GetDriverConfig func() NodeDriverConfig

+ GetNodeDriverID func() NodeDriverID

+ GetStatus func() (NodeStatus, error)

+ MarshalJSON func() ([]byte, error)

+ PlanAndRegister func(nodeName string, repository NodesRepository) error

+ Restart func(message string, time uint32) error

+ Shutdown func(message string, time uint32) error

+ Startup func() error

+ UnmarshalJSON func(data []byte) error

+ Verify func() error

+ func BuildNodeDriver(d NodeDriverConfig) (NodeDriver, error)

+ type NodeDriverConfig struct

+ Driver NodeDriverID

+ DriverConfig *any

+ type NodeDriverID string

+ type NodeDriverInfo struct

+ ID NodeDriverID

+ New func(config *any) (NodeDriver, error)

+ type NodeEntry struct

+ Metadata any

+ NodeDriver NodeDriver

+ NodeName string

+ type NodeStatus string

+ const NodeAvailable

+ const NodeNotAvailable

+ type NodesRepository interface

+ Create func(nodeName string, driver NodeDriver, metadata any) error

+ Delete func() error

+ GetByDaemonId func(daemonId string) (NodeEntry, error)

+ GetSelf func() (NodeEntry, error)

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL