Documentation
¶
Index ¶
- func CephObjectStoreInformer(opts *options.Options) cache.SharedIndexInformer
- func RegisterCustomResourceCollectors(registry *prometheus.Registry, opts *options.Options)
- func RegisterPersistentVolumeAttributesCollector(registry *prometheus.Registry, opts *options.Options)
- func RegisterRBDMirrorCollector(registry *prometheus.Registry, opts *options.Options)
- type CephBlockPoolCollector
- type CephClusterCollector
- type CephObjectStoreCollector
- type Informer
- type MockClient
- type MockDoType
- type ObjectBucketCollector
- type PersistentVolumeAttributesCollector
- type RBDMirrorCollector
- type Tests
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CephObjectStoreInformer ¶
func CephObjectStoreInformer(opts *options.Options) cache.SharedIndexInformer
func RegisterCustomResourceCollectors ¶
func RegisterCustomResourceCollectors(registry *prometheus.Registry, opts *options.Options)
RegisterCustomResourceCollectors registers the custom resource collectors in the given prometheus.Registry This is used to expose metrics about the Custom Resources
func RegisterPersistentVolumeAttributesCollector ¶ added in v0.4.11
func RegisterPersistentVolumeAttributesCollector(registry *prometheus.Registry, opts *options.Options)
RegisterPersistentVolumeAttributesCollector registers PV attribute colletor to registry
func RegisterRBDMirrorCollector ¶ added in v0.4.11
func RegisterRBDMirrorCollector(registry *prometheus.Registry, opts *options.Options)
RegisterRBDMirrorCollector registers RBD mirror metrics collector to registry
Types ¶
type CephBlockPoolCollector ¶
type CephBlockPoolCollector struct {
MirroringImageHealth *prometheus.Desc
MirroringStatus *prometheus.Desc
Informer cache.SharedIndexInformer
AllowedNamespaces []string
}
CephBlockPoolCollector is a custom collector for CephBlockPool Custom Resource
func NewCephBlockPoolCollector ¶
func NewCephBlockPoolCollector(opts *options.Options) *CephBlockPoolCollector
NewCephBlockPoolCollector constructs a collector
func (*CephBlockPoolCollector) Collect ¶
func (c *CephBlockPoolCollector) Collect(ch chan<- prometheus.Metric)
Collect implements prometheus.Collector interface
func (*CephBlockPoolCollector) Describe ¶
func (c *CephBlockPoolCollector) Describe(ch chan<- *prometheus.Desc)
Describe implements prometheus.Collector interface
func (*CephBlockPoolCollector) Run ¶
func (c *CephBlockPoolCollector) Run(stopCh <-chan struct{})
Run starts CephBlockPool informer
type CephClusterCollector ¶ added in v0.4.10
type CephClusterCollector struct {
MirrorDaemonCount *prometheus.Desc
Informer cache.SharedIndexInformer
AllowedNamespaces []string
}
CephClusterCollector is a custom collector for CephCluster Custom Resource
func NewCephClusterCollector ¶ added in v0.4.10
func NewCephClusterCollector(opts *options.Options) *CephClusterCollector
NewCephClusterCollector constructs a collector
func (*CephClusterCollector) Collect ¶ added in v0.4.10
func (c *CephClusterCollector) Collect(ch chan<- prometheus.Metric)
Collect implements prometheus.Collector interface
func (*CephClusterCollector) Describe ¶ added in v0.4.10
func (c *CephClusterCollector) Describe(ch chan<- *prometheus.Desc)
Describe implements prometheus.Collector interface
func (*CephClusterCollector) Run ¶ added in v0.4.10
func (c *CephClusterCollector) Run(stopCh <-chan struct{})
Run starts CephClusters informer
type CephObjectStoreCollector ¶
type CephObjectStoreCollector struct {
RGWHealthStatus *prometheus.Desc
Informer cache.SharedIndexInformer
AllowedNamespaces []string
}
CephObjectStoreCollector is a custom collector for CephObjectStore Custom Resource
func NewCephObjectStoreCollector ¶
func NewCephObjectStoreCollector(opts *options.Options) *CephObjectStoreCollector
NewCephObjectStoreCollector constructs a collector
func (*CephObjectStoreCollector) Collect ¶
func (c *CephObjectStoreCollector) Collect(ch chan<- prometheus.Metric)
Collect implements prometheus.Collector interface
func (*CephObjectStoreCollector) Describe ¶
func (c *CephObjectStoreCollector) Describe(ch chan<- *prometheus.Desc)
Describe implements prometheus.Collector interface
func (*CephObjectStoreCollector) Run ¶
func (c *CephObjectStoreCollector) Run(stopCh <-chan struct{})
Run starts CephObjectStore informer
type Informer ¶
type Informer interface {
GetInformer() cache.SharedIndexInformer
}
type MockClient ¶
type MockClient struct {
// MockDo is a type that mock the Do method from the HTTP package
MockDo MockDoType
}
MockClient is the mock of the HTTP Client It can be used to mock HTTP request/response from the rgw admin ops API
type MockDoType ¶
MockDoType is a custom type that allows setting the function that our Mock Do func will run instead
type ObjectBucketCollector ¶
type ObjectBucketCollector struct {
OBSizeTotal *prometheus.Desc
OBSizeMax *prometheus.Desc
OBObjectCountTotal *prometheus.Desc
OBObjectCountMax *prometheus.Desc
ObjectBucketClaimInfo *prometheus.Desc
Informer cache.SharedIndexInformer
AllowedNamespaces []string
// contains filtered or unexported fields
}
ObjectBucketCollector is a custom collector for CephObjectStore Custom Resource
func NewObjectBucketCollector ¶
func NewObjectBucketCollector(opts *options.Options) *ObjectBucketCollector
NewObjectBucketCollector constructs a collector
func (*ObjectBucketCollector) Collect ¶
func (c *ObjectBucketCollector) Collect(ch chan<- prometheus.Metric)
Collect implements prometheus.Collector interface
func (*ObjectBucketCollector) Describe ¶
func (c *ObjectBucketCollector) Describe(ch chan<- *prometheus.Desc)
Describe implements prometheus.Collector interface
func (*ObjectBucketCollector) Run ¶
func (c *ObjectBucketCollector) Run(stopCh <-chan struct{})
Run starts CephObjectStore informer
type PersistentVolumeAttributesCollector ¶ added in v0.4.11
type PersistentVolumeAttributesCollector struct {
Store *internalcache.PersistentVolumeStore
PVMetadata *prometheus.Desc
}
func NewPersistentVolumeAttributesCollector ¶ added in v0.4.11
func NewPersistentVolumeAttributesCollector(store *internalcache.PersistentVolumeStore, opts *options.Options) *PersistentVolumeAttributesCollector
func (*PersistentVolumeAttributesCollector) Collect ¶ added in v0.4.11
func (c *PersistentVolumeAttributesCollector) Collect(ch chan<- prometheus.Metric)
Collect implements prometheus.Collector interface
func (*PersistentVolumeAttributesCollector) Describe ¶ added in v0.4.11
func (c *PersistentVolumeAttributesCollector) Describe(ch chan<- *prometheus.Desc)
Describe implements prometheus.Collector interface
type RBDMirrorCollector ¶ added in v0.4.11
type RBDMirrorCollector struct {
RBDMirrorStore *internalcache.RBDMirrorStore
PersistentVolumeStore *internalcache.PersistentVolumeStore
// Metric descriptors
MirrorDaemonHealth *prometheus.Desc
ImageStatusState *prometheus.Desc
PrimarySnapshotTimestamp *prometheus.Desc
SecondarySnapshotTimestamp *prometheus.Desc
ImageBytes *prometheus.Desc
ImageSnapshotBytes *prometheus.Desc
}
func NewRBDMirrorCollector ¶ added in v0.4.11
func NewRBDMirrorCollector(mirrorStore *internalcache.RBDMirrorStore, pvStore *internalcache.PersistentVolumeStore, opts *options.Options) *RBDMirrorCollector
func (*RBDMirrorCollector) Collect ¶ added in v0.4.11
func (c *RBDMirrorCollector) Collect(ch chan<- prometheus.Metric)
Collect implements prometheus.Collector interface
func (*RBDMirrorCollector) Describe ¶ added in v0.4.11
func (c *RBDMirrorCollector) Describe(ch chan<- *prometheus.Desc)
Describe implements prometheus.Collector interface