operator

Jan 9, 2026

Changes in this version

+ const NoSelectedResourcesReason

+ func ArgumentsIntersection(a, b []monitoringv1.Argument) []string

+ func KeyForObject(o metav1.Object) string

+ func UpdateStrategyForStatefulSet(updateStrategy *monitoringv1.StatefulSetUpdateStrategy) appsv1.StatefulSetUpdateStrategy

type ReconciliationTracker

+ func (rt *ReconciliationTracker) ResetStatus(key string)

+ func (rt *ReconciliationTracker) SetReasonAndMessage(key string, reason, message string)

Nov 21, 2025

Changes in this version

+ const InvalidConfiguration

+ func CleanupBindings[T ConfigurationResource](ctx context.Context, listerFunc func(labels.Selector, cache.AppendFunc) error, ...) error

+ func SelectNamespacesFromCache(obj metav1.Object, sel *metav1.LabelSelector, nsInfs cache.SharedIndexInformer) ([]string, error)

+ type ConfigResourceSyncer struct

+ func NewConfigResourceSyncer(workload RuntimeObject, client dynamic.Interface, accessor *Accessor) *ConfigResourceSyncer

+ func (crs *ConfigResourceSyncer) GetBindingIndex(bindings []monitoringv1.WorkloadBinding) int

+ func (crs *ConfigResourceSyncer) RemoveBinding(ctx context.Context, configResource ConfigurationObject) error

+ func (crs *ConfigResourceSyncer) UpdateBinding(ctx context.Context, configResource ConfigurationObject, ...) error

+ type ConfigurationObject interface

+ Bindings func() []monitoringv1.WorkloadBinding

+ type ConfigurationResource interface

type FinalizerSyncer

+ func NewNoopFinalizerSyncer() *FinalizerSyncer

+ type PrometheusRuleSelection struct

+ func (prs *PrometheusRuleSelection) RejectedLen() int

+ func (prs *PrometheusRuleSelection) RuleFiles() map[string]string

+ func (prs *PrometheusRuleSelection) Selected() TypedResourcesSelection[*monitoringv1.PrometheusRule]

+ func (prs *PrometheusRuleSelection) SelectedLen() int

+ type PrometheusRuleSyncer struct

+ func NewPrometheusRuleSyncer(logger *slog.Logger, namePrefix string, cmClient clientv1.ConfigMapInterface, ...) *PrometheusRuleSyncer

+ func (prs *PrometheusRuleSyncer) AppendConfigMapNames(configMapNames []string, limit int) []string

+ func (prs *PrometheusRuleSyncer) Sync(ctx context.Context, rules map[string]string) ([]string, error)

+ type RuntimeObject interface

+ type TypedConfigurationResource struct

+ func NewTypedConfigurationResource[T ConfigurationResource](res T, err error, reason string, generation int64) TypedConfigurationResource[T]

+ func (r *TypedConfigurationResource[T]) Conditions() []monitoringv1.ConfigResourceCondition

+ func (r *TypedConfigurationResource[T]) Resource() T

+ type TypedResourcesSelection map[string]TypedConfigurationResource[T]

+ func (resources TypedResourcesSelection[T]) ValidResources() map[string]T

Oct 7, 2025

Changes in this version

+ func ValidationSchemeForPrometheus(version semver.Version) model.ValidationScheme

+ func ValidationSchemeForThanos(version semver.Version) model.ValidationScheme

+ type EventRecorder struct

+ func NewFakeRecorder(bufferSize int, related runtime.Object) *EventRecorder

+ func (er *EventRecorder) Eventf(regarding runtime.Object, eventtype, reason, action, note string, ...)

+ type NewEventRecorderFunc func(related runtime.Object) *EventRecorder

Aug 21, 2025

Changes in this version

+ const ApplicationInstanceLabelKey

+ const ApplicationNameLabelKey

+ const ApplicationVersionLabelKey

+ const DefaultContainerAnnotationKey

+ const InputHashAnnotationKey

+ const ManagedByLabelKey

+ const ManagedByLabelValue

+ func ConfigMapGVK() schema.GroupVersionKind

+ func GenerationChanged(ep EventPayload) bool

+ func LabelsChanged(ep EventPayload) bool

+ func ManagedByOperatorLabelSelector() string

+ func ResourceVersionChanged(ep EventPayload) bool

+ func SecretGVK() schema.GroupVersionKind

type Config

+ WatchObjectRefsInAllNamespaces bool

