cache

package

v1.0.4 Latest Latest Go to latest Published: May 26, 2026 License: MIT Imports: 21 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/MxOrbit/GitHubActionCacheServer

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
func ReadScopesByPermission(scope auth.CacheScope) []string
func WriteScope(scope auth.CacheScope) (string, bool)
type CreateUploadResult
type MatchResult
type Options
type Service
- func NewService(options Options) *Service

Constants ¶

This section is empty.

Variables ¶

View Source

var (
	ErrNoWriteScope        = errors.New("no scope with write permission found")
	ErrUploadAlreadyExists = errors.New("upload already exists")
	ErrUploadNotFound      = errors.New("upload not found")
	ErrNoPartsUploaded     = errors.New("no parts have been uploaded")
	ErrPartsStillUploading = errors.New("not all parts have been uploaded")
	ErrPartCountMismatch   = errors.New("uploaded part count does not match actual part count in storage")
	ErrCacheNotFound       = errors.New("cache not found")
)

Functions ¶

func ReadScopesByPermission ¶

func ReadScopesByPermission(scope auth.CacheScope) []string

func WriteScope ¶

func WriteScope(scope auth.CacheScope) (string, bool)

Types ¶

type CreateUploadResult ¶

type CreateUploadResult struct {
	UploadID int64
}

type MatchResult ¶

type MatchResult struct {
	CacheEntry  *ent.CacheEntry
	DownloadURL string
}

type Options ¶

type Options struct {
	DB                    *ent.Client
	Storage               storage.Adapter
	EnableDirectDownloads bool
	MergeConcurrency      int
}

type Service ¶

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

func NewService ¶

func NewService(options Options) *Service

func (*Service) CommitBlockList ¶

func (s *Service) CommitBlockList(ctx context.Context, uploadID int64, blockIDs []string) error

func (*Service) CompleteUpload ¶

func (s *Service) CompleteUpload(ctx context.Context, key, version string, scope auth.CacheScope) (int64, error)

func (*Service) CreateUpload ¶

func (s *Service) CreateUpload(ctx context.Context, key, version string, scope auth.CacheScope) (*CreateUploadResult, error)

func (*Service) Download ¶

func (s *Service) Download(ctx context.Context, cacheEntryID string) (io.ReadCloser, error)

func (*Service) GetCacheEntryWithDownloadURL ¶

func (s *Service) GetCacheEntryWithDownloadURL(ctx context.Context, keys []string, version string, scope auth.CacheScope, fallbackDownloadURL func(string) string) (*MatchResult, error)

func (*Service) MatchCacheEntry ¶

func (s *Service) MatchCacheEntry(ctx context.Context, keys []string, version string, scope auth.CacheScope) (*ent.CacheEntry, error)

func (*Service) StopAcceptingMerges ¶

func (s *Service) StopAcceptingMerges()

func (*Service) UploadBlock ¶

func (s *Service) UploadBlock(ctx context.Context, uploadID int64, blockID string, stream io.Reader) error

func (*Service) UploadPart ¶

func (s *Service) UploadPart(ctx context.Context, uploadID int64, partIndex int, stream io.Reader) error

func (*Service) WaitForMerges ¶

func (s *Service) WaitForMerges(ctx context.Context) error

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL