monitor

Documentation

Index

• Constants
• func DeleteDisk(diskType longhorn.DiskType, diskName, diskUUID, diskPath, diskDriver string, ...) error
• func GetDiskNamesFromDiskMap(diskInfoMap map[string]*CollectedDiskInfo) []string
• type CollectedDiskInfo
  • func NewDiskInfo(diskName, diskUUID, diskPath string, diskDriver longhorn.DiskDriver, ...) *CollectedDiskInfo
• type DiskServiceClient
• type GenerateDiskConfigHandler
• type GetDiskConfigHandler
• type GetDiskStatHandler
• type GetReplicaDataStoresHandler
• type Monitor
• type NodeMonitor
  • func NewDiskMonitor(logger logrus.FieldLogger, ds *datastore.DataStore, nodeName string, ...) (*NodeMonitor, error)
  • func NewFakeNodeMonitor(logger logrus.FieldLogger, ds *datastore.DataStore, nodeName string, ...) (*NodeMonitor, error)
  • func (m *NodeMonitor) Close()
  • func (m *NodeMonitor) GetCollectedData() (interface{}, error)
  • func (m *NodeMonitor) RunOnce() error
  • func (m *NodeMonitor) Start()
  • func (m *NodeMonitor) UpdateConfiguration(map[string]interface{}) error
• type SnapshotChangeEvent
• type SnapshotMonitor
  • func NewSnapshotMonitor(logger logrus.FieldLogger, ds *datastore.DataStore, nodeName string, ...) (*SnapshotMonitor, error)
  • func (m *SnapshotMonitor) Close()
  • func (m *SnapshotMonitor) GetCollectedData() (interface{}, error)
  • func (m *SnapshotMonitor) RunOnce() error
  • func (m *SnapshotMonitor) Start()
  • func (m *SnapshotMonitor) UpdateConfiguration(map[string]interface{}) error
• type SnapshotMonitorStatus

Constants

const (
	TestDiskID1 = "fsid"

	TestOrphanedReplicaDirectoryName = "test-volume-r-000000000"
)

const (
	NodeMonitorSyncPeriod = 30 * time.Second
)

Functions

func DeleteDisk

func DeleteDisk(diskType longhorn.DiskType, diskName, diskUUID, diskPath, diskDriver string, client *engineapi.DiskService) error

DeleteDisk deletes the disk with the given name, uuid, path and driver

func GetDiskNamesFromDiskMap

func GetDiskNamesFromDiskMap(diskInfoMap map[string]*CollectedDiskInfo) []string

Types

type CollectedDiskInfo

type CollectedDiskInfo struct {
	Path                      string
	NodeOrDiskEvicted         bool
	DiskStat                  *lhtypes.DiskStat
	DiskName                  string
	DiskUUID                  string
	DiskDriver                longhorn.DiskDriver
	Condition                 *longhorn.Condition
	OrphanedReplicaDataStores map[string]string
	InstanceManagerName       string
}

func NewDiskInfo

func NewDiskInfo(diskName, diskUUID, diskPath string, diskDriver longhorn.DiskDriver, nodeOrDiskEvicted bool, stat *lhtypes.DiskStat,
	orphanedReplicaDataStores map[string]string, instanceManagerName string, errorReason, errorMessage string) *CollectedDiskInfo

type DiskServiceClient

type DiskServiceClient struct {
	// contains filtered or unexported fields
}

type GenerateDiskConfigHandler

type GenerateDiskConfigHandler func(longhorn.DiskType, string, string, string, string, *DiskServiceClient) (*util.DiskConfig, error)

type GetDiskConfigHandler

type GetDiskConfigHandler func(longhorn.DiskType, string, string, longhorn.DiskDriver, *DiskServiceClient) (*util.DiskConfig, error)

type GetDiskStatHandler

type GetDiskStatHandler func(longhorn.DiskType, string, string, longhorn.DiskDriver, *DiskServiceClient) (*lhtypes.DiskStat, error)

type GetReplicaDataStoresHandler

type GetReplicaDataStoresHandler func(longhorn.DiskType, *longhorn.Node, string, string, string, string, *DiskServiceClient) (map[string]string, error)

type Monitor

type Monitor interface {
	Start()
	Close()
	UpdateConfiguration(map[string]interface{}) error
	GetCollectedData() (interface{}, error)
	RunOnce() error
}

type NodeMonitor

type NodeMonitor struct {
	// contains filtered or unexported fields
}

func NewDiskMonitor

func NewDiskMonitor(logger logrus.FieldLogger, ds *datastore.DataStore, nodeName string, syncCallback func(key string)) (*NodeMonitor, error)

func NewFakeNodeMonitor

func NewFakeNodeMonitor(logger logrus.FieldLogger, ds *datastore.DataStore, nodeName string, syncCallback func(key string)) (*NodeMonitor, error)

func (*NodeMonitor) Close

func (m *NodeMonitor) Close()

func (*NodeMonitor) GetCollectedData

func (m *NodeMonitor) GetCollectedData() (interface{}, error)

func (*NodeMonitor) RunOnce

func (m *NodeMonitor) RunOnce() error

func (*NodeMonitor) Start

func (m *NodeMonitor) Start()

func (*NodeMonitor) UpdateConfiguration

func (m *NodeMonitor) UpdateConfiguration(map[string]interface{}) error

type SnapshotChangeEvent

type SnapshotChangeEvent struct {
	VolumeName   string
	SnapshotName string
}

type SnapshotMonitor

type SnapshotMonitor struct {
	sync.RWMutex

	SnapshotMonitorStatus
	// contains filtered or unexported fields
}

func NewSnapshotMonitor

func NewSnapshotMonitor(logger logrus.FieldLogger, ds *datastore.DataStore, nodeName string, eventRecorder record.EventRecorder,
	snapshotChangeEventQueue workqueue.TypedInterface[any], syncCallback func(key string)) (*SnapshotMonitor, error)

func (*SnapshotMonitor) Close

func (m *SnapshotMonitor) Close()

func (*SnapshotMonitor) GetCollectedData

func (m *SnapshotMonitor) GetCollectedData() (interface{}, error)

func (*SnapshotMonitor) RunOnce

func (m *SnapshotMonitor) RunOnce() error

func (*SnapshotMonitor) Start

func (m *SnapshotMonitor) Start()

func (*SnapshotMonitor) UpdateConfiguration

func (m *SnapshotMonitor) UpdateConfiguration(map[string]interface{}) error

type SnapshotMonitorStatus

type SnapshotMonitorStatus struct {
	LastSnapshotPeriodicCheckedAt metav1.Time
}