cache

Documentation

Index

• type Cache
  • func NewCache(ttl time.Duration) (Cache, error)
• type ManifestCache
  • func NewManifestCache(ctx context.Context, store ManifestStore, saveInterval time.Duration) (*ManifestCache, error)
  • func (m *ManifestCache) Add(oid string)
  • func (m *ManifestCache) Contains(oid string) bool
  • func (m *ManifestCache) Flush(ctx context.Context)
  • func (m *ManifestCache) SnapshotBytes() ([]byte, string, error)
• type ManifestStore
• type PresignCache
  • func NewPresignCache() (*PresignCache, error)
  • func (p *PresignCache) Get(oid string) (string, bool)
  • func (p *PresignCache) Set(oid, url string, expiresAt time.Time)

Types

type Cache

type Cache interface {
	Get(key string) ([]byte, error)
	Set(key string, entry []byte) error
	Delete(key string) error
}

func NewCache

func NewCache(ttl time.Duration) (Cache, error)

type ManifestCache

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

ManifestCache is an in-memory OID presence set backed by an S3 manifest object. OIDs in S3 are permanent so entries never expire.

func NewManifestCache

func NewManifestCache(ctx context.Context, store ManifestStore, saveInterval time.Duration) (*ManifestCache, error)

func (*ManifestCache) Add

func (m *ManifestCache) Add(oid string)

func (*ManifestCache) Contains

func (m *ManifestCache) Contains(oid string) bool

func (*ManifestCache) Flush

func (m *ManifestCache) Flush(ctx context.Context)

func (*ManifestCache) SnapshotBytes

func (m *ManifestCache) SnapshotBytes() ([]byte, string, error)

type ManifestStore

type ManifestStore interface {
	LoadManifest(ctx context.Context) (oids []string, bootstrapped bool, err error)
	SaveManifest(ctx context.Context, oids []string) error
}

ManifestStore is implemented by AWSService — avoids import cycle.

type PresignCache

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

func NewPresignCache

func NewPresignCache() (*PresignCache, error)

func (*PresignCache) Get

func (p *PresignCache) Get(oid string) (string, bool)

func (*PresignCache) Set

func (p *PresignCache) Set(oid, url string, expiresAt time.Time)