nats

Documentation

Index

• func DefaultManager() *gonats.Manager
• func SetManager(configPath string, logger *log.Helper)

Functions

func DefaultManager

func DefaultManager() *gonats.Manager

DefaultManager 返回全局默认 Manager，用于访问 Core NATS 和 JetStream 能力。

func SetManager

func SetManager(configPath string, logger *log.Helper)

SetManager 初始化全局默认 NATS Manager，由 bootstrap 在启动时调用。 会自动将 Close() 注册到 cdefer，应用退出时优雅关闭连接。