plugin

package

Go to main page

Versions in this module

v1

v1.6.8

Sep 19, 2022

v1.6.7

Sep 19, 2022

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