proxystore

Documentation

Index

• type ProxyStore
  • func New(storage storage.Storage, logger *zap.Logger) *ProxyStore
  • func (store *ProxyStore) CloseStore() error
  • func (store *ProxyStore) DeleteChangeLogs(logs []*spec.ChangeLog) error
  • func (store *ProxyStore) DeleteDocument(id, colName, nsName string) error
  • func (store *ProxyStore) FetchChangeLogs() ([]*spec.ChangeLog, error)
  • func (store *ProxyStore) FetchDocument(docId, colName, nsName string) (*spec.Document, error)
  • func (store *ProxyStore) FetchDocuments(collectionName string, namespaceName string, limit, offset int) ([]*spec.Document, error)
  • func (store *ProxyStore) InitStore() error
  • func (store *ProxyStore) StoreChangeLog(cl *spec.ChangeLog) error
  • func (store *ProxyStore) StoreDocument(doc *spec.Document) error
  • func (store *ProxyStore) StoreDocuments(docs []*spec.Document) error

Types

type ProxyStore

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

func New

func New(storage storage.Storage, logger *zap.Logger) *ProxyStore

func (*ProxyStore) CloseStore

func (store *ProxyStore) CloseStore() error

func (*ProxyStore) DeleteChangeLogs

func (store *ProxyStore) DeleteChangeLogs(logs []*spec.ChangeLog) error

func (*ProxyStore) DeleteDocument

func (store *ProxyStore) DeleteDocument(id, colName, nsName string) error

func (*ProxyStore) FetchChangeLogs

func (store *ProxyStore) FetchChangeLogs() ([]*spec.ChangeLog, error)

func (*ProxyStore) FetchDocument

func (store *ProxyStore) FetchDocument(docId, colName, nsName string) (*spec.Document, error)

func (*ProxyStore) FetchDocuments

func (store *ProxyStore) FetchDocuments(
	collectionName string,
	namespaceName string,
	limit, offset int,
) ([]*spec.Document, error)

func (*ProxyStore) InitStore

func (store *ProxyStore) InitStore() error

func (*ProxyStore) StoreChangeLog

func (store *ProxyStore) StoreChangeLog(cl *spec.ChangeLog) error

func (*ProxyStore) StoreDocument

func (store *ProxyStore) StoreDocument(doc *spec.Document) error

func (*ProxyStore) StoreDocuments

func (store *ProxyStore) StoreDocuments(docs []*spec.Document) error