Versions in this module Expand all Collapse all v1 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