agent

Dec 5, 2025

Changes in this version

+ const QuorumMajority

+ type DrbdConfiguration struct

+ Options struct{ ... }

+ Resource string

+ type DrbdResource struct

+ Config DrbdConfiguration

+ Name string

+ State DrbdResourceState

Jan 20, 2025

Changes in this version

type Options

+ DisableNodeTaints bool

Jan 5, 2024

Changes in this version

+ const PersistentVolumeByPersistentVolumeClaimIndex

+ const PersistentVolumeByResourceDefinitionIndex

+ const PodByPersistentVolumeClaimIndex

+ const SatellitePodIndex

+ const VolumeAttachmentByPersistentVolumeIndex

type Options

+ SatellitePodSelector labels.Selector

Sep 20, 2022

Changes in this version

+ type DrbdDevice struct

+ Quorum bool

Aug 8, 2022

Changes in this version

type Options

+ FailOverUnsafePods bool

Jul 21, 2022

Changes in this version

+ func NewAgent(opt *Options) (*agent, error)

+ func TaintNode(ctx context.Context, client kubernetes.Interface, node *corev1.Node, ...) (bool, error)

+ type DrbdConnection struct

+ ApInFlight int

+ Congested bool

+ ConnectionState string

+ Name string

+ PeerDevices []struct{ ... }

+ PeerNodeId int

+ PeerRole string

+ RsInFlight int

+ type DrbdResourceState struct

+ Connections []DrbdConnection

+ Devices []struct{ ... }

+ ForceIoFailures bool

+ Name string

+ NodeId int

+ Role string

+ Suspended bool

+ SuspendedFencing bool

+ SuspendedNoData bool

+ SuspendedQuorum bool

+ SuspendedUser bool

+ WriteOrdering string

+ func (d *DrbdResourceState) HasQuorum() bool

+ func (d *DrbdResourceState) MayPromote() bool

+ func (d *DrbdResourceState) Primary() bool

+ type DrbdResources interface

+ Get func() []DrbdResourceState

+ StartUpdates func(ctx context.Context) error

+ func NewDrbdResources(resync time.Duration) DrbdResources

+ type Options struct

+ DeletionGraceSec int64

+ DrbdStatusInterval time.Duration

+ FailOverTimeout time.Duration

+ NodeName string

+ OperationTimeout time.Duration

+ ReconcileInterval time.Duration

+ RestConfig *rest.Config

+ ResyncInterval time.Duration

+ func (o *Options) Timeout() time.Duration

+ type ReconcileRequest struct

+ Attachments []*storagev1.VolumeAttachment

+ Nodes []*corev1.Node

+ Pods []*corev1.Pod

+ RefTime time.Time

+ Resource *DrbdResourceState

+ Volume *corev1.PersistentVolume

+ func (r *ReconcileRequest) FindNode(name string) *corev1.Node

+ type Reconciler interface

+ RunForResource func(ctx context.Context, req *ReconcileRequest, recorder events.EventRecorder) error

+ func NewFailoverReconciler(opt *Options, client kubernetes.Interface) Reconciler

+ func NewForceIoErrorReconciler(opt *Options, client kubernetes.Interface) Reconciler

+ func NewSuspendedPodReconciler(opt *Options) Reconciler