natscli

Documentation

Index

• func AddConsumer(streamName string, config *nats.ConsumerConfig) (err error)
• func AddStream(streamName string, subjects []string) error
• func Connect(clientName string, servers []string, options ...Option)
• func DelConsumer(stream, consumer string) (err error)
• func DelStream(streamName string) (err error)
• func JsPub(subj string, data []byte) (err error)
• func JsQueueSubscribe(subject, queueName string, handler nats.MsgHandler) (err error)
• func JsSub(subj string, handler nats.MsgHandler) (err error)
• func NewZlogLoggerWithNATS(level string, subj string)
• func Pub(ctx context.Context, subj string, data []byte)
• func PubGo(ctx context.Context, subj string, data any)
• func QueueSub(subj, queue string, handler nats.MsgHandler) (err error)
• func QueueSubSyncWithChan(subject, queueName string, handler chan *nats.Msg) (sub *nats.Subscription, err error)
• func Request(subj string, data []byte, timeout time.Duration) (*nats.Msg, error)
• func Sub(subj string, handler nats.MsgHandler) (err error)
• type Option
• type Options

Functions

func AddConsumer

func AddConsumer(streamName string, config *nats.ConsumerConfig) (err error)

AddConsumer 添加流消费者

func AddStream

func AddStream(streamName string, subjects []string) error

AddStream 添加流（不会重复创建，也不会删除再创建）

func Connect

func Connect(clientName string, servers []string, options ...Option)

func DelConsumer

func DelConsumer(stream, consumer string) (err error)

DelConsumer 删除流消费者

func DelStream

func DelStream(streamName string) (err error)

DelStream 删除流

func JsPub

func JsPub(subj string, data []byte) (err error)

JsPub 发布流消息

func JsQueueSubscribe

func JsQueueSubscribe(subject, queueName string, handler nats.MsgHandler) (err error)

JsQueueSubscribe 队列方式订阅流消息(分布式场景使用)

func JsSub

func JsSub(subj string, handler nats.MsgHandler) (err error)

JsSub 订阅流消息

func NewZlogLoggerWithNATS

func NewZlogLoggerWithNATS(level string, subj string)

func Pub

func Pub(ctx context.Context, subj string, data []byte)

func PubGo

func PubGo(ctx context.Context, subj string, data any)

func QueueSub

func QueueSub(subj, queue string, handler nats.MsgHandler) (err error)

func QueueSubSyncWithChan

func QueueSubSyncWithChan(subject, queueName string, handler chan *nats.Msg) (sub *nats.Subscription, err error)

func Request

func Request(subj string, data []byte, timeout time.Duration) (*nats.Msg, error)

func Sub

func Sub(subj string, handler nats.MsgHandler) (err error)

Types

type Option

type Option func(*Options)

type Options

type Options struct {

	// 认证配置-用户名密码方式
	Username string // 用户名
	Password string // 密码
	// 认证配置-NKey方式
	NKeySeedFile string
	// 认证配置-TOKEN方式
	Token string
	// contains filtered or unexported fields
}