cache

type CacheKey struct {
	ID      string
	Results []Result
}

type Config struct {
	S3            *S3LayerStoreConfig
	ImportPeriod  time.Duration
	ExportPeriod  time.Duration
	ExportTimeout time.Duration
}

type ExportRecord struct {
	Digest     digest.Digest // record digest
	CacheRefID string        // worker cache id
}

type GetConfigRequest struct {
	CacheMountIDs []string
}

type LayerStore interface {
	content.Provider
	PushLayer(ctx context.Context, layer ocispecs.Descriptor, provider content.Provider) error
}

type Link struct {
	ID       string
	LinkedID string
	Input    int
	Digest   digest.Digest
	Selector digest.Digest
}

type Manager interface {
	solver.CacheManager
	StartCacheMountSynchronization(context.Context, *dagger.Client) error
	Close(context.Context) error
}

type ManagerConfig struct {
	KeyStore    solver.CacheKeyStorage
	ResultStore solver.CacheResultStorage
	Worker      worker.Worker
	ServiceURL  string
}

type RecordLayers struct {
	RecordDigest digest.Digest
	Layers       []ocispecs.Descriptor
}

type Result struct {
	ID          string
	CreatedAt   time.Time
	Description string
}

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

type S3LayerStoreConfig struct {
	Bucket             string
	Region             string
	EndpointURL        string
	UsePathStyle       bool
	BlobsPrefix        string
	CacheMountPrefixes []string
}

type S3ReaderAt struct {
	Ctx      context.Context
	Client   *s3.Client
	Bucket   string
	Key      string
	BlobSize int64
	// contains filtered or unexported fields
}

type Service interface {
	// GetConfig returns configuration needed for the engine to push layer blobs
	GetConfig(context.Context, GetConfigRequest) (*Config, error)

	// UpdateCacheRecords informs the cache service of the current state of the cache metadata.
	// It returns a list of cache refs that should be prepared for export and pushed.
	UpdateCacheRecords(context.Context, UpdateCacheRecordsRequest) (*UpdateCacheRecordsResponse, error)

	// UpdateCacheLayers tells the cache service that layers for the given records have been
	// uploaded with the given digests.
	UpdateCacheLayers(context.Context, UpdateCacheLayersRequest) error

	// ImportCache returns a cache config that the engine can turn into cache manager.
	ImportCache(ctx context.Context) (*remotecache.CacheConfig, error)
}

type UpdateCacheLayersRequest struct {
	UpdatedRecords []RecordLayers
}

type UpdateCacheRecordsRequest struct {
	CacheKeys []CacheKey
	Links     []Link
}

type UpdateCacheRecordsResponse struct {
	// cache records that the engine should prepare layers for and push
	ExportRecords []ExportRecord
}