Documentation ¶
Overview ¶
Code generated by counterfeiter. DO NOT EDIT.
Code generated by counterfeiter. DO NOT EDIT.
Code generated by counterfeiter. DO NOT EDIT.
Code generated by counterfeiter. DO NOT EDIT.
Code generated by counterfeiter. DO NOT EDIT.
This file was generated by counterfeiter ¶
This file was generated by counterfeiter
Index ¶
- type FakeCombinedReporter
- func (fake *FakeCombinedReporter) CaptureBackendExhaustedConns()
- func (fake *FakeCombinedReporter) CaptureBackendExhaustedConnsCallCount() int
- func (fake *FakeCombinedReporter) CaptureBackendInvalidID()
- func (fake *FakeCombinedReporter) CaptureBackendInvalidIDCallCount() int
- func (fake *FakeCombinedReporter) CaptureBackendInvalidTLSCert()
- func (fake *FakeCombinedReporter) CaptureBackendInvalidTLSCertCallCount() int
- func (fake *FakeCombinedReporter) CaptureBackendTLSHandshakeFailed()
- func (fake *FakeCombinedReporter) CaptureBackendTLSHandshakeFailedCallCount() int
- func (fake *FakeCombinedReporter) CaptureBadGateway()
- func (fake *FakeCombinedReporter) CaptureBadGatewayCallCount() int
- func (fake *FakeCombinedReporter) CaptureBadRequest()
- func (fake *FakeCombinedReporter) CaptureBadRequestCallCount() int
- func (fake *FakeCombinedReporter) CaptureRouteServiceResponse(res *http.Response)
- func (fake *FakeCombinedReporter) CaptureRouteServiceResponseArgsForCall(i int) *http.Response
- func (fake *FakeCombinedReporter) CaptureRouteServiceResponseCallCount() int
- func (fake *FakeCombinedReporter) CaptureRoutingRequest(b *route.Endpoint)
- func (fake *FakeCombinedReporter) CaptureRoutingRequestArgsForCall(i int) *route.Endpoint
- func (fake *FakeCombinedReporter) CaptureRoutingRequestCallCount() int
- func (fake *FakeCombinedReporter) CaptureRoutingResponse(statusCode int)
- func (fake *FakeCombinedReporter) CaptureRoutingResponseArgsForCall(i int) int
- func (fake *FakeCombinedReporter) CaptureRoutingResponseCallCount() int
- func (fake *FakeCombinedReporter) CaptureRoutingResponseLatency(b *route.Endpoint, statusCode int, t time.Time, d time.Duration)
- func (fake *FakeCombinedReporter) CaptureRoutingResponseLatencyArgsForCall(i int) (*route.Endpoint, int, time.Time, time.Duration)
- func (fake *FakeCombinedReporter) CaptureRoutingResponseLatencyCallCount() int
- func (fake *FakeCombinedReporter) CaptureWebSocketFailure()
- func (fake *FakeCombinedReporter) CaptureWebSocketFailureCallCount() int
- func (fake *FakeCombinedReporter) CaptureWebSocketUpdate()
- func (fake *FakeCombinedReporter) CaptureWebSocketUpdateCallCount() int
- func (fake *FakeCombinedReporter) Invocations() map[string][][]interface{}
- type FakeProxyReporter
- func (fake *FakeProxyReporter) CaptureBackendExhaustedConns()
- func (fake *FakeProxyReporter) CaptureBackendExhaustedConnsCallCount() int
- func (fake *FakeProxyReporter) CaptureBackendInvalidID()
- func (fake *FakeProxyReporter) CaptureBackendInvalidIDCallCount() int
- func (fake *FakeProxyReporter) CaptureBackendInvalidTLSCert()
- func (fake *FakeProxyReporter) CaptureBackendInvalidTLSCertCallCount() int
- func (fake *FakeProxyReporter) CaptureBackendTLSHandshakeFailed()
- func (fake *FakeProxyReporter) CaptureBackendTLSHandshakeFailedCallCount() int
- func (fake *FakeProxyReporter) CaptureBadGateway()
- func (fake *FakeProxyReporter) CaptureBadGatewayCallCount() int
- func (fake *FakeProxyReporter) CaptureBadRequest()
- func (fake *FakeProxyReporter) CaptureBadRequestCallCount() int
- func (fake *FakeProxyReporter) CaptureRouteServiceResponse(res *http.Response)
- func (fake *FakeProxyReporter) CaptureRouteServiceResponseArgsForCall(i int) *http.Response
- func (fake *FakeProxyReporter) CaptureRouteServiceResponseCallCount() int
- func (fake *FakeProxyReporter) CaptureRoutingRequest(b *route.Endpoint)
- func (fake *FakeProxyReporter) CaptureRoutingRequestArgsForCall(i int) *route.Endpoint
- func (fake *FakeProxyReporter) CaptureRoutingRequestCallCount() int
- func (fake *FakeProxyReporter) CaptureRoutingResponse(statusCode int)
- func (fake *FakeProxyReporter) CaptureRoutingResponseArgsForCall(i int) int
- func (fake *FakeProxyReporter) CaptureRoutingResponseCallCount() int
- func (fake *FakeProxyReporter) CaptureRoutingResponseLatency(b *route.Endpoint, statusCode int, t time.Time, d time.Duration)
- func (fake *FakeProxyReporter) CaptureRoutingResponseLatencyArgsForCall(i int) (*route.Endpoint, int, time.Time, time.Duration)
- func (fake *FakeProxyReporter) CaptureRoutingResponseLatencyCallCount() int
- func (fake *FakeProxyReporter) CaptureWebSocketFailure()
- func (fake *FakeProxyReporter) CaptureWebSocketFailureCallCount() int
- func (fake *FakeProxyReporter) CaptureWebSocketUpdate()
- func (fake *FakeProxyReporter) CaptureWebSocketUpdateCallCount() int
- func (fake *FakeProxyReporter) Invocations() map[string][][]interface{}
- type FakeRouteRegistryReporter
- func (fake *FakeRouteRegistryReporter) CaptureLookupTime(t time.Duration)
- func (fake *FakeRouteRegistryReporter) CaptureLookupTimeArgsForCall(i int) time.Duration
- func (fake *FakeRouteRegistryReporter) CaptureLookupTimeCallCount() int
- func (fake *FakeRouteRegistryReporter) CaptureRegistryMessage(msg metrics.ComponentTagged)
- func (fake *FakeRouteRegistryReporter) CaptureRegistryMessageArgsForCall(i int) metrics.ComponentTagged
- func (fake *FakeRouteRegistryReporter) CaptureRegistryMessageCallCount() int
- func (fake *FakeRouteRegistryReporter) CaptureRouteRegistrationLatency(t time.Duration)
- func (fake *FakeRouteRegistryReporter) CaptureRouteRegistrationLatencyArgsForCall(i int) time.Duration
- func (fake *FakeRouteRegistryReporter) CaptureRouteRegistrationLatencyCallCount() int
- func (fake *FakeRouteRegistryReporter) CaptureRouteStats(totalRoutes int, msSinceLastUpdate uint64)
- func (fake *FakeRouteRegistryReporter) CaptureRouteStatsArgsForCall(i int) (int, uint64)
- func (fake *FakeRouteRegistryReporter) CaptureRouteStatsCallCount() int
- func (fake *FakeRouteRegistryReporter) CaptureRoutesPruned(prunedRoutes uint64)
- func (fake *FakeRouteRegistryReporter) CaptureRoutesPrunedArgsForCall(i int) uint64
- func (fake *FakeRouteRegistryReporter) CaptureRoutesPrunedCallCount() int
- func (fake *FakeRouteRegistryReporter) CaptureUnregistryMessage(msg metrics.ComponentTagged)
- func (fake *FakeRouteRegistryReporter) CaptureUnregistryMessageArgsForCall(i int) metrics.ComponentTagged
- func (fake *FakeRouteRegistryReporter) CaptureUnregistryMessageCallCount() int
- func (fake *FakeRouteRegistryReporter) Invocations() map[string][][]interface{}
- func (fake *FakeRouteRegistryReporter) UnmuzzleRouteRegistrationLatency()
- func (fake *FakeRouteRegistryReporter) UnmuzzleRouteRegistrationLatencyCallCount() int
- type FakeSubscriber
- func (fake *FakeSubscriber) Dropped() (int, error)
- func (fake *FakeSubscriber) DroppedCallCount() int
- func (fake *FakeSubscriber) DroppedReturns(result1 int, result2 error)
- func (fake *FakeSubscriber) DroppedReturnsOnCall(i int, result1 int, result2 error)
- func (fake *FakeSubscriber) Invocations() map[string][][]interface{}
- func (fake *FakeSubscriber) Pending() (int, error)
- func (fake *FakeSubscriber) PendingCallCount() int
- func (fake *FakeSubscriber) PendingReturns(result1 int, result2 error)
- func (fake *FakeSubscriber) PendingReturnsOnCall(i int, result1 int, result2 error)
- type FakeValueChainer
- func (fake *FakeValueChainer) Invocations() map[string][][]interface{}
- func (fake *FakeValueChainer) Send() error
- func (fake *FakeValueChainer) SendCallCount() int
- func (fake *FakeValueChainer) SendReturns(result1 error)
- func (fake *FakeValueChainer) SetTag(key string, value string) metric_sender.ValueChainer
- func (fake *FakeValueChainer) SetTagArgsForCall(i int) (string, string)
- func (fake *FakeValueChainer) SetTagCallCount() int
- func (fake *FakeValueChainer) SetTagReturns(result1 metric_sender.ValueChainer)
- type FakeVarzReporter
- func (fake *FakeVarzReporter) CaptureBadGateway()
- func (fake *FakeVarzReporter) CaptureBadGatewayCallCount() int
- func (fake *FakeVarzReporter) CaptureBadRequest()
- func (fake *FakeVarzReporter) CaptureBadRequestCallCount() int
- func (fake *FakeVarzReporter) CaptureRoutingRequest(b *route.Endpoint)
- func (fake *FakeVarzReporter) CaptureRoutingRequestArgsForCall(i int) *route.Endpoint
- func (fake *FakeVarzReporter) CaptureRoutingRequestCallCount() int
- func (fake *FakeVarzReporter) CaptureRoutingResponseLatency(b *route.Endpoint, statusCode int, t time.Time, d time.Duration)
- func (fake *FakeVarzReporter) CaptureRoutingResponseLatencyArgsForCall(i int) (*route.Endpoint, int, time.Time, time.Duration)
- func (fake *FakeVarzReporter) CaptureRoutingResponseLatencyCallCount() int
- func (fake *FakeVarzReporter) Invocations() map[string][][]interface{}
- type MetricBatcher
- func (fake *MetricBatcher) BatchAddCounter(name string, delta uint64)
- func (fake *MetricBatcher) BatchAddCounterArgsForCall(i int) (string, uint64)
- func (fake *MetricBatcher) BatchAddCounterCallCount() int
- func (fake *MetricBatcher) BatchIncrementCounter(name string)
- func (fake *MetricBatcher) BatchIncrementCounterArgsForCall(i int) string
- func (fake *MetricBatcher) BatchIncrementCounterCallCount() int
- func (fake *MetricBatcher) Close()
- func (fake *MetricBatcher) CloseCallCount() int
- func (fake *MetricBatcher) Invocations() map[string][][]interface{}
- type MetricSender
- func (fake *MetricSender) AddToCounter(name string, delta uint64) error
- func (fake *MetricSender) AddToCounterArgsForCall(i int) (string, uint64)
- func (fake *MetricSender) AddToCounterCallCount() int
- func (fake *MetricSender) AddToCounterReturns(result1 error)
- func (fake *MetricSender) ContainerMetric(appID string, instance int32, cpu float64, mem uint64, disk uint64) metric_sender.ContainerMetricChainer
- func (fake *MetricSender) ContainerMetricArgsForCall(i int) (string, int32, float64, uint64, uint64)
- func (fake *MetricSender) ContainerMetricCallCount() int
- func (fake *MetricSender) ContainerMetricReturns(result1 metric_sender.ContainerMetricChainer)
- func (fake *MetricSender) Counter(name string) metric_sender.CounterChainer
- func (fake *MetricSender) CounterArgsForCall(i int) string
- func (fake *MetricSender) CounterCallCount() int
- func (fake *MetricSender) CounterReturns(result1 metric_sender.CounterChainer)
- func (fake *MetricSender) IncrementCounter(name string) error
- func (fake *MetricSender) IncrementCounterArgsForCall(i int) string
- func (fake *MetricSender) IncrementCounterCallCount() int
- func (fake *MetricSender) IncrementCounterReturns(result1 error)
- func (fake *MetricSender) Invocations() map[string][][]interface{}
- func (fake *MetricSender) Send(event events.Event) error
- func (fake *MetricSender) SendArgsForCall(i int) events.Event
- func (fake *MetricSender) SendCallCount() int
- func (fake *MetricSender) SendContainerMetric(applicationId string, instanceIndex int32, cpuPercentage float64, ...) error
- func (fake *MetricSender) SendContainerMetricArgsForCall(i int) (string, int32, float64, uint64, uint64)
- func (fake *MetricSender) SendContainerMetricCallCount() int
- func (fake *MetricSender) SendContainerMetricReturns(result1 error)
- func (fake *MetricSender) SendReturns(result1 error)
- func (fake *MetricSender) SendValue(name string, value float64, unit string) error
- func (fake *MetricSender) SendValueArgsForCall(i int) (string, float64, string)
- func (fake *MetricSender) SendValueCallCount() int
- func (fake *MetricSender) SendValueReturns(result1 error)
- func (fake *MetricSender) Value(name string, value float64, unit string) metric_sender.ValueChainer
- func (fake *MetricSender) ValueArgsForCall(i int) (string, float64, string)
- func (fake *MetricSender) ValueCallCount() int
- func (fake *MetricSender) ValueReturns(result1 metric_sender.ValueChainer)
- type ValueChainer
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type FakeCombinedReporter ¶
type FakeCombinedReporter struct { CaptureBackendExhaustedConnsStub func() CaptureBackendInvalidIDStub func() CaptureBackendInvalidTLSCertStub func() CaptureBackendTLSHandshakeFailedStub func() CaptureBadRequestStub func() CaptureBadGatewayStub func() CaptureRoutingRequestStub func(b *route.Endpoint) CaptureRoutingResponseStub func(statusCode int) CaptureRoutingResponseLatencyStub func(b *route.Endpoint, statusCode int, t time.Time, d time.Duration) CaptureRouteServiceResponseStub func(res *http.Response) CaptureWebSocketUpdateStub func() CaptureWebSocketFailureStub func() // contains filtered or unexported fields }
func (*FakeCombinedReporter) CaptureBackendExhaustedConns ¶
func (fake *FakeCombinedReporter) CaptureBackendExhaustedConns()
func (*FakeCombinedReporter) CaptureBackendExhaustedConnsCallCount ¶
func (fake *FakeCombinedReporter) CaptureBackendExhaustedConnsCallCount() int
func (*FakeCombinedReporter) CaptureBackendInvalidID ¶
func (fake *FakeCombinedReporter) CaptureBackendInvalidID()
func (*FakeCombinedReporter) CaptureBackendInvalidIDCallCount ¶
func (fake *FakeCombinedReporter) CaptureBackendInvalidIDCallCount() int
func (*FakeCombinedReporter) CaptureBackendInvalidTLSCert ¶
func (fake *FakeCombinedReporter) CaptureBackendInvalidTLSCert()
func (*FakeCombinedReporter) CaptureBackendInvalidTLSCertCallCount ¶
func (fake *FakeCombinedReporter) CaptureBackendInvalidTLSCertCallCount() int
func (*FakeCombinedReporter) CaptureBackendTLSHandshakeFailed ¶
func (fake *FakeCombinedReporter) CaptureBackendTLSHandshakeFailed()
func (*FakeCombinedReporter) CaptureBackendTLSHandshakeFailedCallCount ¶
func (fake *FakeCombinedReporter) CaptureBackendTLSHandshakeFailedCallCount() int
func (*FakeCombinedReporter) CaptureBadGateway ¶
func (fake *FakeCombinedReporter) CaptureBadGateway()
func (*FakeCombinedReporter) CaptureBadGatewayCallCount ¶
func (fake *FakeCombinedReporter) CaptureBadGatewayCallCount() int
func (*FakeCombinedReporter) CaptureBadRequest ¶
func (fake *FakeCombinedReporter) CaptureBadRequest()
func (*FakeCombinedReporter) CaptureBadRequestCallCount ¶
func (fake *FakeCombinedReporter) CaptureBadRequestCallCount() int
func (*FakeCombinedReporter) CaptureRouteServiceResponse ¶
func (fake *FakeCombinedReporter) CaptureRouteServiceResponse(res *http.Response)
func (*FakeCombinedReporter) CaptureRouteServiceResponseArgsForCall ¶
func (fake *FakeCombinedReporter) CaptureRouteServiceResponseArgsForCall(i int) *http.Response
func (*FakeCombinedReporter) CaptureRouteServiceResponseCallCount ¶
func (fake *FakeCombinedReporter) CaptureRouteServiceResponseCallCount() int
func (*FakeCombinedReporter) CaptureRoutingRequest ¶
func (fake *FakeCombinedReporter) CaptureRoutingRequest(b *route.Endpoint)
func (*FakeCombinedReporter) CaptureRoutingRequestArgsForCall ¶
func (fake *FakeCombinedReporter) CaptureRoutingRequestArgsForCall(i int) *route.Endpoint
func (*FakeCombinedReporter) CaptureRoutingRequestCallCount ¶
func (fake *FakeCombinedReporter) CaptureRoutingRequestCallCount() int
func (*FakeCombinedReporter) CaptureRoutingResponse ¶
func (fake *FakeCombinedReporter) CaptureRoutingResponse(statusCode int)
func (*FakeCombinedReporter) CaptureRoutingResponseArgsForCall ¶
func (fake *FakeCombinedReporter) CaptureRoutingResponseArgsForCall(i int) int
func (*FakeCombinedReporter) CaptureRoutingResponseCallCount ¶
func (fake *FakeCombinedReporter) CaptureRoutingResponseCallCount() int
func (*FakeCombinedReporter) CaptureRoutingResponseLatency ¶
func (*FakeCombinedReporter) CaptureRoutingResponseLatencyArgsForCall ¶
func (*FakeCombinedReporter) CaptureRoutingResponseLatencyCallCount ¶
func (fake *FakeCombinedReporter) CaptureRoutingResponseLatencyCallCount() int
func (*FakeCombinedReporter) CaptureWebSocketFailure ¶
func (fake *FakeCombinedReporter) CaptureWebSocketFailure()
func (*FakeCombinedReporter) CaptureWebSocketFailureCallCount ¶
func (fake *FakeCombinedReporter) CaptureWebSocketFailureCallCount() int
func (*FakeCombinedReporter) CaptureWebSocketUpdate ¶
func (fake *FakeCombinedReporter) CaptureWebSocketUpdate()
func (*FakeCombinedReporter) CaptureWebSocketUpdateCallCount ¶
func (fake *FakeCombinedReporter) CaptureWebSocketUpdateCallCount() int
func (*FakeCombinedReporter) Invocations ¶
func (fake *FakeCombinedReporter) Invocations() map[string][][]interface{}
type FakeProxyReporter ¶
type FakeProxyReporter struct { CaptureBackendExhaustedConnsStub func() CaptureBackendInvalidIDStub func() CaptureBackendInvalidTLSCertStub func() CaptureBackendTLSHandshakeFailedStub func() CaptureBadRequestStub func() CaptureBadGatewayStub func() CaptureRoutingRequestStub func(b *route.Endpoint) CaptureRoutingResponseStub func(statusCode int) CaptureRoutingResponseLatencyStub func(b *route.Endpoint, statusCode int, t time.Time, d time.Duration) CaptureRouteServiceResponseStub func(res *http.Response) CaptureWebSocketUpdateStub func() CaptureWebSocketFailureStub func() // contains filtered or unexported fields }
func (*FakeProxyReporter) CaptureBackendExhaustedConns ¶
func (fake *FakeProxyReporter) CaptureBackendExhaustedConns()
func (*FakeProxyReporter) CaptureBackendExhaustedConnsCallCount ¶
func (fake *FakeProxyReporter) CaptureBackendExhaustedConnsCallCount() int
func (*FakeProxyReporter) CaptureBackendInvalidID ¶
func (fake *FakeProxyReporter) CaptureBackendInvalidID()
func (*FakeProxyReporter) CaptureBackendInvalidIDCallCount ¶
func (fake *FakeProxyReporter) CaptureBackendInvalidIDCallCount() int
func (*FakeProxyReporter) CaptureBackendInvalidTLSCert ¶
func (fake *FakeProxyReporter) CaptureBackendInvalidTLSCert()
func (*FakeProxyReporter) CaptureBackendInvalidTLSCertCallCount ¶
func (fake *FakeProxyReporter) CaptureBackendInvalidTLSCertCallCount() int
func (*FakeProxyReporter) CaptureBackendTLSHandshakeFailed ¶
func (fake *FakeProxyReporter) CaptureBackendTLSHandshakeFailed()
func (*FakeProxyReporter) CaptureBackendTLSHandshakeFailedCallCount ¶
func (fake *FakeProxyReporter) CaptureBackendTLSHandshakeFailedCallCount() int
func (*FakeProxyReporter) CaptureBadGateway ¶
func (fake *FakeProxyReporter) CaptureBadGateway()
func (*FakeProxyReporter) CaptureBadGatewayCallCount ¶
func (fake *FakeProxyReporter) CaptureBadGatewayCallCount() int
func (*FakeProxyReporter) CaptureBadRequest ¶
func (fake *FakeProxyReporter) CaptureBadRequest()
func (*FakeProxyReporter) CaptureBadRequestCallCount ¶
func (fake *FakeProxyReporter) CaptureBadRequestCallCount() int
func (*FakeProxyReporter) CaptureRouteServiceResponse ¶
func (fake *FakeProxyReporter) CaptureRouteServiceResponse(res *http.Response)
func (*FakeProxyReporter) CaptureRouteServiceResponseArgsForCall ¶
func (fake *FakeProxyReporter) CaptureRouteServiceResponseArgsForCall(i int) *http.Response
func (*FakeProxyReporter) CaptureRouteServiceResponseCallCount ¶
func (fake *FakeProxyReporter) CaptureRouteServiceResponseCallCount() int
func (*FakeProxyReporter) CaptureRoutingRequest ¶
func (fake *FakeProxyReporter) CaptureRoutingRequest(b *route.Endpoint)
func (*FakeProxyReporter) CaptureRoutingRequestArgsForCall ¶
func (fake *FakeProxyReporter) CaptureRoutingRequestArgsForCall(i int) *route.Endpoint
func (*FakeProxyReporter) CaptureRoutingRequestCallCount ¶
func (fake *FakeProxyReporter) CaptureRoutingRequestCallCount() int
func (*FakeProxyReporter) CaptureRoutingResponse ¶
func (fake *FakeProxyReporter) CaptureRoutingResponse(statusCode int)
func (*FakeProxyReporter) CaptureRoutingResponseArgsForCall ¶
func (fake *FakeProxyReporter) CaptureRoutingResponseArgsForCall(i int) int
func (*FakeProxyReporter) CaptureRoutingResponseCallCount ¶
func (fake *FakeProxyReporter) CaptureRoutingResponseCallCount() int
func (*FakeProxyReporter) CaptureRoutingResponseLatency ¶
func (*FakeProxyReporter) CaptureRoutingResponseLatencyArgsForCall ¶
func (*FakeProxyReporter) CaptureRoutingResponseLatencyCallCount ¶
func (fake *FakeProxyReporter) CaptureRoutingResponseLatencyCallCount() int
func (*FakeProxyReporter) CaptureWebSocketFailure ¶
func (fake *FakeProxyReporter) CaptureWebSocketFailure()
func (*FakeProxyReporter) CaptureWebSocketFailureCallCount ¶
func (fake *FakeProxyReporter) CaptureWebSocketFailureCallCount() int
func (*FakeProxyReporter) CaptureWebSocketUpdate ¶
func (fake *FakeProxyReporter) CaptureWebSocketUpdate()
func (*FakeProxyReporter) CaptureWebSocketUpdateCallCount ¶
func (fake *FakeProxyReporter) CaptureWebSocketUpdateCallCount() int
func (*FakeProxyReporter) Invocations ¶
func (fake *FakeProxyReporter) Invocations() map[string][][]interface{}
type FakeRouteRegistryReporter ¶
type FakeRouteRegistryReporter struct { CaptureRouteStatsStub func(totalRoutes int, msSinceLastUpdate uint64) CaptureRoutesPrunedStub func(prunedRoutes uint64) CaptureLookupTimeStub func(t time.Duration) CaptureRegistryMessageStub func(msg metrics.ComponentTagged) CaptureRouteRegistrationLatencyStub func(t time.Duration) UnmuzzleRouteRegistrationLatencyStub func() CaptureUnregistryMessageStub func(msg metrics.ComponentTagged) // contains filtered or unexported fields }
func (*FakeRouteRegistryReporter) CaptureLookupTime ¶
func (fake *FakeRouteRegistryReporter) CaptureLookupTime(t time.Duration)
func (*FakeRouteRegistryReporter) CaptureLookupTimeArgsForCall ¶
func (fake *FakeRouteRegistryReporter) CaptureLookupTimeArgsForCall(i int) time.Duration
func (*FakeRouteRegistryReporter) CaptureLookupTimeCallCount ¶
func (fake *FakeRouteRegistryReporter) CaptureLookupTimeCallCount() int
func (*FakeRouteRegistryReporter) CaptureRegistryMessage ¶
func (fake *FakeRouteRegistryReporter) CaptureRegistryMessage(msg metrics.ComponentTagged)
func (*FakeRouteRegistryReporter) CaptureRegistryMessageArgsForCall ¶
func (fake *FakeRouteRegistryReporter) CaptureRegistryMessageArgsForCall(i int) metrics.ComponentTagged
func (*FakeRouteRegistryReporter) CaptureRegistryMessageCallCount ¶
func (fake *FakeRouteRegistryReporter) CaptureRegistryMessageCallCount() int
func (*FakeRouteRegistryReporter) CaptureRouteRegistrationLatency ¶
func (fake *FakeRouteRegistryReporter) CaptureRouteRegistrationLatency(t time.Duration)
func (*FakeRouteRegistryReporter) CaptureRouteRegistrationLatencyArgsForCall ¶
func (fake *FakeRouteRegistryReporter) CaptureRouteRegistrationLatencyArgsForCall(i int) time.Duration
func (*FakeRouteRegistryReporter) CaptureRouteRegistrationLatencyCallCount ¶
func (fake *FakeRouteRegistryReporter) CaptureRouteRegistrationLatencyCallCount() int
func (*FakeRouteRegistryReporter) CaptureRouteStats ¶
func (fake *FakeRouteRegistryReporter) CaptureRouteStats(totalRoutes int, msSinceLastUpdate uint64)
func (*FakeRouteRegistryReporter) CaptureRouteStatsArgsForCall ¶
func (fake *FakeRouteRegistryReporter) CaptureRouteStatsArgsForCall(i int) (int, uint64)
func (*FakeRouteRegistryReporter) CaptureRouteStatsCallCount ¶
func (fake *FakeRouteRegistryReporter) CaptureRouteStatsCallCount() int
func (*FakeRouteRegistryReporter) CaptureRoutesPruned ¶
func (fake *FakeRouteRegistryReporter) CaptureRoutesPruned(prunedRoutes uint64)
func (*FakeRouteRegistryReporter) CaptureRoutesPrunedArgsForCall ¶
func (fake *FakeRouteRegistryReporter) CaptureRoutesPrunedArgsForCall(i int) uint64
func (*FakeRouteRegistryReporter) CaptureRoutesPrunedCallCount ¶
func (fake *FakeRouteRegistryReporter) CaptureRoutesPrunedCallCount() int
func (*FakeRouteRegistryReporter) CaptureUnregistryMessage ¶
func (fake *FakeRouteRegistryReporter) CaptureUnregistryMessage(msg metrics.ComponentTagged)
func (*FakeRouteRegistryReporter) CaptureUnregistryMessageArgsForCall ¶
func (fake *FakeRouteRegistryReporter) CaptureUnregistryMessageArgsForCall(i int) metrics.ComponentTagged
func (*FakeRouteRegistryReporter) CaptureUnregistryMessageCallCount ¶
func (fake *FakeRouteRegistryReporter) CaptureUnregistryMessageCallCount() int
func (*FakeRouteRegistryReporter) Invocations ¶
func (fake *FakeRouteRegistryReporter) Invocations() map[string][][]interface{}
func (*FakeRouteRegistryReporter) UnmuzzleRouteRegistrationLatency ¶
func (fake *FakeRouteRegistryReporter) UnmuzzleRouteRegistrationLatency()
func (*FakeRouteRegistryReporter) UnmuzzleRouteRegistrationLatencyCallCount ¶
func (fake *FakeRouteRegistryReporter) UnmuzzleRouteRegistrationLatencyCallCount() int
type FakeSubscriber ¶
type FakeSubscriber struct { PendingStub func() (int, error) DroppedStub func() (int, error) // contains filtered or unexported fields }
func (*FakeSubscriber) Dropped ¶
func (fake *FakeSubscriber) Dropped() (int, error)
func (*FakeSubscriber) DroppedCallCount ¶
func (fake *FakeSubscriber) DroppedCallCount() int
func (*FakeSubscriber) DroppedReturns ¶
func (fake *FakeSubscriber) DroppedReturns(result1 int, result2 error)
func (*FakeSubscriber) DroppedReturnsOnCall ¶
func (fake *FakeSubscriber) DroppedReturnsOnCall(i int, result1 int, result2 error)
func (*FakeSubscriber) Invocations ¶
func (fake *FakeSubscriber) Invocations() map[string][][]interface{}
func (*FakeSubscriber) Pending ¶
func (fake *FakeSubscriber) Pending() (int, error)
func (*FakeSubscriber) PendingCallCount ¶
func (fake *FakeSubscriber) PendingCallCount() int
func (*FakeSubscriber) PendingReturns ¶
func (fake *FakeSubscriber) PendingReturns(result1 int, result2 error)
func (*FakeSubscriber) PendingReturnsOnCall ¶
func (fake *FakeSubscriber) PendingReturnsOnCall(i int, result1 int, result2 error)
type FakeValueChainer ¶
type FakeValueChainer struct { SetTagStub func(key, value string) metric_sender.ValueChainer SendStub func() error // contains filtered or unexported fields }
func (*FakeValueChainer) Invocations ¶
func (fake *FakeValueChainer) Invocations() map[string][][]interface{}
func (*FakeValueChainer) Send ¶
func (fake *FakeValueChainer) Send() error
func (*FakeValueChainer) SendCallCount ¶
func (fake *FakeValueChainer) SendCallCount() int
func (*FakeValueChainer) SendReturns ¶
func (fake *FakeValueChainer) SendReturns(result1 error)
func (*FakeValueChainer) SetTag ¶
func (fake *FakeValueChainer) SetTag(key string, value string) metric_sender.ValueChainer
func (*FakeValueChainer) SetTagArgsForCall ¶
func (fake *FakeValueChainer) SetTagArgsForCall(i int) (string, string)
func (*FakeValueChainer) SetTagCallCount ¶
func (fake *FakeValueChainer) SetTagCallCount() int
func (*FakeValueChainer) SetTagReturns ¶
func (fake *FakeValueChainer) SetTagReturns(result1 metric_sender.ValueChainer)
type FakeVarzReporter ¶
type FakeVarzReporter struct { CaptureBadRequestStub func() CaptureBadGatewayStub func() CaptureRoutingRequestStub func(b *route.Endpoint) CaptureRoutingResponseLatencyStub func(b *route.Endpoint, statusCode int, t time.Time, d time.Duration) // contains filtered or unexported fields }
func (*FakeVarzReporter) CaptureBadGateway ¶
func (fake *FakeVarzReporter) CaptureBadGateway()
func (*FakeVarzReporter) CaptureBadGatewayCallCount ¶
func (fake *FakeVarzReporter) CaptureBadGatewayCallCount() int
func (*FakeVarzReporter) CaptureBadRequest ¶
func (fake *FakeVarzReporter) CaptureBadRequest()
func (*FakeVarzReporter) CaptureBadRequestCallCount ¶
func (fake *FakeVarzReporter) CaptureBadRequestCallCount() int
func (*FakeVarzReporter) CaptureRoutingRequest ¶
func (fake *FakeVarzReporter) CaptureRoutingRequest(b *route.Endpoint)
func (*FakeVarzReporter) CaptureRoutingRequestArgsForCall ¶
func (fake *FakeVarzReporter) CaptureRoutingRequestArgsForCall(i int) *route.Endpoint
func (*FakeVarzReporter) CaptureRoutingRequestCallCount ¶
func (fake *FakeVarzReporter) CaptureRoutingRequestCallCount() int
func (*FakeVarzReporter) CaptureRoutingResponseLatency ¶
func (*FakeVarzReporter) CaptureRoutingResponseLatencyArgsForCall ¶
func (*FakeVarzReporter) CaptureRoutingResponseLatencyCallCount ¶
func (fake *FakeVarzReporter) CaptureRoutingResponseLatencyCallCount() int
func (*FakeVarzReporter) Invocations ¶
func (fake *FakeVarzReporter) Invocations() map[string][][]interface{}
type MetricBatcher ¶
type MetricBatcher struct { BatchIncrementCounterStub func(name string) BatchAddCounterStub func(name string, delta uint64) CloseStub func() // contains filtered or unexported fields }
func (*MetricBatcher) BatchAddCounter ¶
func (fake *MetricBatcher) BatchAddCounter(name string, delta uint64)
func (*MetricBatcher) BatchAddCounterArgsForCall ¶
func (fake *MetricBatcher) BatchAddCounterArgsForCall(i int) (string, uint64)
func (*MetricBatcher) BatchAddCounterCallCount ¶
func (fake *MetricBatcher) BatchAddCounterCallCount() int
func (*MetricBatcher) BatchIncrementCounter ¶
func (fake *MetricBatcher) BatchIncrementCounter(name string)
func (*MetricBatcher) BatchIncrementCounterArgsForCall ¶
func (fake *MetricBatcher) BatchIncrementCounterArgsForCall(i int) string
func (*MetricBatcher) BatchIncrementCounterCallCount ¶
func (fake *MetricBatcher) BatchIncrementCounterCallCount() int
func (*MetricBatcher) Close ¶
func (fake *MetricBatcher) Close()
func (*MetricBatcher) CloseCallCount ¶
func (fake *MetricBatcher) CloseCallCount() int
func (*MetricBatcher) Invocations ¶
func (fake *MetricBatcher) Invocations() map[string][][]interface{}
type MetricSender ¶
type MetricSender struct { SendStub func(event events.Event) error ValueStub func(name string, value float64, unit string) metric_sender.ValueChainer ContainerMetricStub func(appID string, instance int32, cpu float64, mem, disk uint64) metric_sender.ContainerMetricChainer CounterStub func(name string) metric_sender.CounterChainer SendValueStub func(name string, value float64, unit string) error IncrementCounterStub func(name string) error AddToCounterStub func(name string, delta uint64) error SendContainerMetricStub func(applicationId string, instanceIndex int32, cpuPercentage float64, memoryBytes uint64, diskBytes uint64) error // contains filtered or unexported fields }
func (*MetricSender) AddToCounter ¶
func (fake *MetricSender) AddToCounter(name string, delta uint64) error
func (*MetricSender) AddToCounterArgsForCall ¶
func (fake *MetricSender) AddToCounterArgsForCall(i int) (string, uint64)
func (*MetricSender) AddToCounterCallCount ¶
func (fake *MetricSender) AddToCounterCallCount() int
func (*MetricSender) AddToCounterReturns ¶
func (fake *MetricSender) AddToCounterReturns(result1 error)
func (*MetricSender) ContainerMetric ¶
func (fake *MetricSender) ContainerMetric(appID string, instance int32, cpu float64, mem uint64, disk uint64) metric_sender.ContainerMetricChainer
func (*MetricSender) ContainerMetricArgsForCall ¶
func (*MetricSender) ContainerMetricCallCount ¶
func (fake *MetricSender) ContainerMetricCallCount() int
func (*MetricSender) ContainerMetricReturns ¶
func (fake *MetricSender) ContainerMetricReturns(result1 metric_sender.ContainerMetricChainer)
func (*MetricSender) Counter ¶
func (fake *MetricSender) Counter(name string) metric_sender.CounterChainer
func (*MetricSender) CounterArgsForCall ¶
func (fake *MetricSender) CounterArgsForCall(i int) string
func (*MetricSender) CounterCallCount ¶
func (fake *MetricSender) CounterCallCount() int
func (*MetricSender) CounterReturns ¶
func (fake *MetricSender) CounterReturns(result1 metric_sender.CounterChainer)
func (*MetricSender) IncrementCounter ¶
func (fake *MetricSender) IncrementCounter(name string) error
func (*MetricSender) IncrementCounterArgsForCall ¶
func (fake *MetricSender) IncrementCounterArgsForCall(i int) string
func (*MetricSender) IncrementCounterCallCount ¶
func (fake *MetricSender) IncrementCounterCallCount() int
func (*MetricSender) IncrementCounterReturns ¶
func (fake *MetricSender) IncrementCounterReturns(result1 error)
func (*MetricSender) Invocations ¶
func (fake *MetricSender) Invocations() map[string][][]interface{}
func (*MetricSender) SendArgsForCall ¶
func (fake *MetricSender) SendArgsForCall(i int) events.Event
func (*MetricSender) SendCallCount ¶
func (fake *MetricSender) SendCallCount() int
func (*MetricSender) SendContainerMetric ¶
func (*MetricSender) SendContainerMetricArgsForCall ¶
func (*MetricSender) SendContainerMetricCallCount ¶
func (fake *MetricSender) SendContainerMetricCallCount() int
func (*MetricSender) SendContainerMetricReturns ¶
func (fake *MetricSender) SendContainerMetricReturns(result1 error)
func (*MetricSender) SendReturns ¶
func (fake *MetricSender) SendReturns(result1 error)
func (*MetricSender) SendValue ¶
func (fake *MetricSender) SendValue(name string, value float64, unit string) error
func (*MetricSender) SendValueArgsForCall ¶
func (fake *MetricSender) SendValueArgsForCall(i int) (string, float64, string)
func (*MetricSender) SendValueCallCount ¶
func (fake *MetricSender) SendValueCallCount() int
func (*MetricSender) SendValueReturns ¶
func (fake *MetricSender) SendValueReturns(result1 error)
func (*MetricSender) Value ¶
func (fake *MetricSender) Value(name string, value float64, unit string) metric_sender.ValueChainer
func (*MetricSender) ValueArgsForCall ¶
func (fake *MetricSender) ValueArgsForCall(i int) (string, float64, string)
func (*MetricSender) ValueCallCount ¶
func (fake *MetricSender) ValueCallCount() int
func (*MetricSender) ValueReturns ¶
func (fake *MetricSender) ValueReturns(result1 metric_sender.ValueChainer)
type ValueChainer ¶
type ValueChainer interface { SetTag(key, value string) metric_sender.ValueChainer Send() error }
Click to show internal directories.
Click to hide internal directories.