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 Ringpop
  • func (_m *Ringpop) AddListener(_a0 events.EventListener) bool
  • func (_m *Ringpop) App() string
  • func (_m *Ringpop) Bootstrap(opts *swim.BootstrapOptions) ([]string, error)
  • func (_m *Ringpop) Checksum() (uint32, error)
  • func (_m *Ringpop) CountReachableMembers(predicates ...swim.MemberPredicate) (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(predicates ...swim.MemberPredicate) ([]string, error)
  • func (_m *Ringpop) HandleOrForward(key string, request []byte, response *[]byte, service string, endpoint string, ...) (bool, error)
  • func (_m *Ringpop) Labels() (*swim.NodeLabels, error)
  • func (_m *Ringpop) Lookup(key string) (string, error)
  • func (_m *Ringpop) LookupN(key string, n int) ([]string, error)
  • func (_m *Ringpop) RegisterListener(_a0 events.EventListener)
  • func (_m *Ringpop) RegisterSelfEvictHook(hooks swim.SelfEvictHook) error
  • func (_m *Ringpop) RemoveListener(_a0 events.EventListener) bool
  • func (_m *Ringpop) SelfEvict() error
  • 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) AddListener(_a0 events.EventListener) bool
  • func (_m *SwimNode) Bootstrap(opts *swim.BootstrapOptions) ([]string, error)
  • func (_m *SwimNode) CountReachableMembers(predicates ...swim.MemberPredicate) int
  • func (_m *SwimNode) Destroy()
  • func (_m *SwimNode) GetChecksum() uint32
  • func (_m *SwimNode) GetReachableMembers(predicates ...swim.MemberPredicate) []swim.Member
  • func (_m *SwimNode) Labels() *swim.NodeLabels
  • func (_m *SwimNode) MemberStats() swim.MemberStats
  • func (_m *SwimNode) ProtocolStats() swim.ProtocolStats
  • func (_m *SwimNode) Ready() bool
  • func (_m *SwimNode) RegisterSelfEvictHook(hooks swim.SelfEvictHook) error
  • func (_m *SwimNode) RemoveListener(_a0 events.EventListener) bool
  • func (_m *SwimNode) SelfEvict() error
  • func (_m *SwimNode) SetIdentity(identity string) error
• 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{}

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 Ringpop

type Ringpop struct {
	mock.Mock
}

func (*Ringpop) AddListener

func (_m *Ringpop) AddListener(_a0 events.EventListener) bool

AddListener provides a mock function with given fields: _a0

func (*Ringpop) App

func (_m *Ringpop) App() string

App provides a mock function with given fields:

func (*Ringpop) Bootstrap

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

Bootstrap provides a mock function with given fields: opts

func (*Ringpop) Checksum

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

Checksum provides a mock function with given fields:

func (*Ringpop) CountReachableMembers

func (_m *Ringpop) CountReachableMembers(predicates ...swim.MemberPredicate) (int, error)

CountReachableMembers provides a mock function with given fields: predicates

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

func (_m *Ringpop) GetReachableMembers(predicates ...swim.MemberPredicate) ([]string, error)

GetReachableMembers provides a mock function with given fields: predicates

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) Labels

func (_m *Ringpop) Labels() (*swim.NodeLabels, error)

Labels provides a mock function with given fields:

func (*Ringpop) Lookup

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

Lookup provides a mock function with given fields: key

func (*Ringpop) LookupN

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

LookupN provides a mock function with given fields: key, n

func (*Ringpop) RegisterListener

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

RegisterListener provides a mock function with given fields: _a0

func (*Ringpop) RegisterSelfEvictHook

func (_m *Ringpop) RegisterSelfEvictHook(hooks swim.SelfEvictHook) error

RegisterSelfEvictHook provides a mock function with given fields: hooks

func (*Ringpop) RemoveListener

func (_m *Ringpop) RemoveListener(_a0 events.EventListener) bool

RemoveListener provides a mock function with given fields: _a0

func (*Ringpop) SelfEvict

func (_m *Ringpop) SelfEvict() error

SelfEvict provides a mock function with given fields:

func (*Ringpop) Uptime

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

Uptime provides a mock function with given fields:

func (*Ringpop) WhoAmI

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

WhoAmI provides a mock function with given fields:

type StatsReporter

type StatsReporter struct {
	mock.Mock
}

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

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

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

type SwimNode struct {
	mock.Mock
}

func (*SwimNode) AddListener

func (_m *SwimNode) AddListener(_a0 events.EventListener) bool

AddListener provides a mock function with given fields: _a0

func (*SwimNode) Bootstrap

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

Bootstrap provides a mock function with given fields: opts

func (*SwimNode) CountReachableMembers

func (_m *SwimNode) CountReachableMembers(predicates ...swim.MemberPredicate) int

CountReachableMembers provides a mock function with given fields: predicates

func (*SwimNode) Destroy

func (_m *SwimNode) Destroy()

Destroy provides a mock function with given fields:

func (*SwimNode) GetChecksum

func (_m *SwimNode) GetChecksum() uint32

GetChecksum provides a mock function with given fields:

func (*SwimNode) GetReachableMembers

func (_m *SwimNode) GetReachableMembers(predicates ...swim.MemberPredicate) []swim.Member

GetReachableMembers provides a mock function with given fields: predicates

func (*SwimNode) Labels

func (_m *SwimNode) Labels() *swim.NodeLabels

Labels 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) Ready

func (_m *SwimNode) Ready() bool

Ready provides a mock function with given fields:

func (*SwimNode) RegisterSelfEvictHook

func (_m *SwimNode) RegisterSelfEvictHook(hooks swim.SelfEvictHook) error

RegisterSelfEvictHook provides a mock function with given fields: hooks

func (*SwimNode) RemoveListener

func (_m *SwimNode) RemoveListener(_a0 events.EventListener) bool

RemoveListener provides a mock function with given fields: _a0

func (*SwimNode) SelfEvict

func (_m *SwimNode) SelfEvict() error

SelfEvict provides a mock function with given fields:

func (*SwimNode) SetIdentity

func (_m *SwimNode) SetIdentity(identity string) error

SetIdentity provides a mock function with given fields: identity

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)

Call provides a mock function with given fields: ctx, serviceName, methodName, req, resp