s3driver

Documentation

Index

• type S3DataStore
  • func NewDatastore(conf *libqpu.QPUConfig, inputSchema libqpu.Schema) (S3DataStore, error)
  • func (ds S3DataStore) GetNotificationLanency() (float64, float64, float64, float64)
  • func (ds S3DataStore) GetSnapshot(table string, projection, isNull, isNotNull []string) (<-chan libqpu.LogOperation, <-chan error)
  • func (ds S3DataStore) SubscribeOps(table string) (<-chan libqpu.LogOperation, context.CancelFunc, <-chan error)

Types

type S3DataStore

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

S3DataStore ...

func NewDatastore

func NewDatastore(conf *libqpu.QPUConfig, inputSchema libqpu.Schema) (S3DataStore, error)

NewDatastore ...

func (S3DataStore) GetNotificationLanency

func (ds S3DataStore) GetNotificationLanency() (float64, float64, float64, float64)

GetNotificationLanency ...

func (S3DataStore) GetSnapshot

func (ds S3DataStore) GetSnapshot(table string, projection, isNull, isNotNull []string) (<-chan libqpu.LogOperation, <-chan error)

GetSnapshot ...

func (S3DataStore) SubscribeOps

func (ds S3DataStore) SubscribeOps(table string) (<-chan libqpu.LogOperation, context.CancelFunc, <-chan error)

SubscribeOps ...