wss

Documentation

Index

• func Dial(destination, name string) (transport.Connection, error)
• func Listen(bindAddress string, 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 (c *Connection) Close() error
  • func (self *Connection) Conn() net.Conn
  • func (self *Connection) Detail() *transport.ConnectionDetail
  • func (self *Connection) PeerCertificates() []*x509.Certificate
  • func (c *Connection) Read(p []byte) (n int, err error)
  • func (self *Connection) Reader() io.Reader
  • func (self *Connection) SetReadTimeout(t time.Duration) error
  • func (self *Connection) SetWriteTimeout(t time.Duration) error
  • func (c *Connection) Write(p []byte) (n int, err error)
  • func (self *Connection) Writer() io.Writer
• type WSSConfig
  • func NewDefaultWSSConfig() *WSSConfig
  • func (self *WSSConfig) Dump() string
  • func (self *WSSConfig) Load(data map[interface{}]interface{}) error

Functions

func Dial

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

Dial is unsupported for wss transport

func Listen

func Listen(bindAddress string, name string, incoming chan transport.Connection, 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 Connection

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

Connection wraps gorilla websocket to provide io.ReadWriteCloser

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 (c *Connection) Close() error

Close implements io.Closer and closes the underlying connection.

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) Read

func (c *Connection) Read(p []byte) (n int, err error)

Read implements io.Reader by wrapping websocket messages in a buffer.

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) Write

func (c *Connection) Write(p []byte) (n int, err error)

Write implements io.Writer and sends binary messages only.

func (*Connection) Writer

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

type WSSConfig

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

func NewDefaultWSSConfig

func NewDefaultWSSConfig() *WSSConfig

func (*WSSConfig) Dump

func (self *WSSConfig) Dump() string

func (*WSSConfig) Load

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