plugin

package

Go to main page

Versions in this module

v1

v1.2.0

Jun 1, 2017

v1.1.3

Mar 29, 2017

Changes in this version

+ func IsContainsV3(list []string, element string) (exist bool)

type ConsulRegisterPlugin

+ UpdateInterval time.Duration

+ type EtcdV3RegisterPlugin struct

+ BasePath string

+ DialTimeout time.Duration

+ EtcdServers []string

+ KeysAPI *clientv3.Client

+ Metrics metrics.Registry

+ Password string

+ ServiceAddress string

+ Services []string

+ UpdateIntervalInSec int64

+ Username string

+ func (p *EtcdV3RegisterPlugin) Close()

+ func (p *EtcdV3RegisterPlugin) HandleConnAccept(conn net.Conn) (net.Conn, bool)

+ func (p *EtcdV3RegisterPlugin) Name() string

+ func (p *EtcdV3RegisterPlugin) Put(key, value string, opts ...clientv3.OpOption) error

+ func (p *EtcdV3RegisterPlugin) Register(name string, rcvr interface{}, metadata ...string) (err error)

+ func (p *EtcdV3RegisterPlugin) Start() (err error)

+ func (p *EtcdV3RegisterPlugin) Unregister(name string) (err error)

v1.1.2

Dec 21, 2016

Changes in this version

+ func IsContains(list []string, element string) (exist bool)

+ type AliasPlugin struct

+ Aliases map[string]string

+ func NewAliasPlugin() *AliasPlugin

+ func (p *AliasPlugin) Alias(alias string, serviceMethod string)

+ func (p *AliasPlugin) Name() string

+ func (p *AliasPlugin) PostReadRequestHeader(r *rpc.Request) error

+ type CompressionPlugin struct

+ CompressType rpcx.CompressType

+ func NewCompressionPlugin(compressType rpcx.CompressType) *CompressionPlugin

+ func (p *CompressionPlugin) HandleConnAccept(conn net.Conn) (net.Conn, bool)

+ func (p *CompressionPlugin) HandleConnected(conn net.Conn) (net.Conn, bool)

+ func (p *CompressionPlugin) Name() string

type MetricsPlugin

+ func (p *MetricsPlugin) Exp()

+ func (p *MetricsPlugin) Graphite(freq time.Duration, prefix string, addr *net.TCPAddr)

+ func (p *MetricsPlugin) InfluxDB(freq time.Duration, url, database, username, password string)

+ func (p *MetricsPlugin) Log(freq time.Duration, l metrics.Logger)

+ func (p *MetricsPlugin) Syslog(freq time.Duration, w *syslog.Writer)

v1.1.1

Oct 10, 2016

Changes in this version

type RateLimitingPlugin

+ func (plugin *RateLimitingPlugin) Description() string

+ func (plugin *RateLimitingPlugin) Name() string

v1.1.0

Sep 18, 2016

Changes in this version

+ type ConsulRegisterPlugin struct

+ ConsulAddress string

+ ServiceAddress string

+ Services []string

+ func (plugin *ConsulRegisterPlugin) CheckFail(name string)

+ func (plugin *ConsulRegisterPlugin) CheckPass(name string)

+ func (plugin *ConsulRegisterPlugin) Close()

+ func (plugin *ConsulRegisterPlugin) Description() string

+ func (plugin *ConsulRegisterPlugin) FindServices(name string) []*api.AgentService

+ func (plugin *ConsulRegisterPlugin) Name() string

+ func (plugin *ConsulRegisterPlugin) Register(name string, rcvr interface{}, metadata ...string) (err error)

+ func (plugin *ConsulRegisterPlugin) Start() (err error)

+ func (plugin *ConsulRegisterPlugin) Unregister(name string)

+ type EtcdRegisterPlugin struct

+ BasePath string

+ EtcdServers []string

+ KeysAPI client.KeysAPI

+ Metrics metrics.Registry

+ ServiceAddress string

+ Services []string

+ UpdateInterval time.Duration

+ func (plugin *EtcdRegisterPlugin) Close()

+ func (plugin *EtcdRegisterPlugin) Description() string

+ func (plugin *EtcdRegisterPlugin) HandleConnAccept(net.Conn) bool

+ func (plugin *EtcdRegisterPlugin) Name() string

+ func (plugin *EtcdRegisterPlugin) Register(name string, rcvr interface{}, metadata ...string) (err error)

+ func (plugin *EtcdRegisterPlugin) Start() (err error)

+ func (plugin *EtcdRegisterPlugin) Unregister(name string)

+ type LogRegisterPlugin struct

+ Log func(log string)

+ func (plugin *LogRegisterPlugin) Description() string

+ func (plugin *LogRegisterPlugin) Name() string

+ func (plugin *LogRegisterPlugin) Register(name string, rcvr interface{}, metadata ...string) error

+ type MetricsPlugin struct

+ Registry metrics.Registry

+ func NewMetricsPlugin() *MetricsPlugin

+ func (plugin *MetricsPlugin) Description() string

+ func (plugin *MetricsPlugin) HandleConnAccept(net.Conn) bool

+ func (plugin *MetricsPlugin) Name() string

+ func (plugin *MetricsPlugin) PostReadRequestHeader(r *rpc.Request) error

+ func (plugin *MetricsPlugin) PostWriteResponse(r *rpc.Response, body interface{}) error

+ func (plugin *MetricsPlugin) PreReadRequestHeader(r *rpc.Request) error

+ func (plugin *MetricsPlugin) Register(name string, rcvr interface{}, metadata ...string) error

+ type RateLimitingPlugin struct

+ Capacity int64

+ FillInterval time.Duration

+ func NewRateLimitingPlugin(fillInterval time.Duration, capacity int64) *RateLimitingPlugin

+ func (plugin *RateLimitingPlugin) HandleConnAccept(conn net.Conn) bool

+ type ZooKeeperRegisterPlugin struct

+ BasePath string

+ Conn *zk.Conn

+ Metrics metrics.Registry

+ ServiceAddress string

+ Services []string

+ UpdateInterval time.Duration

+ ZooKeeperServers []string

+ func (plugin *ZooKeeperRegisterPlugin) Close()

+ func (plugin *ZooKeeperRegisterPlugin) Description() string

+ func (plugin *ZooKeeperRegisterPlugin) HandleConnAccept(net.Conn) bool

+ func (plugin *ZooKeeperRegisterPlugin) Name() string

+ func (plugin *ZooKeeperRegisterPlugin) Register(name string, rcvr interface{}, metadata ...string) (err error)

+ func (plugin *ZooKeeperRegisterPlugin) Start() (err error)

+ func (plugin *ZooKeeperRegisterPlugin) Unregister(name string)

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL