ws

Documentation

Index

• Constants
• 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) LocalAddr() net.Addr
  • 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) RemoteAddr() net.Addr
  • func (self *Connection) SetDeadline(t time.Time) error
  • func (self *Connection) SetReadDeadline(t time.Time) error
  • func (self *Connection) SetReadTimeout(t time.Duration) error
  • func (self *Connection) SetWriteDeadline(t time.Time) 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 WSConfig
  • func NewDefaultWSConfig() *WSConfig
  • func (self *WSConfig) Dump() string
  • func (self *WSConfig) Load(data map[interface{}]interface{}) error

Constants

const (
	TLS_RSA_WITH_AES_128_CBC_SHA uint16 = 0x002f
	TLS_RSA_WITH_AES_256_CBC_SHA uint16 = 0x0035
)

TLS 1.0 - 1.2 cipher suites supported by ziti-sdk-js

Functions

func Dial

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

Dial is unsupported for ws 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) LocalAddr

func (self *Connection) LocalAddr() net.Addr

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

func (self *Connection) RemoteAddr() net.Addr

func (*Connection) SetDeadline

func (self *Connection) SetDeadline(t time.Time) error

func (*Connection) SetReadDeadline

func (self *Connection) SetReadDeadline(t time.Time) error

func (*Connection) SetReadTimeout

func (self *Connection) SetReadTimeout(t time.Duration) error

func (*Connection) SetWriteDeadline

func (self *Connection) SetWriteDeadline(t time.Time) 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 WSConfig

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

func NewDefaultWSConfig

func NewDefaultWSConfig() *WSConfig

func (*WSConfig) Dump

func (self *WSConfig) Dump() string

func (*WSConfig) Load

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