Versions in this module Expand all Collapse all v1 v1.8.8 May 11, 2023 Changes in this version + 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 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) 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 RedisRateLimitingPlugin struct + func NewRedisRateLimitingPlugin(addrs []string, rate int, burst int, period time.Duration) *RedisRateLimitingPlugin + func (plugin *RedisRateLimitingPlugin) PostReadRequest(ctx context.Context, r *protocol.Message, e error) 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) PostReadRequest(ctx context.Context, r *protocol.Message, e error) 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)