db

Documentation

Index

• type DB
• type Module
  • func (m *Module) Configure(injector *dingo.Injector)
  • func (m *Module) CueConfig() string
  • func (m *Module) FlamingoLegacyConfigAlias() map[string]string
• type ShutdownSubscriber
  • func (s *ShutdownSubscriber) Inject(db DB)
  • func (s *ShutdownSubscriber) Notify(_ context.Context, event flamingo.Event)

Types

type DB

type DB interface {
	Connection() *sqlx.DB
}

DB interface for database connections

type Module

type Module struct{}

Module basic struct

func (*Module) Configure

func (m *Module) Configure(injector *dingo.Injector)

Configure module

func (*Module) CueConfig

func (m *Module) CueConfig() string

CueConfig for the module

func (*Module) FlamingoLegacyConfigAlias

func (m *Module) FlamingoLegacyConfigAlias() map[string]string

FlamingoLegacyConfigAlias maps legacy config entries to new ones

type ShutdownSubscriber

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

ShutdownSubscriber handles the graceful app shutdown for the db connection

func (*ShutdownSubscriber) Inject

func (s *ShutdownSubscriber) Inject(db DB)

Inject dependencies

func (*ShutdownSubscriber) Notify

func (s *ShutdownSubscriber) Notify(_ context.Context, event flamingo.Event)

Notify handles the incoming event if it is an AppShutdownEvent and closes the db connection