Documentation
¶
Overview ¶
Package router provides request routing logic for JSON RPC server pkg/github.com/LiskHQ/lisk-engine/pkg/rpc.
Index ¶
- type Endpoint
- type EndpointHandler
- type EndpointHandlers
- type EndpointRequest
- type EndpointResponseWriter
- type NotFoundHandler
- type Router
- func (b *Router) Close()
- func (b *Router) Init(stateDB *db.DB, logger log.Logger, chain *blockchain.Chain) error
- func (b *Router) Invoke(ctx context.Context, endpoint string, data []byte) rpc.EndpointResponse
- func (b *Router) Publish(event string, data codec.EncodeDecodable) error
- func (b *Router) RegisterEndpoint(namespace, method string, handler EndpointHandler) error
- func (b *Router) RegisterEvents(namespace, event string) error
- func (b *Router) RegisterNotFoundHandler(handler NotFoundHandler)
- func (b *Router) Subscribe(event string) chan rpc.EventContent
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Endpoint ¶
type Endpoint interface {
Get() EndpointHandlers
}
type EndpointHandler ¶
type EndpointHandler func(w EndpointResponseWriter, r *EndpointRequest)
type EndpointHandlers ¶
type EndpointHandlers map[string]EndpointHandler
type EndpointRequest ¶
type EndpointRequest struct {
// contains filtered or unexported fields
}
func NewEndpointRequest ¶
func (*EndpointRequest) Context ¶
func (a *EndpointRequest) Context() context.Context
func (*EndpointRequest) Logger ¶
func (a *EndpointRequest) Logger() log.Logger
func (*EndpointRequest) Params ¶
func (a *EndpointRequest) Params() []byte
type EndpointResponseWriter ¶
type EndpointResponseWriter = rpc.EndpointResponseWriter
type NotFoundHandler ¶
type NotFoundHandler func(namespace, method string, w EndpointResponseWriter, r *EndpointRequest)
type Router ¶
type Router struct {
// contains filtered or unexported fields
}
func (*Router) RegisterEndpoint ¶
func (b *Router) RegisterEndpoint(namespace, method string, handler EndpointHandler) error
func (*Router) RegisterEvents ¶
func (*Router) RegisterNotFoundHandler ¶
func (b *Router) RegisterNotFoundHandler(handler NotFoundHandler)
Source Files
Click to show internal directories.
Click to hide internal directories.