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.
Index ¶
- type AddressTable
- func (fake *AddressTable) Add(infraNames []string, ip string)
- func (fake *AddressTable) AddArgsForCall(i int) ([]string, string)
- func (fake *AddressTable) AddCallCount() int
- func (fake *AddressTable) Invocations() map[string][][]interface{}
- func (fake *AddressTable) PausePruning()
- func (fake *AddressTable) PausePruningCallCount() int
- func (fake *AddressTable) Remove(infraNames []string, ip string)
- func (fake *AddressTable) RemoveArgsForCall(i int) ([]string, string)
- func (fake *AddressTable) RemoveCallCount() int
- func (fake *AddressTable) ResumePruning()
- func (fake *AddressTable) ResumePruningCallCount() int
- func (fake *AddressTable) SetWarm()
- func (fake *AddressTable) SetWarmCallCount() int
- type MetricsSender
- type NatsConn
- func (fake *NatsConn) Close()
- func (fake *NatsConn) CloseCallCount() int
- func (fake *NatsConn) ConnectedUrl() string
- func (fake *NatsConn) ConnectedUrlCallCount() int
- func (fake *NatsConn) ConnectedUrlReturns(result1 string)
- func (fake *NatsConn) ConnectedUrlReturnsOnCall(i int, result1 string)
- func (fake *NatsConn) Flush() error
- func (fake *NatsConn) FlushCallCount() int
- func (fake *NatsConn) FlushReturns(result1 error)
- func (fake *NatsConn) FlushReturnsOnCall(i int, result1 error)
- func (fake *NatsConn) Invocations() map[string][][]interface{}
- func (fake *NatsConn) PublishMsg(m *nats.Msg) error
- func (fake *NatsConn) PublishMsgArgsForCall(i int) *nats.Msg
- func (fake *NatsConn) PublishMsgCallCount() int
- func (fake *NatsConn) PublishMsgReturns(result1 error)
- func (fake *NatsConn) PublishMsgReturnsOnCall(i int, result1 error)
- func (fake *NatsConn) Subscribe(arg1 string, arg2 nats.MsgHandler) (*nats.Subscription, error)
- func (fake *NatsConn) SubscribeArgsForCall(i int) (string, nats.MsgHandler)
- func (fake *NatsConn) SubscribeCallCount() int
- func (fake *NatsConn) SubscribeReturns(result1 *nats.Subscription, result2 error)
- func (fake *NatsConn) SubscribeReturnsOnCall(i int, result1 *nats.Subscription, result2 error)
- type NatsConnProvider
- func (fake *NatsConnProvider) Connection(opts ...nats.Option) (mbus.NatsConn, error)
- func (fake *NatsConnProvider) ConnectionArgsForCall(i int) []nats.Option
- func (fake *NatsConnProvider) ConnectionCallCount() int
- func (fake *NatsConnProvider) ConnectionReturns(result1 mbus.NatsConn, result2 error)
- func (fake *NatsConnProvider) ConnectionReturnsOnCall(i int, result1 mbus.NatsConn, result2 error)
- func (fake *NatsConnProvider) Invocations() map[string][][]interface{}
- type RouteMessageRecorder
- func (fake *RouteMessageRecorder) Invocations() map[string][][]interface{}
- func (fake *RouteMessageRecorder) RecordMessageTransitTime(time int64)
- func (fake *RouteMessageRecorder) RecordMessageTransitTimeArgsForCall(i int) int64
- func (fake *RouteMessageRecorder) RecordMessageTransitTimeCallCount() int
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AddressTable ¶
type AddressTable struct { AddStub func(infraNames []string, ip string) RemoveStub func(infraNames []string, ip string) PausePruningStub func() ResumePruningStub func() SetWarmStub func() // contains filtered or unexported fields }
func (*AddressTable) Add ¶
func (fake *AddressTable) Add(infraNames []string, ip string)
func (*AddressTable) AddArgsForCall ¶
func (fake *AddressTable) AddArgsForCall(i int) ([]string, string)
func (*AddressTable) AddCallCount ¶
func (fake *AddressTable) AddCallCount() int
func (*AddressTable) Invocations ¶
func (fake *AddressTable) Invocations() map[string][][]interface{}
func (*AddressTable) PausePruning ¶
func (fake *AddressTable) PausePruning()
func (*AddressTable) PausePruningCallCount ¶
func (fake *AddressTable) PausePruningCallCount() int
func (*AddressTable) Remove ¶
func (fake *AddressTable) Remove(infraNames []string, ip string)
func (*AddressTable) RemoveArgsForCall ¶
func (fake *AddressTable) RemoveArgsForCall(i int) ([]string, string)
func (*AddressTable) RemoveCallCount ¶
func (fake *AddressTable) RemoveCallCount() int
func (*AddressTable) ResumePruning ¶
func (fake *AddressTable) ResumePruning()
func (*AddressTable) ResumePruningCallCount ¶
func (fake *AddressTable) ResumePruningCallCount() int
func (*AddressTable) SetWarm ¶
func (fake *AddressTable) SetWarm()
func (*AddressTable) SetWarmCallCount ¶
func (fake *AddressTable) SetWarmCallCount() int
type MetricsSender ¶
type MetricsSender struct { IncrementCounterStub func(string) // contains filtered or unexported fields }
func (*MetricsSender) IncrementCounter ¶
func (fake *MetricsSender) IncrementCounter(arg1 string)
func (*MetricsSender) IncrementCounterArgsForCall ¶
func (fake *MetricsSender) IncrementCounterArgsForCall(i int) string
func (*MetricsSender) IncrementCounterCallCount ¶
func (fake *MetricsSender) IncrementCounterCallCount() int
func (*MetricsSender) Invocations ¶
func (fake *MetricsSender) Invocations() map[string][][]interface{}
type NatsConn ¶
type NatsConn struct { PublishMsgStub func(m *nats.Msg) error CloseStub func() FlushStub func() error ConnectedUrlStub func() string SubscribeStub func(string, nats.MsgHandler) (*nats.Subscription, error) // contains filtered or unexported fields }
func (*NatsConn) CloseCallCount ¶
func (*NatsConn) ConnectedUrl ¶
func (*NatsConn) ConnectedUrlCallCount ¶
func (*NatsConn) ConnectedUrlReturns ¶
func (*NatsConn) ConnectedUrlReturnsOnCall ¶
func (*NatsConn) FlushCallCount ¶
func (*NatsConn) FlushReturns ¶
func (*NatsConn) FlushReturnsOnCall ¶
func (*NatsConn) Invocations ¶
func (*NatsConn) PublishMsgArgsForCall ¶
func (*NatsConn) PublishMsgCallCount ¶
func (*NatsConn) PublishMsgReturns ¶
func (*NatsConn) PublishMsgReturnsOnCall ¶
func (*NatsConn) Subscribe ¶
func (fake *NatsConn) Subscribe(arg1 string, arg2 nats.MsgHandler) (*nats.Subscription, error)
func (*NatsConn) SubscribeArgsForCall ¶
func (fake *NatsConn) SubscribeArgsForCall(i int) (string, nats.MsgHandler)
func (*NatsConn) SubscribeCallCount ¶
func (*NatsConn) SubscribeReturns ¶
func (fake *NatsConn) SubscribeReturns(result1 *nats.Subscription, result2 error)
func (*NatsConn) SubscribeReturnsOnCall ¶
func (fake *NatsConn) SubscribeReturnsOnCall(i int, result1 *nats.Subscription, result2 error)
type NatsConnProvider ¶
type NatsConnProvider struct { ConnectionStub func(opts ...nats.Option) (mbus.NatsConn, error) // contains filtered or unexported fields }
func (*NatsConnProvider) Connection ¶
func (*NatsConnProvider) ConnectionArgsForCall ¶
func (fake *NatsConnProvider) ConnectionArgsForCall(i int) []nats.Option
func (*NatsConnProvider) ConnectionCallCount ¶
func (fake *NatsConnProvider) ConnectionCallCount() int
func (*NatsConnProvider) ConnectionReturns ¶
func (fake *NatsConnProvider) ConnectionReturns(result1 mbus.NatsConn, result2 error)
func (*NatsConnProvider) ConnectionReturnsOnCall ¶
func (fake *NatsConnProvider) ConnectionReturnsOnCall(i int, result1 mbus.NatsConn, result2 error)
func (*NatsConnProvider) Invocations ¶
func (fake *NatsConnProvider) Invocations() map[string][][]interface{}
type RouteMessageRecorder ¶
type RouteMessageRecorder struct { RecordMessageTransitTimeStub func(time int64) // contains filtered or unexported fields }
func (*RouteMessageRecorder) Invocations ¶
func (fake *RouteMessageRecorder) Invocations() map[string][][]interface{}
func (*RouteMessageRecorder) RecordMessageTransitTime ¶
func (fake *RouteMessageRecorder) RecordMessageTransitTime(time int64)
func (*RouteMessageRecorder) RecordMessageTransitTimeArgsForCall ¶
func (fake *RouteMessageRecorder) RecordMessageTransitTimeArgsForCall(i int) int64
func (*RouteMessageRecorder) RecordMessageTransitTimeCallCount ¶
func (fake *RouteMessageRecorder) RecordMessageTransitTimeCallCount() int
Click to show internal directories.
Click to hide internal directories.