cache

Documentation

Index

• func LoadOrRebuild(ctx context.Context, c Cache, fbc fs.FS) error
• type Cache
  • func New(cacheDir string) (Cache, error)
• type JSON
  • func NewJSON(baseDir string) *JSON
  • func (q *JSON) Build(ctx context.Context, fbcFsys fs.FS) error
  • func (q *JSON) CheckIntegrity(fbcFsys fs.FS) error
  • func (q *JSON) GetBundle(_ context.Context, pkgName, channelName, csvName string) (*api.Bundle, error)
  • func (q *JSON) GetBundleForChannel(ctx context.Context, pkgName string, channelName string) (*api.Bundle, error)
  • func (q *JSON) GetBundleThatProvides(ctx context.Context, group, version, kind string) (*api.Bundle, error)
  • func (q *JSON) GetBundleThatReplaces(ctx context.Context, name, pkgName, channelName string) (*api.Bundle, error)
  • func (q *JSON) GetChannelEntriesThatProvide(ctx context.Context, group, version, kind string) ([]*registry.ChannelEntry, error)
  • func (pkgs JSON) GetChannelEntriesThatReplace(_ context.Context, name string) ([]*registry.ChannelEntry, error)
  • func (q *JSON) GetLatestChannelEntriesThatProvide(ctx context.Context, group, version, kind string) ([]*registry.ChannelEntry, error)
  • func (pkgs JSON) GetPackage(_ context.Context, name string) (*registry.PackageManifest, error)
  • func (q *JSON) ListBundles(ctx context.Context) ([]*api.Bundle, error)
  • func (pkgs JSON) ListPackages(_ context.Context) ([]string, error)
  • func (q *JSON) Load() error
  • func (q *JSON) SendBundles(_ context.Context, s registry.BundleSender) error

Functions

func LoadOrRebuild

func LoadOrRebuild(ctx context.Context, c Cache, fbc fs.FS) error

Types

type Cache

type Cache interface {
	registry.GRPCQuery

	CheckIntegrity(fbc fs.FS) error
	Build(ctx context.Context, fbc fs.FS) error
	Load() error
}

func New

func New(cacheDir string) (Cache, error)

New creates a new Cache. It chooses a cache implementation based on the files it finds in the cache directory, with a preference for the latest iteration of the cache implementation. It returns an error if cacheDir exists and contains unexpected files.

type JSON

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

func NewJSON

func NewJSON(baseDir string) *JSON

func (*JSON) Build

func (q *JSON) Build(ctx context.Context, fbcFsys fs.FS) error

func (*JSON) CheckIntegrity

func (q *JSON) CheckIntegrity(fbcFsys fs.FS) error

func (*JSON) GetBundle

func (q *JSON) GetBundle(_ context.Context, pkgName, channelName, csvName string) (*api.Bundle, error)

func (*JSON) GetBundleForChannel

func (q *JSON) GetBundleForChannel(ctx context.Context, pkgName string, channelName string) (*api.Bundle, error)

func (*JSON) GetBundleThatProvides

func (q *JSON) GetBundleThatProvides(ctx context.Context, group, version, kind string) (*api.Bundle, error)

func (*JSON) GetBundleThatReplaces

func (q *JSON) GetBundleThatReplaces(ctx context.Context, name, pkgName, channelName string) (*api.Bundle, error)

func (*JSON) GetChannelEntriesThatProvide

func (q *JSON) GetChannelEntriesThatProvide(ctx context.Context, group, version, kind string) ([]*registry.ChannelEntry, error)

func (JSON) GetChannelEntriesThatReplace

func (pkgs JSON) GetChannelEntriesThatReplace(_ context.Context, name string) ([]*registry.ChannelEntry, error)

func (*JSON) GetLatestChannelEntriesThatProvide

func (q *JSON) GetLatestChannelEntriesThatProvide(ctx context.Context, group, version, kind string) ([]*registry.ChannelEntry, error)

func (JSON) GetPackage

func (pkgs JSON) GetPackage(_ context.Context, name string) (*registry.PackageManifest, error)

func (*JSON) ListBundles

func (q *JSON) ListBundles(ctx context.Context) ([]*api.Bundle, error)

func (JSON) ListPackages

func (pkgs JSON) ListPackages(_ context.Context) ([]string, error)

func (*JSON) Load

func (q *JSON) Load() error

func (*JSON) SendBundles

func (q *JSON) SendBundles(_ context.Context, s registry.BundleSender) error