Documentation ¶
Overview ¶
Code generated by counterfeiter. DO NOT EDIT.
Code generated by counterfeiter. DO NOT EDIT.
Code generated by counterfeiter. DO NOT EDIT.
Index ¶
- func MatchV2Metric(target MetricAndValue) types.GomegaMatcher
- func MatchV2MetricAndValue(target MetricAndValue) types.GomegaMatcher
- func TestMetricChan(receiversChan chan loggregator_v2.Ingress_BatchSenderServer) (chan *loggregator_v2.Envelope, chan struct{})
- type FakeIngressClient
- func (fake *FakeIngressClient) IncrementCounter(arg1 string) error
- func (fake *FakeIngressClient) IncrementCounterArgsForCall(i int) string
- func (fake *FakeIngressClient) IncrementCounterCallCount() int
- func (fake *FakeIngressClient) IncrementCounterCalls(stub func(string) error)
- func (fake *FakeIngressClient) IncrementCounterReturns(result1 error)
- func (fake *FakeIngressClient) IncrementCounterReturnsOnCall(i int, result1 error)
- func (fake *FakeIngressClient) IncrementCounterWithDelta(arg1 string, arg2 uint64) error
- func (fake *FakeIngressClient) IncrementCounterWithDeltaArgsForCall(i int) (string, uint64)
- func (fake *FakeIngressClient) IncrementCounterWithDeltaCallCount() int
- func (fake *FakeIngressClient) IncrementCounterWithDeltaCalls(stub func(string, uint64) error)
- func (fake *FakeIngressClient) IncrementCounterWithDeltaReturns(result1 error)
- func (fake *FakeIngressClient) IncrementCounterWithDeltaReturnsOnCall(i int, result1 error)
- func (fake *FakeIngressClient) Invocations() map[string][][]interface{}
- func (fake *FakeIngressClient) SendAppErrorLog(arg1 string, arg2 string, arg3 map[string]string) error
- func (fake *FakeIngressClient) SendAppErrorLogArgsForCall(i int) (string, string, map[string]string)
- func (fake *FakeIngressClient) SendAppErrorLogCallCount() int
- func (fake *FakeIngressClient) SendAppErrorLogCalls(stub func(string, string, map[string]string) error)
- func (fake *FakeIngressClient) SendAppErrorLogReturns(result1 error)
- func (fake *FakeIngressClient) SendAppErrorLogReturnsOnCall(i int, result1 error)
- func (fake *FakeIngressClient) SendAppLog(arg1 string, arg2 string, arg3 map[string]string) error
- func (fake *FakeIngressClient) SendAppLogArgsForCall(i int) (string, string, map[string]string)
- func (fake *FakeIngressClient) SendAppLogCallCount() int
- func (fake *FakeIngressClient) SendAppLogCalls(stub func(string, string, map[string]string) error)
- func (fake *FakeIngressClient) SendAppLogRate(arg1 float64, arg2 float64, arg3 map[string]string) error
- func (fake *FakeIngressClient) SendAppLogRateArgsForCall(i int) (float64, float64, map[string]string)
- func (fake *FakeIngressClient) SendAppLogRateCallCount() int
- func (fake *FakeIngressClient) SendAppLogRateCalls(stub func(float64, float64, map[string]string) error)
- func (fake *FakeIngressClient) SendAppLogRateReturns(result1 error)
- func (fake *FakeIngressClient) SendAppLogRateReturnsOnCall(i int, result1 error)
- func (fake *FakeIngressClient) SendAppLogReturns(result1 error)
- func (fake *FakeIngressClient) SendAppLogReturnsOnCall(i int, result1 error)
- func (fake *FakeIngressClient) SendAppMetrics(arg1 diego_logging_client.ContainerMetric) error
- func (fake *FakeIngressClient) SendAppMetricsArgsForCall(i int) diego_logging_client.ContainerMetric
- func (fake *FakeIngressClient) SendAppMetricsCallCount() int
- func (fake *FakeIngressClient) SendAppMetricsCalls(stub func(diego_logging_client.ContainerMetric) error)
- func (fake *FakeIngressClient) SendAppMetricsReturns(result1 error)
- func (fake *FakeIngressClient) SendAppMetricsReturnsOnCall(i int, result1 error)
- func (fake *FakeIngressClient) SendBytesPerSecond(arg1 string, arg2 float64) error
- func (fake *FakeIngressClient) SendBytesPerSecondArgsForCall(i int) (string, float64)
- func (fake *FakeIngressClient) SendBytesPerSecondCallCount() int
- func (fake *FakeIngressClient) SendBytesPerSecondCalls(stub func(string, float64) error)
- func (fake *FakeIngressClient) SendBytesPerSecondReturns(result1 error)
- func (fake *FakeIngressClient) SendBytesPerSecondReturnsOnCall(i int, result1 error)
- func (fake *FakeIngressClient) SendComponentMetric(arg1 string, arg2 float64, arg3 string) error
- func (fake *FakeIngressClient) SendComponentMetricArgsForCall(i int) (string, float64, string)
- func (fake *FakeIngressClient) SendComponentMetricCallCount() int
- func (fake *FakeIngressClient) SendComponentMetricCalls(stub func(string, float64, string) error)
- func (fake *FakeIngressClient) SendComponentMetricReturns(result1 error)
- func (fake *FakeIngressClient) SendComponentMetricReturnsOnCall(i int, result1 error)
- func (fake *FakeIngressClient) SendDuration(arg1 string, arg2 time.Duration, arg3 ...loggregator.EmitGaugeOption) error
- func (fake *FakeIngressClient) SendDurationArgsForCall(i int) (string, time.Duration, []loggregator.EmitGaugeOption)
- func (fake *FakeIngressClient) SendDurationCallCount() int
- func (fake *FakeIngressClient) SendDurationCalls(stub func(string, time.Duration, ...loggregator.EmitGaugeOption) error)
- func (fake *FakeIngressClient) SendDurationReturns(result1 error)
- func (fake *FakeIngressClient) SendDurationReturnsOnCall(i int, result1 error)
- func (fake *FakeIngressClient) SendMebiBytes(arg1 string, arg2 int, arg3 ...loggregator.EmitGaugeOption) error
- func (fake *FakeIngressClient) SendMebiBytesArgsForCall(i int) (string, int, []loggregator.EmitGaugeOption)
- func (fake *FakeIngressClient) SendMebiBytesCallCount() int
- func (fake *FakeIngressClient) SendMebiBytesCalls(stub func(string, int, ...loggregator.EmitGaugeOption) error)
- func (fake *FakeIngressClient) SendMebiBytesReturns(result1 error)
- func (fake *FakeIngressClient) SendMebiBytesReturnsOnCall(i int, result1 error)
- func (fake *FakeIngressClient) SendMetric(arg1 string, arg2 int, arg3 ...loggregator.EmitGaugeOption) error
- func (fake *FakeIngressClient) SendMetricArgsForCall(i int) (string, int, []loggregator.EmitGaugeOption)
- func (fake *FakeIngressClient) SendMetricCallCount() int
- func (fake *FakeIngressClient) SendMetricCalls(stub func(string, int, ...loggregator.EmitGaugeOption) error)
- func (fake *FakeIngressClient) SendMetricReturns(result1 error)
- func (fake *FakeIngressClient) SendMetricReturnsOnCall(i int, result1 error)
- func (fake *FakeIngressClient) SendRequestsPerSecond(arg1 string, arg2 float64) error
- func (fake *FakeIngressClient) SendRequestsPerSecondArgsForCall(i int) (string, float64)
- func (fake *FakeIngressClient) SendRequestsPerSecondCallCount() int
- func (fake *FakeIngressClient) SendRequestsPerSecondCalls(stub func(string, float64) error)
- func (fake *FakeIngressClient) SendRequestsPerSecondReturns(result1 error)
- func (fake *FakeIngressClient) SendRequestsPerSecondReturnsOnCall(i int, result1 error)
- func (fake *FakeIngressClient) SendSpikeMetrics(arg1 diego_logging_client.SpikeMetric) error
- func (fake *FakeIngressClient) SendSpikeMetricsArgsForCall(i int) diego_logging_client.SpikeMetric
- func (fake *FakeIngressClient) SendSpikeMetricsCallCount() int
- func (fake *FakeIngressClient) SendSpikeMetricsCalls(stub func(diego_logging_client.SpikeMetric) error)
- func (fake *FakeIngressClient) SendSpikeMetricsReturns(result1 error)
- func (fake *FakeIngressClient) SendSpikeMetricsReturnsOnCall(i int, result1 error)
- type FakeIngressServer
- func (fake *FakeIngressServer) BatchSender(arg1 loggregator_v2.Ingress_BatchSenderServer) error
- func (fake *FakeIngressServer) BatchSenderArgsForCall(i int) loggregator_v2.Ingress_BatchSenderServer
- func (fake *FakeIngressServer) BatchSenderCallCount() int
- func (fake *FakeIngressServer) BatchSenderReturns(result1 error)
- func (fake *FakeIngressServer) BatchSenderReturnsOnCall(i int, result1 error)
- func (fake *FakeIngressServer) Invocations() map[string][][]interface{}
- func (f *FakeIngressServer) Send(context.Context, *loggregator_v2.EnvelopeBatch) (*loggregator_v2.SendResponse, error)
- func (fake *FakeIngressServer) Sender(arg1 loggregator_v2.Ingress_SenderServer) error
- func (fake *FakeIngressServer) SenderArgsForCall(i int) loggregator_v2.Ingress_SenderServer
- func (fake *FakeIngressServer) SenderCallCount() int
- func (fake *FakeIngressServer) SenderReturns(result1 error)
- func (fake *FakeIngressServer) SenderReturnsOnCall(i int, result1 error)
- type FakeIngress_SenderServer
- func (fake *FakeIngress_SenderServer) Context() context.Context
- func (fake *FakeIngress_SenderServer) ContextCallCount() int
- func (fake *FakeIngress_SenderServer) ContextReturns(result1 context.Context)
- func (fake *FakeIngress_SenderServer) ContextReturnsOnCall(i int, result1 context.Context)
- func (fake *FakeIngress_SenderServer) Invocations() map[string][][]interface{}
- func (fake *FakeIngress_SenderServer) Recv() (*loggregator_v2.Envelope, error)
- func (fake *FakeIngress_SenderServer) RecvCallCount() int
- func (fake *FakeIngress_SenderServer) RecvMsg(m interface{}) error
- func (fake *FakeIngress_SenderServer) RecvMsgArgsForCall(i int) interface{}
- func (fake *FakeIngress_SenderServer) RecvMsgCallCount() int
- func (fake *FakeIngress_SenderServer) RecvMsgReturns(result1 error)
- func (fake *FakeIngress_SenderServer) RecvMsgReturnsOnCall(i int, result1 error)
- func (fake *FakeIngress_SenderServer) RecvReturns(result1 *loggregator_v2.Envelope, result2 error)
- func (fake *FakeIngress_SenderServer) RecvReturnsOnCall(i int, result1 *loggregator_v2.Envelope, result2 error)
- func (fake *FakeIngress_SenderServer) SendAndClose(arg1 *loggregator_v2.IngressResponse) error
- func (fake *FakeIngress_SenderServer) SendAndCloseArgsForCall(i int) *loggregator_v2.IngressResponse
- func (fake *FakeIngress_SenderServer) SendAndCloseCallCount() int
- func (fake *FakeIngress_SenderServer) SendAndCloseReturns(result1 error)
- func (fake *FakeIngress_SenderServer) SendAndCloseReturnsOnCall(i int, result1 error)
- func (fake *FakeIngress_SenderServer) SendHeader(arg1 metadata.MD) error
- func (fake *FakeIngress_SenderServer) SendHeaderArgsForCall(i int) metadata.MD
- func (fake *FakeIngress_SenderServer) SendHeaderCallCount() int
- func (fake *FakeIngress_SenderServer) SendHeaderReturns(result1 error)
- func (fake *FakeIngress_SenderServer) SendHeaderReturnsOnCall(i int, result1 error)
- func (fake *FakeIngress_SenderServer) SendMsg(m interface{}) error
- func (fake *FakeIngress_SenderServer) SendMsgArgsForCall(i int) interface{}
- func (fake *FakeIngress_SenderServer) SendMsgCallCount() int
- func (fake *FakeIngress_SenderServer) SendMsgReturns(result1 error)
- func (fake *FakeIngress_SenderServer) SendMsgReturnsOnCall(i int, result1 error)
- func (fake *FakeIngress_SenderServer) SetHeader(arg1 metadata.MD) error
- func (fake *FakeIngress_SenderServer) SetHeaderArgsForCall(i int) metadata.MD
- func (fake *FakeIngress_SenderServer) SetHeaderCallCount() int
- func (fake *FakeIngress_SenderServer) SetHeaderReturns(result1 error)
- func (fake *FakeIngress_SenderServer) SetHeaderReturnsOnCall(i int, result1 error)
- func (fake *FakeIngress_SenderServer) SetTrailer(arg1 metadata.MD)
- func (fake *FakeIngress_SenderServer) SetTrailerArgsForCall(i int) metadata.MD
- func (fake *FakeIngress_SenderServer) SetTrailerCallCount() int
- type MetricAndValue
- type TestIngressServer
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func MatchV2Metric ¶
func MatchV2Metric(target MetricAndValue) types.GomegaMatcher
func MatchV2MetricAndValue ¶
func MatchV2MetricAndValue(target MetricAndValue) types.GomegaMatcher
func TestMetricChan ¶
func TestMetricChan(receiversChan chan loggregator_v2.Ingress_BatchSenderServer) (chan *loggregator_v2.Envelope, chan struct{})
Types ¶
type FakeIngressClient ¶
type FakeIngressClient struct { IncrementCounterStub func(string) error IncrementCounterWithDeltaStub func(string, uint64) error SendAppErrorLogStub func(string, string, map[string]string) error SendAppLogStub func(string, string, map[string]string) error SendAppLogRateStub func(float64, float64, map[string]string) error SendAppMetricsStub func(diego_logging_client.ContainerMetric) error SendBytesPerSecondStub func(string, float64) error SendComponentMetricStub func(string, float64, string) error SendDurationStub func(string, time.Duration, ...loggregator.EmitGaugeOption) error SendMebiBytesStub func(string, int, ...loggregator.EmitGaugeOption) error SendMetricStub func(string, int, ...loggregator.EmitGaugeOption) error SendRequestsPerSecondStub func(string, float64) error SendSpikeMetricsStub func(diego_logging_client.SpikeMetric) error // contains filtered or unexported fields }
func (*FakeIngressClient) IncrementCounter ¶
func (fake *FakeIngressClient) IncrementCounter(arg1 string) error
func (*FakeIngressClient) IncrementCounterArgsForCall ¶
func (fake *FakeIngressClient) IncrementCounterArgsForCall(i int) string
func (*FakeIngressClient) IncrementCounterCallCount ¶
func (fake *FakeIngressClient) IncrementCounterCallCount() int
func (*FakeIngressClient) IncrementCounterCalls ¶
func (fake *FakeIngressClient) IncrementCounterCalls(stub func(string) error)
func (*FakeIngressClient) IncrementCounterReturns ¶
func (fake *FakeIngressClient) IncrementCounterReturns(result1 error)
func (*FakeIngressClient) IncrementCounterReturnsOnCall ¶
func (fake *FakeIngressClient) IncrementCounterReturnsOnCall(i int, result1 error)
func (*FakeIngressClient) IncrementCounterWithDelta ¶
func (fake *FakeIngressClient) IncrementCounterWithDelta(arg1 string, arg2 uint64) error
func (*FakeIngressClient) IncrementCounterWithDeltaArgsForCall ¶
func (fake *FakeIngressClient) IncrementCounterWithDeltaArgsForCall(i int) (string, uint64)
func (*FakeIngressClient) IncrementCounterWithDeltaCallCount ¶
func (fake *FakeIngressClient) IncrementCounterWithDeltaCallCount() int
func (*FakeIngressClient) IncrementCounterWithDeltaCalls ¶
func (fake *FakeIngressClient) IncrementCounterWithDeltaCalls(stub func(string, uint64) error)
func (*FakeIngressClient) IncrementCounterWithDeltaReturns ¶
func (fake *FakeIngressClient) IncrementCounterWithDeltaReturns(result1 error)
func (*FakeIngressClient) IncrementCounterWithDeltaReturnsOnCall ¶
func (fake *FakeIngressClient) IncrementCounterWithDeltaReturnsOnCall(i int, result1 error)
func (*FakeIngressClient) Invocations ¶
func (fake *FakeIngressClient) Invocations() map[string][][]interface{}
func (*FakeIngressClient) SendAppErrorLog ¶
func (*FakeIngressClient) SendAppErrorLogArgsForCall ¶
func (*FakeIngressClient) SendAppErrorLogCallCount ¶
func (fake *FakeIngressClient) SendAppErrorLogCallCount() int
func (*FakeIngressClient) SendAppErrorLogCalls ¶
func (*FakeIngressClient) SendAppErrorLogReturns ¶
func (fake *FakeIngressClient) SendAppErrorLogReturns(result1 error)
func (*FakeIngressClient) SendAppErrorLogReturnsOnCall ¶
func (fake *FakeIngressClient) SendAppErrorLogReturnsOnCall(i int, result1 error)
func (*FakeIngressClient) SendAppLog ¶
func (*FakeIngressClient) SendAppLogArgsForCall ¶
func (*FakeIngressClient) SendAppLogCallCount ¶
func (fake *FakeIngressClient) SendAppLogCallCount() int
func (*FakeIngressClient) SendAppLogCalls ¶
func (*FakeIngressClient) SendAppLogRate ¶
func (*FakeIngressClient) SendAppLogRateArgsForCall ¶
func (*FakeIngressClient) SendAppLogRateCallCount ¶
func (fake *FakeIngressClient) SendAppLogRateCallCount() int
func (*FakeIngressClient) SendAppLogRateCalls ¶
func (*FakeIngressClient) SendAppLogRateReturns ¶
func (fake *FakeIngressClient) SendAppLogRateReturns(result1 error)
func (*FakeIngressClient) SendAppLogRateReturnsOnCall ¶
func (fake *FakeIngressClient) SendAppLogRateReturnsOnCall(i int, result1 error)
func (*FakeIngressClient) SendAppLogReturns ¶
func (fake *FakeIngressClient) SendAppLogReturns(result1 error)
func (*FakeIngressClient) SendAppLogReturnsOnCall ¶
func (fake *FakeIngressClient) SendAppLogReturnsOnCall(i int, result1 error)
func (*FakeIngressClient) SendAppMetrics ¶
func (fake *FakeIngressClient) SendAppMetrics(arg1 diego_logging_client.ContainerMetric) error
func (*FakeIngressClient) SendAppMetricsArgsForCall ¶
func (fake *FakeIngressClient) SendAppMetricsArgsForCall(i int) diego_logging_client.ContainerMetric
func (*FakeIngressClient) SendAppMetricsCallCount ¶
func (fake *FakeIngressClient) SendAppMetricsCallCount() int
func (*FakeIngressClient) SendAppMetricsCalls ¶
func (fake *FakeIngressClient) SendAppMetricsCalls(stub func(diego_logging_client.ContainerMetric) error)
func (*FakeIngressClient) SendAppMetricsReturns ¶
func (fake *FakeIngressClient) SendAppMetricsReturns(result1 error)
func (*FakeIngressClient) SendAppMetricsReturnsOnCall ¶
func (fake *FakeIngressClient) SendAppMetricsReturnsOnCall(i int, result1 error)
func (*FakeIngressClient) SendBytesPerSecond ¶
func (fake *FakeIngressClient) SendBytesPerSecond(arg1 string, arg2 float64) error
func (*FakeIngressClient) SendBytesPerSecondArgsForCall ¶
func (fake *FakeIngressClient) SendBytesPerSecondArgsForCall(i int) (string, float64)
func (*FakeIngressClient) SendBytesPerSecondCallCount ¶
func (fake *FakeIngressClient) SendBytesPerSecondCallCount() int
func (*FakeIngressClient) SendBytesPerSecondCalls ¶
func (fake *FakeIngressClient) SendBytesPerSecondCalls(stub func(string, float64) error)
func (*FakeIngressClient) SendBytesPerSecondReturns ¶
func (fake *FakeIngressClient) SendBytesPerSecondReturns(result1 error)
func (*FakeIngressClient) SendBytesPerSecondReturnsOnCall ¶
func (fake *FakeIngressClient) SendBytesPerSecondReturnsOnCall(i int, result1 error)
func (*FakeIngressClient) SendComponentMetric ¶
func (fake *FakeIngressClient) SendComponentMetric(arg1 string, arg2 float64, arg3 string) error
func (*FakeIngressClient) SendComponentMetricArgsForCall ¶
func (fake *FakeIngressClient) SendComponentMetricArgsForCall(i int) (string, float64, string)
func (*FakeIngressClient) SendComponentMetricCallCount ¶
func (fake *FakeIngressClient) SendComponentMetricCallCount() int
func (*FakeIngressClient) SendComponentMetricCalls ¶
func (fake *FakeIngressClient) SendComponentMetricCalls(stub func(string, float64, string) error)
func (*FakeIngressClient) SendComponentMetricReturns ¶
func (fake *FakeIngressClient) SendComponentMetricReturns(result1 error)
func (*FakeIngressClient) SendComponentMetricReturnsOnCall ¶
func (fake *FakeIngressClient) SendComponentMetricReturnsOnCall(i int, result1 error)
func (*FakeIngressClient) SendDuration ¶
func (fake *FakeIngressClient) SendDuration(arg1 string, arg2 time.Duration, arg3 ...loggregator.EmitGaugeOption) error
func (*FakeIngressClient) SendDurationArgsForCall ¶
func (fake *FakeIngressClient) SendDurationArgsForCall(i int) (string, time.Duration, []loggregator.EmitGaugeOption)
func (*FakeIngressClient) SendDurationCallCount ¶
func (fake *FakeIngressClient) SendDurationCallCount() int
func (*FakeIngressClient) SendDurationCalls ¶
func (fake *FakeIngressClient) SendDurationCalls(stub func(string, time.Duration, ...loggregator.EmitGaugeOption) error)
func (*FakeIngressClient) SendDurationReturns ¶
func (fake *FakeIngressClient) SendDurationReturns(result1 error)
func (*FakeIngressClient) SendDurationReturnsOnCall ¶
func (fake *FakeIngressClient) SendDurationReturnsOnCall(i int, result1 error)
func (*FakeIngressClient) SendMebiBytes ¶
func (fake *FakeIngressClient) SendMebiBytes(arg1 string, arg2 int, arg3 ...loggregator.EmitGaugeOption) error
func (*FakeIngressClient) SendMebiBytesArgsForCall ¶
func (fake *FakeIngressClient) SendMebiBytesArgsForCall(i int) (string, int, []loggregator.EmitGaugeOption)
func (*FakeIngressClient) SendMebiBytesCallCount ¶
func (fake *FakeIngressClient) SendMebiBytesCallCount() int
func (*FakeIngressClient) SendMebiBytesCalls ¶
func (fake *FakeIngressClient) SendMebiBytesCalls(stub func(string, int, ...loggregator.EmitGaugeOption) error)
func (*FakeIngressClient) SendMebiBytesReturns ¶
func (fake *FakeIngressClient) SendMebiBytesReturns(result1 error)
func (*FakeIngressClient) SendMebiBytesReturnsOnCall ¶
func (fake *FakeIngressClient) SendMebiBytesReturnsOnCall(i int, result1 error)
func (*FakeIngressClient) SendMetric ¶
func (fake *FakeIngressClient) SendMetric(arg1 string, arg2 int, arg3 ...loggregator.EmitGaugeOption) error
func (*FakeIngressClient) SendMetricArgsForCall ¶
func (fake *FakeIngressClient) SendMetricArgsForCall(i int) (string, int, []loggregator.EmitGaugeOption)
func (*FakeIngressClient) SendMetricCallCount ¶
func (fake *FakeIngressClient) SendMetricCallCount() int
func (*FakeIngressClient) SendMetricCalls ¶
func (fake *FakeIngressClient) SendMetricCalls(stub func(string, int, ...loggregator.EmitGaugeOption) error)
func (*FakeIngressClient) SendMetricReturns ¶
func (fake *FakeIngressClient) SendMetricReturns(result1 error)
func (*FakeIngressClient) SendMetricReturnsOnCall ¶
func (fake *FakeIngressClient) SendMetricReturnsOnCall(i int, result1 error)
func (*FakeIngressClient) SendRequestsPerSecond ¶
func (fake *FakeIngressClient) SendRequestsPerSecond(arg1 string, arg2 float64) error
func (*FakeIngressClient) SendRequestsPerSecondArgsForCall ¶
func (fake *FakeIngressClient) SendRequestsPerSecondArgsForCall(i int) (string, float64)
func (*FakeIngressClient) SendRequestsPerSecondCallCount ¶
func (fake *FakeIngressClient) SendRequestsPerSecondCallCount() int
func (*FakeIngressClient) SendRequestsPerSecondCalls ¶
func (fake *FakeIngressClient) SendRequestsPerSecondCalls(stub func(string, float64) error)
func (*FakeIngressClient) SendRequestsPerSecondReturns ¶
func (fake *FakeIngressClient) SendRequestsPerSecondReturns(result1 error)
func (*FakeIngressClient) SendRequestsPerSecondReturnsOnCall ¶
func (fake *FakeIngressClient) SendRequestsPerSecondReturnsOnCall(i int, result1 error)
func (*FakeIngressClient) SendSpikeMetrics ¶
func (fake *FakeIngressClient) SendSpikeMetrics(arg1 diego_logging_client.SpikeMetric) error
func (*FakeIngressClient) SendSpikeMetricsArgsForCall ¶
func (fake *FakeIngressClient) SendSpikeMetricsArgsForCall(i int) diego_logging_client.SpikeMetric
func (*FakeIngressClient) SendSpikeMetricsCallCount ¶
func (fake *FakeIngressClient) SendSpikeMetricsCallCount() int
func (*FakeIngressClient) SendSpikeMetricsCalls ¶
func (fake *FakeIngressClient) SendSpikeMetricsCalls(stub func(diego_logging_client.SpikeMetric) error)
func (*FakeIngressClient) SendSpikeMetricsReturns ¶
func (fake *FakeIngressClient) SendSpikeMetricsReturns(result1 error)
func (*FakeIngressClient) SendSpikeMetricsReturnsOnCall ¶
func (fake *FakeIngressClient) SendSpikeMetricsReturnsOnCall(i int, result1 error)
type FakeIngressServer ¶
type FakeIngressServer struct { SenderStub func(loggregator_v2.Ingress_SenderServer) error BatchSenderStub func(loggregator_v2.Ingress_BatchSenderServer) error // contains filtered or unexported fields }
func (*FakeIngressServer) BatchSender ¶
func (fake *FakeIngressServer) BatchSender(arg1 loggregator_v2.Ingress_BatchSenderServer) error
func (*FakeIngressServer) BatchSenderArgsForCall ¶
func (fake *FakeIngressServer) BatchSenderArgsForCall(i int) loggregator_v2.Ingress_BatchSenderServer
func (*FakeIngressServer) BatchSenderCallCount ¶
func (fake *FakeIngressServer) BatchSenderCallCount() int
func (*FakeIngressServer) BatchSenderReturns ¶
func (fake *FakeIngressServer) BatchSenderReturns(result1 error)
func (*FakeIngressServer) BatchSenderReturnsOnCall ¶
func (fake *FakeIngressServer) BatchSenderReturnsOnCall(i int, result1 error)
func (*FakeIngressServer) Invocations ¶
func (fake *FakeIngressServer) Invocations() map[string][][]interface{}
func (*FakeIngressServer) Send ¶
func (f *FakeIngressServer) Send(context.Context, *loggregator_v2.EnvelopeBatch) (*loggregator_v2.SendResponse, error)
func (*FakeIngressServer) Sender ¶
func (fake *FakeIngressServer) Sender(arg1 loggregator_v2.Ingress_SenderServer) error
func (*FakeIngressServer) SenderArgsForCall ¶
func (fake *FakeIngressServer) SenderArgsForCall(i int) loggregator_v2.Ingress_SenderServer
func (*FakeIngressServer) SenderCallCount ¶
func (fake *FakeIngressServer) SenderCallCount() int
func (*FakeIngressServer) SenderReturns ¶
func (fake *FakeIngressServer) SenderReturns(result1 error)
func (*FakeIngressServer) SenderReturnsOnCall ¶
func (fake *FakeIngressServer) SenderReturnsOnCall(i int, result1 error)
type FakeIngress_SenderServer ¶
type FakeIngress_SenderServer struct { SendAndCloseStub func(*loggregator_v2.IngressResponse) error RecvStub func() (*loggregator_v2.Envelope, error) SetHeaderStub func(metadata.MD) error SendHeaderStub func(metadata.MD) error SetTrailerStub func(metadata.MD) ContextStub func() context.Context SendMsgStub func(m interface{}) error RecvMsgStub func(m interface{}) error // contains filtered or unexported fields }
func (*FakeIngress_SenderServer) Context ¶
func (fake *FakeIngress_SenderServer) Context() context.Context
func (*FakeIngress_SenderServer) ContextCallCount ¶
func (fake *FakeIngress_SenderServer) ContextCallCount() int
func (*FakeIngress_SenderServer) ContextReturns ¶
func (fake *FakeIngress_SenderServer) ContextReturns(result1 context.Context)
func (*FakeIngress_SenderServer) ContextReturnsOnCall ¶
func (fake *FakeIngress_SenderServer) ContextReturnsOnCall(i int, result1 context.Context)
func (*FakeIngress_SenderServer) Invocations ¶
func (fake *FakeIngress_SenderServer) Invocations() map[string][][]interface{}
func (*FakeIngress_SenderServer) Recv ¶
func (fake *FakeIngress_SenderServer) Recv() (*loggregator_v2.Envelope, error)
func (*FakeIngress_SenderServer) RecvCallCount ¶
func (fake *FakeIngress_SenderServer) RecvCallCount() int
func (*FakeIngress_SenderServer) RecvMsg ¶
func (fake *FakeIngress_SenderServer) RecvMsg(m interface{}) error
func (*FakeIngress_SenderServer) RecvMsgArgsForCall ¶
func (fake *FakeIngress_SenderServer) RecvMsgArgsForCall(i int) interface{}
func (*FakeIngress_SenderServer) RecvMsgCallCount ¶
func (fake *FakeIngress_SenderServer) RecvMsgCallCount() int
func (*FakeIngress_SenderServer) RecvMsgReturns ¶
func (fake *FakeIngress_SenderServer) RecvMsgReturns(result1 error)
func (*FakeIngress_SenderServer) RecvMsgReturnsOnCall ¶
func (fake *FakeIngress_SenderServer) RecvMsgReturnsOnCall(i int, result1 error)
func (*FakeIngress_SenderServer) RecvReturns ¶
func (fake *FakeIngress_SenderServer) RecvReturns(result1 *loggregator_v2.Envelope, result2 error)
func (*FakeIngress_SenderServer) RecvReturnsOnCall ¶
func (fake *FakeIngress_SenderServer) RecvReturnsOnCall(i int, result1 *loggregator_v2.Envelope, result2 error)
func (*FakeIngress_SenderServer) SendAndClose ¶
func (fake *FakeIngress_SenderServer) SendAndClose(arg1 *loggregator_v2.IngressResponse) error
func (*FakeIngress_SenderServer) SendAndCloseArgsForCall ¶
func (fake *FakeIngress_SenderServer) SendAndCloseArgsForCall(i int) *loggregator_v2.IngressResponse
func (*FakeIngress_SenderServer) SendAndCloseCallCount ¶
func (fake *FakeIngress_SenderServer) SendAndCloseCallCount() int
func (*FakeIngress_SenderServer) SendAndCloseReturns ¶
func (fake *FakeIngress_SenderServer) SendAndCloseReturns(result1 error)
func (*FakeIngress_SenderServer) SendAndCloseReturnsOnCall ¶
func (fake *FakeIngress_SenderServer) SendAndCloseReturnsOnCall(i int, result1 error)
func (*FakeIngress_SenderServer) SendHeader ¶
func (fake *FakeIngress_SenderServer) SendHeader(arg1 metadata.MD) error
func (*FakeIngress_SenderServer) SendHeaderArgsForCall ¶
func (fake *FakeIngress_SenderServer) SendHeaderArgsForCall(i int) metadata.MD
func (*FakeIngress_SenderServer) SendHeaderCallCount ¶
func (fake *FakeIngress_SenderServer) SendHeaderCallCount() int
func (*FakeIngress_SenderServer) SendHeaderReturns ¶
func (fake *FakeIngress_SenderServer) SendHeaderReturns(result1 error)
func (*FakeIngress_SenderServer) SendHeaderReturnsOnCall ¶
func (fake *FakeIngress_SenderServer) SendHeaderReturnsOnCall(i int, result1 error)
func (*FakeIngress_SenderServer) SendMsg ¶
func (fake *FakeIngress_SenderServer) SendMsg(m interface{}) error
func (*FakeIngress_SenderServer) SendMsgArgsForCall ¶
func (fake *FakeIngress_SenderServer) SendMsgArgsForCall(i int) interface{}
func (*FakeIngress_SenderServer) SendMsgCallCount ¶
func (fake *FakeIngress_SenderServer) SendMsgCallCount() int
func (*FakeIngress_SenderServer) SendMsgReturns ¶
func (fake *FakeIngress_SenderServer) SendMsgReturns(result1 error)
func (*FakeIngress_SenderServer) SendMsgReturnsOnCall ¶
func (fake *FakeIngress_SenderServer) SendMsgReturnsOnCall(i int, result1 error)
func (*FakeIngress_SenderServer) SetHeader ¶
func (fake *FakeIngress_SenderServer) SetHeader(arg1 metadata.MD) error
func (*FakeIngress_SenderServer) SetHeaderArgsForCall ¶
func (fake *FakeIngress_SenderServer) SetHeaderArgsForCall(i int) metadata.MD
func (*FakeIngress_SenderServer) SetHeaderCallCount ¶
func (fake *FakeIngress_SenderServer) SetHeaderCallCount() int
func (*FakeIngress_SenderServer) SetHeaderReturns ¶
func (fake *FakeIngress_SenderServer) SetHeaderReturns(result1 error)
func (*FakeIngress_SenderServer) SetHeaderReturnsOnCall ¶
func (fake *FakeIngress_SenderServer) SetHeaderReturnsOnCall(i int, result1 error)
func (*FakeIngress_SenderServer) SetTrailer ¶
func (fake *FakeIngress_SenderServer) SetTrailer(arg1 metadata.MD)
func (*FakeIngress_SenderServer) SetTrailerArgsForCall ¶
func (fake *FakeIngress_SenderServer) SetTrailerArgsForCall(i int) metadata.MD
func (*FakeIngress_SenderServer) SetTrailerCallCount ¶
func (fake *FakeIngress_SenderServer) SetTrailerCallCount() int
type MetricAndValue ¶
type TestIngressServer ¶
type TestIngressServer struct {
// contains filtered or unexported fields
}
func NewTestIngressServer ¶
func NewTestIngressServer(serverCert, serverKey, caCert string) (*TestIngressServer, error)
func (*TestIngressServer) Addr ¶
func (t *TestIngressServer) Addr() string
func (*TestIngressServer) Port ¶
func (t *TestIngressServer) Port() (int, error)
func (*TestIngressServer) Receivers ¶
func (t *TestIngressServer) Receivers() chan loggregator_v2.Ingress_BatchSenderServer
func (*TestIngressServer) Start ¶
func (t *TestIngressServer) Start() error
func (*TestIngressServer) Stop ¶
func (t *TestIngressServer) Stop()
Click to show internal directories.
Click to hide internal directories.