Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

cache

package

Go to main page

Versions in this module

v0

v0.4.13

Jun 1, 2023

Changes in this version

+ type CephBlocklistLs struct

+ IP string

+ Nonce int

+ Port int

+ Until time.Time

+ func (c *CephBlocklistLs) UnmarshalJSON(data []byte) error

+ type CephBlocklistStore struct

+ Mutex sync.RWMutex

+ Store []CephBlocklistLs

+ func NewCephBlocklistStore(opts *options.Options) *CephBlocklistStore

+ func (c *CephBlocklistStore) Add(obj interface{}) error

+ func (c *CephBlocklistStore) Delete(obj interface{}) error

+ func (c *CephBlocklistStore) Get(obj interface{}) (item interface{}, exists bool, err error)

+ func (c *CephBlocklistStore) GetByKey(key string) (item interface{}, exists bool, err error)

+ func (c *CephBlocklistStore) IsBlocked(ip string, port, nonce int) bool

+ func (c *CephBlocklistStore) List() []interface{}

+ func (c *CephBlocklistStore) ListKeys() []string

+ func (c *CephBlocklistStore) Replace(list []interface{}, _ string) error

+ func (c *CephBlocklistStore) Resync() error

+ func (c *CephBlocklistStore) Update(obj interface{}) error

+ type Clients struct

+ Watchers []Watcher

type PersistentVolumeStore

+ RBDClientMap map[string][]string

+ type Watcher struct

+ Address string

+ Client int

+ Cookie json.Number

v0.4.12

Dec 23, 2022

v0.4.11

Oct 14, 2022

Changes in this version

+ func CreateCephBlockPoolListWatch(cephClient rookclient.Interface, namespace, fieldSelector string) cache.ListerWatcher

+ func CreatePersistentVolumeListWatch(kubeClient clientset.Interface, fieldSelector string) cache.ListerWatcher

+ type PersistentVolumeAttributes struct

+ ImageName string

+ PersistentVolumeClaimName string

+ PersistentVolumeClaimNamespace string

+ PersistentVolumeName string

+ Pool string

+ type PersistentVolumeStore struct

+ Mutex sync.RWMutex

+ Store map[types.UID]PersistentVolumeAttributes

+ 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 struct

+ DaemonID string

+ Hostname string

+ InstanceID string

+ ServiceID string

+ type RBDMirrorDaemonStatus struct

+ CephVersion string

+ ClientID string

+ Health string

+ Hostname string

+ InstanceID string

+ Leader bool

+ ServiceID string

+ type RBDMirrorImageStatus struct

+ DaemonService RBDMirrorDaemonService

+ Description string

+ GlobalID string

+ LastUpdate string

+ Name string

+ PeerSites []RBDMirrorPeerSite

+ State string

+ type RBDMirrorImageStatusStates struct

+ Error int

+ Replaying int

+ StartingReplay int

+ Stopped int

+ StoppingReplay int

+ Syncing int

+ Unknown int

+ type RBDMirrorPeerSite struct

+ Description string

+ LastUpdate string

+ MirrorUuids string

+ SiteName string

+ State string

+ type RBDMirrorPeerSiteDescription struct

+ BytesPerSecond float64

+ BytesPerSnapshot float64

+ LocalSnapshotTimestamp int64

+ RemoteSnapshotTimestamp int64

+ ReplayState string

+ type RBDMirrorPoolStatusSummary struct

+ DaemonHealth string

+ Health string

+ ImageHealth string

+ States RBDMirrorImageStatusStates

+ type RBDMirrorPoolStatusVerbose struct

+ MirrorStatus RBDMirrorStatusVerbose

+ PoolName string

+ PoolNamespace string

+ type RBDMirrorStatusVerbose struct

+ Daemons []RBDMirrorDaemonStatus

+ Images []RBDMirrorImageStatus

+ Summary RBDMirrorPoolStatusSummary

+ type RBDMirrorStore struct

+ Mutex sync.RWMutex

+ Store map[types.UID]RBDMirrorPoolStatusVerbose

+ 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