nats

package

v0.0.0-...-60af706 Latest Latest Go to latest Published: Apr 15, 2025 License: MIT Imports: 19 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/gwos/tcg

Documentation ¶

Index ¶

Variables
func IsStartedDispatcher() bool
func IsStartedServer() bool
func Pub(subj string, data []byte, header http.Header) error
func Publish(subj string, data []byte, header http.Header) errordeprecated
func StartDispatcher(options []DurableCfg) error
func StartServer(config Config) error
func StopDispatcher() error
func StopServer()
type Config
type DurableCfg

Constants ¶

This section is empty.

Variables ¶

View Source

var (
	ErrNATS       = fmt.Errorf("nats error")
	ErrDispatcher = fmt.Errorf("%w: dispatcher", ErrNATS)
	ErrPayloadLim = fmt.Errorf("%w: payload oversized limit", ErrNATS)
)

View Source

var (

	// RetryDelays is overridden from config package
	RetryDelays = []time.Duration{time.Second * 30, time.Minute * 1, time.Minute * 5, time.Minute * 20}
)

Functions ¶

func IsStartedDispatcher ¶

func IsStartedDispatcher() bool

func IsStartedServer ¶

func IsStartedServer() bool

func Pub ¶

func Pub(subj string, data []byte, header http.Header) error

Pub sends NATS message in buffered channel

func Publish deprecated

func Publish(subj string, data []byte, header http.Header) error

Publish sends NATS message

Deprecated: Use Pub

func StartDispatcher ¶

func StartDispatcher(options []DurableCfg) error

StartDispatcher connects to stan and adds durable subscriptions

func StartServer ¶

func StartServer(config Config) error

StartServer runs NATS

func StopDispatcher ¶

func StopDispatcher() error

StopDispatcher ends dispatching

func StopServer ¶

func StopServer()

StopServer shutdowns NATS

Types ¶

type Config ¶

type Config struct {
	AckWait            time.Duration
	LogColors          bool
	MaxInflight        int
	MaxPubAcksInflight int
	MaxPayload         int32
	MonitorPort        int
	StoreDir           string
	StoreType          string
	StoreMaxAge        time.Duration
	StoreMaxBytes      int64
	StoreMaxMsgs       int64

	ConfigFile string
}

Config defines NATS configurable options

type DurableCfg ¶

type DurableCfg struct {
	Durable string
	Handler func(context.Context, jetstream.Msg) error
}

DurableCfg defines subscription

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL