rpc

Documentation

Index

• Variables
• type Config
  • func (c *Config) Validate() error
• type Server
  • func NewServer(conf *Config, be *backend.Backend) (*Server, error)
  • func (s *Server) GRPCServer() *grpc.Server
  • func (s *Server) Shutdown(graceful bool)
  • func (s *Server) Start() error

Variables

var (
	// ErrInvalidRPCPort occurs when the port in the config is invalid.
	ErrInvalidRPCPort = errors.New("invalid port number for RPC server")
	// ErrInvalidCertFile occurs when the certificate file is invalid.
	ErrInvalidCertFile = errors.New("invalid cert file for RPC server")
	// ErrInvalidKeyFile occurs when the key file is invalid.
	ErrInvalidKeyFile = errors.New("invalid key file for RPC server")
)

Types

type Config

type Config struct {
	// Port is the port number for the RPC server.
	Port int

	// CertFile is the path to the certificate file.
	CertFile string

	// KeyFile is the path to the key file.
	KeyFile string

	// MaxRequestBytes is the maximum client request size in bytes the server will accept.
	MaxRequestBytes uint64
}

Config is the configuration for creating a Server instance.

func (*Config) Validate

func (c *Config) Validate() error

Validate validates the port number and the files for certification.

type Server

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

Server is a normal server that processes the logic requested by the client.

func NewServer

func NewServer(conf *Config, be *backend.Backend) (*Server, error)

NewServer creates a new instance of Server.

func (*Server) GRPCServer

func (s *Server) GRPCServer() *grpc.Server

GRPCServer returns the gRPC server.

func (*Server) Shutdown

func (s *Server) Shutdown(graceful bool)

Shutdown shuts down this server.

func (*Server) Start

func (s *Server) Start() error

Start starts this server by opening the rpc port.