proxystore

package
v0.7.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 22, 2024 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type ProxyStore

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

func New

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

func (*ProxyStore) DeleteChangeLogs

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

func (*ProxyStore) DeleteDocument

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

func (*ProxyStore) DeleteDocuments

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

func (*ProxyStore) FetchChangeLogs

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

func (*ProxyStore) FetchDocument

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

func (*ProxyStore) FetchDocuments

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

func (*ProxyStore) InitStore

func (store *ProxyStore) InitStore() error

func (*ProxyStore) StoreChangeLog

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

TODO: add retry for failed store operations

func (*ProxyStore) StoreDocument

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL