core

type NATSConnectParams struct {
	// connect to NATS JetStream cluster with this URI
	ServerURI string `validate:"required,uri"`
	// max time to wait for connection in ns
	ConnectTimeout time.Duration
	// on connection failure, max number of reconnect attempt. "-1" means infinite
	MaxReconnectAttempt int `validate:"gte=-1"`
	// wait duration between reconnect attempts
	ReconnectWait time.Duration
	// callback on client disconnect
	OnDisconnectCallback func(*nats.Conn, error)
	// callback on client reconnect
	OnReconnectCallback func(*nats.Conn)
	// callback on client connection closed
	OnCloseCallback func(*nats.Conn)
}

type NatsClient struct {
	goutils.Component
	// contains filtered or unexported fields
}