server

Documentation

Index

• Constants
• Variables
• type Handler
  • func NewHandler(b backend.StorageBackend, serverDomain, uploadPath string) *Handler
  • func (h *Handler) Handle(s *Session, message string, id uint) error
• type NNTPServer
  • func NewNNTPServer(cfg config.Config) (*NNTPServer, error)
  • func (ns *NNTPServer) Start() error
  • func (ns *NNTPServer) Stop()
• type Session
  • func NewSession(ctx context.Context, conn net.Conn, remoteAddr string, ...) (*Session, error)
• type SessionMode

Constants

const (
	SessionModeTransit = iota
	SessionModeReader
)

Variables

var (
	Capabilities = protocol.Capabilities{
		{Type: protocol.VersionCapability, Params: "2"},
		{Type: protocol.ImplementationCapability, Params: fmt.Sprintf("%s %s", common.ServerName, common.ServerVersion)},
		{Type: protocol.OverCapability, Params: "MSGID"},
		{Type: protocol.ModeReaderCapability},
		{Type: protocol.IHaveCapability},
	}
)

Types

type Handler

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

func NewHandler

func NewHandler(b backend.StorageBackend, serverDomain, uploadPath string) *Handler

func (*Handler) Handle

func (h *Handler) Handle(s *Session, message string, id uint) error

type NNTPServer

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

func NewNNTPServer

func NewNNTPServer(cfg config.Config) (*NNTPServer, error)

func (*NNTPServer) Start

func (ns *NNTPServer) Start() error

func (*NNTPServer) Stop

func (ns *NNTPServer) Stop()

type Session

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

func NewSession

func NewSession(
	ctx context.Context,
	conn net.Conn,
	remoteAddr string,
	caps protocol.Capabilities,
	id string,
	closed chan<- bool,
	handler *Handler,
) (*Session, error)

type SessionMode

type SessionMode int