ws

Documentation

Index

• func Accept(w http.ResponseWriter, r *http.Request) (*websocket.Conn, error)
• type Inbound
  • func NewInbound(internalAddr, externalAddr string) (*Inbound, error)
  • func (i *Inbound) Endpoint() string
  • func (i *Inbound) Start(prov transport.Provider) error
  • func (i *Inbound) Stop() error
• type OutboundClient
  • func NewOutbound() *OutboundClient
  • func (cs *OutboundClient) Accept(url string) bool
  • func (cs *OutboundClient) AcceptRecipient(keys []string) bool
  • func (cs *OutboundClient) Send(data []byte, destination *service.Destination) (string, error)
  • func (cs *OutboundClient) Start(prov transport.Provider) error

Functions

func Accept

func Accept(w http.ResponseWriter, r *http.Request) (*websocket.Conn, error)

Accept accepts a WebSocket handshake from a client and upgrades the the connection to a WebSocket.

Types

type Inbound

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

Inbound http(ws) type.

func NewInbound

func NewInbound(internalAddr, externalAddr string) (*Inbound, error)

NewInbound creates a new WebSocket inbound transport instance.

func (*Inbound) Endpoint

func (i *Inbound) Endpoint() string

Endpoint provides the http(ws) connection details.

func (*Inbound) Start

func (i *Inbound) Start(prov transport.Provider) error

Start the http(ws) server.

func (*Inbound) Stop

func (i *Inbound) Stop() error

Stop the http(ws) server.

type OutboundClient

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

OutboundClient websocket outbound.

func NewOutbound

func NewOutbound() *OutboundClient

NewOutbound creates a client for Outbound WS transport.

func (*OutboundClient) Accept

func (cs *OutboundClient) Accept(url string) bool

Accept checks for the url scheme.

func (*OutboundClient) AcceptRecipient

func (cs *OutboundClient) AcceptRecipient(keys []string) bool

AcceptRecipient checks if there is a connection for the list of recipient keys

func (*OutboundClient) Send

func (cs *OutboundClient) Send(data []byte, destination *service.Destination) (string, error)

Send sends a2a data via WS.

func (*OutboundClient) Start

func (cs *OutboundClient) Start(prov transport.Provider) error

Start starts the outbound transport.