repository

Documentation

Overview

Package repository contains control entety repositories

Index

• type AfterOption
• type GroupOption
  • func (opt *GroupOption) PrepareQuery(query *gorm.DB) *gorm.DB
• type ListOptions
  • func (opts ListOptions) PrepareAfterQuery(query *gorm.DB, idCol string, orderColumns ...OrderingColumn) *gorm.DB
  • func (opts ListOptions) PrepareQuery(query *gorm.DB) *gorm.DB
  • func (opts ListOptions) With(prep QOption) ListOptions
• type OrderingColumn
• type OrderingColumnsOption
• type Pagination
  • func (p *Pagination) PrepareAfterQuery(q *gorm.DB, idCol string, orderColumns []OrderingColumn) *gorm.DB
  • func (p *Pagination) PrepareQuery(q *gorm.DB) *gorm.DB
• type PreloadOption
  • func (opt *PreloadOption) PrepareQuery(query *gorm.DB) *gorm.DB
• type QOption
• type Repository
  • func (r *Repository) Logger(ctx context.Context) *zap.Logger
  • func (r *Repository) Master(ctx context.Context) *gorm.DB
  • func (r *Repository) PermissionManager(ctx context.Context) *permissions.Manager
  • func (r *Repository) Slave(ctx context.Context) *gorm.DB
  • func (r *Repository) Transaction(ctx context.Context) (*gorm.DB, context.Context, bool, error)
  • func (r *Repository) TransactionExec(ctx context.Context, fn func(ctx context.Context, tx *gorm.DB) error, ...) error

Types

type AfterOption

type AfterOption interface {
	PrepareAfterQuery(query *gorm.DB, idCol string, orderColumns []OrderingColumn) *gorm.DB
}

AfterOption prepare query after

type GroupOption

type GroupOption struct {
	Groups        []string
	SummingFields []string
}

func (*GroupOption) PrepareQuery

func (opt *GroupOption) PrepareQuery(query *gorm.DB) *gorm.DB

type ListOptions

type ListOptions []QOption

ListOptions for query preparation

func (ListOptions) PrepareAfterQuery

func (opts ListOptions) PrepareAfterQuery(query *gorm.DB, idCol string, orderColumns ...OrderingColumn) *gorm.DB

func (ListOptions) PrepareQuery

func (opts ListOptions) PrepareQuery(query *gorm.DB) *gorm.DB

func (ListOptions) With

func (opts ListOptions) With(prep QOption) ListOptions

type OrderingColumn

type OrderingColumn struct {
	Name string
	DESC bool
}

type OrderingColumnsOption

type OrderingColumnsOption interface {
	OrderingColumns() []OrderingColumn
}

type Pagination

type Pagination struct {
	After  string
	Offset int
	Page   int
	Size   int
}

Pagination of the objects list

func (*Pagination) PrepareAfterQuery

func (p *Pagination) PrepareAfterQuery(q *gorm.DB, idCol string, orderColumns []OrderingColumn) *gorm.DB

func (*Pagination) PrepareQuery

func (p *Pagination) PrepareQuery(q *gorm.DB) *gorm.DB

PrepareQuery prepare query with pagination

type PreloadOption

type PreloadOption struct {
	Fields []string
}

func (*PreloadOption) PrepareQuery

func (opt *PreloadOption) PrepareQuery(query *gorm.DB) *gorm.DB

type QOption

type QOption interface {
	PrepareQuery(query *gorm.DB) *gorm.DB
}

QOption prepare query

type Repository

type Repository struct{}

Repository with basic functionality

func (*Repository) Logger

func (r *Repository) Logger(ctx context.Context) *zap.Logger

Logger returns logger object from context

func (*Repository) Master

func (r *Repository) Master(ctx context.Context) *gorm.DB

Master returns master database executor TODO: rename to Leader

func (*Repository) PermissionManager

func (r *Repository) PermissionManager(ctx context.Context) *permissions.Manager

PermissionManager returns permission-manager object from context

func (*Repository) Slave

func (r *Repository) Slave(ctx context.Context) *gorm.DB

Slave returns readonly database connection TODO: rename to ReadOnly

func (*Repository) Transaction

func (r *Repository) Transaction(ctx context.Context) (*gorm.DB, context.Context, bool, error)

Transaction returns new or exists transaction executor

func (*Repository) TransactionExec

func (r *Repository) TransactionExec(ctx context.Context, fn func(ctx context.Context, tx *gorm.DB) error, dbs ...*gorm.DB) error

TransactionExec executes function in transaction