postgres

Documentation

Index

• Constants
• type Backend
  • func NewPostgresBackend(connectionString string) (*Backend, error)
  • func (b *Backend) AddUploadPart(repoKey string, id int, part s.CachePart) error
  • func (b *Backend) CreateCache(repoKey, key, version string, scopes []s.Scope, backend string) (int, error)
  • func (b *Backend) FinishCache(repoKey string, id int, path string) error
  • func (b *Backend) Migrate() error
  • func (b *Backend) SearchCache(repoKey, key, version string, scopes []s.Scope, restoreKeys []string) (s.Cache, error)
  • func (b *Backend) Type() string
  • func (b *Backend) ValidateUpload(repoKey string, id int, size int64) ([]s.CachePart, error)

Constants

const (
	SetCacheFinished   = `UPDATE cache SET finished = TRUE, storage_path = $1 WHERE repository = $2 AND cache_id = $3;`
	SearchCacheExact   = `` /* 170-byte string literal not displayed */
	SearchCachePartial = `` /* 175-byte string literal not displayed */

	InsertPart  = `` /* 129-byte string literal not displayed */
	GetAllParts = `` /* 136-byte string literal not displayed */
)

const InsertNewCache = `` /* 148-byte string literal not displayed */

Types

type Backend

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

func NewPostgresBackend

func NewPostgresBackend(connectionString string) (*Backend, error)

func (*Backend) AddUploadPart

func (b *Backend) AddUploadPart(repoKey string, id int, part s.CachePart) error

func (*Backend) CreateCache

func (b *Backend) CreateCache(repoKey, key, version string, scopes []s.Scope, backend string) (int, error)

func (*Backend) FinishCache

func (b *Backend) FinishCache(repoKey string, id int, path string) error

func (*Backend) Migrate

func (b *Backend) Migrate() error

func (*Backend) SearchCache

func (b *Backend) SearchCache(repoKey, key, version string, scopes []s.Scope, restoreKeys []string) (s.Cache, error)

func (*Backend) Type

func (b *Backend) Type() string

func (*Backend) ValidateUpload

func (b *Backend) ValidateUpload(repoKey string, id int, size int64) ([]s.CachePart, error)