framework

package
v1.1.2 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 25, 2024 License: AGPL-3.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var Module fx.Option = fx.Module("framework",
	fx.Provide(func(ev *env.Env) *redpandaCfg {
		return &redpandaCfg{ev: ev}
	}),

	fx.Provide(func(ev *env.Env, logger *slog.Logger) (*nats.JetstreamClient, error) {
		name := "audit-worker:jetstream-client"
		nc, err := nats.NewClient(ev.NatsURL, nats.ClientOpts{
			Name:   name,
			Logger: logger,
		})
		if err != nil {
			return nil, errors.NewE(err)
		}
		return nats.NewJetstreamClient(nc)
	}),

	fx.Provide(func(ev *env.Env) *eventsDbCfg {
		return &eventsDbCfg{ev: ev}
	}),
	repos.NewMongoClientFx[*eventsDbCfg](),
	app.Module,
)

Functions

This section is empty.

Types

This section is empty.

Jump to

Keyboard shortcuts

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