model

Documentation

Index

• Variables
• type CommonConfigRepository
• type ConfigRepository
• type ModulesRepository
• type SchemaRepository

Variables

var (
	DbClient = database.NewRxDbClient(
		database.WithSchemaEnsuring(),
		database.WithSchemaAutoInjecting(),
		database.WithMigrationsEnsuring(),
		database.WithInitializingErrorHandler(func(err *database.ErrorEvent) {
			log.Fatal(stdcodes.InitializingDbError, err.Error())
		}),
	)
	ConfigRep       ConfigRepository       = &configRepPg{rxClient: DbClient}
	CommonConfigRep CommonConfigRepository = &commonConfigRepPg{rxClient: DbClient}
	SchemaRep       SchemaRepository       = &schemaRepPg{rxClient: DbClient}
	ModuleRep       ModulesRepository      = &modulesRepPg{rxClient: DbClient}
)

Types

type CommonConfigRepository

type CommonConfigRepository interface {
	Snapshot() ([]entity.CommonConfig, error)
	Upsert(config entity.CommonConfig) (*entity.CommonConfig, error)
	Delete(identities []string) (int, error)
}

type ConfigRepository

type ConfigRepository interface {
	Snapshot() ([]entity.Config, error)
	Upsert(config entity.Config) (*entity.Config, error)
	Delete(identities []string) (int, error)
}

type ModulesRepository

type ModulesRepository interface {
	Snapshot() ([]entity.Module, error)
	Upsert(module entity.Module) (*entity.Module, error)
	Delete(identities []string) (int, error)
}

type SchemaRepository

type SchemaRepository interface {
	Snapshot() ([]entity.ConfigSchema, error)
	Upsert(schema entity.ConfigSchema) (*entity.ConfigSchema, error)
	Delete(identities []string) (int, error)
}