transport

Documentation

Index

• Constants
• func AddAddressParser(addressParser AddressParser)
• type Address
  • func ParseAddress(addressString string) (Address, error)
• type AddressParser
• type Configuration
• type Connection
• type ConnectionDetail
  • func (cd *ConnectionDetail) String() string

Constants

const (
	DefaultWsWriteTimeout      = time.Second * 10
	DefaultWsReadTimeout       = time.Second * 5
	DefaultWsIdleTimeout       = time.Second * 5
	DefaultWsPongTimeout       = time.Second * 60
	DefaultWsPingInterval      = (DefaultWsPongTimeout * 9) / 10
	DefaultWsHandshakeTimeout  = time.Second * 10
	DefaultWsReadBufferSize    = 4096
	DefaultWsWriteBufferSize   = 4096
	DefaultWsEnableCompression = true
)

Functions

func AddAddressParser

func AddAddressParser(addressParser AddressParser)

AddAddressParser adds an AddressParser to the globally-configured address parsers.

Types

type Address

type Address interface {
	Dial(name string, i *identity.TokenId, timeout time.Duration, tcfg Configuration) (Connection, error)
	Listen(name string, i *identity.TokenId, incoming chan Connection, tcfg Configuration) (io.Closer, error)
	MustListen(name string, i *identity.TokenId, incoming chan Connection, tcfg Configuration) io.Closer
	String() string
	Type() string
}

Address implements the functionality provided by a generic "address".

func ParseAddress

func ParseAddress(addressString string) (Address, error)

ParseAddress uses the globally-configured AddressParser instances to parse an address.

type AddressParser

type AddressParser interface {
	Parse(addressString string) (Address, error)
}

AddressParser implements the functionality provided by an "address parser".

type Configuration

type Configuration map[interface{}]interface{}

type Connection

type Connection interface {
	Detail() *ConnectionDetail
	PeerCertificates() []*x509.Certificate
	Reader() io.Reader
	Writer() io.Writer
	Conn() net.Conn
	SetReadTimeout(t time.Duration) error
	ClearReadTimeout() error
	SetWriteTimeout(t time.Duration) error
	ClearWriteTimeout() error
	io.Closer
}

Connection represents an abstract connection (ingress or egress).

type ConnectionDetail

type ConnectionDetail struct {
	Address string
	InBound bool
	Name    string
}

func (*ConnectionDetail) String

func (cd *ConnectionDetail) String() string