sqldb

Jun 30, 2025

Changes in this version

+ var ErrCIRARepo = consoleerrors.CreateConsoleError("CIRARepo")

+ var ErrCIRARepoDatabase = DatabaseError

+ var ErrCIRARepoNotUnique = NotUniqueError

+ var ErrDeviceDatabase = DatabaseError

+ var ErrDeviceNotUnique = NotUniqueError

+ var ErrDomainDatabase = DatabaseError

+ var ErrDomainNotUnique = NotUniqueError

+ var ErrIEEE8021xDatabase = DatabaseError

+ var ErrIEEE8021xNotUnique = NotUniqueError

+ var ErrProfileDatabase = DatabaseError

+ var ErrProfileNotUnique = NotUniqueError

+ var ErrProfileWiFiConfigsDatabase = DatabaseError

+ var ErrProfileWiFiConfigsForeignKeyViolation = ForeignKeyViolationError

+ var ErrProfileWiFiConfigsNotUnique = NotUniqueError

+ var ErrWiFiDatabase = DatabaseError

+ var ErrWiFiIEEEForeignKeyViolation = ForeignKeyViolationError

+ var ErrWiFiNotUnique = NotUniqueError

+ type CIRARepo struct

+ func NewCIRARepo(database *db.SQL, log logger.Interface) *CIRARepo

+ func (r *CIRARepo) Delete(_ context.Context, configName, tenantID string) (bool, error)

+ func (r *CIRARepo) Get(_ context.Context, top, skip int, tenantID string) ([]entity.CIRAConfig, error)

+ func (r *CIRARepo) GetByName(_ context.Context, configName, tenantID string) (*entity.CIRAConfig, error)

+ func (r *CIRARepo) GetCount(_ context.Context, tenantID string) (int, error)

+ func (r *CIRARepo) Insert(_ context.Context, p *entity.CIRAConfig) (string, error)

+ func (r *CIRARepo) Update(_ context.Context, p *entity.CIRAConfig) (bool, error)

+ type DatabaseError struct

+ Console consoleerrors.InternalError

+ func (e DatabaseError) Error() string

+ func (e DatabaseError) Wrap(call, function string, err error) error

+ type DeviceRepo struct

+ func NewDeviceRepo(database *db.SQL, log logger.Interface) *DeviceRepo

+ func (r *DeviceRepo) Delete(_ context.Context, guid, tenantID string) (bool, error)

+ func (r *DeviceRepo) Get(_ context.Context, top, skip int, tenantID string) ([]entity.Device, error)

+ func (r *DeviceRepo) GetByColumn(_ context.Context, columnName, queryValue, tenantID string) ([]entity.Device, error)

+ func (r *DeviceRepo) GetByID(_ context.Context, guid, tenantID string) (*entity.Device, error)

+ func (r *DeviceRepo) GetByTags(_ context.Context, tags []string, method string, limit, offset int, ...) ([]entity.Device, error)

+ func (r *DeviceRepo) GetCount(_ context.Context, tenantID string) (int, error)

+ func (r *DeviceRepo) GetDistinctTags(_ context.Context, tenantID string) ([]string, error)

+ func (r *DeviceRepo) Insert(_ context.Context, d *entity.Device) (string, error)

+ func (r *DeviceRepo) Update(_ context.Context, d *entity.Device) (bool, error)

+ type DomainRepo struct

+ func NewDomainRepo(database *db.SQL, log logger.Interface) *DomainRepo

+ func (r *DomainRepo) Delete(_ context.Context, domainName, tenantID string) (bool, error)

+ func (r *DomainRepo) Get(_ context.Context, top, skip int, tenantID string) ([]entity.Domain, error)

+ func (r *DomainRepo) GetByName(_ context.Context, domainName, tenantID string) (*entity.Domain, error)

+ func (r *DomainRepo) GetCount(_ context.Context, tenantID string) (int, error)

+ func (r *DomainRepo) GetDomainByDomainSuffix(_ context.Context, domainSuffix, tenantID string) (*entity.Domain, error)

+ func (r *DomainRepo) Insert(_ context.Context, d *entity.Domain) (string, error)

