protonmdc

Documentation

Overview

Package protonmdc provides a NMDC connection implementation.

Index

• Variables
• type Conn
  • func NewConn(logLevel log.Level, remoteLabel string, nconn net.Conn, applyReadTimeout bool, ...) *Conn
  • func (p *Conn) Read() (protocommon.MsgDecodable, error)
  • func (p *Conn) Write(msg protocommon.MsgEncodable)
• type NmdcKeepAlive

Variables

var ReNmdcAddress = regexp.MustCompile("^(" + protocommon.ReStrIP + "):(" + protocommon.ReStrPort + ")$")

ReNmdcAddress is the regex to parse a NMDC address.

var ReNmdcCommand = regexp.MustCompile(`(?s)^\$([a-zA-Z0-9:]+)( (.+))?$`)

ReNmdcCommand is the regex to parse a NMDC command

Types

type Conn

type Conn struct {
	*protocommon.BaseConn
}

Conn is a NMDC connection.

func NewConn

func NewConn(logLevel log.Level, remoteLabel string, nconn net.Conn,
	applyReadTimeout bool, applyWriteTimeout bool,
) *Conn

NewConn allocates a Conn.

func (*Conn) Read

func (p *Conn) Read() (protocommon.MsgDecodable, error)

Read reads a message.

func (*Conn) Write

func (p *Conn) Write(msg protocommon.MsgEncodable)

Write writes a message.

type NmdcKeepAlive

type NmdcKeepAlive struct{}

NmdcKeepAlive is a NMDC keepalive.