store

Documentation

Index

• type S3DataStore
  • func New(aKeyID string, aSecretKey string, endP string, bName string, logSEndP string) S3DataStore
  • func (ds S3DataStore) GetSnapshot(msg chan *pbUtils.LogOperation) <-chan error
  • func (ds S3DataStore) Op(op *pbUtils.LogOperation)
  • func (ds S3DataStore) SubscribeOps(msg chan *pbUtils.LogOperation, ack chan bool, sync bool) (*grpc.ClientConn, <-chan error)

Types

type S3DataStore

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

S3DataStore represents a s3datastore object

func New

func New(aKeyID string, aSecretKey string, endP string, bName string, logSEndP string) S3DataStore

New creates and initializes an instance of S3S3DataStore

func (S3DataStore) GetSnapshot

func (ds S3DataStore) GetSnapshot(msg chan *pbUtils.LogOperation) <-chan error

GetSnapshot reads a snapshot of all objects in the specified bucket, and their metadata attributes by performing a http GET request to list all objects in the bucket and the a http HEAD to read the metadata attributes of each object

func (S3DataStore) Op

func (ds S3DataStore) Op(op *pbUtils.LogOperation)

Op ...

func (S3DataStore) SubscribeOps

func (ds S3DataStore) SubscribeOps(msg chan *pbUtils.LogOperation, ack chan bool, sync bool) (*grpc.ClientConn, <-chan error)

SubscribeOps subscribes to updates from scality/cloudserver (supports sync and async mode) each time an update is received, it is formated as a pbUtils.LogOperation and sent to datastoredriver via a channel