server

Documentation

Overview

Package server implements server.

Index

• Constants
• Variables
• func IsServerError(err error, serverError error) bool
• type Config
• type Server
  • func New(cfg Config, log logging.Logger) (Server, error)

Constants

const (
	MinNodes     uint32 = 1
	DefaultNodes uint32 = 5
)

Variables

var (
	ErrInvalidVMName          = errors.New("invalid VM name")
	ErrInvalidPort            = errors.New("invalid port")
	ErrClosed                 = errors.New("server closed")
	ErrNotEnoughNodesForStart = errors.New("not enough nodes specified for start")
	ErrAlreadyBootstrapped    = errors.New("already bootstrapped")
	ErrNotBootstrapped        = errors.New("not bootstrapped")
	ErrNodeNotFound           = errors.New("node not found")
	ErrPeerNotFound           = errors.New("peer not found")
	ErrStatusCanceled         = errors.New("gRPC stream status canceled")
	ErrNoBlockchainSpec       = errors.New("no blockchain spec was provided")
)

Functions

func IsServerError

func IsServerError(err error, serverError error) bool

grpc encapsulates the non protocol-related, ANR server domain errors, inside grpc.status.Status structs, with status.Code() code.Unknown, and original error msg inside status.Message() string this aux function is to be used by clients, to check for the appropiate ANR domain error kind

Types

type Config

type Config struct {
	Port   string
	GwPort string
	// true to disable grpc-gateway server
	GwDisabled          bool
	DialTimeout         time.Duration
	RedirectNodesOutput bool
	SnapshotsDir        string
	LogLevel            logging.Level
}

type Server

type Server interface {
	Run(rootCtx context.Context) error
}

func New

func New(cfg Config, log logging.Logger) (Server, error)