mockdriver

Documentation

Index

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

Types

type MockDataStore

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

MockDataStore ...

func NewDatastore

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

NewDatastore ...

func (MockDataStore) GetNotificationLanency

func (ds MockDataStore) GetNotificationLanency() (float64, float64, float64, float64)

GetNotificationLanency ...

func (MockDataStore) GetSnapshot

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

GetSnapshot ...

func (MockDataStore) SubscribeOps

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