auditor

Documentation

Index

• Constants
• type Auditor
  • func New(clientset *kubernetes.Clientset) Auditor
• type EventStore
  • func NewEventStore() *EventStore
  • func (es *EventStore) AddRecordForResource(resType string, resName string, record *localstorageapis.EventRecord)
  • func (es *EventStore) Run(clientSet *localstorageclientset.Clientset, ...)

Constants

const (
	ResourceTypeCluster     = "Cluster"
	ResourceTypeStorageNode = "StorageNode"
	ResourceTypeVolume      = "Volume"
	ResourceTypeDisk        = "Disk"

	ActionVolumeCreate  = "Create"
	ActionVolumeDelete  = "Delete"
	ActionVolumeMount   = "Mount"
	ActionVolumeUnmount = "Unmount"
	ActionVolumeConvert = "Convert"
	ActionVolumeMigrate = "Migrate"
	ActionVolumeExpand  = "Expand"

	ActionStateSubmit   = "Submit"
	ActionStateStart    = "Start"
	ActionStateComplete = "Complete"
	ActionStateAbort    = "Abort"

	ActionNodeAdd                       = "Add"
	ActionNodeRemove                    = "Remove"
	ActionNodeStateChange               = "StateChange"
	ActionNodeStoragePoolCapacityExpand = "CapacityExpand"

	ActionClusterInstall = "Install"
	ActionClusterChange  = "Change"
	ActionClusterUpgrade = "Upgrade"

	ActionDiskAdd      = "Add"
	ActionDiskRelocate = "Relocate"
	ActionDiskAllocate = "Allocate"
	ActionDiskReserve  = "Reserve"
	ActionDiskRelease  = "Release"
	ActionDiskChange   = "Change"

	ErrMsgSuccess = "Added a record"
	ErrMsgFailure = "Failed to add a record"
)

Types

type Auditor

type Auditor interface {
	Run(informerCache runtimecache.Cache, stopCh <-chan struct{}) error
}

Auditor interface

func New

func New(clientset *kubernetes.Clientset) Auditor

New an assistant instance

type EventStore

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

func NewEventStore

func NewEventStore() *EventStore

func (*EventStore) AddRecordForResource

func (es *EventStore) AddRecordForResource(resType string, resName string, record *localstorageapis.EventRecord)

func (*EventStore) Run

func (es *EventStore) Run(clientSet *localstorageclientset.Clientset, lsFactory localstorageinformers.SharedInformerFactory, stopCh <-chan struct{})