rpc

Documentation

Index

• func SMDBoxHandler(opts options.Rpc) func(w http.ResponseWriter, r *http.Request)
• func SchemaHandler(rpcsrv *Server) func(w http.ResponseWriter, r *http.Request)
• type Server
  • func NewServer(ctx context.Context, dbAdapter db.Adapter, redis *cache.Redis, ...) (*Server, error)
  • func (s *Server) Register(namespace string, service zenrpc.Invoker)
  • func (s *Server) Start() error
  • func (s *Server) Stop() error
  • func (s *Server) Use(m ...zenrpc.MiddlewareFunc)

Functions

func SMDBoxHandler

func SMDBoxHandler(opts options.Rpc) func(w http.ResponseWriter, r *http.Request)

SMDBoxHandler is a handler for SMDBox web app.

func SchemaHandler

func SchemaHandler(rpcsrv *Server) func(w http.ResponseWriter, r *http.Request)

Types

type Server

type Server struct {
	zenrpc.Server
	// contains filtered or unexported fields
}

Server represents a JSON-RPC server

func NewServer

func NewServer(ctx context.Context, dbAdapter db.Adapter, redis *cache.Redis, opts options.Rpc) (*Server, error)

NewServer creates a new JSON+RPC Server instance

func (*Server) Register

func (s *Server) Register(namespace string, service zenrpc.Invoker)

Register appends new JSON+RPC service under specified namespace

func (*Server) Start

func (s *Server) Start() error

Start starts the JSON+RPC server on the specified network address

func (*Server) Stop

func (s *Server) Stop() error

func (*Server) Use

func (s *Server) Use(m ...zenrpc.MiddlewareFunc)