serverplugin

package

Go to main page

Versions in this module

v1

v1.6.17

Nov 2, 2021

v1.6.16

Nov 2, 2021

v1.6.15

Nov 2, 2021

v1.6.14

Nov 2, 2021

v1.6.13

Nov 2, 2021

v1.6.12

Nov 2, 2021

Changes in this version

+ var ErrReqReachLimit = errors.New("request reached rate limit")

+ func InfluxDB(r metrics.Registry, d time.Duration, url, database, username, password string)

+ func InfluxDBWithTags(r metrics.Registry, d time.Duration, url, database, username, password string, ...)

+ type BlacklistPlugin struct

+ Blacklist map[string]bool

+ BlacklistMask []*net.IPNet

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

+ type ConsulRegisterPlugin struct

+ BasePath string

+ ConsulServers []string

+ Metrics metrics.Registry

+ Options *store.Config

+ ServiceAddress string

+ Services []string

+ UpdateInterval time.Duration

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

+ func (p *ConsulRegisterPlugin) PreCall(_ context.Context, _, _ string, args interface{}) (interface{}, error)

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

+ func (p *ConsulRegisterPlugin) RegisterFunction(serviceName, fname string, fn interface{}, metadata string) error

+ func (p *ConsulRegisterPlugin) Start() error

+ func (p *ConsulRegisterPlugin) Stop() error

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

type MDNSRegisterPlugin

+ func (p *MDNSRegisterPlugin) PreCall(_ context.Context, _, _ string, args interface{}) (interface{}, error)

+ func (p *MDNSRegisterPlugin) RegisterFunction(serviceName, fname string, fn interface{}, metadata string) error

+ func (p *MDNSRegisterPlugin) Stop() error

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

type MetricsPlugin

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

+ type OpenCensusPlugin struct

+ func (p OpenCensusPlugin) PostConnAccept(conn net.Conn) (net.Conn, bool)

+ func (p OpenCensusPlugin) PostWriteResponse(ctx context.Context, req *protocol.Message, res *protocol.Message, err error) error

+ func (p OpenCensusPlugin) PreHandleRequest(ctx context.Context, r *protocol.Message) error

+ func (p OpenCensusPlugin) Register(name string, rcvr interface{}, metadata string) error

+ func (p OpenCensusPlugin) RegisterFunction(serviceName, fname string, fn interface{}, metadata string) error

+ type OpenTracingPlugin struct

+ func (p OpenTracingPlugin) PostConnAccept(conn net.Conn) (net.Conn, bool)

+ func (p OpenTracingPlugin) PostWriteResponse(ctx context.Context, req *protocol.Message, res *protocol.Message, err error) error

+ func (p OpenTracingPlugin) PreHandleRequest(ctx context.Context, r *protocol.Message) error

+ func (p OpenTracingPlugin) Register(name string, rcvr interface{}, metadata string) error

+ func (p OpenTracingPlugin) RegisterFunction(serviceName, fname string, fn interface{}, metadata string) error

+ type RedisRegisterPlugin struct

+ BasePath string

+ Metrics metrics.Registry

+ Options *store.Config

+ RedisServers []string

+ ServiceAddress string

+ Services []string

+ UpdateInterval time.Duration

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

+ func (p *RedisRegisterPlugin) PreCall(_ context.Context, _, _ string, args interface{}) (interface{}, error)

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

+ func (p *RedisRegisterPlugin) Start() error

+ func (p *RedisRegisterPlugin) Stop() error

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

+ type ReqRateLimitingPlugin struct

+ Capacity int64

+ FillInterval time.Duration

+ func NewReqRateLimitingPlugin(fillInterval time.Duration, capacity int64, block bool) *ReqRateLimitingPlugin

+ func (plugin *ReqRateLimitingPlugin) PreReadRequest(ctx context.Context) error

+ type TeeConnPlugin struct

+ func NewTeeConnPlugin(w io.Writer) *TeeConnPlugin

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

+ func (plugin *TeeConnPlugin) Update(w io.Writer)

+ type WhitelistPlugin struct

+ Whitelist map[string]bool

+ WhitelistMask []*net.IPNet

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

+ type ZooKeeperRegisterPlugin struct

+ BasePath string

+ Metrics metrics.Registry

+ Options *store.Config

+ ServiceAddress string

+ Services []string

+ UpdateInterval time.Duration

+ ZooKeeperServers []string

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

+ func (p *ZooKeeperRegisterPlugin) PreCall(_ context.Context, _, _ string, args interface{}) (interface{}, error)

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

+ func (p *ZooKeeperRegisterPlugin) RegisterFunction(serviceName, fname string, fn interface{}, metadata string) error

+ func (p *ZooKeeperRegisterPlugin) Start() error

+ func (p *ZooKeeperRegisterPlugin) Stop() error

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

v1.3.1

Feb 22, 2018

Changes in this version

+ func GetFunctionName(i interface{}) string

+ type AliasPlugin struct

+ Aliases map[string]*aliasPair

+ ReseverseAliases map[string]*aliasPair

+ func NewAliasPlugin() *AliasPlugin

+ func (p *AliasPlugin) Alias(aliasServicePath, aliasServiceMethod string, servicePath, serviceMethod string)

+ func (p *AliasPlugin) PostReadRequest(ctx context.Context, r *protocol.Message, e error) error

+ func (p *AliasPlugin) PreWriteResponse(ctx context.Context, r *protocol.Message) error

+ type MDNSRegisterPlugin struct

+ Metrics metrics.Registry

+ ServiceAddress string

+ Services []*serviceMeta

+ UpdateInterval time.Duration

+ func NewMDNSRegisterPlugin(serviceAddress string, port int, m metrics.Registry, ...) *MDNSRegisterPlugin

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

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

+ func (p *MDNSRegisterPlugin) Start() error

+ type MetricsPlugin struct

+ Prefix string

+ Registry metrics.Registry

+ func NewMetricsPlugin(registry metrics.Registry) *MetricsPlugin

+ func (p *MetricsPlugin) Exp()

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

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

+ 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) PostReadRequest(ctx context.Context, r *protocol.Message, e error) error

+ func (p *MetricsPlugin) PostWriteResponse(ctx context.Context, req *protocol.Message, res *protocol.Message, e error) error

+ func (p *MetricsPlugin) PreReadRequest(ctx context.Context) error

+ func (p *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) (net.Conn, bool)

+ type TracePlugin struct

+ func (p *TracePlugin) PostConnAccept(conn net.Conn) (net.Conn, bool)

+ func (p *TracePlugin) PostReadRequest(ctx context.Context, r *protocol.Message, e error) error

+ func (p *TracePlugin) PostWriteResponse(ctx context.Context, req *protocol.Message, res *protocol.Message, err error) error

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

+ func (p *TracePlugin) RegisterFunction(name string, fn interface{}, metadata string) error

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