Sum sums the values over the buckets in the last 10 seconds.

The Default Collector function will panic if collectors are not setup to specification.

Flush purges all circuit and metric information from memory.

GoC runs your function while tracking the health of previous calls to it. If your function begins slowing down or failing repeatedly, we will block ne

ConfigureCommand applies settings for a circuit

GetCircuit returns the circuit for the given command and whether this call created it.

Increment increments the number in current timeBucket.

Percentile computes the percentile given with a linear interpolation.

Add appends the time.Duration given to the current time bucket.

Timeouts returns the rolling number of timeouts

Failures returns the rolling number of failures

NumRequests returns the rolling number of requests

DoC runs your function in a synchronous manner, blocking until either your function succeeds or an error is returned, including hystrix circuit errors

FallbackSuccesses returns the rolling number of fallback successes

IsOpen is called before any Command execution to check whether or not it should be attempted. An "open" circuit means it is disabled.

Successes returns the rolling number of successes

errorWithFallback triggers the fallback while reporting the appropriate metric events.

Mean computes the average timing in the last 60 seconds.

NewNumber initializes a RollingNumber struct.

Reset resets the internal counters and timers.

Max returns the maximum value seen in the last 10 seconds.

ReportEvent records command metrics for tracking recent error rates and exposing data to the dashboard.

ShortCircuits returns the rolling number of short circuits

UpdateMax updates the maximum value in the current bucket.

Errors returns the rolling number of errors

FallbackFailures returns the rolling number of fallback failures

Go runs your function while tracking the health of previous calls to it. If your function begins slowing down or failing repeatedly, we will block new

InitializeStatsdCollector creates the connection to the Statsd server and should be called before any metrics are recorded. Users should ensure to ca

NewStatsdCollector creates a collector for a specific circuit. The prefix given to this circuit will be {config.Prefix}.{circuit_name}.{metric}. Circu

RunDuration returns the rolling run duration

SortedDurations returns an array of time.Duration sorted from shortest to longest that have occurred in the last 60 seconds.

Stop shuts down the metric collection routine

TotalDuration returns the rolling total duration

Update accepts a set of metrics from a command execution for remote instrumentation

grabFirstFromStream reads on the http request until we see the first full result printed

AllowRequest is checked before a command executes, ensuring that circuit state and metric health allow it. When the circuit is open, this call will oc

InitializeMetricCollectors runs the registried MetricCollector Initializers to create an array of MetricCollectors.

NewDatadogCollectorWithClient accepts an interface which allows you to provide your own implementation of a statsd client, alter configuration on "git

NewStreamHandler returns a server capable of exposing dashboard metrics via HTTP.

NewTiming creates a RollingTiming struct.

Register places a MetricCollector Initializer in the registry maintained by this metricCollectorRegistry.

Rejects returns the rolling number of rejects

Reset resets all metrics in this collector to 0.

Start begins watching the in-memory circuit breakers for metrics

newCircuitBreaker creates a CircuitBreaker with associated Health

toggleForceOpen allows manually causing the fallback logic for all instances of a given command.