agent

type DrbdConnection struct {
	Name            string `json:"name"`
	PeerRole        string `json:"peer-role"`
	ConnectionState string `json:"connection-state"`
}

type DrbdDevice struct {
	Quorum bool `json:"quorum"`
}

type DrbdResourceState struct {
	Name            string           `json:"name"`
	Role            string           `json:"role"`
	Suspended       bool             `json:"suspended"`
	ForceIoFailures bool             `json:"force-io-failures"`
	Devices         []DrbdDevice     `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
	// FailOverUnsafePods indicates if Pods with unknown other volume types should be failed over as well.
	FailOverUnsafePods bool
	// SatellitePodSelector selects the Pods that should be considered LINSTOR Satellites.
	// If the DRBD connection name matches on of these Pods, the Kubernetes Node name is taken from these Pods.
	SatellitePodSelector labels.Selector
}

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
}