s3datastore

Documentation

Index

• Variables
• type S3Datastore
  • func (ds *S3Datastore) Batch() (datastore.Batch, error)
  • func (ds *S3Datastore) Close() error
  • func (ds *S3Datastore) Delete(key datastore.Key) (err error)
  • func (ds *S3Datastore) Get(key datastore.Key) (value interface{}, err error)
  • func (ds *S3Datastore) Has(key datastore.Key) (exists bool, err error)
  • func (ds *S3Datastore) IsThreadSafe()
  • func (ds *S3Datastore) Put(key datastore.Key, value interface{}) (err error)
  • func (ds *S3Datastore) Query(q query.Query) (query.Results, error)

Variables

var ErrInvalidType = errors.New("s3 datastore: invalid type error")

Types

type S3Datastore

type S3Datastore struct {
	Client *s3.S3
	Bucket string
	ACL    s3.ACL
}

func (*S3Datastore) Batch

func (ds *S3Datastore) Batch() (datastore.Batch, error)

func (*S3Datastore) Close

func (ds *S3Datastore) Close() error

func (*S3Datastore) Delete

func (ds *S3Datastore) Delete(key datastore.Key) (err error)

func (*S3Datastore) Get

func (ds *S3Datastore) Get(key datastore.Key) (value interface{}, err error)

func (*S3Datastore) Has

func (ds *S3Datastore) Has(key datastore.Key) (exists bool, err error)

func (*S3Datastore) IsThreadSafe

func (ds *S3Datastore) IsThreadSafe()

func (*S3Datastore) Put

func (ds *S3Datastore) Put(key datastore.Key, value interface{}) (err error)

func (*S3Datastore) Query

func (ds *S3Datastore) Query(q query.Query) (query.Results, error)