proxystore

package

v0.10.0 Latest Latest Go to latest Published: Jun 13, 2024 License: Apache-2.0 Imports: 7 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

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

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

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

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

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

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

func (store *ProxyStore) FetchDocuments(
	namespaceName, collectionName 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