Documentation ¶
Index ¶
- func GetPrefixFromApp(app types.SinkApp) (string, error)
- type Sink
- func (d Sink) Close() error
- func (d Sink) GetPrefix() string
- func (d Sink) GetSinkName() string
- func (d Sink) MetricCleaned(succeed bool, kind string, tags []string) error
- func (d Sink) MetricCleanedForReinjection(succeed bool, kind string, tags []string) error
- func (d Sink) MetricCleanupDuration(duration time.Duration, tags []string) error
- func (d Sink) MetricDisruptionCompletedDuration(duration time.Duration, tags []string) error
- func (d Sink) MetricDisruptionOngoingDuration(duration time.Duration, tags []string) error
- func (d Sink) MetricDisruptionScheduled(tags []string) error
- func (d Sink) MetricDisruptionsCount(kind chaostypes.DisruptionKindName, tags []string) error
- func (d Sink) MetricDisruptionsGauge(gauge float64, tags []string) error
- func (d Sink) MetricInformed(tags []string) error
- func (d Sink) MetricInjectDuration(duration time.Duration, tags []string) error
- func (d Sink) MetricInjected(succeed bool, kind string, tags []string) error
- func (d Sink) MetricMissingTargetFound(tags []string) error
- func (d Sink) MetricNextScheduledTime(duration time.Duration, tags []string) error
- func (d Sink) MetricOrphanFound(tags []string) error
- func (d Sink) MetricPodsCreated(target, instanceName, namespace string, succeed bool) error
- func (d Sink) MetricPodsGauge(gauge float64) error
- func (d Sink) MetricReconcile() error
- func (d Sink) MetricReconcileDuration(duration time.Duration, tags []string) error
- func (d Sink) MetricReinjected(succeed bool, kind string, tags []string) error
- func (d Sink) MetricRestart() error
- func (d Sink) MetricSelectorCacheGauge(gauge float64) error
- func (d Sink) MetricStuckOnRemoval(tags []string) error
- func (d Sink) MetricStuckOnRemovalGauge(gauge float64) error
- func (d Sink) MetricTargetMissing(duration time.Duration, tags []string) error
- func (d Sink) MetricTooLate(tags []string) error
- func (d Sink) MetricValidationCreated(tags []string) error
- func (d Sink) MetricValidationDeleted(tags []string) error
- func (d Sink) MetricValidationFailed(tags []string) error
- func (d Sink) MetricValidationUpdated(tags []string) error
- func (d Sink) MetricWatcherCalls(tags []string) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type Sink ¶
type Sink struct {
// contains filtered or unexported fields
}
Sink describes a Datadog sink (statsd)
func (Sink) GetSinkName ¶
GetSinkName returns the name of the sink
func (Sink) MetricCleaned ¶
MetricCleaned increments the cleaned metric
func (Sink) MetricCleanedForReinjection ¶
MetricCleanedForReinjection increments the cleanedForReinjection metric
func (Sink) MetricCleanupDuration ¶
MetricCleanupDuration send timing metric for cleanup duration
func (Sink) MetricDisruptionCompletedDuration ¶
MetricDisruptionCompletedDuration sends timing metric for entire disruption duration
func (Sink) MetricDisruptionOngoingDuration ¶
MetricDisruptionOngoingDuration sends timing metric for disruption duration so far
func (Sink) MetricDisruptionScheduled ¶
MetricDisruptionScheduled reports when a new disruption is scheduled
func (Sink) MetricDisruptionsCount ¶
func (d Sink) MetricDisruptionsCount(kind chaostypes.DisruptionKindName, tags []string) error
MetricDisruptionsCount counts finished disruptions, and tags the disruption kind
func (Sink) MetricDisruptionsGauge ¶
MetricDisruptionsGauge sends the disruptions.gauge metric counting ongoing disruptions
func (Sink) MetricInformed ¶
MetricInformed increments when the pod informer receives an event to process before reconciliation
func (Sink) MetricInjectDuration ¶
MetricInjectDuration send timing metric for inject duration
func (Sink) MetricInjected ¶
MetricInjected increments the injected metric
func (Sink) MetricMissingTargetFound ¶
MetricMissingTargetFound reports when a scheduled Disruption which had initially been deemed missing is "found" and running in the kubernetes namespace
func (Sink) MetricNextScheduledTime ¶
MetricNextScheduledTime reports the duration until the next scheduled disruption will run
func (Sink) MetricOrphanFound ¶
MetricOrphanFound increments when a chaos pod without a corresponding disruption resource is found
func (Sink) MetricPodsCreated ¶
MetricPodsCreated increment pods.created metric
func (Sink) MetricPodsGauge ¶
MetricPodsGauge sends the pods.gauge metric counting existing chaos pods
func (Sink) MetricReconcile ¶
MetricReconcile increment reconcile metric
func (Sink) MetricReconcileDuration ¶
MetricReconcileDuration send timing metric for reconcile loop
func (Sink) MetricReinjected ¶
MetricReinjected increments the reinjected metric
func (Sink) MetricRestart ¶
MetricRestart sends an increment of the controller restart metric
func (Sink) MetricSelectorCacheGauge ¶
MetricSelectorCacheGauge reports how many caches are still in the cache array to prevent leaks
func (Sink) MetricStuckOnRemoval ¶
MetricStuckOnRemoval increments disruptions.stuck_on_removal metric
func (Sink) MetricStuckOnRemovalGauge ¶
MetricStuckOnRemovalGauge sends disruptions.stuck_on_removal_total metric containing the gauge of stuck disruptions
func (Sink) MetricTargetMissing ¶
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 ¶
MetricTooLate reports when a scheduled disruption misses its aloted time to be scheduled specific to cron and rollout controllers
func (Sink) MetricValidationCreated ¶
MetricValidationCreated increments the created validation metric
func (Sink) MetricValidationDeleted ¶
MetricValidationDeleted increments the deleted validation metric
func (Sink) MetricValidationFailed ¶
MetricValidationFailed increments the failed validation metric
func (Sink) MetricValidationUpdated ¶
MetricValidationUpdated increments the updated validation metric
func (Sink) MetricWatcherCalls ¶
MetricWatcherCalls is a counter of watcher calls.