s3ds

README

S3 Datastore Implementation

This is an implementation of the datastore interface backed by amazon s3.

NOTE: Plugins only work on Linux and MacOS at the moment. You can track the progress of this issue here: https://github.com/golang/go/issues/19282

Building and Installing

You can this plugin by running make build. You can then install it into your local IPFS repo by running make install.

Plugins need to be built against the correct version of go-ipfs. This package generally tracks the latest go-ipfs release but if you need to build against a different version, please set the IPFS_VERSION environment variable.

You can set IPFS_VERSION to:

• vX.Y.Z to build against that version of IPFS.
• $commit or $branch to build against a specific go-ipfs commit or branch.
• /absolute/path/to/source to build against a specific go-ipfs checkout.

To update the go-ipfs, run:

> make go.mod IPFS_VERSION=version

Contribute

Feel free to join in. All welcome. Open an issue!

This repository falls under the IPFS Code of Conduct.

Want to hack on IPFS?

License

MIT

Documentation

Index

• type Config
• type S3Bucket
  • func NewS3Datastore(conf Config) (*S3Bucket, error)
  • func (s *S3Bucket) Batch() (ds.Batch, error)
  • func (s *S3Bucket) Close() error
  • func (s *S3Bucket) Delete(k ds.Key) error
  • func (s *S3Bucket) Get(k ds.Key) ([]byte, error)
  • func (s *S3Bucket) GetSize(k ds.Key) (size int, err error)
  • func (s *S3Bucket) Has(k ds.Key) (exists bool, err error)
  • func (s *S3Bucket) Put(k ds.Key, value []byte) error
  • func (s *S3Bucket) Query(q dsq.Query) (dsq.Results, error)

Types

type Config

type Config struct {
	AccessKey      string
	SecretKey      string
	SessionToken   string
	Bucket         string
	Region         string
	RegionEndpoint string
	RootDirectory  string
	Workers        int
}

type S3Bucket

type S3Bucket struct {
	Config
	S3 *s3.S3
}

func NewS3Datastore

func NewS3Datastore(conf Config) (*S3Bucket, error)

func (*S3Bucket) Batch

func (s *S3Bucket) Batch() (ds.Batch, error)

func (*S3Bucket) Close

func (s *S3Bucket) Close() error

func (*S3Bucket) Delete

func (s *S3Bucket) Delete(k ds.Key) error

func (*S3Bucket) Get

func (s *S3Bucket) Get(k ds.Key) ([]byte, error)

func (*S3Bucket) GetSize

func (s *S3Bucket) GetSize(k ds.Key) (size int, err error)

func (*S3Bucket) Has

func (s *S3Bucket) Has(k ds.Key) (exists bool, err error)

func (*S3Bucket) Put

func (s *S3Bucket) Put(k ds.Key, value []byte) error

func (*S3Bucket) Query

func (s *S3Bucket) Query(q dsq.Query) (dsq.Results, error)