di

Documentation

Index

• Variables
• func NewBadgerDB(lc fx.Lifecycle, config AppConfig) (*badger.DB, error)
• func NewDBRepository(db *badger.DB) repository.DBRepository
• func NewEngine(params EngineParams) *engine.Engine
• func NewEngineLogger(_ *zap.Logger) logging.Logger
• func NewRegistry(dbRepo repository.DBRepository, config AppConfig) registry.Registry
• func NewZapBaseLogger(lc fx.Lifecycle) (*zap.Logger, error)
• type AppConfig
• type Container
  • func NewContainer() *Container
  • func (c *Container) Get(name string) (interface{}, error)
  • func (c *Container) Register(name string, service interface{})
• type EngineParams
• type QuietLogger
  • func (l *QuietLogger) LogEvent(event fxevent.Event)

Variables

var Module = fx.Options(
	fx.Provide(

		NewZapBaseLogger,

		NewBadgerDB,
		NewDBRepository,
		NewRegistry,

		services.NewFunctionService,
		NewEngine,

		fx.Annotate(
			NewEngineLogger,
			fx.As(new(logging.Logger)),
		),
	),

	fx.WithLogger(func(logger *zap.Logger) fxevent.Logger {
		return &QuietLogger{Logger: logger}
	}),

	fx.NopLogger,
)

Functions

func NewBadgerDB

func NewBadgerDB(lc fx.Lifecycle, config AppConfig) (*badger.DB, error)

func NewDBRepository

func NewDBRepository(db *badger.DB) repository.DBRepository

func NewEngine

func NewEngine(params EngineParams) *engine.Engine

func NewEngineLogger

func NewEngineLogger(_ *zap.Logger) logging.Logger

func NewRegistry

func NewRegistry(dbRepo repository.DBRepository, config AppConfig) registry.Registry

func NewZapBaseLogger

func NewZapBaseLogger(lc fx.Lifecycle) (*zap.Logger, error)

Types

type AppConfig

type AppConfig struct {
	SocketPath  string
	HTTPAddr    string
	RegistryDir string
}

type Container

type Container struct {
	// contains filtered or unexported fields
}

func NewContainer

func NewContainer() *Container

func (*Container) Get

func (c *Container) Get(name string) (interface{}, error)

func (*Container) Register

func (c *Container) Register(name string, service interface{})

type EngineParams

type EngineParams struct {
	fx.In

	Registry        registry.Registry
	FunctionService services.FunctionService
	Config          AppConfig
	Logger          logging.Logger
}

type QuietLogger

type QuietLogger struct {
	Logger *zap.Logger
}

func (*QuietLogger) LogEvent

func (l *QuietLogger) LogEvent(event fxevent.Event)