transport

Sep 6, 2024

Changes in this version

type Configuration

+ func (self Configuration) GetInt64Value(first string, rest ...string) (int64, bool, error)

+ func (self Configuration) GetUIntValue(first string, rest ...string) (uint, bool, error)

+ func (self Configuration) GetValue(first string, rest ...string) (interface{}, error)

Aug 19, 2024

Changes in this version

+ const KeyCachedHandshakeTimeout

+ const KeyHandshakeTimeout

type Configuration

+ func (self Configuration) GetHandshakeTimeout() (time.Duration, error)

Aug 23, 2023

Changes in this version

+ const KeyCachedProxyConfiguration

+ const KeyProtocol

+ const KeyProxy

type Configuration

+ func (self Configuration) GetProxyConfiguration() (*ProxyConfiguration, error)

+ type ProxyConfiguration struct

+ Address string

+ Auth *proxy.Auth

+ Type ProxyType

+ func LoadProxyConfiguration(cfg map[interface{}]interface{}) (*ProxyConfiguration, error)

+ type ProxyType string

+ const ProxyTypeHttpConnect

+ const ProxyTypeNone

Jul 14, 2023

Changes in this version

type Configuration

+ func (self Configuration) Protocols() []string

Jul 13, 2023

Changes in this version

+ type HostPortAddress interface

+ Hostname func() string

+ Port func() uint16

May 9, 2022

Changes in this version

+ const DefaultWsEnableCompression

+ const DefaultWsHandshakeTimeout

+ const DefaultWsIdleTimeout

+ const DefaultWsPingInterval

+ const DefaultWsPongTimeout

+ const DefaultWsReadBufferSize

+ const DefaultWsReadTimeout

+ const DefaultWsWriteBufferSize

+ const DefaultWsWriteTimeout

+ func AddAddressParser(addressParser AddressParser)

+ func NewDialerWithLocalBinding(addressType string, timeout time.Duration, localBinding string) (*net.Dialer, error)

+ func ResolveInterface(toResolve string) (*net.Interface, error)

+ func ResolveLocalBinding(localBinding string) (net.IP, error)

+ type Address interface

+ Dial func(name string, i *identity.TokenId, timeout time.Duration, tcfg Configuration) (Conn, error)

+ DialWithLocalBinding func(name string, binding string, i *identity.TokenId, timeout time.Duration, ...) (Conn, error)

+ Listen func(name string, i *identity.TokenId, acceptF func(Conn), tcfg Configuration) (io.Closer, error)

+ MustListen func(name string, i *identity.TokenId, acceptF func(Conn), tcfg Configuration) io.Closer

+ String func() string

+ Type func() string

+ func ParseAddress(addressString string) (Address, error)

+ type AddressParser interface

+ Parse func(addressString string) (Address, error)

+ type Configuration map[interface{}]interface

+ type Conn interface

+ Detail func() *ConnectionDetail

+ PeerCertificates func() []*x509.Certificate

+ type ConnectionDetail struct

+ Address string

+ InBound bool

+ Name string

+ func (cd *ConnectionDetail) String() string