marked

Documentation

Index

• func WrapStorage(base storagev1.Storage, checker Checker) storagev1.Storage
• type Checker
  • func NewSharedKVChecker(kv storagev1.SharedKV, opts ...SharedKVOption) Checker
• type SharedKVOption
  • func WithAutoClear(clear bool) SharedKVOption
  • func WithPrefix(prefix string) SharedKVOption

Functions

func WrapStorage

func WrapStorage(base storagev1.Storage, checker Checker) storagev1.Storage

WrapStorage wraps a storage with push-mark logic. If checker is nil, returns the original storage.

Types

type Checker

type Checker interface {
	Marked(ctx context.Context, id *object.ID, md *object.Metadata) (bool, error)
	TrieAdd(ctx context.Context, storePath string)
}

Checker decides whether a cached object should be marked expired. Return true to mark expired.

func NewSharedKVChecker

func NewSharedKVChecker(kv storagev1.SharedKV, opts ...SharedKVOption) Checker

type SharedKVOption

type SharedKVOption func(*checker)

func WithAutoClear

func WithAutoClear(clear bool) SharedKVOption

func WithPrefix

func WithPrefix(prefix string) SharedKVOption