Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type DeltaProcessor ¶
type DeltaProcessor interface {
// Process is the function that will process messages.
Process(context.Context, cache.Delta) error
}
ObjectResourceMessageProcessor defines a function to process object resource messages arriving from the store.
type MeterDefinitionRemovalWatcher ¶
type MeterDefinitionRemovalWatcher struct {
*Processor
// contains filtered or unexported fields
}
func ProvideMeterDefinitionRemovalWatcher ¶
func ProvideMeterDefinitionRemovalWatcher( dictionary *stores.MeterDefinitionDictionary, meterDefinitionStore *stores.MeterDefinitionStore, mb *mailbox.Mailbox, log logr.Logger, kubeClient client.Client, nsWatcher *filter.NamespaceWatcher, ) *MeterDefinitionRemovalWatcher
type Processor ¶
type Processor struct {
DeltaProcessor
// contains filtered or unexported fields
}
processorImpl creates a listener and processes new object resource messages to update the meterdefinition status.
type PrometheusMdefProcessor ¶
type PrometheusMdefProcessor struct {
*Processor
// contains filtered or unexported fields
}
PrometheusMdefProcessor will update the meter definition status with the objects that matched it.
func ProvidePrometheusMdefProcessor ¶
func ProvidePrometheusMdefProcessor( log logr.Logger, mb *mailbox.Mailbox, scheme *runtime.Scheme, prometheusData *metrics.PrometheusData, _ managers.CacheIsStarted, ) *PrometheusMdefProcessor
NewPrometheusMdefProcessor is the provider that creates the processor.
type PrometheusProcessor ¶
type PrometheusProcessor struct {
*Processor
// contains filtered or unexported fields
}
PrometheusProcessor will update the meter definition status with the objects that matched it.
func ProvidePrometheusProcessor ¶
func ProvidePrometheusProcessor( log logr.Logger, mb *mailbox.Mailbox, scheme *runtime.Scheme, prometheusData *metrics.PrometheusData, ) *PrometheusProcessor
NewPrometheusProcessor is the provider that creates the processor.
type ServiceAnnotatorProcessor ¶
type ServiceAnnotatorProcessor struct {
*Processor
// contains filtered or unexported fields
}
ServiceProcessor will update the meter definition status with the objects that matched it.
func ProvideServiceAnnotatorProcessor ¶
func ProvideServiceAnnotatorProcessor( log logr.Logger, kubeClient client.Client, mb *mailbox.Mailbox, _ managers.CacheIsStarted, ) *ServiceAnnotatorProcessor
NewServiceProcessor is the provider that creates the processor.
type StatusFlushDuration ¶
type StatusProcessor ¶
type StatusProcessor struct {
*Processor
// contains filtered or unexported fields
}
StatusProcessor will update the meter definition status with the objects that matched it.
func ProvideStatusProcessor ¶
func ProvideStatusProcessor( log logr.Logger, kubeClient client.Client, mb *mailbox.Mailbox, duration StatusFlushDuration, _ managers.CacheIsStarted, ) *StatusProcessor
NewStatusProcessor is the provider that creates the processor.
Source Files