clusterd

Jul 18, 2023

Changes in this version

type Context

+ ApiExtensionsClient apiextensionsclient.Interface

May 16, 2023

Changes in this version

+ func DiscoverDevicesWithFilter(executor exec.Executor, deviceFilter, metaDevice string) ([]*sys.LocalDisk, error)

Aug 12, 2021

Changes in this version

type Context

+ DynamicClientset dynamic.Interface

Jul 22, 2021

Changes in this version

type Context

+ RemoteExecutor exec.RemotePodCommandExecutor

Dec 2, 2020

Changes in this version

type Context

+ RequestCancelOrchestration *abool.AtomicBool

Aug 6, 2020

Changes in this version

type Context

+ Client client.Client

Apr 7, 2020

Changes in this version

type Context

+ NetworkClient netclient.K8sCniCncfIoV1Interface

Sep 12, 2019

Changes in this version

+ func PopulateDeviceInfo(d string, executor exec.Executor) *sys.LocalDisk

+ func PopulateDeviceUdevInfo(d string, executor exec.Executor, disk *sys.LocalDisk) *sys.LocalDisk

type Context

+ KubeConfig *rest.Config

Jul 18, 2018

Changes in this version

+ func GetDeviceEmpty(device *sys.LocalDisk) bool

type NetworkInfo

+ ClusterAddr string

+ PublicAddr string

+ func (in NetworkInfo) Simplify() NetworkInfo

Feb 21, 2018

Changes in this version

type Context

+ RookClientset rookclient.Interface

Nov 8, 2017

Changes in this version

+ func GetAvailableDevices(devices []*LocalDisk) []string

type Context

+ Devices []*LocalDisk

+ type LocalDisk struct

+ Empty bool

+ FileSystem string

+ HasChildren bool

+ ID string

+ MountPoint string

+ Name string

+ Parent string

+ Readonly bool

+ Rotational bool

+ Size uint64

+ Type string

+ UUID string

+ func DiscoverDevices(executor exec.Executor) ([]*LocalDisk, error)

Aug 8, 2017

Changes in this version

type Context

+ APIExtensionClientset apiextensionsclient.Interface

+ Clientset kubernetes.Interface

+ type DirectContext struct

+ EtcdClient etcd.KeysAPI

+ Inventory *inventory.Config

+ NodeID string

+ Services []*ClusterService

Mar 3, 2017

Changes in this version

+ func VerifyNetworkInfo(networkInfo NetworkInfo) error

type Context

+ ConfigFileOverride string

+ NetworkInfo NetworkInfo

+ func ToContext(context *DaemonContext) *Context

+ type DaemonContext struct

+ ConfigDir string

+ ConfigFileOverride string

+ Executor exec.Executor

+ LogLevel capnslog.LogLevel

+ ProcMan *proc.ProcManager

+ func NewDaemonContext(dataDir, cephConfigOverride string, logLevel capnslog.LogLevel) *DaemonContext

+ func ToDaemonContext(context *Context) *DaemonContext

+ type NetworkInfo struct

+ ClusterAddrIPv4 string

+ ClusterNetwork string

+ PublicAddrIPv4 string

+ PublicNetwork string

Dec 5, 2016

Changes in this version

+ const AppliedKey

+ const DesiredKey

type Context

+ LogLevel capnslog.LogLevel

Nov 8, 2016

Changes in this version

+ const EtcdRequestTimeout

+ const InfiniteTimeout

+ const LeaderElectionKey

+ const LeaderKey

+ const NodeConfigStatusAbort

+ const NodeConfigStatusFailed

+ const NodeConfigStatusNotTriggered

+ const NodeConfigStatusRunning

+ const NodeConfigStatusSucceeded

+ const NodeConfigStatusTimeout

+ const NodeConfigStatusTriggered

+ const NodeConfigStatusUnknown

+ const NodeStatusRootKey

+ const NodeStatusServiceKey

+ const StatusValue

+ const SystemLogDir

+ func ConfigureServiceIfTriggered(context *Context, agent ServiceAgent) bool

+ func GetNodeProgressKey(nodeID string) string

