natscliws

README

go-nats-cli-ws

Go nats.io client via websockets proxy

package main

import (
    mqs "github.com/9glt/go-stan-cli-ws"
    stan "github.com/nats-io/stan.go"
)

func main() {
    conn, err := mqs.New("wss://host.domain.tld/path?token=tok", "nats://user:pass@127.0.0.1:4222", "test-cluster", "client-1")
    if err != nil {
        panic(err)
    }
    
    sc := conn.UnderlyingConn()

    // use sc 
    
    // ...
}

Documentation

Index

• type MQ
  • func New(ws, n, cluster, client string) (*MQ, error)
  • func (mq *MQ) UnderlyingConn() stan.Conn

Types

type MQ

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

func New

func New(ws, n, cluster, client string) (*MQ, error)

New connects to nats via websocket dialer

func (*MQ) UnderlyingConn

func (mq *MQ) UnderlyingConn() stan.Conn