mocks

README

Files in this directory have been automatically generated using mockery.

Documentation

Index

• type ClientFactory
  • func (_m *ClientFactory) GetLocalClient() interface{}
  • func (_m *ClientFactory) MakeRemoteClient(client thrift.TChanClient) interface{}
• 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
  • 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)
• type SwimNode
  • 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)
• type TChanClient
  • func (_m *TChanClient) Call(ctx thrift.Context, serviceName string, methodName string, req athrift.TStruct, ...) (bool, error)

Types

type ClientFactory

type ClientFactory struct {
	mock.Mock
}

func (*ClientFactory) GetLocalClient

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

func (*ClientFactory) MakeRemoteClient

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

type Logger

type Logger struct {
	mock.Mock
}

func (*Logger) Debug

func (_m *Logger) Debug(args ...interface{})

func (*Logger) Debugf

func (_m *Logger) Debugf(format string, args ...interface{})

func (*Logger) Error

func (_m *Logger) Error(args ...interface{})

func (*Logger) Errorf

func (_m *Logger) Errorf(format string, args ...interface{})

func (*Logger) Fatal

func (_m *Logger) Fatal(args ...interface{})

func (*Logger) Fatalf

func (_m *Logger) Fatalf(format string, args ...interface{})

func (*Logger) Fields

func (_m *Logger) Fields() bark.Fields

func (*Logger) Info

func (_m *Logger) Info(args ...interface{})

func (*Logger) Infof

func (_m *Logger) Infof(format string, args ...interface{})

func (*Logger) Panic

func (_m *Logger) Panic(args ...interface{})

func (*Logger) Panicf

func (_m *Logger) Panicf(format string, args ...interface{})

func (*Logger) Warn

func (_m *Logger) Warn(args ...interface{})

func (*Logger) Warnf

func (_m *Logger) Warnf(format string, args ...interface{})

func (*Logger) WithField

func (_m *Logger) WithField(key string, value interface{}) bark.Logger

func (*Logger) WithFields

func (_m *Logger) WithFields(keyValues bark.LogFields) bark.Logger

type Ringpop

type Ringpop struct {
	mock.Mock
}

func (*Ringpop) App

func (_m *Ringpop) App() string

func (*Ringpop) Bootstrap

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

func (*Ringpop) Checksum

func (_m *Ringpop) Checksum() (uint32, error)

func (*Ringpop) CountReachableMembers

func (_m *Ringpop) CountReachableMembers() (int, error)

func (*Ringpop) Destroy

func (_m *Ringpop) Destroy()

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)

func (*Ringpop) GetReachableMembers

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

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)

func (*Ringpop) Lookup

func (_m *Ringpop) Lookup(key string) (string, error)

func (*Ringpop) LookupN

func (_m *Ringpop) LookupN(key string, n int) ([]string, error)

func (*Ringpop) RegisterListener

func (_m *Ringpop) RegisterListener(l events.EventListener)

func (*Ringpop) Uptime

func (_m *Ringpop) Uptime() (time.Duration, error)

func (*Ringpop) WhoAmI

func (_m *Ringpop) WhoAmI() (string, error)

type StatsReporter

type StatsReporter struct {
	mock.Mock
}

func (*StatsReporter) IncCounter

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

func (*StatsReporter) RecordTimer

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

func (*StatsReporter) UpdateGauge

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

type SwimNode

type SwimNode struct {
	mock.Mock
}

func (*SwimNode) Bootstrap

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

func (*SwimNode) CountReachableMembers

func (_m *SwimNode) CountReachableMembers() int

func (*SwimNode) Destroy

func (_m *SwimNode) Destroy()

func (*SwimNode) GetReachableMembers

func (_m *SwimNode) GetReachableMembers() []string

func (*SwimNode) MemberStats

func (_m *SwimNode) MemberStats() swim.MemberStats

func (*SwimNode) ProtocolStats

func (_m *SwimNode) ProtocolStats() swim.ProtocolStats

func (*SwimNode) Ready

func (_m *SwimNode) Ready() bool

func (*SwimNode) RegisterListener

func (_m *SwimNode) RegisterListener(l swim.EventListener)

type TChanClient

type TChanClient struct {
	mock.Mock
}

func (*TChanClient) Call

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