cache

Documentation

Index

• type Cache
  • func NewCache(cacheDir string, syncFreq time.Duration, opts Options) *Cache
  • func (r *Cache) Close(ctx context.Context, cr *configv1alpha1.Repository) error
  • func (r *Cache) Open(ctx context.Context, cr *configv1alpha1.Repository) (*CachedRepository, error)
• type CachedRepository
  • func (r *CachedRepository) Close() error
  • func (r *CachedRepository) DeletePackageRevision(ctx context.Context, pkgRev *pkgv1alpha1.PackageRevision) error
  • func (r *CachedRepository) EnsurePackageRevision(ctx context.Context, pkgRev *pkgv1alpha1.PackageRevision) error
  • func (r *CachedRepository) GetResources(ctx context.Context, pkgRev *pkgv1alpha1.PackageRevision) (map[string]string, error)
  • func (r *CachedRepository) ListPackageRevisions(ctx context.Context, opts *repository.ListOption) ([]*pkgv1alpha1.PackageRevision, error)
  • func (r *CachedRepository) UpsertPackageRevision(ctx context.Context, pkgRev *pkgv1alpha1.PackageRevision, ...) error
• type Options

Types

type Cache

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

func NewCache

func NewCache(cacheDir string, syncFreq time.Duration, opts Options) *Cache

func (*Cache) Close

func (r *Cache) Close(ctx context.Context, cr *configv1alpha1.Repository) error

func (*Cache) Open

func (r *Cache) Open(ctx context.Context, cr *configv1alpha1.Repository) (*CachedRepository, error)

type CachedRepository

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

func (*CachedRepository) Close

func (r *CachedRepository) Close() error

func (*CachedRepository) DeletePackageRevision

func (r *CachedRepository) DeletePackageRevision(ctx context.Context, pkgRev *pkgv1alpha1.PackageRevision) error

func (*CachedRepository) EnsurePackageRevision

func (r *CachedRepository) EnsurePackageRevision(ctx context.Context, pkgRev *pkgv1alpha1.PackageRevision) error

func (*CachedRepository) GetResources

func (r *CachedRepository) GetResources(ctx context.Context, pkgRev *pkgv1alpha1.PackageRevision) (map[string]string, error)

func (*CachedRepository) ListPackageRevisions

func (r *CachedRepository) ListPackageRevisions(ctx context.Context, opts *repository.ListOption) ([]*pkgv1alpha1.PackageRevision, error)

func (*CachedRepository) UpsertPackageRevision

func (r *CachedRepository) UpsertPackageRevision(ctx context.Context, pkgRev *pkgv1alpha1.PackageRevision, resources map[string]string) error

type Options

type Options struct {
	Client             client.Client
	CredentialResolver auth.CredentialResolver
	UserInfoProvider   auth.UserInfoProvider
}