noop

package
v0.0.0-...-1e8dc9b Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 26, 2024 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Sink

type Sink struct {
	// contains filtered or unexported fields
}

Sink describes a no-op sink

func New

func New(log *zap.SugaredLogger) Sink

New ...

func (Sink) Close

func (n Sink) Close() error

Close returns nil

func (Sink) GetPrefix

func (n Sink) GetPrefix() string

GetPrefix returns the prefix used when sending metrics to datadog

func (Sink) GetSinkName

func (n Sink) GetSinkName() string

GetSinkName returns the name of the sink

func (Sink) MetricCleaned

func (n Sink) MetricCleaned(succeed bool, kind string, tags []string) error

MetricCleaned increments the cleaned metric

func (Sink) MetricCleanedForReinjection

func (n Sink) MetricCleanedForReinjection(succeed bool, kind string, tags []string) error

MetricCleanedForReinjection increments the cleanedForReinjection metric

func (Sink) MetricCleanupDuration

func (n Sink) MetricCleanupDuration(duration time.Duration, tags []string) error

MetricCleanupDuration send timing metric for cleanup duration

func (Sink) MetricDisruptionCompletedDuration

func (n Sink) MetricDisruptionCompletedDuration(duration time.Duration, tags []string) error

MetricDisruptionCompletedDuration sends timing metric for entire disruption duration

func (Sink) MetricDisruptionOngoingDuration

func (n Sink) MetricDisruptionOngoingDuration(duration time.Duration, tags []string) error

MetricDisruptionOngoingDuration sends timing metric for disruption duration so far

func (Sink) MetricDisruptionScheduled

func (n Sink) MetricDisruptionScheduled(tags []string) error

MetricDisruptionScheduled reports when a new disruption is scheduled

func (Sink) MetricDisruptionsCount

func (n Sink) MetricDisruptionsCount(kind chaostypes.DisruptionKindName, tags []string) error

MetricDisruptionsCount counts finished disruptions, and tags the disruption kind

func (Sink) MetricDisruptionsGauge

func (n Sink) MetricDisruptionsGauge(gauge float64, tags []string) error

MetricDisruptionsGauge sends disruptions.gauge metric

func (Sink) MetricInformed

func (n Sink) MetricInformed(tags []string) error

func (Sink) MetricInjectDuration

func (n Sink) MetricInjectDuration(duration time.Duration, tags []string) error

MetricInjectDuration send timing metric for inject duration

func (Sink) MetricInjected

func (n Sink) MetricInjected(succeed bool, kind string, tags []string) error

MetricInjected increments the injected metric

func (Sink) MetricMissingTargetFound

func (n Sink) MetricMissingTargetFound(tags []string) error

MetricMissingTargetFound reports when a scheduled Disruption which had initially been deemed missing is "found" and running in the kubernetes namespace

func (Sink) MetricNextScheduledTime

func (n Sink) MetricNextScheduledTime(duration time.Duration, tags []string) error

MetricNextScheduledTime reports the duration until the next scheduled disruption will run

func (Sink) MetricOrphanFound

func (n Sink) MetricOrphanFound(tags []string) error

func (Sink) MetricPodsCreated

func (n Sink) MetricPodsCreated(target, instanceName, namespace string, succeed bool) error

MetricPodsCreated increment pods.created metric

func (Sink) MetricPodsGauge

func (n Sink) MetricPodsGauge(gauge float64) error

MetricPodsGauge sends pods.gauge metric

func (Sink) MetricReconcile

func (n Sink) MetricReconcile() error

MetricReconcile increment reconcile metric

func (Sink) MetricReconcileDuration

func (n Sink) MetricReconcileDuration(duration time.Duration, tags []string) error

MetricReconcileDuration send timing metric for reconcile loop

func (Sink) MetricReinjected

func (n Sink) MetricReinjected(succeed bool, kind string, tags []string) error

MetricReinjected increments the reinjected metric

func (Sink) MetricRestart

func (n Sink) MetricRestart() error

MetricRestart sends restart metric

func (Sink) MetricSelectorCacheGauge

func (n Sink) MetricSelectorCacheGauge(gauge float64) error

MetricSelectorCacheGauge reports how many caches are still in the cache array to prevent leaks

func (Sink) MetricStuckOnRemoval

func (n Sink) MetricStuckOnRemoval(tags []string) error

MetricStuckOnRemoval increments disruptions.stuck_on_removal metric

func (Sink) MetricStuckOnRemovalGauge

func (n Sink) MetricStuckOnRemovalGauge(gauge float64) error

MetricStuckOnRemovalGauge sends disruptions.stuck_on_removal_total metric

func (Sink) MetricTargetMissing

func (n Sink) MetricTargetMissing(duration time.Duration, tags []string) error

MetricTargetMissing reports when a scheduled Disruption can not find its specific target either for the first time or multiple times. A deletion occurs on the final alert

func (Sink) MetricTooLate

func (n Sink) MetricTooLate(tags []string) error

MetricTooLate reports when a scheduled disruption misses its aloted time to be scheduled specific to cron and rollout controllers

func (Sink) MetricValidationCreated

func (n Sink) MetricValidationCreated(tags []string) error

func (Sink) MetricValidationDeleted

func (n Sink) MetricValidationDeleted(tags []string) error

func (Sink) MetricValidationFailed

func (n Sink) MetricValidationFailed(tags []string) error

func (Sink) MetricValidationUpdated

func (n Sink) MetricValidationUpdated(tags []string) error

func (Sink) MetricWatcherCalls

func (n Sink) MetricWatcherCalls(tags []string) error

MetricWatcherCalls count the number of watcher calls

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL