Documentation ¶
Index ¶
- type ClientFactory
- 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
- 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
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 Ringpop ¶
func (*Ringpop) AddListener ¶ added in v0.7.0
func (_m *Ringpop) AddListener(_a0 events.EventListener) bool
AddListener provides a mock function with given fields: _a0
func (*Ringpop) Bootstrap ¶
func (_m *Ringpop) Bootstrap(opts *swim.BootstrapOptions) ([]string, error)
Bootstrap provides a mock function with given fields: opts
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 ¶ added in v0.7.0
func (_m *Ringpop) Labels() (*swim.NodeLabels, error)
Labels provides a mock function with given fields:
func (*Ringpop) RegisterListener ¶
func (_m *Ringpop) RegisterListener(_a0 events.EventListener)
RegisterListener provides a mock function with given fields: _a0
func (*Ringpop) RegisterSelfEvictHook ¶ added in v0.8.0
func (_m *Ringpop) RegisterSelfEvictHook(hooks swim.SelfEvictHook) error
RegisterSelfEvictHook provides a mock function with given fields: hooks
func (*Ringpop) RemoveListener ¶ added in v0.7.0
func (_m *Ringpop) RemoveListener(_a0 events.EventListener) bool
RemoveListener provides a mock function with given fields: _a0
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) AddListener ¶ added in v0.7.0
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 ¶ added in v0.3.0
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 ¶ added in v0.7.0
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) RegisterSelfEvictHook ¶ added in v0.8.0
func (_m *SwimNode) RegisterSelfEvictHook(hooks swim.SelfEvictHook) error
RegisterSelfEvictHook provides a mock function with given fields: hooks
func (*SwimNode) RemoveListener ¶ added in v0.7.0
func (_m *SwimNode) RemoveListener(_a0 events.EventListener) bool
RemoveListener provides a mock function with given fields: _a0
func (*SwimNode) SetIdentity ¶ added in v0.8.0
SetIdentity provides a mock function with given fields: identity