Versions in this module Expand all Collapse all v1 v1.0.1 Feb 11, 2016 v1.0.0 Sep 27, 2015 Changes in this version + const DefaultMaxMessageSize + const Version + var ErrAlreadyOpened = errors.New("A connection to this ip / port is already open.") + var ErrNotOpened = errors.New("A connection to this ip / port must be opened first.") + func FormatAddress(address string, port string) string + type ListenCallback func([]byte) error + type Manager struct + func NewManager() *Manager + func (bm *Manager) CloseListener(address string) error + func (bm *Manager) CloseWriter(address string) error + func (bm *Manager) Dial(cfg TCPWriterConfig) error + func (bm *Manager) StartListening(cfg TCPListenerConfig) error + func (bm *Manager) Write(address string, data []byte) (int, error) + type TCPListener struct + func ListenTCP(cfg TCPListenerConfig) (*TCPListener, error) + func (btl *TCPListener) Close() + func (btl *TCPListener) StartListening() error + func (btl *TCPListener) StartListeningAsync() error + type TCPListenerConfig struct + Address string + Callback ListenCallback + EnableLogging bool + MaxMessageSize int + type TCPWriter struct + func DialTCP(cfg TCPWriterConfig) (*TCPWriter, error) + func (btw *TCPWriter) Close() error + func (btw *TCPWriter) Reopen() error + func (btw *TCPWriter) Write(data []byte) (int, error) + type TCPWriterConfig struct + Address string + EnableLogging bool + MaxMessageSize int Incompatible versions in this module v2.0.0+incompatible Mar 28, 2016
Go to main page