rpc

Documentation

Index

• Variables
• type Result
• type Server
  • func NewServer(db elldb.DB, addr string, cfg *config.EngineConfig, log logger.Logger) *Server
  • func (s *Server) APIs() jsonrpc.APISet
  • func (s *Server) AddAPI(apis ...jsonrpc.APISet)
  • func (s *Server) GetAddr() string
  • func (s *Server) IsStarted() bool
  • func (s *Server) Serve()
  • func (s *Server) Stop()

Variables

var (
	// ErrMethodArgType creates an error about an invalid type
	// sent as an argument to a RPC method
	ErrMethodArgType = func(expectedType string) error {
		return fmt.Errorf("invalid argument type: expecting " + expectedType)
	}
)

Types

type Result

type Result struct {
	Error   string
	ErrCode int
	Status  int
	Data    map[string]interface{}
}

Result represent a response to a service method call

type Server

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

Server represents a rpc server

func NewServer

func NewServer(db elldb.DB, addr string, cfg *config.EngineConfig, log logger.Logger) *Server

NewServer creates a new RPC server

func (*Server) APIs

func (s *Server) APIs() jsonrpc.APISet

APIs returns all API handlers

func (*Server) AddAPI

func (s *Server) AddAPI(apis ...jsonrpc.APISet)

AddAPI adds one or more API sets

func (*Server) GetAddr

func (s *Server) GetAddr() string

GetAddr gets the address

func (*Server) IsStarted

func (s *Server) IsStarted() bool

IsStarted returns the start state

func (*Server) Serve

func (s *Server) Serve()

Serve starts the server

func (*Server) Stop

func (s *Server) Stop()

Stop stops the server and frees resources