Breaker is the base of a circuit breaker. It maintains failure and success counters as well as the event subscribers.

BreakerEvent indicates the type of event received over an event channel

A Class is a set of types of outcomes (including errors) that will often be handled in the same way.

ClientMetrics represents a collection of metrics to be registered on a Prometheus metrics registry for a gRPC client.

A CounterOption lets you add options to Counter metrics using With* funcs.

EtcdResolver is an implementation of grpc.naming.Resolver

EtcdWatcher is the implementation of grpc.naming.Watcher

please upgrade the proto package

ExampleServiceClient is the client API for ExampleService service. For semantics around ctx use and closing/ending streaming RPCs, please refer to ht

ExampleServiceServer is the server API for ExampleService service.

HTTPClient is a wrapper around http.Client that provides circuit breaker capabilities. By default, the client will use its defaultBreaker. A BreakerL

A HistogramOption lets you add options to Histogram metrics using With* funcs.

ListenerEvent includes a reference to the circuit breaker and the event.

Option instances may be used in OpenTracing(Server|Client)Interceptor initialization. See this post about the "functional options" pattern: http://da

Options holds breaker configuration options.

Panel tracks a group of circuit breakers by name.

PanelEvent wraps a BreakerEvent and provides the string name of the breaker

RateLimiter instances are thread-safe.

ServerMetrics represents a collection of metrics to be registered on a Prometheus metrics registry for a gRPC server.

SpanDecoratorFunc provides an (optional) mechanism for otgrpc users to add arbitrary tags/logs/etc to the opentracing.Span associated with client and/

SpanInclusionFunc provides an optional mechanism to decide whether or not to trace a given gRPC call. Return true to create a Span and initiate tracin

Statter interface provides a way to gather statistics from breakers

TripFunc is a function called by a Breaker's Fail() function and determines whether the breaker should trip. It will receive the Breaker as an argumen

bucket holds counts of failures and successes

metadataReaderWriter satisfies both the opentracing.TextMapReader and opentracing.TextMapWriter interfaces.

monitoredClientStream wraps grpc.ClientStream allowing each Sent/Recv of message to increment counters.

monitoredStream wraps grpc.ServerStream allowing each Sent/Recv of message to increment counters.

The internal-only options struct. Obviously overkill at the moment; but will scale well as production use dictates other configuration and tuning para

window maintains a ring of buckets and increments the failure and success counts of the current bucket. Once a specified time has elapsed, it will adv