store

type BoltDBTable[E IdentifiableEntry] struct {
	// contains filtered or unexported fields
}

type CachedBundle struct {
	*api.Bundle
	BundleID            string             `json:"id"`
	Repository          string             `json:"repository"`
	DefaultChannelName  string             `json:"defaultChannelName"`
	PackageDependencies []property.Package `json:"packageDependencies"`
}

type CachedGVKBundle struct {
	CachedBundle
	GVKID string `json:"gvkId"`
	GVK   string `json:"gvk"`
}

type CachedPackage struct {
	*api.Package
	PackageID  string `json:"id"`
	Repository string `json:"repository"`
}

type CachedRepository struct {
	RepositoryName   string `json:"name"`
	RepositorySource string `json:"source"`
}

type FilterFunction[E IdentifiableEntry] func(*E) (bool, error)

type IdentifiableEntry interface {
	EntryID() string
}

type IterationFunction[E IdentifiableEntry] func(*E) error

type PackageDatabase interface {
	HasRepository(ctx context.Context, repo string) (bool, error)
	ListRepositories(ctx context.Context) ([]CachedRepository, error)
	ListPackages(ctx context.Context) ([]CachedPackage, error)
	ListBundles(ctx context.Context) ([]CachedBundle, error)
	ListBundlesForGVK(ctx context.Context, group string, version string, kind string) ([]CachedBundle, error)
	ListGVKs(ctx context.Context) (map[string][]CachedBundle, error)
	SearchPackages(ctx context.Context, searchTerm string) ([]CachedPackage, error)
	SearchBundles(ctx context.Context, searchTerm string) ([]CachedBundle, error)
	CacheRepository(ctx context.Context, repository repository.Repository) error
	RemoveRepository(ctx context.Context, repoName string) error
	GetPackage(ctx context.Context, packageID string) (*CachedPackage, error)
	GetBundle(ctx context.Context, bundleID string) (*CachedBundle, error)
	IterateBundles(ctx context.Context, fn func(bundle *CachedBundle) error) error
	GetBundlesForPackage(ctx context.Context, packageName string, options ...PackageSearchOption) ([]CachedBundle, error)
	Close() error
}

type PackageSearchOption func(config *packageSearchConfig)