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.
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
- func (fake *MetricsSender) IncrementCounter(arg1 string)
- func (fake *MetricsSender) IncrementCounterArgsForCall(i int) string
- func (fake *MetricsSender) IncrementCounterCallCount() int
- func (fake *MetricsSender) Invocations() map[string][][]interface{}
- func (fake *MetricsSender) SendDuration(arg1 string, arg2 time.Duration)
- func (fake *MetricsSender) SendDurationArgsForCall(i int) (string, time.Duration)
- func (fake *MetricsSender) SendDurationCallCount() int
- 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{}
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 { SendDurationStub func(string, time.Duration) 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{}
func (*MetricsSender) SendDuration ¶
func (fake *MetricsSender) SendDuration(arg1 string, arg2 time.Duration)
func (*MetricsSender) SendDurationArgsForCall ¶
func (fake *MetricsSender) SendDurationArgsForCall(i int) (string, time.Duration)
func (*MetricsSender) SendDurationCallCount ¶
func (fake *MetricsSender) SendDurationCallCount() int
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{}
Click to show internal directories.
Click to hide internal directories.