+ type EventHandlerOption func(*EventHandler)

+ func WithFilter(filter FilterFunc) EventHandlerOption

+ type EventPayload struct

+ Current interface{}

+ CurrentMeta metav1.Object

+ EventType EventType

+ Old interface{}

+ OldMeta metav1.Object

+ type EventType int

+ const EventTypeOnAdd

+ const EventTypeOnDelete

+ const EventTypeOnUpdate

+ type FilterFunc func(EventPayload) bool

+ func AnyFilter(filters ...FilterFunc) FilterFunc

+ func HasReferenceFunc(informerGetter InformerGetter, refResolver RefResolver) FilterFunc

+ type InformerGetter interface

+ GetInformers func() []informers.InformLister

type ObjectOption

+ func WithSelectorLabels(selector *metav1.LabelSelector) ObjectOption

type ReconciliationTracker

+ func (rt *ReconciliationTracker) HasRefTo(key string, obj runtime.Object) bool

+ func (rt *ReconciliationTracker) UpdateReferenceTracker(key string, refTracker ReferenceTracker)

+ type RefResolver interface

+ HasRefTo func(namespacedName string, obj runtime.Object) bool

+ type ReferenceTracker interface

+ Has func(runtime.Object) bool

type StringSet

+ func MergeAllowLists(a, b StringSet) StringSet

Jul 14, 2025

Changes in this version

+ func GetObjectFromKey[T runtime.Object](infs *informers.ForResource, key string) (T, error)

+ type FinalizerSyncer struct

+ func NewFinalizerSyncer(mdClient metadata.Interface, gvr schema.GroupVersionResource, ...) *FinalizerSyncer

+ func (s *FinalizerSyncer) Sync(ctx context.Context, p metav1.Object, logger *slog.Logger, ...) (bool, error)

May 30, 2025

Changes in this version

type FeatureGateName

+ const StatusForConfigurationResourcesFeature

Mar 11, 2025

Changes in this version

type FeatureGateName

+ const PrometheusShardRetentionPolicyFeature

Feb 4, 2025

Changes in this version

type FeatureGateName

+ const PrometheusTopologyShardingFeature

Dec 13, 2024

Changes in this version

+ var DefaultPrometheusV2 = getLatestPrometheusV2()

Sep 25, 2024

Changes in this version

+ type OwnedResourceOwner interface

+ Get func(string) (runtime.Object, error)

Sep 19, 2024

Changes in this version

+ var DefaultPrometheusExperimentalVersion = PrometheusExperimentalVersions[len(PrometheusExperimentalVersions)-1]

+ var MaxConfigMapDataSize = int(float64(v1.MaxSecretSize) * 0.5)

+ var PrometheusExperimentalVersions = []string

+ type ResourceGetter interface

+ Get func(string) (runtime.Object, error)

Aug 14, 2024

Changes in this version

+ const InputHashAnnotationName

type Config

+ EventRecorderFactory EventRecorderFactory

+ SecretListWatchFieldSelector FieldSelector

+ SecretListWatchLabelSelector LabelSelector

type ObjectOption

+ func WithInputHashAnnotation(h string) ObjectOption

+ func WithoutKubectlAnnotations() ObjectOption

type ReloaderOption

+ func WithDaemonSetMode() ReloaderOption

Jun 26, 2024

Changes in this version

+ const NodeNameEnvVar

+ func BuildImagePathForAgent(specImage, baseImage, version string) (string, error)

+ func ExecAction(u string) *v1.ExecAction

type Config

+ Gates *FeatureGates

+ func (c *Config) RegisterFeatureGatesFlags(fs *flag.FlagSet, flags *k8sflag.MapStringBool)

+ type FeatureGate struct

+ type FeatureGateName string

+ const PrometheusAgentDaemonSetFeature

+ type FeatureGates map[FeatureGateName]FeatureGate

+ func (fg *FeatureGates) Collect(ch chan<- prometheus.Metric)

+ func (fg *FeatureGates) Describe(ch chan<- *prometheus.Desc)

+ func (fg *FeatureGates) Descriptions() []string

+ func (fg *FeatureGates) String() string

+ func (fg *FeatureGates) UpdateFeatureGates(flags map[string]bool) error

+ func (fg FeatureGates) Enabled(name FeatureGateName) bool

type ReloaderOption

+ func InitContainer() ReloaderOption

+ func WithNodeNameEnv() ReloaderOption

