communication

package

v0.0.1 Latest Latest Go to latest Published: Oct 15, 2017 License: MIT Imports: 3 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Package communication is responsible for all data exchange handling.

This section is empty.

This section is empty.

This section is empty.

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

BridgeConnection is used to wrap underlying connections with server and client.

func NewBridgeConnection(
	srcConn,
	dstConn net.Conn,
	analysisChan analysis.Aggregation,
	errChan chan error,
) *BridgeConnection

NewBridgeConnection returns a new BridgeConnection that forwards connections from source to destination and vice versa.

func (b *BridgeConnection) Bind()

Bind starts the binding between the server and client connections.

type Listener struct {
	Listener net.Listener
	// contains filtered or unexported fields
}

Listener is used to wrap an underlying listener.

func NewListener(listener net.Listener, errorChan chan error) *Listener

NewListener allocates and returns and Listener.

func (l *Listener) Accept() (net.Conn, error)

Accept waits for and returns the next connection to the listener.

func (l *Listener) Addr() net.Addr

Addr returns the underlying listener's network address.

func (l *Listener) AwaitForConnections(clientConnChan chan<- net.Conn)

AwaitForConnections blocks on new connections, and when getting one it passes it to the provided channel.

func (l *Listener) Close() error

Close closes the underlying listener.