s3

Documentation

Index

• type Store
  • func New(endpoint string, accessKey string, secretKey string, bucket string, ...) (*Store, error)
  • func (s *Store) ChunkWrite(_ context.Context, name string, transactionID string, info *stotypes.ChunkInfo) error
  • func (s *Store) CompleteChunkWrite(_ context.Context, name string, transactionID string, ...) error
  • func (s *Store) CreateChunkWrite(_ context.Context, name string) (string, error)
  • func (s *Store) Delete(_ context.Context, name string, ignoreNotExists bool) error
  • func (s *Store) Get(_ context.Context, name string) (io.ReadCloser, error)
  • func (s *Store) GetDigest(ctx context.Context, name string) (string, error)
  • func (s *Store) GetSize(_ context.Context, name string) (int64, error)
  • func (s *Store) Move(ctx context.Context, src, dest string) error
  • func (s *Store) Put(_ context.Context, name string, digest string, in io.ReadSeeker) error
  • func (s *Store) PutWithChunk(ctx context.Context, name string, digest string, size int, chunkSize int, ...) error
  • func (s *Store) SeekRead(_ context.Context, name string, start int64) (io.ReadCloser, error)

Types

type Store

type Store struct {
	Endpoint  string
	AccessKey string
	SecretKey string
	Bucket    string
	BaseDir   string
	// contains filtered or unexported fields
}

func New

func New(endpoint string, accessKey string, secretKey string, bucket string, baseDir string, t *testing.T) (*Store, error)

func (*Store) ChunkWrite

func (s *Store) ChunkWrite(_ context.Context, name string, transactionID string, info *stotypes.ChunkInfo) error

func (*Store) CompleteChunkWrite

func (s *Store) CompleteChunkWrite(
	_ context.Context,
	name string,
	transactionID string,
	chunkList []*stotypes.ChunkInfo,
) error

func (*Store) CreateChunkWrite

func (s *Store) CreateChunkWrite(_ context.Context, name string) (string, error)

func (*Store) Delete

func (s *Store) Delete(_ context.Context, name string, ignoreNotExists bool) error

func (*Store) Get

func (s *Store) Get(_ context.Context, name string) (io.ReadCloser, error)

func (*Store) GetDigest

func (s *Store) GetDigest(ctx context.Context, name string) (string, error)

func (*Store) GetSize

func (s *Store) GetSize(_ context.Context, name string) (int64, error)

func (*Store) Move

func (s *Store) Move(ctx context.Context, src, dest string) error

func (*Store) Put

func (s *Store) Put(_ context.Context, name string, digest string, in io.ReadSeeker) error

func (*Store) PutWithChunk

func (s *Store) PutWithChunk(ctx context.Context, name string, digest string, size int, chunkSize int, in io.ReaderAt) error

func (*Store) SeekRead

func (s *Store) SeekRead(_ context.Context, name string, start int64) (io.ReadCloser, error)