Documentation ¶
Index ¶
- type ClientFactory
- type Logger
- func (_m *Logger) Debug(args ...interface{})
- func (_m *Logger) Debugf(format string, args ...interface{})
- func (_m *Logger) Error(args ...interface{})
- func (_m *Logger) Errorf(format string, args ...interface{})
- func (_m *Logger) Fatal(args ...interface{})
- func (_m *Logger) Fatalf(format string, args ...interface{})
- func (_m *Logger) Fields() bark.Fields
- func (_m *Logger) Info(args ...interface{})
- func (_m *Logger) Infof(format string, args ...interface{})
- func (_m *Logger) Panic(args ...interface{})
- func (_m *Logger) Panicf(format string, args ...interface{})
- func (_m *Logger) Warn(args ...interface{})
- func (_m *Logger) Warnf(format string, args ...interface{})
- func (_m *Logger) WithField(key string, value interface{}) bark.Logger
- func (_m *Logger) WithFields(keyValues bark.LogFields) bark.Logger
- type Ringpop
- func (_m *Ringpop) App() string
- func (_m *Ringpop) Bootstrap(opts *swim.BootstrapOptions) ([]string, error)
- func (_m *Ringpop) Checksum() (uint32, error)
- func (_m *Ringpop) CountReachableMembers() (int, error)
- func (_m *Ringpop) Destroy()
- func (_m *Ringpop) Forward(dest string, keys []string, request []byte, service string, endpoint string, ...) ([]byte, error)
- func (_m *Ringpop) GetReachableMembers() ([]string, error)
- func (_m *Ringpop) HandleOrForward(key string, request []byte, response *[]byte, service string, endpoint string, ...) (bool, error)
- func (_m *Ringpop) Lookup(key string) (string, error)
- func (_m *Ringpop) LookupN(key string, n int) ([]string, error)
- func (_m *Ringpop) RegisterListener(l events.EventListener)
- func (_m *Ringpop) Uptime() (time.Duration, error)
- func (_m *Ringpop) WhoAmI() (string, error)
- type StatsReporter
- type SwimNode
- func (_m *SwimNode) Bootstrap(opts *swim.BootstrapOptions) ([]string, error)
- func (_m *SwimNode) CountReachableMembers() int
- func (_m *SwimNode) Destroy()
- func (_m *SwimNode) GetChecksum() uint32
- func (_m *SwimNode) GetReachableMembers() []string
- func (_m *SwimNode) MemberStats() swim.MemberStats
- func (_m *SwimNode) ProtocolStats() swim.ProtocolStats
- func (_m *SwimNode) Ready() bool
- func (_m *SwimNode) RegisterListener(l swim.EventListener)
- type TChanClient
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ClientFactory ¶
func (*ClientFactory) GetLocalClient ¶
func (_m *ClientFactory) GetLocalClient() interface{}
GetLocalClient provides a mock function with given fields:
func (*ClientFactory) MakeRemoteClient ¶
func (_m *ClientFactory) MakeRemoteClient(client thrift.TChanClient) interface{}
MakeRemoteClient provides a mock function with given fields: client
type Logger ¶
func (*Logger) Debug ¶
func (_m *Logger) Debug(args ...interface{})
Debug provides a mock function with given fields: args
func (*Logger) Error ¶
func (_m *Logger) Error(args ...interface{})
Error provides a mock function with given fields: args
func (*Logger) Fatal ¶
func (_m *Logger) Fatal(args ...interface{})
Fatal provides a mock function with given fields: args
func (*Logger) Info ¶
func (_m *Logger) Info(args ...interface{})
Info provides a mock function with given fields: args
func (*Logger) Panic ¶
func (_m *Logger) Panic(args ...interface{})
Panic provides a mock function with given fields: args
func (*Logger) Warn ¶
func (_m *Logger) Warn(args ...interface{})
Warn provides a mock function with given fields: args
type Ringpop ¶
func (*Ringpop) Bootstrap ¶
func (_m *Ringpop) Bootstrap(opts *swim.BootstrapOptions) ([]string, error)
Bootstrap provides a mock function with given fields: opts
func (*Ringpop) CountReachableMembers ¶
CountReachableMembers provides a mock function with given fields:
func (*Ringpop) Destroy ¶
func (_m *Ringpop) Destroy()
Destroy provides a mock function with given fields:
func (*Ringpop) Forward ¶
func (_m *Ringpop) Forward(dest string, keys []string, request []byte, service string, endpoint string, format tchannel.Format, opts *forward.Options) ([]byte, error)
Forward provides a mock function with given fields: dest, keys, request, service, endpoint, format, opts
func (*Ringpop) GetReachableMembers ¶
GetReachableMembers provides a mock function with given fields:
func (*Ringpop) HandleOrForward ¶
func (_m *Ringpop) HandleOrForward(key string, request []byte, response *[]byte, service string, endpoint string, format tchannel.Format, opts *forward.Options) (bool, error)
HandleOrForward provides a mock function with given fields: key, request, response, service, endpoint, format, opts
func (*Ringpop) RegisterListener ¶
func (_m *Ringpop) RegisterListener(l events.EventListener)
RegisterListener provides a mock function with given fields: l
type StatsReporter ¶
func (*StatsReporter) IncCounter ¶
func (_m *StatsReporter) IncCounter(name string, tags bark.Tags, value int64)
IncCounter provides a mock function with given fields: name, tags, value
func (*StatsReporter) RecordTimer ¶
RecordTimer provides a mock function with given fields: name, tags, d
func (*StatsReporter) UpdateGauge ¶
func (_m *StatsReporter) UpdateGauge(name string, tags bark.Tags, value int64)
UpdateGauge provides a mock function with given fields: name, tags, value
type SwimNode ¶
func (*SwimNode) Bootstrap ¶
func (_m *SwimNode) Bootstrap(opts *swim.BootstrapOptions) ([]string, error)
Bootstrap provides a mock function with given fields: opts
func (*SwimNode) CountReachableMembers ¶
CountReachableMembers provides a mock function with given fields:
func (*SwimNode) Destroy ¶
func (_m *SwimNode) Destroy()
Destroy provides a mock function with given fields:
func (*SwimNode) GetChecksum ¶ added in v0.3.0
GetChecksum provides a mock function with given fields:
func (*SwimNode) GetReachableMembers ¶
GetReachableMembers provides a mock function with given fields:
func (*SwimNode) MemberStats ¶
func (_m *SwimNode) MemberStats() swim.MemberStats
MemberStats provides a mock function with given fields:
func (*SwimNode) ProtocolStats ¶
func (_m *SwimNode) ProtocolStats() swim.ProtocolStats
ProtocolStats provides a mock function with given fields:
func (*SwimNode) RegisterListener ¶
func (_m *SwimNode) RegisterListener(l swim.EventListener)
RegisterListener provides a mock function with given fields: l