natsws

Dec 13, 2022

Changes in this version

+ const UseDialer

Dec 12, 2022

Changes in this version

+ type ChangeReason string

+ const Connect

+ const Disconnect

+ const Reconnect

type Connection

+ func (c *Connection) ChangeReason() ChangeReason

type Manager

+ IsDebug func() bool

type Proxy

+ Context context.Context

Dec 11, 2022

Changes in this version

+ const Ping

+ const State

+ const StateClientName

+ func Observe(ctx app.Context, value *Connection) app.Observer

+ type Component struct

+ func (n *Component) OnMount(ctx app.Context)

+ func (n *Component) Render() app.UI

+ type Connection struct

+ func (c *Connection) ClientName() string

+ func (c *Connection) InProcessConn() (netConn net.Conn, err error)

+ func (c *Connection) IsConnected() bool

+ func (c *Connection) Nats() (conn *nats.Conn, err error)

+ func (c *Connection) Publish(subject string, message []byte) (err error)

+ func (c *Connection) Subscribe(subject string, cb nats.MsgHandler) (err error)

+ type Manager interface

+ Backends func() []string

+ OnError func(message string, err error)

+ Randomize func() bool

+ TLSConfig func() *tls.Config

+ func StaticManager(backends ...string) Manager

+ type Proxy struct

+ Manager Manager

+ func (a *Proxy) ServeHTTP(writer http.ResponseWriter, request *http.Request)