Versions in this module Expand all Collapse all v0 v0.2.3 Jan 15, 2016 v0.2.2 Jan 12, 2016 Changes in this version + type ClientFactory struct + func (_m *ClientFactory) GetLocalClient() interface{} + func (_m *ClientFactory) MakeRemoteClient(client thrift.TChanClient) interface{} + type Logger struct + 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 struct + 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 struct + 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 struct + 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 struct + func (_m *TChanClient) Call(ctx thrift.Context, serviceName string, methodName string, req athrift.TStruct, ...) (bool, error)
Go to main page