connection

Documentation

Index

• Constants
• func Address(host string, port uint16) string
• func AppendDelimeter(raw []byte) []byte
• func GetIdFromAddr(addr *net.Addr) int
• func GetIdFromConn(conn *net.Conn) int
• func GetTcpAddress(host string, port uint16) (addr *net.TCPAddr, err error)
• func GetUdpAddress(host string, port uint16) (addr *net.UDPAddr, err error)
• func GetUnixAddress(host string, port uint16) (addr *net.UnixAddr, err error)
• func TruncateDelimeter(raw []byte) []byte
• type Event
• type EventType
• type EventsToChannel
  • func NewEventsToChannel(messageChannel chan<- Message, eventChannel chan<- Event) *EventsToChannel
  • func (e2c *EventsToChannel) Connected(id int)
  • func (e2c *EventsToChannel) Disconnected(id int)
  • func (e2c *EventsToChannel) Received(id int, message []byte)
• type Handler
• type Message
• type Protocol

Constants

const DefaultDelimiter = 0x00

Functions

func Address

func Address(host string, port uint16) string

func AppendDelimeter

func AppendDelimeter(raw []byte) []byte

func GetIdFromAddr

func GetIdFromAddr(addr *net.Addr) int

func GetIdFromConn

func GetIdFromConn(conn *net.Conn) int

func GetTcpAddress

func GetTcpAddress(host string,
	port uint16) (addr *net.TCPAddr, err error)

func GetUdpAddress

func GetUdpAddress(host string,
	port uint16) (addr *net.UDPAddr, err error)

func GetUnixAddress

func GetUnixAddress(host string,
	port uint16) (addr *net.UnixAddr, err error)

func TruncateDelimeter

func TruncateDelimeter(raw []byte) []byte

Types

type Event

type Event struct {
	Id int
	EventType
}

type EventType

type EventType int

const (
	DISCONNECTED EventType = 0
	CONNECTED    EventType = 1
	ERROR        EventType = -1
)

type EventsToChannel

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

func NewEventsToChannel

func NewEventsToChannel(messageChannel chan<- Message,
	eventChannel chan<- Event) *EventsToChannel

func (*EventsToChannel) Connected

func (e2c *EventsToChannel) Connected(id int)

func (*EventsToChannel) Disconnected

func (e2c *EventsToChannel) Disconnected(id int)

func (*EventsToChannel) Received

func (e2c *EventsToChannel) Received(id int, message []byte)

type Handler

type Handler interface {
	Connected(id int)
	Received(id int, message []byte)
	Disconnected(id int)
}

type Message

type Message struct {
	Id      int
	Content []byte
}

type Protocol

type Protocol string

const (
	Tcp  Protocol = "tcp"
	Udp  Protocol = "udp"
	Tls  Protocol = "tls"
	Unix Protocol = "unix"
)