rpc

Documentation

Index

• func NewGRPCServer(node partitionNode, opts ...Option) (*grpcServer, error)
• func NewRESTServer(addr string, maxBodySize int64, registrars ...Registrar) *http.Server
• type Option
  • func WithMaxGetBlocksBatchSize(maxGetBlocksBatchSize uint64) Option
• type Options
• type Registrar
• type RegistrarFunc
  • func InfoEndpoints(node partitionNode, name string, self *network.Peer) RegistrarFunc
  • func MetricsEndpoints() RegistrarFunc
  • func NodeEndpoints(node partitionNode) RegistrarFunc
  • func (f RegistrarFunc) Register(r *mux.Router)

Functions

func NewGRPCServer

func NewGRPCServer(node partitionNode, opts ...Option) (*grpcServer, error)

func NewRESTServer

func NewRESTServer(addr string, maxBodySize int64, registrars ...Registrar) *http.Server

Types

type Option

type Option func(*Options)

func WithMaxGetBlocksBatchSize

func WithMaxGetBlocksBatchSize(maxGetBlocksBatchSize uint64) Option

type Options

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

type Registrar

type Registrar interface {
	Register(r *mux.Router)
}

Registrar registers new HTTP handlers for given router.

type RegistrarFunc

type RegistrarFunc func(r *mux.Router)

RegistrarFunc type is an adapter to allow the use of ordinary function as Registrar.

func InfoEndpoints

func InfoEndpoints(node partitionNode, name string, self *network.Peer) RegistrarFunc

func MetricsEndpoints

func MetricsEndpoints() RegistrarFunc

func NodeEndpoints

func NodeEndpoints(node partitionNode) RegistrarFunc

func (RegistrarFunc) Register

func (f RegistrarFunc) Register(r *mux.Router)