nats_streaming

Documentation

Index

• func Dynamic(opts *cli.Options) error
• func NewClient(opts *cli.Options) (*nats.Conn, error)
• func Read(opts *cli.Options, md *desc.MessageDescriptor) error
• func Write(opts *cli.Options, md *desc.MessageDescriptor) error
• type NatsStreaming
  • func (n *NatsStreaming) Read() error
  • func (n *NatsStreaming) Write(value []byte) error

Functions

func Dynamic

func Dynamic(opts *cli.Options) error

Dynamic starts up a new GRPC client connected to the dProxy service and receives a stream of outbound replay messages which are then written to the message bus.

func NewClient

func NewClient(opts *cli.Options) (*nats.Conn, error)

NewClient creates a new Nats client connection

func Read

func Read(opts *cli.Options, md *desc.MessageDescriptor) error

func Write

func Write(opts *cli.Options, md *desc.MessageDescriptor) error

Types

type NatsStreaming

type NatsStreaming struct {
	Options    *cli.Options
	MsgDesc    *desc.MessageDescriptor
	Client     *nats.Conn
	StanClient stan.Conn
	// contains filtered or unexported fields
}

func (*NatsStreaming) Read

func (n *NatsStreaming) Read() error

func (*NatsStreaming) Write

func (n *NatsStreaming) Write(value []byte) error

Write publishes a message to a NATS streaming channel. The publish is synchronous, and will not complete until an ACK has been received by the server