lpostgres

Documentation

Index

• func LoadConfig(cfg []byte) (*database.PostgresParams, error)
• func NewLoader(ctx context.Context, logger *zap.SugaredLogger) func(key string, cfg []byte) (loader.Loader, error)
• type Loader
  • func (l *Loader) Add(ctx context.Context, m *model.Model, changes util.ValueMap) ([]any, error)
  • func (l *Loader) Connection(ctx context.Context) (any, error)
  • func (l *Loader) Count(ctx context.Context, m *model.Model) (int, error)
  • func (l *Loader) Default(ctx context.Context, m *model.Model) ([]any, error)
  • func (l *Loader) Get(ctx context.Context, m *model.Model, ids []any) (*result.Result, error)
  • func (l *Loader) List(ctx context.Context, m *model.Model, opts *filter.Options) (*result.Result, error)
  • func (l *Loader) Query(ctx context.Context, enums model.Models, sql string) (*result.Result, error)
  • func (l *Loader) Remove(ctx context.Context, m *model.Model, fields []string, values []any, ...) (int, error)
  • func (l *Loader) Save(ctx context.Context, m *model.Model, ids []any, changes util.ValueMap) ([]any, error)
  • func (l *Loader) Schema(ctx context.Context) (*schema.Schema, error)

Functions

func LoadConfig

func LoadConfig(cfg []byte) (*database.PostgresParams, error)

func NewLoader

func NewLoader(ctx context.Context, logger *zap.SugaredLogger) func(key string, cfg []byte) (loader.Loader, error)

Types

type Loader

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

func (*Loader) Add

func (l *Loader) Add(ctx context.Context, m *model.Model, changes util.ValueMap) ([]any, error)

func (*Loader) Connection

func (l *Loader) Connection(ctx context.Context) (any, error)

func (*Loader) Count

func (l *Loader) Count(ctx context.Context, m *model.Model) (int, error)

func (*Loader) Default

func (l *Loader) Default(ctx context.Context, m *model.Model) ([]any, error)

func (*Loader) Get

func (l *Loader) Get(ctx context.Context, m *model.Model, ids []any) (*result.Result, error)

func (*Loader) List

func (l *Loader) List(ctx context.Context, m *model.Model, opts *filter.Options) (*result.Result, error)

func (*Loader) Query

func (l *Loader) Query(ctx context.Context, enums model.Models, sql string) (*result.Result, error)

func (*Loader) Remove

func (l *Loader) Remove(ctx context.Context, m *model.Model, fields []string, values []any, expected int) (int, error)

func (*Loader) Save

func (l *Loader) Save(ctx context.Context, m *model.Model, ids []any, changes util.ValueMap) ([]any, error)

func (*Loader) Schema

func (l *Loader) Schema(ctx context.Context) (*schema.Schema, error)