Documentation
¶
Index ¶
- func CreateCephBlockPoolListWatch(cephClient rookclient.Interface, namespace, fieldSelector string) cache.ListerWatcher
- func CreatePersistentVolumeListWatch(kubeClient clientset.Interface, fieldSelector string) cache.ListerWatcher
- type PersistentVolumeAttributes
- type PersistentVolumeStore
- func (p *PersistentVolumeStore) Add(obj interface{}) error
- func (p *PersistentVolumeStore) Delete(obj interface{}) error
- func (p *PersistentVolumeStore) Get(obj interface{}) (item interface{}, exists bool, err error)
- func (p *PersistentVolumeStore) GetByKey(key string) (item interface{}, exists bool, err error)
- func (p *PersistentVolumeStore) List() []interface{}
- func (p *PersistentVolumeStore) ListKeys() []string
- func (p *PersistentVolumeStore) Replace(list []interface{}, _ string) error
- func (p *PersistentVolumeStore) Resync() error
- func (p *PersistentVolumeStore) Update(obj interface{}) error
- type RBDMirrorDaemonService
- type RBDMirrorDaemonStatus
- type RBDMirrorImageStatus
- type RBDMirrorImageStatusStates
- type RBDMirrorPeerSite
- type RBDMirrorPeerSiteDescription
- type RBDMirrorPoolStatusSummary
- type RBDMirrorPoolStatusVerbose
- type RBDMirrorStatusVerbose
- type RBDMirrorStore
- func (s *RBDMirrorStore) Add(obj interface{}) error
- func (s *RBDMirrorStore) Delete(obj interface{}) error
- func (s *RBDMirrorStore) Get(obj interface{}) (item interface{}, exists bool, err error)
- func (s *RBDMirrorStore) GetByKey(key string) (item interface{}, exists bool, err error)
- func (s *RBDMirrorStore) List() []interface{}
- func (s *RBDMirrorStore) ListKeys() []string
- func (s *RBDMirrorStore) Replace(list []interface{}, _ string) error
- func (s *RBDMirrorStore) Resync() error
- func (s *RBDMirrorStore) Update(obj interface{}) error
- func (s *RBDMirrorStore) WithRBDCommandInput(namespace string) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CreateCephBlockPoolListWatch ¶
func CreateCephBlockPoolListWatch(cephClient rookclient.Interface, namespace, fieldSelector string) cache.ListerWatcher
func CreatePersistentVolumeListWatch ¶
func CreatePersistentVolumeListWatch(kubeClient clientset.Interface, fieldSelector string) cache.ListerWatcher
Types ¶
type PersistentVolumeStore ¶
type PersistentVolumeStore struct {
Mutex sync.RWMutex
// Store is a map of PV UID to PersistentVolumeAttributes
Store map[types.UID]PersistentVolumeAttributes
}
PersistentVolumeStore implements the k8s.io/client-go/tools/cache.Store interface. It stores persistent volume CSI attributes
func NewPersistentVolumeStore ¶
func NewPersistentVolumeStore() *PersistentVolumeStore
func (*PersistentVolumeStore) Add ¶
func (p *PersistentVolumeStore) Add(obj interface{}) error
Add inserts to the PersistentVolumeStore.
func (*PersistentVolumeStore) Delete ¶
func (p *PersistentVolumeStore) Delete(obj interface{}) error
Delete deletes an existing entry in the PersistentVolumeStore.
func (*PersistentVolumeStore) Get ¶
func (p *PersistentVolumeStore) Get(obj interface{}) (item interface{}, exists bool, err error)
Get implements the Get method of the store interface.
func (*PersistentVolumeStore) GetByKey ¶
func (p *PersistentVolumeStore) GetByKey(key string) (item interface{}, exists bool, err error)
GetByKey implements the GetByKey method of the store interface.
func (*PersistentVolumeStore) List ¶
func (p *PersistentVolumeStore) List() []interface{}
List implements the List method of the store interface.
func (*PersistentVolumeStore) ListKeys ¶
func (p *PersistentVolumeStore) ListKeys() []string
ListKeys implements the ListKeys method of the store interface.
func (*PersistentVolumeStore) Replace ¶
func (p *PersistentVolumeStore) Replace(list []interface{}, _ string) error
Replace will delete the contents of the store, using instead the given list.
func (*PersistentVolumeStore) Resync ¶
func (p *PersistentVolumeStore) Resync() error
Resync implements the Resync method of the store interface.
func (*PersistentVolumeStore) Update ¶
func (p *PersistentVolumeStore) Update(obj interface{}) error
Update updates the existing entry in the PersistentVolumeStore.
type RBDMirrorDaemonService ¶
type RBDMirrorDaemonStatus ¶
type RBDMirrorImageStatus ¶
type RBDMirrorImageStatus struct {
Name string `json:"name"`
GlobalID string `json:"global_id"`
State string `json:"state"`
Description string `json:"description"`
DaemonService RBDMirrorDaemonService `json:"daemon_service"`
LastUpdate string `json:"last_update"`
PeerSites []RBDMirrorPeerSite `json:"peer_sites"`
}
type RBDMirrorPeerSite ¶
type RBDMirrorPeerSiteDescription ¶
type RBDMirrorPeerSiteDescription struct {
BytesPerSecond float64 `json:"bytes_per_second"`
BytesPerSnapshot float64 `json:"bytes_per_snapshot"`
LocalSnapshotTimestamp int64 `json:"local_snapshot_timestamp"`
RemoteSnapshotTimestamp int64 `json:"remote_snapshot_timestamp"`
ReplayState string `json:"replay_state"`
}
type RBDMirrorPoolStatusSummary ¶
type RBDMirrorPoolStatusSummary struct {
Health string `json:"health"`
DaemonHealth string `json:"daemon_health"`
ImageHealth string `json:"image_health"`
States RBDMirrorImageStatusStates `json:"states"`
}
type RBDMirrorPoolStatusVerbose ¶
type RBDMirrorPoolStatusVerbose struct {
PoolName string
PoolNamespace string
MirrorStatus RBDMirrorStatusVerbose
}
type RBDMirrorStatusVerbose ¶
type RBDMirrorStatusVerbose struct {
Summary RBDMirrorPoolStatusSummary `json:"summary"`
Daemons []RBDMirrorDaemonStatus `json:"daemons"`
Images []RBDMirrorImageStatus `json:"images"`
}
type RBDMirrorStore ¶
type RBDMirrorStore struct {
Mutex sync.RWMutex
// Store is a map of Pool UID to RBDMirrorPoolStatusVerbose
Store map[types.UID]RBDMirrorPoolStatusVerbose
// contains filtered or unexported fields
}
RBDMirrorStore implements the k8s.io/client-go/tools/cache.Store interface. It stores rbd mirror data.
func NewRBDMirrorStore ¶
func NewRBDMirrorStore(opts *options.Options) *RBDMirrorStore
func (*RBDMirrorStore) Add ¶
func (s *RBDMirrorStore) Add(obj interface{}) error
func (*RBDMirrorStore) Delete ¶
func (s *RBDMirrorStore) Delete(obj interface{}) error
func (*RBDMirrorStore) Get ¶
func (s *RBDMirrorStore) Get(obj interface{}) (item interface{}, exists bool, err error)
func (*RBDMirrorStore) GetByKey ¶
func (s *RBDMirrorStore) GetByKey(key string) (item interface{}, exists bool, err error)
func (*RBDMirrorStore) List ¶
func (s *RBDMirrorStore) List() []interface{}
func (*RBDMirrorStore) ListKeys ¶
func (s *RBDMirrorStore) ListKeys() []string
func (*RBDMirrorStore) Replace ¶
func (s *RBDMirrorStore) Replace(list []interface{}, _ string) error
func (*RBDMirrorStore) Resync ¶
func (s *RBDMirrorStore) Resync() error
func (*RBDMirrorStore) Update ¶
func (s *RBDMirrorStore) Update(obj interface{}) error
func (*RBDMirrorStore) WithRBDCommandInput ¶
func (s *RBDMirrorStore) WithRBDCommandInput(namespace string) error