agent

type DrbdConnection struct {
	PeerNodeId      int    `json:"peer-node-id"`
	Name            string `json:"name"`
	ConnectionState string `json:"connection-state"`
	Congested       bool   `json:"congested"`
	PeerRole        string `json:"peer-role"`
	ApInFlight      int    `json:"ap-in-flight"`
	RsInFlight      int    `json:"rs-in-flight"`
	PeerDevices     []struct {
		Volume                 int     `json:"volume"`
		ReplicationState       string  `json:"replication-state"`
		PeerDiskState          string  `json:"peer-disk-state"`
		PeerClient             bool    `json:"peer-client"`
		ResyncSuspended        string  `json:"resync-suspended"`
		Received               int     `json:"received"`
		Sent                   int     `json:"sent"`
		OutOfSync              int     `json:"out-of-sync"`
		Pending                int     `json:"pending"`
		Unacked                int     `json:"unacked"`
		HasSyncDetails         bool    `json:"has-sync-details"`
		HasOnlineVerifyDetails bool    `json:"has-online-verify-details"`
		PercentInSync          float64 `json:"percent-in-sync"`
	} `json:"peer_devices"`
}

type DrbdResourceState struct {
	Name             string `json:"name"`
	NodeId           int    `json:"node-id"`
	Role             string `json:"role"`
	Suspended        bool   `json:"suspended"`
	SuspendedUser    bool   `json:"suspended-user"`
	SuspendedNoData  bool   `json:"suspended-no-data"`
	SuspendedFencing bool   `json:"suspended-fencing"`
	SuspendedQuorum  bool   `json:"suspended-quorum"`
	ForceIoFailures  bool   `json:"force-io-failures"`
	WriteOrdering    string `json:"write-ordering"`
	Devices          []struct {
		Volume       int    `json:"volume"`
		Minor        int    `json:"minor"`
		DiskState    string `json:"disk-state"`
		Client       bool   `json:"client"`
		Quorum       bool   `json:"quorum"`
		Size         int    `json:"size"`
		Read         int    `json:"read"`
		Written      int    `json:"written"`
		AlWrites     int    `json:"al-writes"`
		BmWrites     int    `json:"bm-writes"`
		UpperPending int    `json:"upper-pending"`
		LowerPending int    `json:"lower-pending"`
	} `json:"devices"`
	Connections []DrbdConnection `json:"connections"`
}

type DrbdResources interface {
	// StartUpdates starts the process of updating the current state of DRBD resources.
	StartUpdates(ctx context.Context) error
	// Get returns the resource state at the time the last update was made.
	Get() []DrbdResourceState
}

type Options struct {
	// NodeName is the name of the local node, as used by DRBD and Kubernetes.
	NodeName string
	// RestConfig is the config used to connect to Kubernetes.
	RestConfig *rest.Config
	// DeletionGraceSec is the number of seconds to wait for graceful pod termination in eviction/deletion requests.
	DeletionGraceSec int64
	// ReconcileInterval is the maximum interval between reconcilation runs.
	ReconcileInterval time.Duration
	// ResyncInterval is the maximum interval between resyncing internal caches with Kubernetes.
	ResyncInterval time.Duration
	// DrbdStatusInterval is the maxmimum interval between drbd state updates.
	DrbdStatusInterval time.Duration
	// OperationTimeout is the timeout used for reconcile operations.
	OperationTimeout time.Duration
	// FailOverTimeout is minimum wait between noticing quorum loss and starting the fail-over process.
	FailOverTimeout time.Duration
}

type ReconcileRequest struct {
	RefTime     time.Time
	Resource    *DrbdResourceState
	Volume      *corev1.PersistentVolume
	Pods        []*corev1.Pod
	Attachments []*storagev1.VolumeAttachment
	Nodes       []*corev1.Node
}

type Reconciler interface {
	RunForResource(ctx context.Context, req *ReconcileRequest, recorder events.EventRecorder) error
}