wstransport

Documentation

Index

• Constants
• type WsTransport
  • func NewWsTransport(logger smudge.Logger, remoteWsServerPort *int, wsBasePath string) (*WsTransport, error)
  • func (wst *WsTransport) AllowMulticast() bool
  • func (wst *WsTransport) Dial(ctx context.Context, laddr transport.SockAddr, raddr transport.SockAddr) (transport.GenericConn, error)
  • func (wst *WsTransport) Listen(network string, addr transport.SockAddr) (transport.GenericConn, error)
  • func (wst *WsTransport) Network() string
  • func (wst *WsTransport) ResolveAddr(network string, addr string) (transport.SockAddr, error)
  • func (wst *WsTransport) UpgageWebsocket(w http.ResponseWriter, r *http.Request) error

Constants

const (
	MaxLRUCacheItems int = 100
)

const (
	WebsocketRoutePath = "/memberlist"
)

Types

type WsTransport

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

func NewWsTransport

func NewWsTransport(logger smudge.Logger, remoteWsServerPort *int, wsBasePath string) (*WsTransport, error)

func (*WsTransport) AllowMulticast

func (wst *WsTransport) AllowMulticast() bool

func (*WsTransport) Dial

func (wst *WsTransport) Dial(ctx context.Context, laddr transport.SockAddr,
	raddr transport.SockAddr,
) (transport.GenericConn, error)

func (*WsTransport) Listen

func (wst *WsTransport) Listen(network string, addr transport.SockAddr) (transport.GenericConn, error)

func (*WsTransport) Network

func (wst *WsTransport) Network() string

Return network, udp, websockets, tcp, ipv4, etc.

func (*WsTransport) ResolveAddr

func (wst *WsTransport) ResolveAddr(network string, addr string) (transport.SockAddr, error)

func (*WsTransport) UpgageWebsocket

func (wst *WsTransport) UpgageWebsocket(w http.ResponseWriter, r *http.Request) error

UpgageWebsocket upgrade http request to websocket connection. Pass it to web server handler.