nats

package

v0.4.2 Latest Latest Go to latest Published: Jun 22, 2026 License: MIT Imports: 10 Imported by: 0

Details

This section is empty.

This section is empty.

func InitializeNATS(ctx context.Context, config c.NatsConfig, logger l.Logger) (jetstream.JetStream, *natsgo.Conn, *server.Server)

type Option func(*options)

func WithConnectOptions(opts ...natsgo.Option) Option

func WithConnection(conn *natsgo.Conn, opts ...jetstream.JetStreamOpt) Option

func WithJetStream(js jetstream.JetStream) Option

func WithJetStreamOptions(opts ...jetstream.JetStreamOpt) Option

func WithURL(url string, opts ...natsgo.Option) Option

type Runtime struct {
	JetStream jetstream.JetStream
	Conn      *natsgo.Conn
	Server    *server.Server
	// contains filtered or unexported fields
}

func Start(ctx context.Context, config c.NatsConfig, logger l.Logger, runtimeOpts ...Option) (*Runtime, error)

func (r *Runtime) Close()