drpcserver

README

package drpcserver

import "storj.io/drpc/drpcserver"

package drpcserver allows one to execute registered rpcs.

Usage

type Server

type Server struct {
}

func New

func New() *Server

func (*Server) HandleRPC

func (s *Server) HandleRPC(stream *drpcstream.Stream, rpc string) error

func (*Server) Register

func (s *Server) Register(srv interface{}, desc drpc.Description)

func (*Server) Serve

func (s *Server) Serve(ctx context.Context, lis net.Listener) error

func (*Server) ServeOne

func (s *Server) ServeOne(ctx context.Context, tr drpc.Transport) (err error)

Documentation

Overview

package drpcserver allows one to execute registered rpcs.

Index

• type Server
  • func New() *Server
  • func (s *Server) HandleRPC(stream *drpcstream.Stream, rpc string) error
  • func (s *Server) Register(srv interface{}, desc drpc.Description)
  • func (s *Server) Serve(ctx context.Context, lis net.Listener) error
  • func (s *Server) ServeOne(ctx context.Context, tr drpc.Transport) (err error)

Types

type Server

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

func New

func New() *Server

func (*Server) HandleRPC

func (s *Server) HandleRPC(stream *drpcstream.Stream, rpc string) error

func (*Server) Register

func (s *Server) Register(srv interface{}, desc drpc.Description)

func (*Server) Serve

func (s *Server) Serve(ctx context.Context, lis net.Listener) error

func (*Server) ServeOne

func (s *Server) ServeOne(ctx context.Context, tr drpc.Transport) (err error)