wss

Documentation

Index

• Constants
• func ClientTLSConfig(u url.URL, i *identity.TokenId) *tls.Config
• func Dial(name string, u url.URL, i *identity.TokenId, _ time.Duration, ...) (transport.Conn, error)
• func DialWithLocalBinding(name string, u url.URL, localBinding string, i *identity.TokenId, ...) (transport.Conn, error)
• func Listen(bindAddress string, name string, i *identity.TokenId, ...) (io.Closer, error)
• type AddressParser
  • func (ap AddressParser) Parse(s string) (transport.Address, error)
• type Config
  • func NewDefaultConfig() *Config
  • func (self *Config) Dump(name string) string
  • func (self *Config) Load(data map[interface{}]interface{}) error

Constants

const Type = "wss"

Functions

func ClientTLSConfig

func ClientTLSConfig(u url.URL, i *identity.TokenId) *tls.Config

func Dial

func Dial(name string, u url.URL, i *identity.TokenId, _ time.Duration, _ transport.Configuration) (transport.Conn, error)

func DialWithLocalBinding

func DialWithLocalBinding(name string, u url.URL, localBinding string, i *identity.TokenId, timeout time.Duration, tcfg transport.Configuration) (transport.Conn, error)

func Listen

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

Types

type AddressParser

type AddressParser struct{}

func (AddressParser) Parse

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

type Config

type Config struct {
	WriteTimeout      time.Duration
	ReadTimeout       time.Duration
	IdleTimeout       time.Duration
	PongTimeout       time.Duration
	PingInterval      time.Duration
	HandshakeTimeout  time.Duration
	ReadBufferSize    int
	WriteBufferSize   int
	EnableCompression bool
	Identity          identity.Identity
}

func NewDefaultConfig

func NewDefaultConfig() *Config

func (*Config) Dump

func (self *Config) Dump(name string) string

func (*Config) Load

func (self *Config) Load(data map[interface{}]interface{}) error