tcp

Documentation

Index

• func Dial(destination, name string, timeout time.Duration) (transport.Connection, error)
• func DialWithLocalBinding(destination, name, localBinding string, timeout time.Duration) (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, timeout time.Duration) (transport.Connection, error)

func DialWithLocalBinding

func DialWithLocalBinding(destination, name, localBinding string, timeout time.Duration) (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