sqldb

package
v1.0.0-alpha.7 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 19, 2024 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrCIRARepo          = consoleerrors.CreateConsoleError("CIRARepo")
	ErrCIRARepoDatabase  = DatabaseError{Console: consoleerrors.CreateConsoleError("CIRARepo")}
	ErrCIRARepoNotUnique = NotUniqueError{Console: consoleerrors.CreateConsoleError("CIRARepo")}
)
View Source 
var (
	ErrDeviceDatabase  = DatabaseError{Console: consoleerrors.CreateConsoleError("DeviceRepo")}
	ErrDeviceNotUnique = NotUniqueError{Console: consoleerrors.CreateConsoleError("DeviceRepo")}
)
View Source 
var (
	ErrDomainDatabase  = DatabaseError{Console: consoleerrors.CreateConsoleError("DomainRepo")}
	ErrDomainNotUnique = NotUniqueError{Console: consoleerrors.CreateConsoleError("DomainRepo")}
)
View Source 
var (
	ErrIEEE8021xDatabase  = DatabaseError{Console: consoleerrors.CreateConsoleError("IEEE8021xRepo")}
	ErrIEEE8021xNotUnique = NotUniqueError{Console: consoleerrors.CreateConsoleError("IEEE8021xRepo")}
)
View Source 
var (
	ErrProfileDatabase  = DatabaseError{Console: consoleerrors.CreateConsoleError("ProfileRepo")}
	ErrProfileNotUnique = NotUniqueError{Console: consoleerrors.CreateConsoleError("ProfileRepo")}
)
View Source 
var (
	ErrProfileWiFiConfigsDatabase            = DatabaseError{Console: consoleerrors.CreateConsoleError("ProfileWiFiConfigsRepo")}
	ErrProfileWiFiConfigsNotUnique           = NotUniqueError{Console: consoleerrors.CreateConsoleError("ProfileWiFiConfigsRepo")}
	ErrProfileWiFiConfigsForeignKeyViolation = ForeignKeyViolationError{Console: consoleerrors.CreateConsoleError("ProfileWiFiConfigsRepo")}
)
View Source 
var (
	ErrWiFiDatabase                = DatabaseError{Console: consoleerrors.CreateConsoleError("WirelessRepo")}
	ErrWiFiNotUnique               = NotUniqueError{Console: consoleerrors.CreateConsoleError("WirelessRepo")}
	ErrWiFiIEEEForeignKeyViolation = ForeignKeyViolationError{Console: consoleerrors.CreateConsoleError("WirelessRepo")}
)

Functions

This section is empty.

Types

type CIRARepo 

type CIRARepo struct {
	*db.SQL
	// contains filtered or unexported fields
}

CIRARepo -.

func NewCIRARepo 

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

New -.

func (*CIRARepo) Delete 

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

Delete -.

func (*CIRARepo) Get 

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

Get -.

func (*CIRARepo) GetByName 

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

GetByName -.

func (*CIRARepo) GetCount 

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

GetCount -.

func (*CIRARepo) Insert 

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

Insert -.

func (*CIRARepo) Update 

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

Update -.

type DatabaseError 

type DatabaseError struct {
	Console consoleerrors.InternalError
}

func (DatabaseError) Error 

func (e DatabaseError) Error() string

func (DatabaseError) Wrap 

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

type DeviceRepo 

type DeviceRepo struct {
	*db.SQL
	// contains filtered or unexported fields
}

DeviceRepo -.

func NewDeviceRepo 

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

New -.

func (*DeviceRepo) Delete 

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

Delete -.

func (*DeviceRepo) Get 

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

Get -.

func (*DeviceRepo) GetByColumn 

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

func (*DeviceRepo) GetByID 

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

GetByID -.

func (*DeviceRepo) GetByTags 

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

func (*DeviceRepo) GetCount 

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

GetCount -.

func (*DeviceRepo) GetDistinctTags 

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

func (*DeviceRepo) Insert 

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

Insert -.

func (*DeviceRepo) Update 

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

Update -.

type DomainRepo 

type DomainRepo struct {
	*db.SQL
	// contains filtered or unexported fields
}

DomainRepo -.

func NewDomainRepo 

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

New -.

func (*DomainRepo) Delete 

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

Delete -.

func (*DomainRepo) Get 

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

Get -.

func (*DomainRepo) GetByName 

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

GetByName -.

func (*DomainRepo) GetCount 

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

GetCount -.

func (*DomainRepo) GetDomainByDomainSuffix 

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

GetDomainByDomainSuffix -.

func (*DomainRepo) Insert 

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

Insert -.

func (*DomainRepo) Update 

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

Update -.

type ForeignKeyViolationError 

type ForeignKeyViolationError struct {
	Console consoleerrors.InternalError
}

func (ForeignKeyViolationError) Error 

func (e ForeignKeyViolationError) Error() string

func (ForeignKeyViolationError) Wrap 

func (e ForeignKeyViolationError) Wrap(details string) error

type IEEE8021xRepo 

type IEEE8021xRepo struct {
	*db.SQL
	// contains filtered or unexported fields
}

IEEE8021xRepo -.

func NewIEEE8021xRepo 

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

New -.

func (*IEEE8021xRepo) CheckProfileExists 

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

CheckProfileExits -.

func (*IEEE8021xRepo) Delete 

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

Delete -.

func (*IEEE8021xRepo) Get 

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

Get -.

func (*IEEE8021xRepo) GetByName 

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

GetByName -.

func (*IEEE8021xRepo) GetCount 

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

GetCount -.

func (*IEEE8021xRepo) Insert 

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

Insert -.

func (*IEEE8021xRepo) Update 

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

Update -.

type NotFoundError 

type NotFoundError struct {
	Console consoleerrors.InternalError
}

func (NotFoundError) Error 

func (e NotFoundError) Error() string

func (NotFoundError) Wrap 

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

type NotUniqueError 

type NotUniqueError struct {
	Console consoleerrors.InternalError
}

func (NotUniqueError) Error 

func (e NotUniqueError) Error() string

func (NotUniqueError) Wrap 

func (e NotUniqueError) Wrap(details string) error

type ProfileRepo 

type ProfileRepo struct {
	*db.SQL
	// contains filtered or unexported fields
}

func NewProfileRepo 

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

func (*ProfileRepo) Delete 

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

func (*ProfileRepo) Get 

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

func (*ProfileRepo) GetByName 

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

func (*ProfileRepo) GetCount 

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

func (*ProfileRepo) Insert 

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

func (*ProfileRepo) Update 

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

type ProfileWiFiConfigsRepo 

type ProfileWiFiConfigsRepo struct {
	*db.SQL
	logger.Interface
}

func NewProfileWiFiConfigsRepo 

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

func (*ProfileWiFiConfigsRepo) DeleteByProfileName 

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

Delete -.

func (*ProfileWiFiConfigsRepo) GetByProfileName 

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

Get by profile name -.

func (*ProfileWiFiConfigsRepo) Insert 

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

Insert -.

type WirelessRepo 

type WirelessRepo struct {
	*db.SQL
	logger.Interface
}

WirelessRepo -.

func NewWirelessRepo 

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

New -.

func (*WirelessRepo) CheckProfileExists 

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

CheckProfileExits -.

func (*WirelessRepo) Delete 

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

Delete -.

func (*WirelessRepo) Get 

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

Get -.

func (*WirelessRepo) GetByName 

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

GetByName -.

func (*WirelessRepo) GetCount 

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

GetCount -.

func (*WirelessRepo) Insert 

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

Insert -.

func (*WirelessRepo) Update 

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

Update -.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.