tele

type Addr ¶

type Addr struct {
	ID  n.WorkerID
	PID int
	TCP *net.TCPAddr
}

Addr maintains a single unique instance for each addr. Addr object uniqueness is required by the n.Addr interface.

func NewNetAddr(id n.WorkerID, pid int, addr net.Addr) *Addr

func ParseAddr(s string) (*Addr, error)

func (a *Addr) FileName() string

func (a *Addr) NetAddr() net.Addr

func (a *Addr) String() string

func (a *Addr) WorkerID() n.WorkerID

type Conn ¶

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

func NewConn(sub *blend.Conn, addr *Addr) *Conn

func (c *Conn) Abort(reason error)

func (c *Conn) Addr() n.Addr

func (c *Conn) Close() error

func (c *Conn) Read() (v interface{}, err error)

func (c *Conn) Write(v interface{}) (err error)

type Dialer ¶

type Dialer struct {
	sync.Mutex
	// contains filtered or unexported fields
}

Dialer

func (d *Dialer) Dial(addr n.Addr) (conn n.Conn, err error)

type HelloMsg ¶

type HelloMsg struct {
	SourceAddr n.Addr
	TargetAddr n.Addr
}

Dialer sends HelloMsg to accepter when opening a session to advertise its workerID and local process ID

type Listener ¶

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

Listener

func (l *Listener) Accept() n.Conn

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

func (l *Listener) Close()

type RejectMsg ¶

type RejectMsg struct {
	Err error
}

type System ¶

type System struct{}

System is the high-level type that encloses a monolithic networking functionality

func (s *System) NewTransport(workerID n.WorkerID, addr net.Addr, key []byte) n.Transport

func (s *System) ParseAddr(a string) (n.Addr, error)

func (s *System) ParseNetAddr(a string) (net.Addr, error)

type Transport ¶

type Transport struct {
	n.WorkerID
	*Dialer
	*Listener
}

Transport cumulatively represents the ability to listen for connections and dial into remote endpoints.

type WelcomeMsg ¶

type WelcomeMsg struct{}