rpcserver

Documentation

Index

• Constants
• type Config
  • func DefaultConfig() Config
  • func (c Config) Validate() []error
• type Server
  • func New(config Config, cdnService supervisor.CDNService, opts ...grpc.ServerOption) (*Server, error)
  • func (css *Server) GetConfig() Config
  • func (css *Server) GetPieceTasks(ctx context.Context, req *base.PieceTaskRequest) (piecePacket *base.PiecePacket, err error)
  • func (css *Server) ListenAndServe() error
  • func (css *Server) ObtainSeeds(ctx context.Context, req *cdnsystem.SeedRequest, ...) (err error)
  • func (css *Server) Shutdown() error

Constants

const (
	// DefaultListenPort is the default port cdn server listens on.
	DefaultListenPort = 8003
	// DefaultDownloadPort is the default port for download files from cdn.
	DefaultDownloadPort = 8001
)

Types

type Config

type Config struct {

	// AdvertiseIP is used to set the ip that we advertise to other peer in the p2p-network.
	// By default, the first non-loop address is advertised.
	AdvertiseIP string `yaml:"advertiseIP" mapstructure:"advertiseIP"`

	// ListenPort is the port cdn server listens on.
	// default: 8002
	ListenPort int `yaml:"listenPort" mapstructure:"listenPort"`

	// DownloadPort is the port for download files from cdn.
	// default: 8001
	DownloadPort int `yaml:"downloadPort" mapstructure:"downloadPort"`
}

func DefaultConfig

func DefaultConfig() Config

func (Config) Validate

func (c Config) Validate() []error

type Server

type Server struct {
	*grpc.Server
	// contains filtered or unexported fields
}

func New

func New(config Config, cdnService supervisor.CDNService, opts ...grpc.ServerOption) (*Server, error)

New returns a new Manager Object.

func (*Server) GetConfig

func (css *Server) GetConfig() Config

func (*Server) GetPieceTasks

func (css *Server) GetPieceTasks(ctx context.Context, req *base.PieceTaskRequest) (piecePacket *base.PiecePacket, err error)

func (*Server) ListenAndServe

func (css *Server) ListenAndServe() error

func (*Server) ObtainSeeds

func (css *Server) ObtainSeeds(ctx context.Context, req *cdnsystem.SeedRequest, psc chan<- *cdnsystem.PieceSeed) (err error)

func (*Server) Shutdown

func (css *Server) Shutdown() error