mirror of
https://github.com/bitmagnet-io/bitmagnet.git
synced 2026-07-24 05:05:17 -04:00
mgdigital
23 lines
582 B
Go
23 lines
582 B
Go
package queuefx
|
|
|
|
import (
|
|
"github.com/bitmagnet-io/bitmagnet/internal/boilerplate/config/configfx"
|
|
"github.com/bitmagnet-io/bitmagnet/internal/queue"
|
|
"github.com/bitmagnet-io/bitmagnet/internal/queue/client"
|
|
"github.com/bitmagnet-io/bitmagnet/internal/queue/prometheus"
|
|
"github.com/bitmagnet-io/bitmagnet/internal/queue/server"
|
|
"go.uber.org/fx"
|
|
)
|
|
|
|
func New() fx.Option {
|
|
return fx.Module(
|
|
"queue",
|
|
configfx.NewConfigModule[queue.Config]("queue", queue.NewDefaultConfig()),
|
|
fx.Provide(
|
|
client.New,
|
|
prometheus.New,
|
|
server.New,
|
|
),
|
|
)
|
|
}
|