server

Documentation

Index

• Variables
• type Config
• type Server
  • func New(log *zap.Logger, tlsOptions *tlsopts.Options, publicAddr, privateAddr string) (*Server, error)
  • func (p *Server) Addr() net.Addr
  • func (p *Server) Close() error
  • func (p *Server) DRPC() *drpcmux.Mux
  • func (p *Server) Identity() *identity.FullIdentity
  • func (p *Server) PrivateAddr() net.Addr
  • func (p *Server) PrivateDRPC() *drpcmux.Mux
  • func (p *Server) Run(ctx context.Context) (err error)

Variables

var (

	// Error is a pkg/server error.
	Error = errs.Class("server error")
)

Types

type Config

type Config struct {
	tlsopts.Config
	Address        string `user:"true" help:"public address to listen on" default:":7777"`
	PrivateAddress string `user:"true" help:"private address to listen on" default:"127.0.0.1:7778"`

	DebugLogTraffic bool `hidden:"true" default:"false"` // Deprecated
}

Config holds server specific configuration parameters.

type Server

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

Server represents a bundle of services defined by a specific ID. Examples of servers are the satellite, the storagenode, and the uplink.

func New

func New(log *zap.Logger, tlsOptions *tlsopts.Options, publicAddr, privateAddr string) (*Server, error)

New creates a Server out of an Identity, a net.Listener, and interceptors.

func (*Server) Addr

func (p *Server) Addr() net.Addr

Addr returns the server's public listener address.

func (*Server) Close

func (p *Server) Close() error

Close shuts down the server.

func (*Server) DRPC

func (p *Server) DRPC() *drpcmux.Mux

DRPC returns the server's dRPC mux for registration purposes.

func (*Server) Identity

func (p *Server) Identity() *identity.FullIdentity

Identity returns the server's identity.

func (*Server) PrivateAddr

func (p *Server) PrivateAddr() net.Addr

PrivateAddr returns the server's private listener address.

func (*Server) PrivateDRPC

func (p *Server) PrivateDRPC() *drpcmux.Mux

PrivateDRPC returns the server's dRPC mux for registration purposes.

func (*Server) Run

func (p *Server) Run(ctx context.Context) (err error)

Run will run the server and all of its services.