connectors

Documentation

Index

• type SocketConnector
• type SocketConnectorConfig
• type WebSocketConnector
  • func NewWebSocketConnector() *WebSocketConnector
  • func (c *WebSocketConnector) Dial(config SocketConnectorConfig) (adapters.SocketAdapter, error)
  • func (c *WebSocketConnector) GetSchemes() []string
• type WebTransportConnector
  • func NewWebTransportConnector() *WebTransportConnector
  • func (c *WebTransportConnector) Dial(config SocketConnectorConfig) (adapters.SocketAdapter, error)
  • func (c *WebTransportConnector) GetSchemes() []string

Types

type SocketConnector

type SocketConnector interface {
	Dial(config SocketConnectorConfig) (adapters.SocketAdapter, error)
	GetSchemes() []string
}

type SocketConnectorConfig

type SocketConnectorConfig interface {
	GetProxyURL() *url.URL
	GetTLSConfig() *tls.Config
	GetHeaders() http.Header
	GetServerURL() *url.URL

	EnhanceConn(conn net.Conn) error
	GetDialer() *net.Dialer
}

type WebSocketConnector

type WebSocketConnector struct {
}

func NewWebSocketConnector

func NewWebSocketConnector() *WebSocketConnector

func (*WebSocketConnector) Dial

func (c *WebSocketConnector) Dial(config SocketConnectorConfig) (adapters.SocketAdapter, error)

func (*WebSocketConnector) GetSchemes

func (c *WebSocketConnector) GetSchemes() []string

type WebTransportConnector

type WebTransportConnector struct {
}

func NewWebTransportConnector

func NewWebTransportConnector() *WebTransportConnector

func (*WebTransportConnector) Dial

func (c *WebTransportConnector) Dial(config SocketConnectorConfig) (adapters.SocketAdapter, error)

func (*WebTransportConnector) GetSchemes

func (c *WebTransportConnector) GetSchemes() []string