Versions in this module Expand all Collapse all v0 v0.3.1 Sep 24, 2018 v0.3.0 Sep 19, 2018 Changes in this version + const ErrBindAddressChanged + const ErrClosed + const ErrDispatcherDead + const ErrLocalAddressChanged + const ErrReconnecterStopped + const ErrReconnecterTimeoutExpired + var DefaultTickerInterval = time.Second + type AtomicBool struct + func (f *AtomicBool) IsFalse() bool + func (f *AtomicBool) IsTrue() bool + func (f *AtomicBool) Set(v bool) + type BaseOperation struct + type IOOperation interface + Do func(conn snet.Conn) error + IsWrite func() bool + type ProxyConn struct + func NewProxyConn(conn snet.Conn, reconnecter Reconnecter) *ProxyConn + func (conn *ProxyConn) BindAddr() net.Addr + func (conn *ProxyConn) Close() error + func (conn *ProxyConn) DoIO(op IOOperation) error + func (conn *ProxyConn) LocalAddr() net.Addr + func (conn *ProxyConn) Read(b []byte) (int, error) + func (conn *ProxyConn) ReadFrom(b []byte) (int, net.Addr, error) + func (conn *ProxyConn) ReadFromSCION(b []byte) (int, *snet.Addr, error) + func (conn *ProxyConn) Reconnect() (snet.Conn, error) + func (conn *ProxyConn) RemoteAddr() net.Addr + func (conn *ProxyConn) SVC() addr.HostSVC + func (conn *ProxyConn) SetDeadline(deadline time.Time) error + func (conn *ProxyConn) SetReadDeadline(deadline time.Time) error + func (conn *ProxyConn) SetWriteDeadline(deadline time.Time) error + func (conn *ProxyConn) Write(b []byte) (int, error) + func (conn *ProxyConn) WriteTo(b []byte, address net.Addr) (int, error) + func (conn *ProxyConn) WriteToSCION(b []byte, address *snet.Addr) (int, error) + type ProxyNetwork struct + func NewProxyNetwork(network snet.Network) *ProxyNetwork + func (pn *ProxyNetwork) DialSCIONWithBindSVC(network string, laddr, raddr, baddr *snet.Addr, svc addr.HostSVC, ...) (snet.Conn, error) + func (pn *ProxyNetwork) ListenSCIONWithBindSVC(network string, laddr, baddr *snet.Addr, svc addr.HostSVC, ...) (snet.Conn, error) + type ReadFromOperation struct + func (op *ReadFromOperation) Do(conn snet.Conn) error + type ReadFromSCIONOperation struct + func (op *ReadFromSCIONOperation) Do(conn snet.Conn) error + type ReadOperation struct + func (_ *ReadOperation) IsWrite() bool + func (op *ReadOperation) Do(conn snet.Conn) error + type Reconnecter interface + Reconnect func(timeout time.Duration) (snet.Conn, error) + Stop func() + type State struct + func NewState() *State + func (s *State) SetDown() + func (s *State) SetUp() + func (s *State) Up() <-chan struct{} + type TickingReconnecter struct + func NewTickingReconnecter(f func(timeout time.Duration) (snet.Conn, error)) *TickingReconnecter + func (r *TickingReconnecter) Reconnect(timeout time.Duration) (snet.Conn, error) + func (r *TickingReconnecter) Stop() + type WriteOperation struct + func (_ *WriteOperation) IsWrite() bool + func (op *WriteOperation) Do(conn snet.Conn) error + type WriteToOperation struct + func (op *WriteToOperation) Do(conn snet.Conn) error + type WriteToSCIONOperation struct + func (op *WriteToSCIONOperation) Do(conn snet.Conn) error
Go to main page