s3

Documentation

Index

• type AllocTempDestFn
• type S3ChunkService
  • func NewS3ChunkService(AccessKey string, SecretKey string, endpoint string, bucket string, ...) *S3ChunkService
  • func (c *S3ChunkService) Delete(key *v2.Key)
  • func (c *S3ChunkService) Get(key *v2.Key) (v2.Resource, error)
  • func (c *S3ChunkService) Iterate() v2.KeyIterator
  • func (c *S3ChunkService) Put(key *v2.Key, resource v2.Resource) error
• type S3KeyIterator
  • func (c *S3KeyIterator) HasNext() bool
  • func (c *S3KeyIterator) Next() *v2.Key
• type S3Parameters

Types

type AllocTempDestFn

type AllocTempDestFn func() string

type S3ChunkService

type S3ChunkService struct {
	S3Parameters
	DownloadDir  string
	MaxFetchKeys int64
}

func NewS3ChunkService

func NewS3ChunkService(AccessKey string, SecretKey string, endpoint string, bucket string, prefix string, getDestFn AllocTempDestFn) *S3ChunkService

func (*S3ChunkService) Delete

func (c *S3ChunkService) Delete(key *v2.Key)

func (*S3ChunkService) Get

func (c *S3ChunkService) Get(key *v2.Key) (v2.Resource, error)

func (*S3ChunkService) Iterate

func (c *S3ChunkService) Iterate() v2.KeyIterator

func (*S3ChunkService) Put

func (c *S3ChunkService) Put(key *v2.Key, resource v2.Resource) error

type S3KeyIterator

type S3KeyIterator struct {
	Bucket       string
	Prefix       string
	MaxFetchKeys int64
	S3C          *ss.S3
	MorePages    bool
	NextMarker   string
	// contains filtered or unexported fields
}

func (*S3KeyIterator) HasNext

func (c *S3KeyIterator) HasNext() bool

func (*S3KeyIterator) Next

func (c *S3KeyIterator) Next() *v2.Key

type S3Parameters

type S3Parameters struct {
	EndPoint  string
	Bucket    string
	Keys      s3gof3r.Keys
	GetDestFn AllocTempDestFn
	Prefix    string
}