mocks

func (_m *ClientFactory) GetLocalClient() interface{}

func (_m *ClientFactory) MakeRemoteClient(client thrift.TChanClient) interface{}

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

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, format tchannel.Format, opts *forward.Options) ([]byte, error)

func (_m *Ringpop) GetReachableMembers() ([]string, error)

func (_m *Ringpop) HandleOrForward(key string, request []byte, response *[]byte, service string, endpoint string, format tchannel.Format, opts *forward.Options) (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)

func (_m *StatsReporter) IncCounter(name string, tags bark.Tags, value int64)

func (_m *StatsReporter) RecordTimer(name string, tags bark.Tags, d time.Duration)

func (_m *StatsReporter) UpdateGauge(name string, tags bark.Tags, value int64)

func (_m *SwimNode) Bootstrap(opts *swim.BootstrapOptions) ([]string, error)

func (_m *SwimNode) CountReachableMembers() int

func (_m *SwimNode) Destroy()

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)

func (_m *TChanClient) Call(ctx thrift.Context, serviceName string, methodName string, req athrift.TStruct, resp athrift.TStruct) (bool, error)