database

Documentation

Index

• type Storage
  • func NewStorage(dbPath string) (*Storage, error)
  • func (s *Storage) Close() error
  • func (s *Storage) CountDependencies() (int64, error)
  • func (s *Storage) CountModules() (int64, error)
  • func (s *Storage) DeleteModule(name, _ string) error
  • func (s *Storage) GetDependenciesByModule(moduleName string) (*pb.DependenciesProto, error)
  • func (s *Storage) GetModule(name, _ string) (*pb.ModuleProto, error)
  • func (s *Storage) GetModuleByName(name string) ([]*pb.ModuleProto, error)
  • func (s *Storage) ListModules() ([]*pb.ModuleProto, error)
  • func (s *Storage) UpsertDependencies(moduleName string, deps *pb.DependenciesProto) error
  • func (s *Storage) UpsertModule(module *pb.ModuleProto) error
  • func (s *Storage) UpsertModules(module []*pb.ModuleProto) error

Types

type Storage

type Storage struct {
	// contains filtered or unexported fields
}

Storage wraps BoltDB with module tracking functionality

func NewStorage

func NewStorage(dbPath string) (*Storage, error)

NewStorage initializes BoltDB connection and creates buckets

func (*Storage) Close

func (s *Storage) Close() error

Close closes the database connection

func (*Storage) CountDependencies

func (s *Storage) CountDependencies() (int64, error)

CountDependencies returns the total number of dependency entries

func (*Storage) CountModules

func (s *Storage) CountModules() (int64, error)

CountModules returns the total number of modules

func (*Storage) DeleteModule

func (s *Storage) DeleteModule(name, _ string) error

DeleteModule removes a module and updates indexes (version is ignored since we store one version per module)

func (*Storage) GetDependenciesByModule

func (s *Storage) GetDependenciesByModule(moduleName string) (*pb.DependenciesProto, error)

GetDependenciesByModule retrieves dependencies for a module

func (*Storage) GetModule

func (s *Storage) GetModule(name, _ string) (*pb.ModuleProto, error)

GetModule retrieves a module by name (version is optional, ignored since we store one version per module)

func (*Storage) GetModuleByName

func (s *Storage) GetModuleByName(name string) ([]*pb.ModuleProto, error)

GetModuleByName retrieves a module by name (returns a slice for API compatibility)

func (*Storage) ListModules

func (s *Storage) ListModules() ([]*pb.ModuleProto, error)

ListModules retrieves all modules ordered by time (most recent first)

func (*Storage) UpsertDependencies

func (s *Storage) UpsertDependencies(moduleName string, deps *pb.DependenciesProto) error

UpsertDependencies stores dependencies for a module

func (*Storage) UpsertModule

func (s *Storage) UpsertModule(module *pb.ModuleProto) error

UpsertModule inserts or updates a module Uses a hash of the module name (without version) as the primary key This ensures only one entry per module, with the latest version stored

func (*Storage) UpsertModules

func (s *Storage) UpsertModules(module []*pb.ModuleProto) error

UpsertModules inserts or updates a module