cache

type CacheStore interface {
	// update cached resource
	UpdateCache(ctx context.Context, data Resource) error

	// find resource in cache, return nil if not in cache
	FindFromCache(ctx context.Context, id ResourceKey) (*Resource, error)

	// disable cache
	DisableCache(ctx context.Context, id ResourceKey) error
}

type ErrHandler interface {
	// go through on cache err, store limiter will also work
	ThroughOnCacheErr(ctx context.Context, resource ResourceKey, err error) (goThrough bool)

	//data downgrading if find data has err
	Downgrading(ctx context.Context, resource ResourceKey, err error) (*Resource, error)
}

type Handler struct {
	Key ResourceKey
	// contains filtered or unexported fields
}

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

type ReadProcessType int

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

type RepositoryHandler interface {
	SourceDataStore
	CacheStore
	RepositoryMonitor
	RepositoryHook
}

type RepositoryHook interface {
	BeforeResourceCache(key ResourceKey)
}

type RepositoryMonitor interface {
	AddFindRecord(key ResourceKey, hit bool, downgrade bool, err error, total time.Duration)
}

type Resource struct {
	Key  ResourceKey
	Data interface{}
}

type ResourceHandler struct {
	Category                string
	FetchFromStoreFunc      func(ctx context.Context, id ResourceKey) (*Resource, error)
	UpdateCacheFunc         func(ctx context.Context, data Resource) error
	FindFromCacheFunc       func(ctx context.Context, id ResourceKey) (*Resource, error)
	DisableCache            func(ctx context.Context, id ResourceKey) error
	ThroughOnCacheErr       func(ctx context.Context, resource ResourceKey, err error) (goThrough bool)   // go through on cache err, store limiter will also work
	DowngradeOnErr          func(ctx context.Context, resource ResourceKey, err error) (*Resource, error) //data downgrading
	BeforeResourceCacheFunc func(key ResourceKey)
}

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

type ResourceKey struct {
	Category string // used for category, helper field
	ID       string
}

type SourceDataStore interface {
	// return nil, if not exists
	FetchFromStore(ctx context.Context, id ResourceKey) (*Resource, error)
}

type Span struct {
	Hit             bool
	ReadProcessType ReadProcessType
	CacheRead       time.Duration
	StoreRead       time.Duration
	DowngradeRead   time.Duration
	WaitDuration    time.Duration
}

type Tracers interface {
	OpenTracer(error) Span
}