type ShardedSecret

+ func ReconcileShardedSecret(ctx context.Context, data map[string][]byte, client kubernetes.Interface, ...) (*ShardedSecret, error)

May 17, 2024

Changes in this version

+ func AvailableFeatureGates() []string

+ func ValidateFeatureGates(flags *k8sflag.MapStringBool) (string, error)

Apr 4, 2024

Changes in this version

type Config

+ ControllerID string

+ type EventHandler struct

+ func NewEventHandler(logger log.Logger, accessor *Accessor, metrics *Metrics, objName string, ...) *EventHandler

+ func (e *EventHandler) OnAdd(obj interface{}, _ bool)

+ func (e *EventHandler) OnDelete(obj interface{})

+ func (e *EventHandler) OnUpdate(old, cur interface{})

+ type NodeAddressPriority string

+ func (p *NodeAddressPriority) Set(value string) error

+ func (p *NodeAddressPriority) String() string

Mar 4, 2024

Changes in this version

+ type EventRecorderFactory func(client kubernetes.Interface, component string) record.EventRecorder

+ func NewEventRecorderFactory(emitEvents bool) EventRecorderFactory

type ShardedSecret

+ func (s *ShardedSecret) Hash() (uint64, error)

+ func (s *ShardedSecret) Volume(name string) v1.Volume

Jan 12, 2024

Changes in this version

+ const InvalidConfigurationEvent

+ func NewEventRecorder(client kubernetes.Interface, component string) record.EventRecorder

+ func UpdateObject(o metav1.Object, opts ...ObjectOption)

+ type Byter interface

+ Bytes func() []byte

+ type ObjectOption func(metav1.Object)

+ func WithAnnotations(annotations map[string]string) ObjectOption

+ func WithLabels(labels map[string]string) ObjectOption

+ func WithManagingOwner(owner Owner) ObjectOption

+ func WithName(name string) ObjectOption

+ func WithNamespace(namespace string) ObjectOption

+ func WithOwner(owner Owner) ObjectOption

+ type Owner interface

type ShardedSecret

+ func ReconcileShardedSecretForTLSAssets(ctx context.Context, store *assets.Store, client kubernetes.Interface, ...) (*ShardedSecret, error)

+ func (s *ShardedSecret) Append(k fmt.Stringer, v Byter)

+ func (s *ShardedSecret) SecretNames() []string

+ func (s *ShardedSecret) UpdateSecrets(ctx context.Context, sClient corev1.SecretInterface) error

Nov 30, 2023

Changes in this version

type Config

+ AlertmanagerSelector LabelSelector

+ type FieldSelector string

+ func (fs *FieldSelector) Set(value string) error

+ func (fs *FieldSelector) String() string

+ type LabelSelector string

+ func (ls *LabelSelector) Set(value string) error

+ func (ls *LabelSelector) String() string

type Namespaces

+ func (n *Namespaces) Finalize()

+ func (n *Namespaces) String() string

type ReloaderOption

+ func ReloaderUseSignal() ReloaderOption

+ func RuntimeInfoURL(u url.URL) ReloaderOption

+ type StringSet map[string]struct

+ func (s StringSet) Insert(value string)

+ func (s StringSet) Set(value string) error

+ func (s StringSet) Slice() []string

+ func (s StringSet) String() string

Nov 9, 2023

Changes in this version

+ const PrometheusOperatorFieldManager

+ func CheckStorageClass(ctx context.Context, canReadStorageClass bool, kclient kubernetes.Interface, ...) error

type Config

+ ImpersonateUser string

+ KubernetesVersion version.Info

type ReloaderOption

+ func WebConfigFile(config string) ReloaderOption

Sep 8, 2023

Changes in this version

type Config

+ func DefaultConfig(cpu, memory string) Config

type ContainerConfig

+ CPULimits Quantity

+ CPURequests Quantity

+ MemoryLimits Quantity

+ MemoryRequests Quantity

+ func (cc ContainerConfig) ResourceRequirements() v1.ResourceRequirements

+ type Quantity struct

+ func (q *Quantity) Set(value string) error

+ func (q *Quantity) String() string

Jul 27, 2023

Changes in this version

+ type Map map[string]string

+ func (m *Map) Merge(other map[string]string) map[string]string

+ func (m *Map) Set(value string) error

+ func (m *Map) SortedKeys() []string

+ func (m *Map) String() string

Jun 14, 2023

Changes in this version

