scalablestore

Documentation

Index

• type S3Manager
  • func NewS3Manager(confCtx *config.Context) *S3Manager
  • func (s *S3Manager) Get(key string) (*ScalableStoreGetResponse, error)
  • func (s *S3Manager) IsEligibleForBootstrap() (bool, error)
  • func (s *S3Manager) Put(key string, body io.ReadSeeker) error
• type ScalableStoreGetResponse

Types

type S3Manager

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

func NewS3Manager

func NewS3Manager(confCtx *config.Context) *S3Manager

func (*S3Manager) Get

func (s *S3Manager) Get(key string) (*ScalableStoreGetResponse, error)

this can panic() on context deadline

func (*S3Manager) IsEligibleForBootstrap

func (s *S3Manager) IsEligibleForBootstrap() (bool, error)

bucket is eligible for bootstrap if it is completely empty

func (*S3Manager) Put

func (s *S3Manager) Put(key string, body io.ReadSeeker) error

type ScalableStoreGetResponse

type ScalableStoreGetResponse struct {
	Body io.ReadCloser
}