rpcqueue

Documentation

Index

• Constants
• type Client
  • func NewClient(cfg Config, appName string) (*Client, error)
• type Config
• type Message
• type Printf
• type RPCQueue
  • func New(subject string, js jetstream.JetStream, srv zenrpc.Server, pf Printf) RPCQueue
  • func (q *RPCQueue) Run(ctx context.Context) error

Constants

const StreamName = "BROKERSRV"

Types

type Client

type Client struct {
	JetStreamConn jetstream.JetStream
	NatsConn      *nats.Conn
}

func NewClient

func NewClient(cfg Config, appName string) (*Client, error)

type Config

type Config struct {
	URL string
}

type Message

type Message struct {
	Request json.RawMessage `json:"request"`
	Header  http.Header     `json:"header"`
}

type Printf

type Printf func(format string, v ...interface{})

type RPCQueue

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

func New

func New(subject string, js jetstream.JetStream, srv zenrpc.Server, pf Printf) RPCQueue

New initialize new brokersrv rpc queue.

func (*RPCQueue) Run

func (q *RPCQueue) Run(ctx context.Context) error

Run subscribe to NATs Streaming subject and process events