+ const PodNameEnvVar

+ const ShardEnvVar

+ type Annotations struct

+ AnnotationsMap map[string]string

+ AnnotationsString string

+ func (annotations *Annotations) Merge(otherAnnotations map[string]string) map[string]string

+ func (annotations *Annotations) Set(value string) error

+ func (annotations *Annotations) String() string

type Config

+ Annotations Annotations

+ KubeletSelector string

May 4, 2023

Changes in this version

+ func FindStatusCondition(conditions []monitoringv1.Condition, conditionType monitoringv1.ConditionType) *monitoringv1.Condition

+ func StatusPoller(ctx context.Context, sr StatusReconciler)

+ func UpdateConditions(conditions []monitoringv1.Condition, newConditions ...monitoringv1.Condition) []monitoringv1.Condition

type ContainerConfig

+ EnableProbes bool

+ type GoverningObject interface

+ ExpectedReplicas func() int

+ SetAvailableReplicas func(int)

+ SetReplicas func(int)

+ SetUnavailableReplicas func(int)

+ SetUpdatedReplicas func(int)

type ReconciliationTracker

+ func (rt *ReconciliationTracker) GetCondition(k string, gen int64) monitoringv1.Condition

type StatefulSetReporter

+ func (sr *StatefulSetReporter) Update(gObj GoverningObject) monitoringv1.Condition

+ type StatusReconciler interface

+ Iterate func(func(metav1.Object, []monitoringv1.Condition))

+ RefreshStatusFor func(metav1.Object)

Mar 29, 2023

Changes in this version

+ func ListMatchingNamespaces(selector labels.Selector, nsInf cache.SharedIndexInformer) ([]string, error)

+ type Accessor struct

+ func NewAccessor(l log.Logger) *Accessor

+ func (a *Accessor) MetaNamespaceKey(obj interface{}) (string, bool)

+ func (a *Accessor) ObjectMetadata(obj interface{}) (metav1.Object, bool)

+ type PrometheusRuleSelector struct

+ func NewPrometheusRuleSelector(ruleFormat RuleConfigurationFormat, labelSelector *metav1.LabelSelector, ...) (*PrometheusRuleSelector, error)

+ func (pr *PrometheusRuleSelector) Select(namespaces []string) (map[string]string, int, error)

+ type RuleConfigurationFormat int

+ const PrometheusFormat

+ const ThanosFormat

Feb 8, 2023

Changes in this version

+ var DefaultReloaderTestConfig = &Config

+ func BuildArgs(args []monitoringv1.Argument, additionalArgs []monitoringv1.Argument) ([]string, error)

+ func TestSidecarsResources(t *testing.T, ...)

+ type ContainerConfig struct

+ CPULimit string

+ CPURequest string

+ Image string

+ MemoryLimit string

+ MemoryRequest string

type Labels

+ func (labels *Labels) SortedKeys() []string

+ type Pod v1.Pod

+ func (p *Pod) Message() string

+ func (p *Pod) Ready() bool

+ type StatefulSetReporter struct

+ Pods []*Pod

+ func NewStatefulSetReporter(ctx context.Context, kclient kubernetes.Interface, sset *appsv1.StatefulSet) (*StatefulSetReporter, error)

+ func (sr *StatefulSetReporter) IsUpdated(p *Pod) bool

+ func (sr *StatefulSetReporter) ReadyPods() []*Pod

+ func (sr *StatefulSetReporter) UpdatedPods() []*Pod

Jan 5, 2023

Changes in this version

type ReloaderOption

+ func ImagePullPolicy(imagePullPolicy v1.PullPolicy) ReloaderOption

Nov 21, 2022

Changes in this version

+ const AddEvent

+ const DeleteEvent

+ const UpdateEvent

+ func GenerateRulesConfiguration(promRule monitoringv1.PrometheusRuleSpec, logger log.Logger) (string, error)

+ func ValidateRule(promRule monitoringv1.PrometheusRuleSpec) []error

+ type HandlerEvent string

+ type ReconcilerMetrics interface

+ TriggerByCounter func(string, HandlerEvent) prometheus.Counter

+ type ResourceReconciler struct

+ func NewResourceReconciler(l log.Logger, syncer Syncer, metrics ReconcilerMetrics, kind string, ...) *ResourceReconciler

+ func (rr *ResourceReconciler) DeletionInProgress(o metav1.Object) bool

