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 CollectedEnvironmentCheckInfo
• type DiskMonitor
  • func NewDiskMonitor(logger logrus.FieldLogger, ds *datastore.DataStore, nodeName string, ...) (*DiskMonitor, error)
  • func NewFakeDiskMonitor(logger logrus.FieldLogger, ds *datastore.DataStore, nodeName string, ...) (*DiskMonitor, error)
  • func (m *DiskMonitor) GetCollectedData() (interface{}, error)
  • func (m *DiskMonitor) RunOnce() error
  • func (m *DiskMonitor) Start()
  • func (m *DiskMonitor) Stop()
  • func (m *DiskMonitor) UpdateConfiguration(map[string]interface{}) error
• type DiskServiceClient
• type EnvironmentCheckMonitor
  • func NewEnvironmentCheckMonitor(logger logrus.FieldLogger, ds *datastore.DataStore, nodeName string, ...) (*EnvironmentCheckMonitor, error)
  • func (m *EnvironmentCheckMonitor) GetCollectedData() (interface{}, error)
  • func (m *EnvironmentCheckMonitor) RunOnce() error
  • func (m *EnvironmentCheckMonitor) Start()
  • func (m *EnvironmentCheckMonitor) Stop()
  • func (m *EnvironmentCheckMonitor) UpdateConfiguration(map[string]interface{}) error
• type FakeEnvironmentCheckMonitor
  • func NewFakeEnvironmentCheckMonitor(logger logrus.FieldLogger, ds *datastore.DataStore, nodeName string, ...) (*FakeEnvironmentCheckMonitor, error)
  • func (m *FakeEnvironmentCheckMonitor) GetCollectedData() (interface{}, error)
  • func (m *FakeEnvironmentCheckMonitor) RunOnce() error
  • func (m *FakeEnvironmentCheckMonitor) Start()
  • func (m *FakeEnvironmentCheckMonitor) Stop()
  • func (m *FakeEnvironmentCheckMonitor) UpdateConfiguration(map[string]interface{}) error
• type GenerateDiskConfigHandler
• type GetDiskConfigHandler
• type GetDiskStatHandler
• type GetReplicaDataStoresHandler
• type Monitor
• type SnapshotChangeEvent
• type SnapshotMonitor
  • func NewSnapshotMonitor(logger logrus.FieldLogger, ds *datastore.DataStore, nodeName string, ...) (*SnapshotMonitor, error)
  • func (m *SnapshotMonitor) GetCollectedData() (interface{}, error)
  • func (m *SnapshotMonitor) RunOnce() error
  • func (m *SnapshotMonitor) Start()
  • func (m *SnapshotMonitor) Stop()
  • func (m *SnapshotMonitor) UpdateConfiguration(map[string]interface{}) error
• type SnapshotMonitorStatus

Constants

const (
	TestDiskID1 = "fsid"

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

const (
	DiskMonitorSyncPeriod = 30 * time.Second
)

const (
	EnvironmentCheckMonitorSyncPeriod = 1800 * 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 CollectedEnvironmentCheckInfo

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

type DiskMonitor

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

func NewDiskMonitor

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

func NewFakeDiskMonitor

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

func (*DiskMonitor) GetCollectedData

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

func (*DiskMonitor) RunOnce

func (m *DiskMonitor) RunOnce() error

func (*DiskMonitor) Start

func (m *DiskMonitor) Start()

func (*DiskMonitor) Stop

func (m *DiskMonitor) Stop()

func (*DiskMonitor) UpdateConfiguration

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

type DiskServiceClient

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

type EnvironmentCheckMonitor

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

func NewEnvironmentCheckMonitor

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

func (*EnvironmentCheckMonitor) GetCollectedData

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

func (*EnvironmentCheckMonitor) RunOnce

func (m *EnvironmentCheckMonitor) RunOnce() error

func (*EnvironmentCheckMonitor) Start

func (m *EnvironmentCheckMonitor) Start()

func (*EnvironmentCheckMonitor) Stop

func (m *EnvironmentCheckMonitor) Stop()

func (*EnvironmentCheckMonitor) UpdateConfiguration

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

type FakeEnvironmentCheckMonitor

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

func NewFakeEnvironmentCheckMonitor

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

func (*FakeEnvironmentCheckMonitor) GetCollectedData

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

func (*FakeEnvironmentCheckMonitor) RunOnce

func (m *FakeEnvironmentCheckMonitor) RunOnce() error

func (*FakeEnvironmentCheckMonitor) Start

func (m *FakeEnvironmentCheckMonitor) Start()

func (*FakeEnvironmentCheckMonitor) Stop

func (m *FakeEnvironmentCheckMonitor) Stop()

func (*FakeEnvironmentCheckMonitor) UpdateConfiguration

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

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()
	Stop()
	UpdateConfiguration(map[string]interface{}) error
	GetCollectedData() (interface{}, error)
	RunOnce() 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) GetCollectedData

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

func (*SnapshotMonitor) RunOnce

func (m *SnapshotMonitor) RunOnce() error

func (*SnapshotMonitor) Start

func (m *SnapshotMonitor) Start()

func (*SnapshotMonitor) Stop

func (m *SnapshotMonitor) Stop()

func (*SnapshotMonitor) UpdateConfiguration

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

type SnapshotMonitorStatus

type SnapshotMonitorStatus struct {
	LastSnapshotPeriodicCheckedAt metav1.Time
}