serverplugin

Apr 29, 2021

Changes in this version

type ZmqRegisterPlugin

+ ZmqServers []string

Apr 29, 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 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, res *protocol.Message) error

+ 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 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) PreCall(_ context.Context, _, _ string, args interface{}) (interface{}, error)

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

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

+ func (p *MDNSRegisterPlugin) Start() error

+ func (p *MDNSRegisterPlugin) Stop() error

+ func (p *MDNSRegisterPlugin) Unregister(name string) (err 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) InfluxDBWithTags(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 NacosRegisterPlugin struct

+ ClientConfig constant.ClientConfig

+ Cluster string

+ ServerConfig []constant.ServerConfig

+ ServiceAddress string

+ Services []string

+ Weight float64

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

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

+ func (p *NacosRegisterPlugin) Start() error

+ func (p *NacosRegisterPlugin) Stop() error

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

+ 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 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 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 ZmqRegisterPlugin struct

+ BasePath string

+ Metrics metrics.Registry

+ Options *store.Config

+ ServiceAddress string

+ Services []string

+ UpdateInterval time.Duration

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

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

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

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

+ func (p *ZmqRegisterPlugin) Start() error

+ func (p *ZmqRegisterPlugin) Stop() error

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

+ 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)