Documentation ¶
Index ¶
- type BasePlugin
- func (p *BasePlugin) HandleConnAccept(conn net.Conn) (net.Conn, bool)
- func (p *BasePlugin) HandleConnClose(conn net.Conn) bool
- func (p *BasePlugin) HeartbeatRequest(ctx context.Context, req *protocol.Message) error
- func (p *BasePlugin) PostCall(ctx context.Context, serviceName, methodName string, args, reply interface{}) (interface{}, error)
- func (p *BasePlugin) PostReadRequest(ctx context.Context, r *protocol.Message, e error) error
- func (p *BasePlugin) PostWriteRequest(ctx context.Context, r *protocol.Message, e error) error
- func (p *BasePlugin) PostWriteResponse(ctx context.Context, req *protocol.Message, resp *protocol.Message, err error) error
- func (p *BasePlugin) PreCall(ctx context.Context, serviceName, methodName string, args interface{}) (interface{}, error)
- func (p *BasePlugin) PreHandleRequest(ctx context.Context, r *protocol.Message) error
- func (p *BasePlugin) PreReadRequest(ctx context.Context) error
- func (p *BasePlugin) PreWriteRequest(ctx context.Context) error
- func (p *BasePlugin) PreWriteResponse(ctx context.Context, req *protocol.Message, resp *protocol.Message, err error) error
- func (p *BasePlugin) Register(name string, rcvr interface{}, metadata string) error
- func (p *BasePlugin) RegisterFunction(serviceName, fname string, fn interface{}, metadata string) error
- func (p *BasePlugin) Unregister(name string) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type BasePlugin ¶
type BasePlugin struct{}
func (*BasePlugin) HandleConnAccept ¶
func (*BasePlugin) HandleConnClose ¶
func (p *BasePlugin) HandleConnClose(conn net.Conn) bool
func (*BasePlugin) HeartbeatRequest ¶
func (*BasePlugin) PostCall ¶
func (p *BasePlugin) PostCall(ctx context.Context, serviceName, methodName string, args, reply interface{}) (interface{}, error)
func (*BasePlugin) PostReadRequest ¶
func (*BasePlugin) PostWriteRequest ¶
func (*BasePlugin) PostWriteResponse ¶
func (*BasePlugin) PreCall ¶
func (p *BasePlugin) PreCall(ctx context.Context, serviceName, methodName string, args interface{}) (interface{}, error)
func (*BasePlugin) PreHandleRequest ¶
func (*BasePlugin) PreReadRequest ¶
func (p *BasePlugin) PreReadRequest(ctx context.Context) error
func (*BasePlugin) PreWriteRequest ¶
func (p *BasePlugin) PreWriteRequest(ctx context.Context) error
func (*BasePlugin) PreWriteResponse ¶
func (*BasePlugin) Register ¶
func (p *BasePlugin) Register(name string, rcvr interface{}, metadata string) error
func (*BasePlugin) RegisterFunction ¶
func (p *BasePlugin) RegisterFunction(serviceName, fname string, fn interface{}, metadata string) error
func (*BasePlugin) Unregister ¶
func (p *BasePlugin) Unregister(name string) error
Click to show internal directories.
Click to hide internal directories.