stream_multiplexer

Documentation

Index

• Constants
• func StartEgressHandler(serverAddress string, maxMessageSize int, upstreamChan chan []byte, ...)
• func StartIngressServer(port int, maxMessageSize int, upstreamChan chan []byte, ...)
• type EgressServer
• type IngressServer
• type MultiplexedConnection

Constants

const MULTIPLEXER_HEADER_SIZE = 8

MULTIPLEXER_HEADER_SIZE is the size of the header for the multiplexed data, currently 4 byte for StreamID and 4 byte for length

Functions

func StartEgressHandler

func StartEgressHandler(serverAddress string, maxMessageSize int, upstreamChan chan []byte, downstreamChan chan []byte, stopChan chan bool, verbose bool)

StartEgressHandler creates (and block) an Egress Server

func StartIngressServer

func StartIngressServer(port int, maxMessageSize int, upstreamChan chan []byte, downstreamChan chan []byte, stopChan chan bool, verbose bool)

StartIngressServer creates (and block) an Ingress Server

Types

type EgressServer

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

EgressServer takes data from a go channel and recreates the multiplexed TCP streams

type IngressServer

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

IngressServer accepts TCPs connections and multiplexes them (read- and write-) over go channels

type MultiplexedConnection

type MultiplexedConnection struct {
	ID       string
	ID_bytes []byte
	// contains filtered or unexported fields
}

MultiplexedConnection represents a TCP connections to which we assigned a stream ID