+ func GetNodeStatusKey(service, nodeID string) string

+ func IsLeader(l Lease, nodeID string) bool

+ func IsNodeUnhealthy(node *inventory.NodeConfig) (int, bool)

+ func RunConfigureAgent(context *Context, agent ServiceAgent) error

+ func SetNodeConfigStatus(etcdClient etcd.KeysAPI, nodeID, taskKey string, nodeStatus NodeConfigStatus) error

+ func SetNodeConfigStatusWithPrevIndex(etcdClient etcd.KeysAPI, nodeID string, nodeStatus NodeConfigStatus, ...) (*etcd.Response, error)

+ func TriggerAgents(etcdClient etcd.KeysAPI, nodeIDs []string, agentKey string) error

+ func TriggerAgentsAndWait(etcdClient etcd.KeysAPI, nodeIDs []string, agentKey string, ...) error

+ func TriggerAgentsAndWaitForCompletion(etcdClient etcd.KeysAPI, nodeIDs []string, agentKey string, ...) error

+ func WaitForNodeConfigCompletion(etcdClient etcd.KeysAPI, taskKey string, nodes []string, timeout int) (int, error)

+ type ClusterMember struct

+ func (r *ClusterMember) ElectLeader() error

+ type ClusterRefresher struct

+ func NewClusterRefresher() *ClusterRefresher

+ func (c *ClusterRefresher) Start()

+ func (c *ClusterRefresher) Stop()

+ func (c *ClusterRefresher) TriggerDevicesChanged(nodeID string) bool

+ func (c *ClusterRefresher) TriggerRefresh() bool

+ type ClusterService struct

+ Agents []ServiceAgent

+ Leader ServiceLeader

+ Name string

+ type Context struct

+ ConfigDir string

+ Debug bool

+ EtcdClient etcd.KeysAPI

+ Executor exec.Executor

+ Inventory *inventory.Config

+ NodeID string

+ ProcMan *proc.ProcManager

+ Services []*ClusterService

+ func StartJoinCluster(services []*ClusterService, ...) (*Context, error)

+ func (c *Context) GetEtcdClient() (etcd.KeysAPI, error)

+ func (c *Context) GetExecutor() exec.Executor

+ type Leader interface

+ GetLeaseName func() string

+ OnLeadershipAcquired func() error

+ OnLeadershipLost func() error

+ type Lease interface

+ Index func() uint64

+ MachineID func() string

+ Release func() error

+ Renew func(time.Duration) error

+ TimeRemaining func() time.Duration

+ Version func() int

+ type Manager interface

+ AcquireLease func(name, machID string, ver int, period time.Duration) (Lease, error)

+ GetLease func(name string) (Lease, error)

+ StealLease func(name, machID string, ver int, period time.Duration, idx uint64) (Lease, error)

+ type NodeConfigStatus int

+ func GetNodeConfigStatus(etcdClient etcd.KeysAPI, taskKey, nodeID string) (NodeConfigStatus, uint64, error)

+ func ParseNodeConfigStatus(status string) NodeConfigStatus

+ func WatchNodeConfigStatus(etcdClient etcd.KeysAPI, taskKey, nodeID string, timeout int, index *uint64) (NodeConfigStatus, error)

+ func (n NodeConfigStatus) String() string

+ type RefreshEvent struct

+ Context *Context

+ NodesAdded *util.Set

+ NodesChanged *util.Set

+ NodesRemoved *util.Set

+ NodesUnhealthy map[string]*UnhealthyNode

+ func NewRefreshEvent() *RefreshEvent

+ type RefreshKey struct

+ Path string

+ Triggered func(response *etcd.Response, refresher *ClusterRefresher)

+ type ServiceAgent interface

+ ConfigureLocalService func(context *Context) error

+ DestroyLocalService func(context *Context) error

+ Initialize func(context *Context) error

+ Name func() string

+ type ServiceLeader interface

+ HandleRefresh func(e *RefreshEvent)

+ RefreshKeys func() []*RefreshKey

+ type UnhealthyNode struct

+ AgeSeconds int

+ ID string