+ func (rr *ResourceReconciler) EnqueueForReconciliation(obj metav1.Object)

+ func (rr *ResourceReconciler) EnqueueForStatus(obj metav1.Object)

+ func (rr *ResourceReconciler) OnAdd(obj interface{})

+ func (rr *ResourceReconciler) OnDelete(obj interface{})

+ func (rr *ResourceReconciler) OnUpdate(old, cur interface{})

+ func (rr *ResourceReconciler) Run(ctx context.Context)

+ func (rr *ResourceReconciler) Stop()

+ type Syncer interface

+ Resolve func(*appsv1.StatefulSet) metav1.Object

+ Sync func(context.Context, string) error

+ UpdateStatus func(context.Context, string) error

Sep 2, 2022

Changes in this version

+ func GunzipConfig(b []byte) (string, error)

+ func GzipConfig(w io.Writer, conf []byte) error

Jun 3, 2022

Changes in this version

+ func CurlProber(u string) string

+ func MakeHostAliases(input []monitoringv1.HostAlias) []v1.HostAlias

+ func WgetProber(u string) string

Apr 22, 2022

Changes in this version

type Metrics

+ func (m *Metrics) ReconcileDurationHistogram() prometheus.Histogram

+ type ReconciliationStatus struct

+ func (rs ReconciliationStatus) Message() string

+ func (rs ReconciliationStatus) Ok() bool

+ func (rs ReconciliationStatus) Reason() string

+ type ReconciliationTracker struct

+ func (rt *ReconciliationTracker) Collect(ch chan<- prometheus.Metric)

+ func (rt *ReconciliationTracker) Describe(ch chan<- *prometheus.Desc)

+ func (rt *ReconciliationTracker) ForgetObject(k string)

+ func (rt *ReconciliationTracker) GetStatus(k string) (ReconciliationStatus, bool)

+ func (rt *ReconciliationTracker) SetStatus(k string, err error)

Mar 10, 2022

Changes in this version

type Namespaces

+ AlertmanagerConfigAllowList map[string]struct{}

Jan 27, 2022

Changes in this version

+ func CompareScrapeTimeoutToScrapeInterval(scrapeTimeout, scrapeInterval string) error

Dec 16, 2021

Changes in this version

+ const MaxSecretDataSizeBytes

+ type ShardedSecret struct

+ func NewShardedSecret(template *v1.Secret, namePrefix string) *ShardedSecret

+ func (s *ShardedSecret) AppendData(key string, data []byte)

+ func (s *ShardedSecret) ShardNames() []string

+ func (s *ShardedSecret) StoreSecrets(ctx context.Context, sClient corev1.SecretInterface) error

Nov 4, 2021

Changes in this version

+ func ValidateDurationField(durationField string) error

+ func ValidateSizeField(sizeField string) error

Jul 6, 2021

Changes in this version

+ type ConfigReloader struct

+ type ReloaderOption = func(*ConfigReloader)

+ func ConfigEnvsubstFile(configEnvsubstFile string) ReloaderOption

+ func ConfigFile(configFile string) ReloaderOption

+ func ListenLocal(listenLocal bool) ReloaderOption

+ func LocalHost(localHost string) ReloaderOption

+ func LogFormat(logFormat string) ReloaderOption

+ func LogLevel(logLevel string) ReloaderOption

+ func ReloaderResources(rc ReloaderConfig) ReloaderOption

+ func ReloaderRunOnce() ReloaderOption

+ func ReloaderURL(reloadURL url.URL) ReloaderOption

+ func Shard(shard int32) ReloaderOption

+ func VolumeMounts(mounts []v1.VolumeMount) ReloaderOption

+ func WatchedDirectories(watchedDirectories []string) ReloaderOption

Apr 13, 2021

Changes in this version

type ReloaderConfig

+ CPULimit string

+ CPURequest string

+ MemoryLimit string

+ MemoryRequest string

Nov 4, 2020

Changes in this version

+ func WaitForNamedCacheSync(ctx context.Context, controllerName string, logger log.Logger, ...) bool

Oct 27, 2020

Changes in this version

+ func CreateConfigReloader(config ReloaderConfig, reloadURL url.URL, listenLocal bool, localHost string, ...) v1.Container

+ func WaitForCacheSync(ctx context.Context, logger log.Logger, inf cache.SharedIndexInformer) bool

type Config

+ AlertManagerSelector string

+ AlertmanagerDefaultBaseImage string

+ ClusterDomain string

