tcp

Documentation

Index

• func Dial(destination, name string) (transport.Connection, error)
• func Listen(bindAddress, name string, incoming chan transport.Connection) (io.Closer, error)
• type AddressParser
  • func (ap AddressParser) Parse(s string) (transport.Address, error)
• type Connection
  • func (self *Connection) ClearReadTimeout() error
  • func (self *Connection) ClearWriteTimeout() error
  • func (self *Connection) Close() error
  • func (self *Connection) Conn() net.Conn
  • func (self *Connection) Detail() *transport.ConnectionDetail
  • func (self *Connection) PeerCertificates() []*x509.Certificate
  • func (self *Connection) Reader() io.Reader
  • func (self *Connection) SetReadTimeout(t time.Duration) error
  • func (self *Connection) SetWriteTimeout(t time.Duration) error
  • func (self *Connection) Writer() io.Writer

Functions

func Dial

func Dial(destination, name string) (transport.Connection, error)

func Listen

func Listen(bindAddress, name string, incoming chan transport.Connection) (io.Closer, error)

Types

type AddressParser

type AddressParser struct{}

func (AddressParser) Parse

func (ap AddressParser) Parse(s string) (transport.Address, error)

type Connection

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

func (*Connection) ClearReadTimeout

func (self *Connection) ClearReadTimeout() error

ClearReadTimeout clears the read time for all current and future reads

func (*Connection) ClearWriteTimeout

func (self *Connection) ClearWriteTimeout() error

ClearWriteTimeout clears the write timeout for all current and future writes

func (*Connection) Close

func (self *Connection) Close() error

func (*Connection) Conn

func (self *Connection) Conn() net.Conn

func (*Connection) Detail

func (self *Connection) Detail() *transport.ConnectionDetail

func (*Connection) PeerCertificates

func (self *Connection) PeerCertificates() []*x509.Certificate

func (*Connection) Reader

func (self *Connection) Reader() io.Reader

func (*Connection) SetReadTimeout

func (self *Connection) SetReadTimeout(t time.Duration) error

func (*Connection) SetWriteTimeout

func (self *Connection) SetWriteTimeout(t time.Duration) error

func (*Connection) Writer

func (self *Connection) Writer() io.Writer