+ func (r *DomainRepo) Update(_ context.Context, d *entity.Domain) (bool, error)

+ type ForeignKeyViolationError struct

+ Console consoleerrors.InternalError

+ func (e ForeignKeyViolationError) Error() string

+ func (e ForeignKeyViolationError) Wrap(details string) error

+ type IEEE8021xRepo struct

+ func NewIEEE8021xRepo(database *db.SQL, log logger.Interface) *IEEE8021xRepo

+ func (r *IEEE8021xRepo) CheckProfileExists(_ context.Context, profileName, tenantID string) (bool, error)

+ func (r *IEEE8021xRepo) Delete(_ context.Context, profileName, tenantID string) (bool, error)

+ func (r *IEEE8021xRepo) Get(_ context.Context, top, skip int, tenantID string) ([]entity.IEEE8021xConfig, error)

+ func (r *IEEE8021xRepo) GetByName(_ context.Context, profileName, tenantID string) (*entity.IEEE8021xConfig, error)

+ func (r *IEEE8021xRepo) GetCount(_ context.Context, tenantID string) (int, error)

+ func (r *IEEE8021xRepo) Insert(_ context.Context, p *entity.IEEE8021xConfig) (string, error)

+ func (r *IEEE8021xRepo) Update(_ context.Context, p *entity.IEEE8021xConfig) (bool, error)

+ type NotFoundError struct

+ Console consoleerrors.InternalError

+ func (e NotFoundError) Error() string

+ func (e NotFoundError) Wrap(call, function string, err error) error

+ func (e NotFoundError) WrapWithMessage(call, function, message string) error

+ type NotUniqueError struct

+ Console consoleerrors.InternalError

+ func (e NotUniqueError) Error() string

+ func (e NotUniqueError) Wrap(details string) error

+ type ProfileRepo struct

+ func NewProfileRepo(database *db.SQL, log logger.Interface) *ProfileRepo

+ func (r *ProfileRepo) Delete(_ context.Context, profileName, tenantID string) (bool, error)

+ func (r *ProfileRepo) Get(_ context.Context, top, skip int, tenantID string) ([]entity.Profile, error)

+ func (r *ProfileRepo) GetByName(_ context.Context, profileName, tenantID string) (*entity.Profile, error)

+ func (r *ProfileRepo) GetCount(_ context.Context, tenantID string) (int, error)

+ func (r *ProfileRepo) Insert(_ context.Context, p *entity.Profile) (string, error)

+ func (r *ProfileRepo) Update(_ context.Context, p *entity.Profile) (bool, error)

+ type ProfileWiFiConfigsRepo struct

+ func NewProfileWiFiConfigsRepo(database *db.SQL, log logger.Interface) *ProfileWiFiConfigsRepo

+ func (r *ProfileWiFiConfigsRepo) DeleteByProfileName(_ context.Context, profileName, tenantID string) (bool, error)

+ func (r *ProfileWiFiConfigsRepo) GetByProfileName(_ context.Context, profileName, tenantID string) ([]entity.ProfileWiFiConfigs, error)

+ func (r *ProfileWiFiConfigsRepo) Insert(_ context.Context, p *entity.ProfileWiFiConfigs) (string, error)

+ type WirelessRepo struct

+ func NewWirelessRepo(database *db.SQL, log logger.Interface) *WirelessRepo

+ func (r *WirelessRepo) CheckProfileExists(_ context.Context, profileName, tenantID string) (bool, error)

+ func (r *WirelessRepo) Delete(_ context.Context, profileName, tenantID string) (bool, error)

+ func (r *WirelessRepo) Get(_ context.Context, top, skip int, tenantID string) ([]entity.WirelessConfig, error)

+ func (r *WirelessRepo) GetByName(_ context.Context, profileName, tenantID string) (*entity.WirelessConfig, error)

+ func (r *WirelessRepo) GetCount(_ context.Context, tenantID string) (int, error)

+ func (r *WirelessRepo) Insert(_ context.Context, p *entity.WirelessConfig) (string, error)

+ func (r *WirelessRepo) Update(_ context.Context, p *entity.WirelessConfig) (bool, error)