+ KubeletObject string

+ Labels Labels

+ ListenAddress string

+ LocalHost string

+ LogFormat string

+ LogLevel string

+ Namespaces Namespaces

+ PromSelector string

+ PrometheusDefaultBaseImage string

+ ReloaderConfig ReloaderConfig

+ SecretListWatchSelector string

+ ServerTLSConfig TLSServerConfig

+ ThanosDefaultBaseImage string

+ ThanosRulerSelector string

+ type Labels struct

+ LabelsMap map[string]string

+ LabelsString string

+ func (labels *Labels) Merge(otherLabels map[string]string) map[string]string

+ func (labels *Labels) Set(value string) error

+ func (labels *Labels) String() string

type Metrics

+ func (m *Metrics) Collect(ch chan<- prometheus.Metric)

+ func (m *Metrics) Describe(ch chan<- *prometheus.Desc)

+ func (m *Metrics) ForgetObject(objKey string)

+ func (m *Metrics) Ready() prometheus.Gauge

+ func (m *Metrics) SetRejectedResources(objKey, resource string, v int)

+ func (m *Metrics) SetSelectedResources(objKey, resource string, v int)

+ func (m *Metrics) SetSyncStatus(objKey string, success bool)

+ type Namespaces struct

+ AlertmanagerAllowList map[string]struct{}

+ AllowList map[string]struct{}

+ DenyList map[string]struct{}

+ PrometheusAllowList map[string]struct{}

+ ThanosRulerAllowList map[string]struct{}

+ type ReloaderConfig struct

+ CPU string

+ Image string

+ Memory string

Sep 10, 2020

Changes in this version

+ const DefaultAlertmanagerBaseImage

+ const DefaultAlertmanagerImage

+ const DefaultAlertmanagerVersion

+ const DefaultConfigMapReloaderImage

+ const DefaultThanosBaseImage

+ const DefaultThanosImage

+ const DefaultThanosVersion

+ var DefaultPrometheusBaseImage = "quay.io/prometheus/prometheus"

+ var DefaultPrometheusConfigReloaderImage = "quay.io/prometheus-operator/prometheus-config-reloader:v" + version.Version

+ var DefaultPrometheusImage = DefaultPrometheusBaseImage + ":" + DefaultPrometheusVersion

+ var DefaultPrometheusVersion = PrometheusCompatibilityMatrix[len(PrometheusCompatibilityMatrix)-1]

+ var PrometheusCompatibilityMatrix = []string

+ func BuildImagePath(image, version, tag, sha string) (string, error)

+ func MakeVolumeClaimTemplate(e monitoringv1.EmbeddedPersistentVolumeClaim) *v1.PersistentVolumeClaim

+ func NewStoreCollector(resource string, s cache.Store) prometheus.Collector

+ func NewTLSConfig(logger log.Logger, certFile, keyFile, clientCAFile, minVersion string, ...) (*tls.Config, error)

+ func SanitizeSTS(sts *appsv1.StatefulSet)

+ func StringPtrValOrDefault(val *string, defaultVal string) string

+ func StringValOrDefault(val, defaultVal string) string

+ type Metrics struct

+ func NewMetrics(name string, r prometheus.Registerer) *Metrics

+ func (m *Metrics) MustRegister(metrics ...prometheus.Collector)

+ func (m *Metrics) NewInstrumentedListerWatcher(lw cache.ListerWatcher) cache.ListerWatcher

+ func (m *Metrics) ReconcileCounter() prometheus.Counter

+ func (m *Metrics) ReconcileErrorsCounter() prometheus.Counter

+ func (m *Metrics) StsDeleteCreateCounter() prometheus.Counter

+ func (m *Metrics) TriggerByCounter(triggered_by, action string) prometheus.Counter

+ type TLSServerConfig struct

+ CertFile string

+ CipherSuites []string

+ ClientCAFile string

+ KeyFile string

+ MinVersion string

+ ReloadInterval time.Duration

Nov 9, 2016

Changes in this version

+ func NewPrometheusListWatch(client *rest.RESTClient) *cache.ListWatch

+ func NewServiceMonitorListWatch(client *rest.RESTClient) *cache.ListWatch

+ type Config struct

+ Host string

+ TLSConfig rest.TLSClientConfig

+ TLSInsecure bool

+ type Operator struct

+ func New(c Config) (*Operator, error)

+ func (c *Operator) Run(stopc <-chan struct{}) error