serverplugin

package

Go to main page

Versions in this module

v5

v5.7.9

Nov 19, 2020

Changes in this version

type ConsulRegisterPlugin

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

type EtcdRegisterPlugin

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

type EtcdV3RegisterPlugin

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

type MDNSRegisterPlugin

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

type NacosRegisterPlugin

+ Weight float64

type RedisRegisterPlugin

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

type ZooKeeperRegisterPlugin

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

v5.7.8

Aug 19, 2020

v5.7.7

Aug 17, 2020

v5.7.6

Aug 14, 2020

v5.7.4

Aug 11, 2020

v5.7.3

Aug 11, 2020

v5.7.2

Aug 6, 2020

Changes in this version

type TeeConnPlugin

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

v5.7.1

Jun 10, 2020

Changes in this version

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

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

v5.6.0

Apr 28, 2020

v5.3.0

Apr 9, 2020

Changes in this version

+ var SendFileServiceName = "_filetransfer"

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

+ func RegisterFileTransfer(s *server.Server, fileTransfer *FileTransfer)

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

+ FileName string

+ type DownloadFileHandler func(conn net.Conn, args *DownloadFileArgs)

+ type EtcdRegisterPlugin struct

+ BasePath string

+ EtcdServers []string

+ Metrics metrics.Registry

+ Options *store.Config

+ ServiceAddress string

+ Services []string

+ UpdateInterval time.Duration

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

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

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

+ func (p *EtcdRegisterPlugin) Start() error

+ func (p *EtcdRegisterPlugin) Stop() error

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

+ type EtcdV3RegisterPlugin struct

+ BasePath string

+ EtcdServers []string

+ Metrics metrics.Registry

+ Options *store.Config

+ ServiceAddress string

+ Services []string

+ UpdateInterval time.Duration

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

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

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

+ func (p *EtcdV3RegisterPlugin) Start() error

+ func (p *EtcdV3RegisterPlugin) Stop() error

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

+ type FileTransfer struct

+ Addr string

+ func NewFileTransfer(addr string, handler FileTransferHandler, ...) *FileTransfer

+ func (s *FileTransfer) Start() error

+ func (s *FileTransfer) Stop() error

+ type FileTransferArgs struct

+ FileName string

+ FileSize int64

+ Meta map[string]string

+ type FileTransferHandler func(conn net.Conn, args *FileTransferArgs)

+ type FileTransferReply struct

+ Addr string

+ Token []byte

+ type FileTransferService struct

+ FileTransfer *FileTransfer

+ func (s *FileTransferService) DownloadFile(ctx context.Context, args *DownloadFileArgs, reply *FileTransferReply) error

+ func (s *FileTransferService) TransferFile(ctx context.Context, args *FileTransferArgs, reply *FileTransferReply) 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) 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

+ Tenant string

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

Other modules containing this package

github.com/smallnest/rpcx

github.com/smallnest/rpcx/v6

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