drpcserver

package
v0.0.30 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 17, 2022 License: MIT Imports: 10 Imported by: 34

README

package drpcserver

import "storj.io/drpc/drpcserver"

Package drpcserver allows one to execute registered rpcs.

Usage

type Options
type Options struct {
	// Manager controls the options we pass to the managers this server creates.
	Manager drpcmanager.Options

	// Log is called when errors happen that can not be returned up, like
	// temporary network errors when accepting connections, or errors
	// handling individual clients. It is not called if nil.
	Log func(error)
}

Options controls configuration settings for a server.

type Server
type Server struct {
}

Server is an implementation of drpc.Server to serve drpc connections.

func New
func New(handler drpc.Handler) *Server

New constructs a new Server.

func NewWithOptions
func NewWithOptions(handler drpc.Handler, opts Options) *Server

NewWithOptions constructs a new Server using the provided options to tune how the drpc connections are handled.

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

Serve listens for connections on the listener and serves the drpc request on new connections.

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

ServeOne serves a single set of rpcs on the provided transport.

Documentation

Overview

Package drpcserver allows one to execute registered rpcs.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Options added in v0.0.7

type Options struct {
	// Manager controls the options we pass to the managers this server creates.
	Manager drpcmanager.Options

	// Log is called when errors happen that can not be returned up, like
	// temporary network errors when accepting connections, or errors
	// handling individual clients. It is not called if nil.
	Log func(error)
}

Options controls configuration settings for a server.

type Server

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

Server is an implementation of drpc.Server to serve drpc connections.

func New

func New(handler drpc.Handler) *Server

New constructs a new Server.

func NewWithOptions added in v0.0.7

func NewWithOptions(handler drpc.Handler, opts Options) *Server

NewWithOptions constructs a new Server using the provided options to tune how the drpc connections are handled.

func (*Server) Serve

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

Serve listens for connections on the listener and serves the drpc request on new connections.

func (*Server) ServeOne

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

ServeOne serves a single set of rpcs on the provided transport.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL