nats_muxer

Documentation

Index

• Variables
• func HandleMuxedNATSRequest(client yagnats.NATSClient, subject string, callback MuxedHandler) (int64, error)
• type MuxedHandler
• type NATSMuxerClient
  • func NewNATSMuxerClient(client yagnats.NATSClient) *NATSMuxerClient
  • func (c *NATSMuxerClient) ListenForResponses() error
  • func (c *NATSMuxerClient) Request(subject string, payload []byte, timeout time.Duration) ([]byte, error)
  • func (c *NATSMuxerClient) Shutdown() error

Variables

var TimeoutError = errors.New("timeout")

Functions

func HandleMuxedNATSRequest

func HandleMuxedNATSRequest(client yagnats.NATSClient, subject string, callback MuxedHandler) (int64, error)

Types

type MuxedHandler

type MuxedHandler func([]byte) []byte

type NATSMuxerClient

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

func NewNATSMuxerClient

func NewNATSMuxerClient(client yagnats.NATSClient) *NATSMuxerClient

func (*NATSMuxerClient) ListenForResponses

func (c *NATSMuxerClient) ListenForResponses() error

func (*NATSMuxerClient) Request

func (c *NATSMuxerClient) Request(subject string, payload []byte, timeout time.Duration) ([]byte, error)

func (*NATSMuxerClient) Shutdown

func (c *NATSMuxerClient) Shutdown() error