sql

Documentation

Index

• type SqlConfig
• type SqlPlugin
  • func NewSqlPlugin() *SqlPlugin
  • func (p *SqlPlugin) CanHotReload() bool
  • func (p *SqlPlugin) GetConfig() SqlConfig
  • func (p *SqlPlugin) GetDefaultConfig() map[string]interface{}
  • func (p *SqlPlugin) GetEventSubscriptions() map[string]gorgo.EventHandler
  • func (p *SqlPlugin) GetMiddleware() []gorgo.MiddlewareFunc
  • func (p *SqlPlugin) GetPool() *pgxpool.Pool
  • func (p *SqlPlugin) GetServices() map[string]interface{}
  • func (p *SqlPlugin) Initialize(container *container.Container, config map[string]interface{}) error
  • func (p *SqlPlugin) OnAfterInit(ctx context.Context) error
  • func (p *SqlPlugin) OnAfterStart(ctx context.Context) error
  • func (p *SqlPlugin) OnAfterStop(ctx context.Context) error
  • func (p *SqlPlugin) OnBeforeInit(ctx context.Context) error
  • func (p *SqlPlugin) OnBeforeStart(ctx context.Context) error
  • func (p *SqlPlugin) OnBeforeStop(ctx context.Context) error
  • func (p *SqlPlugin) OnHotReload(newConfig map[string]interface{}) error
  • func (p *SqlPlugin) Start(ctx context.Context) error
  • func (p *SqlPlugin) Stop(ctx context.Context) error
  • func (p *SqlPlugin) TransactionMiddleware() gorgo.MiddlewareFunc
  • func (p *SqlPlugin) ValidateConfig(config map[string]interface{}) error

Types

type SqlConfig

type SqlConfig struct {
	Host     string `toml:"host"`
	Port     int    `toml:"port"`
	User     string `toml:"user"`
	Password string `toml:"password"`
	Database string `toml:"db"`
	MaxConns int    `toml:"max_conns"`
	MinConns int    `toml:"min_conns"`
}

type SqlPlugin

type SqlPlugin struct {
	gorgo.BasePlugin
	// contains filtered or unexported fields
}

func NewSqlPlugin

func NewSqlPlugin() *SqlPlugin

func (*SqlPlugin) CanHotReload

func (p *SqlPlugin) CanHotReload() bool

HotReloadable implementation

func (*SqlPlugin) GetConfig

func (p *SqlPlugin) GetConfig() SqlConfig

func (*SqlPlugin) GetDefaultConfig

func (p *SqlPlugin) GetDefaultConfig() map[string]interface{}

func (*SqlPlugin) GetEventSubscriptions

func (p *SqlPlugin) GetEventSubscriptions() map[string]gorgo.EventHandler

EventSubscriber implementation

func (*SqlPlugin) GetMiddleware

func (p *SqlPlugin) GetMiddleware() []gorgo.MiddlewareFunc

MiddlewareProvider implementation

func (*SqlPlugin) GetPool

func (p *SqlPlugin) GetPool() *pgxpool.Pool

Additional methods for database operations

func (*SqlPlugin) GetServices

func (p *SqlPlugin) GetServices() map[string]interface{}

ServiceProvider implementation

func (*SqlPlugin) Initialize

func (p *SqlPlugin) Initialize(container *container.Container, config map[string]interface{}) error

Main plugin methods

func (*SqlPlugin) OnAfterInit

func (p *SqlPlugin) OnAfterInit(ctx context.Context) error

func (*SqlPlugin) OnAfterStart

func (p *SqlPlugin) OnAfterStart(ctx context.Context) error

func (*SqlPlugin) OnAfterStop

func (p *SqlPlugin) OnAfterStop(ctx context.Context) error

func (*SqlPlugin) OnBeforeInit

func (p *SqlPlugin) OnBeforeInit(ctx context.Context) error

LifecycleHooks implementation

func (*SqlPlugin) OnBeforeStart

func (p *SqlPlugin) OnBeforeStart(ctx context.Context) error

func (*SqlPlugin) OnBeforeStop

func (p *SqlPlugin) OnBeforeStop(ctx context.Context) error

func (*SqlPlugin) OnHotReload

func (p *SqlPlugin) OnHotReload(newConfig map[string]interface{}) error

func (*SqlPlugin) Start

func (p *SqlPlugin) Start(ctx context.Context) error

func (*SqlPlugin) Stop

func (p *SqlPlugin) Stop(ctx context.Context) error

func (*SqlPlugin) TransactionMiddleware

func (p *SqlPlugin) TransactionMiddleware() gorgo.MiddlewareFunc

Middleware for automatic transaction management

func (*SqlPlugin) ValidateConfig

func (p *SqlPlugin) ValidateConfig(config map[string]interface{}) error

ConfigurablePlugin implementation