cache

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 NewPersistentVolumeStore() *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 NewRBDMirrorStore(opts *options.Options) *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

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 PersistentVolumeAttributes

type PersistentVolumeAttributes struct {
	PersistentVolumeName           string
	PersistentVolumeClaimName      string
	PersistentVolumeClaimNamespace string
	ImageName                      string
	Pool                           string
}

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 RBDMirrorDaemonService struct {
	ServiceID  string `json:"service_id"`
	InstanceID string `json:"instance_id"`
	DaemonID   string `json:"daemon_id"`
	Hostname   string `json:"hostname"`
}

type RBDMirrorDaemonStatus

type RBDMirrorDaemonStatus struct {
	ServiceID   string `json:"service_id"`
	InstanceID  string `json:"instance_id"`
	ClientID    string `json:"client_id"`
	Hostname    string `json:"hostname"`
	CephVersion string `json:"ceph_version"`
	Leader      bool   `json:"leader"`
	Health      string `json:"health"`
}

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 RBDMirrorImageStatusStates

type RBDMirrorImageStatusStates struct {
	Unknown        int `json:"unknown"`
	Error          int `json:"error"`
	Syncing        int `json:"syncing"`
	StartingReplay int `json:"starting_replay"`
	Replaying      int `json:"replaying"`
	StoppingReplay int `json:"stopping_replay"`
	Stopped        int `json:"stopped"`
}

type RBDMirrorPeerSite

type RBDMirrorPeerSite struct {
	SiteName    string `json:"site_name"`
	MirrorUuids string `json:"mirror_uuids"`
	State       string `json:"state"`
	Description string `json:"description"`
	LastUpdate  string `json:"last_update"`
}

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