Versions in this module Expand all Collapse all v0 v0.0.3 Apr 15, 2022 v0.0.1 Apr 15, 2022 Changes in this version + var ErrConnectionNotEstablished = errors.New("connection has not yet been established") + func HijackIfPossible(w http.ResponseWriter) (net.Conn, *bufio.ReadWriter, error) + type ManagedConnection struct + func NewDurableConnection(target string, messageChan chan []byte, logger *zap.SugaredLogger) *ManagedConnection + func NewDurableSendingConnection(target string, logger *zap.SugaredLogger) *ManagedConnection + func NewDurableSendingConnectionGuaranteed(target string, duration time.Duration, logger *zap.SugaredLogger) (*ManagedConnection, error) + func (c *ManagedConnection) Send(msg interface{}) error + func (c *ManagedConnection) SendRaw(messageType int, msg []byte) error + func (c *ManagedConnection) Shutdown() error + func (c *ManagedConnection) Status() error