Documentation
¶
Index ¶
- func NewContractRepo(db *clover.DB) repositories.Contract
- func NewDB(path string, collections []string) (*clover.DB, error)
- func NewFreeResources(db *clover.DB) repositories.FreeResources
- func NewGenericEntityRepository[T repositories.ModelType](db *clover.DB) repositories.GenericEntityRepository[T]
- func NewGenericRepository[T repositories.ModelType](db *clover.DB) repositories.GenericRepository[T]
- func NewMachineResourcesRepository(db *clover.DB) repositories.MachineResources
- func NewOnboardedResources(db *clover.DB) repositories.OnboardedResources
- func NewOnboardingConfig(db *clover.DB) repositories.OnboardingConfig
- func NewOrchestratorView(db *clover.DB) repositories.OrchestratorView
- func NewRequestTracker(db *clover.DB) repositories.RequestTracker
- func NewResourceAllocation(db *clover.DB) repositories.ResourceAllocation
- func NewStorageVolume(db *clover.DB) repositories.StorageVolume
- type ContractRepoClover
- type FreeResourcesClover
- type GenericEntityRepositoryClover
- func (repo *GenericEntityRepositoryClover[T]) Clear(_ context.Context) error
- func (repo *GenericEntityRepositoryClover[T]) Get(_ context.Context) (T, error)
- func (repo *GenericEntityRepositoryClover[T]) GetQuery() repositories.Query[T]
- func (repo *GenericEntityRepositoryClover[T]) History(_ context.Context, query repositories.Query[T]) ([]T, error)
- func (repo *GenericEntityRepositoryClover[T]) Save(_ context.Context, data T) (T, error)
- type GenericRepositoryClover
- func (repo *GenericRepositoryClover[T]) Create(ctx context.Context, data T) (T, error)
- func (repo *GenericRepositoryClover[T]) Delete(ctx context.Context, id interface{}) error
- func (repo *GenericRepositoryClover[T]) Find(ctx context.Context, query repositories.Query[T]) (T, error)
- func (repo *GenericRepositoryClover[T]) FindAll(ctx context.Context, query repositories.Query[T]) ([]T, error)
- func (repo *GenericRepositoryClover[T]) Get(ctx context.Context, id interface{}) (T, error)
- func (repo *GenericRepositoryClover[T]) GetQuery() repositories.Query[T]
- func (repo *GenericRepositoryClover[T]) Update(ctx context.Context, id interface{}, data T) (T, error)
- type MachineResourcesRepositoryClover
- type OnboardedResourcesClover
- type OnboardingConfigRepository
- type OrchestratorViewClover
- type RequestTrackerClover
- type ResourceAllocationClover
- type StorageVolumeClover
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewContractRepo ¶
func NewContractRepo(db *clover.DB) repositories.Contract
NewContractRepo creates a contract repo
func NewDB ¶
NewDB initializes and sets up the clover database using bbolt under the hood. Additionally, it automatically creates collections for the necessary types.
func NewFreeResources ¶
func NewFreeResources(db *clover.DB) repositories.FreeResources
NewFreeResources creates a new instance of FreeResourcesClover. It initializes and returns a Clover-based repository for FreeResources entity.
func NewGenericEntityRepository ¶
func NewGenericEntityRepository[T repositories.ModelType]( db *clover.DB, ) repositories.GenericEntityRepository[T]
NewGenericEntityRepository creates a new instance of GenericEntityRepositoryClover. It initializes and returns a repository with the provided Clover database, primary key field, and value.
func NewGenericRepository ¶
func NewGenericRepository[T repositories.ModelType]( db *clover.DB, ) repositories.GenericRepository[T]
NewGenericRepository creates a new instance of GenericRepositoryClover. It initializes and returns a repository with the provided Clover database.
func NewMachineResourcesRepository ¶
func NewMachineResourcesRepository(db *clover.DB) repositories.MachineResources
NewMachineResourcesRepository creates a new instance of MachineResourcesRepositoryClover. It initializes and returns a Clover-based repository for MachineResources entity.
func NewOnboardedResources ¶
func NewOnboardedResources(db *clover.DB) repositories.OnboardedResources
NewOnboardedResources creates a new instance of OnboardedResourcesClover. It initializes and returns a Clover-based repository for OnboardedResources entity.
func NewOnboardingConfig ¶
func NewOnboardingConfig(db *clover.DB) repositories.OnboardingConfig
NewOnboardingConfigRepository creates a new instance of OnboardingConfigRepository. It initializes and returns a Clover-based repository for OnboardingConfig entity.
func NewOrchestratorView ¶
func NewOrchestratorView(db *clover.DB) repositories.OrchestratorView
NewOrchestratorView creates a new instance of OrchestratorViewClover. It initializes and returns a Clover-based repository for StorageVolume entities.
func NewRequestTracker ¶
func NewRequestTracker(db *clover.DB) repositories.RequestTracker
NewRequestTracker creates a new instance of RequestTrackerClover. It initializes and returns a Clover-based repository for RequestTracker entities.
func NewResourceAllocation ¶
func NewResourceAllocation(db *clover.DB) repositories.ResourceAllocation
NewResourceAllocation creates a new instance of ResourceAllocationClover. It initializes and returns a Clover-based repository for ResourceAllocation entity.
func NewStorageVolume ¶
func NewStorageVolume(db *clover.DB) repositories.StorageVolume
NewStorageVolume creates a new instance of StorageVolumeClover. It initializes and returns a Clover-based repository for StorageVolume entities.
Types ¶
type ContractRepoClover ¶
type ContractRepoClover struct { repositories.GenericRepository[contract.Contract] }
ContractRepoClover
type FreeResourcesClover ¶
type FreeResourcesClover struct { repositories.GenericEntityRepository[types.FreeResources] }
FreeResourcesClover is a Clover implementation of the FreeResources interface.
type GenericEntityRepositoryClover ¶
type GenericEntityRepositoryClover[T repositories.ModelType] struct { // contains filtered or unexported fields }
GenericEntityRepositoryClover is a generic single entity repository implementation using Clover. It is intended to be embedded in single entity model repositories to provide basic database operations.
func (*GenericEntityRepositoryClover[T]) Clear ¶
func (repo *GenericEntityRepositoryClover[T]) Clear(_ context.Context) error
Clear removes the record with its history from the repository.
func (*GenericEntityRepositoryClover[T]) Get ¶
func (repo *GenericEntityRepositoryClover[T]) Get(_ context.Context) (T, error)
Get retrieves the record from the repository.
func (*GenericEntityRepositoryClover[T]) GetQuery ¶
func (repo *GenericEntityRepositoryClover[T]) GetQuery() repositories.Query[T]
GetQuery returns a clean Query instance for building queries.
func (*GenericEntityRepositoryClover[T]) History ¶
func (repo *GenericEntityRepositoryClover[T]) History(_ context.Context, query repositories.Query[T]) ([]T, error)
History retrieves previous versions of the record from the repository.
type GenericRepositoryClover ¶
type GenericRepositoryClover[T repositories.ModelType] struct { // contains filtered or unexported fields }
GenericRepositoryClover is a generic repository implementation using Clover. It is intended to be embedded in model repositories to provide basic database operations.
func (*GenericRepositoryClover[T]) Create ¶
func (repo *GenericRepositoryClover[T]) Create(ctx context.Context, data T) (T, error)
Create adds a new record to the repository and returns the created data.
func (*GenericRepositoryClover[T]) Delete ¶
func (repo *GenericRepositoryClover[T]) Delete(ctx context.Context, id interface{}) error
Delete removes a record by its identifier.
func (*GenericRepositoryClover[T]) Find ¶
func (repo *GenericRepositoryClover[T]) Find( ctx context.Context, query repositories.Query[T], ) (T, error)
Find retrieves a single record based on a query.
func (*GenericRepositoryClover[T]) FindAll ¶
func (repo *GenericRepositoryClover[T]) FindAll( ctx context.Context, query repositories.Query[T], ) ([]T, error)
FindAll retrieves multiple records based on a query.
func (*GenericRepositoryClover[T]) Get ¶
func (repo *GenericRepositoryClover[T]) Get(ctx context.Context, id interface{}) (T, error)
Get retrieves a record by its identifier.
func (*GenericRepositoryClover[T]) GetQuery ¶
func (repo *GenericRepositoryClover[T]) GetQuery() repositories.Query[T]
GetQuery returns a clean Query instance for building queries.
type MachineResourcesRepositoryClover ¶
type MachineResourcesRepositoryClover struct { repositories.GenericEntityRepository[types.MachineResources] }
MachineResourcesRepositoryClover is a Clover implementation of the MachineResourcesRepository interface.
type OnboardedResourcesClover ¶
type OnboardedResourcesClover struct { repositories.GenericEntityRepository[types.OnboardedResources] }
OnboardedResourcesClover is a Clover implementation of the OnboardedResources interface.
type OnboardingConfigRepository ¶
type OnboardingConfigRepository struct { repositories.GenericEntityRepository[types.OnboardingConfig] }
OnboardingConfigRepository is a Clover implementation of the OnboardingConfigRepository interface.
type OrchestratorViewClover ¶
type OrchestratorViewClover struct { repositories.GenericRepository[job_types.OrchestratorView] }
OrchestratorViewClover is a Clover implementation of the StorageVolume interface.
type RequestTrackerClover ¶
type RequestTrackerClover struct { repositories.GenericRepository[types.RequestTracker] }
RequestTrackerClover is a Clover implementation of the RequestTracker interface.
type ResourceAllocationClover ¶
type ResourceAllocationClover struct { repositories.GenericRepository[types.ResourceAllocation] }
ResourceAllocationClover is a Clover implementation of the ResourceAllocation interface.
type StorageVolumeClover ¶
type StorageVolumeClover struct { repositories.GenericRepository[types.StorageVolume] }
StorageVolumeClover is a Clover implementation of the StorageVolume interface.