datastore

package

Go to main page

Versions in this module

v0

v0.0.13

Oct 2, 2023

v0.0.12

Sep 28, 2023

v0.0.11

Sep 28, 2023

Changes in this version

type DataStore

+ FindAllIncludingSoftDeleted func(ctx context.Context, records interface{}, pagination *Pagination) error

+ FindSoftDeleted func(ctx context.Context, record Record) error

+ FindWithFilterIncludingSoftDeleted func(ctx context.Context, filter Record, records interface{}, ...) error

v0.0.10

Sep 26, 2023

v0.0.9

Sep 19, 2023

Changes in this version

+ const ERROR_DUPLICATE_DATABASE

+ const MaxIdleConns

type DataStore

+ func FromEnvWithDB(l *logrus.Entry, a authorizer.Authorizer, instancer authorizer.Instancer, ...) (d DataStore, err error)

v0.0.8

Aug 9, 2023

Changes in this version

type TestHelper

+ HasTable func(tableName string) (bool, error)

v0.0.7

May 27, 2023

v0.0.6

Apr 20, 2023

Changes in this version

+ func DBCreate(cfg DBConfig) error

+ func DBExists(cfg DBConfig) bool

type DBConfig

+ func ConfigFromEnv(dbName string) DBConfig

type DataStore

+ SoftDelete func(ctx context.Context, record Record) (int64, error)

v0.0.5

Mar 28, 2023

Changes in this version

+ const COLUMN_INSTANCEID

+ const DbConfigInstanceId

+ const ERROR_DUPLICATE_KEY

+ const FIELD_INSTANCEID

+ func GetFieldValue(record Record, fieldName, columnName string) (string, bool)

+ func GetInstanceId(record Record) (string, bool)

+ func IsColumnPresent(x Record, tableName, columnName string) bool

+ func IsMultiInstanced(x Record, tableName string, instancerConfigured bool) bool

+ func IsMultiTenanted(x Record, tableName string) bool

+ func IsRevisioned(x Record, tableName string) bool

+ func IsRowLevelSecurityRequired(record Record, tableName string, instancerConfigured bool) bool

+ func SetFieldValue(record Record, fieldName, columnName, value string) bool

+ func SetInstanceId(record Record, value string) bool

type DataStore

+ GetInstancer func() authorizer.Instancer

+ type TenancyInfo struct

+ DbRole dbrole.DbRole

+ InstanceId string

+ OrgId string

v0.0.4

Mar 1, 2023

Changes in this version

+ const DEFAULT_LIMIT

+ const DEFAULT_OFFSET

+ const DEFAULT_SORTBY

+ var TRACE = func(format string, v ...any)

+ func GetGormLogger(l *logrus.Entry) logger.Interface

+ func GetLogLevel() string

type DataStore

+ Register func(ctx context.Context, roleMapping map[string]dbrole.DbRole, records ...Record) error

type Helper

+ RegisterHelper func(ctx context.Context, roleMapping map[string]dbrole.DbRole, tableName string, ...) error

+ type Pagination struct

+ Limit int

+ Offset int

+ SortBy string

+ func DefaultPagination() *Pagination

+ func GetPagination(offset int, limit int, sortBy string) *Pagination

+ func NoPagination() *Pagination

v0.0.3

Feb 14, 2023

Changes in this version

+ const COLUMN_ORGID

+ const COLUMN_REVISION

+ const COMP

+ const DB_ADMIN_PASSWORD_ENV_VAR

+ const DB_ADMIN_USERNAME_ENV_VAR

+ const DB_HOST_ENV_VAR

+ const DB_NAME_ENV_VAR

+ const DB_PORT_ENV_VAR

+ const DbConfigOrgId

+ const FIELD_ORGID

+ const LOG_LEVEL_ENV_VAR

+ const MAIN

+ const REVISION_OUTDATED_MSG

+ const SAAS_PERSISTENCE

+ const SSL_MODE_ENV_VAR

+ var LOG = GetCompLogger()

+ func GetCompLogger() *logrus.Entry

+ func GetLogger() *logrus.Logger

+ func GetOrgId(record Record) (string, bool)

+ func GetTableName(x interface{}) string

+ func GetTableNameFromSlice(x interface{}) string

+ func IsMultitenant(x Record, tableNames ...string) bool

+ func IsPointerToStruct(x interface{}) (isPtrType bool)

+ func IsRevisioningSupported(tableName string, x Record) bool

+ func TypeName(x interface{}) (typeName string)

+ type DBConfig struct

+ type DataStore interface

+ Delete func(ctx context.Context, record Record) (int64, error)

+ Find func(ctx context.Context, record Record) error

+ FindAll func(ctx context.Context, records interface{}) error

+ FindWithFilter func(ctx context.Context, record Record, records interface{}) error

+ GetAuthorizer func() authorizer.Authorizer

+ GetTransaction func(ctx context.Context, record ...Record) (tx *gorm.DB, err error)

+ Helper func() Helper

+ Insert func(ctx context.Context, record Record) (int64, error)

+ RegisterWithDAL func(ctx context.Context, roleMapping map[string]dbrole.DbRole, record Record) error

+ Reset func()

+ TestHelper func() TestHelper

+ Update func(ctx context.Context, record Record) (int64, error)

+ Upsert func(ctx context.Context, record Record) (int64, error)

+ func FromConfig(l *logrus.Entry, authorizer authorizer.Authorizer, cfg DBConfig) (d DataStore, err error)

+ func FromEnv(l *logrus.Entry, authorizer authorizer.Authorizer) (d DataStore, err error)

+ type Helper interface

+ DeleteInTable func(ctx context.Context, tableName string, record Record) (int64, error)

+ FindAllInTable func(ctx context.Context, tableName string, records interface{}) error

+ FindInTable func(ctx context.Context, tableName string, record Record) error

+ FindWithFilterInTable func(ctx context.Context, tableName string, record Record, records interface{}) error

+ GetAuthorizer func() authorizer.Authorizer

+ GetDBTransaction func(ctx context.Context, tableName string, record Record) (tx *gorm.DB, err error)

+ InsertInTable func(ctx context.Context, tableName string, record Record) (int64, error)

+ RegisterWithDALHelper func(ctx context.Context, roleMapping map[string]dbrole.DbRole, tableName string, ...) error

+ UpdateInTable func(ctx context.Context, tableName string, record Record) (int64, error)

+ UpsertInTable func(ctx context.Context, tableName string, record Record) (int64, error)

+ type Record interface

+ func GetRecordInstanceFromSlice(x interface{}) Record

+ type TestHelper interface

+ DropTables func(records ...Record) error

+ Truncate func(tableNames ...string) error

+ TruncateCascade func(cascade bool, tableNames ...string) error

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL