mongodb

Documentation

Index

• type Model
• type MongodbStore
  • func (store *MongodbStore) BeginTransaction(ctx context.Context) (context.Context, error)
  • func (store *MongodbStore) CommitTransaction(ctx context.Context) error
  • func (store *MongodbStore) DeleteEntry(ctx context.Context, fullpath util.FullPath) error
  • func (store *MongodbStore) DeleteFolderChildren(ctx context.Context, fullpath util.FullPath) error
  • func (store *MongodbStore) FindEntry(ctx context.Context, fullpath util.FullPath) (entry *filer.Entry, err error)
  • func (store *MongodbStore) GetName() string
  • func (store *MongodbStore) Initialize(configuration util.Configuration, prefix string) (err error)
  • func (store *MongodbStore) InsertEntry(ctx context.Context, entry *filer.Entry) (err error)
  • func (store *MongodbStore) KvDelete(ctx context.Context, key []byte) (err error)
  • func (store *MongodbStore) KvGet(ctx context.Context, key []byte) (value []byte, err error)
  • func (store *MongodbStore) KvPut(ctx context.Context, key []byte, value []byte) (err error)
  • func (store *MongodbStore) ListDirectoryEntries(ctx context.Context, dirPath util.FullPath, startFileName string, ...) (lastFileName string, err error)
  • func (store *MongodbStore) ListDirectoryPrefixedEntries(ctx context.Context, dirPath util.FullPath, startFileName string, ...) (lastFileName string, err error)
  • func (store *MongodbStore) RollbackTransaction(ctx context.Context) error
  • func (store *MongodbStore) Shutdown()
  • func (store *MongodbStore) UpdateEntry(ctx context.Context, entry *filer.Entry) (err error)

Types

type Model

type Model struct {
	Directory string `bson:"directory"`
	Name      string `bson:"name"`
	Meta      []byte `bson:"meta"`
}

type MongodbStore

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

func (*MongodbStore) BeginTransaction

func (store *MongodbStore) BeginTransaction(ctx context.Context) (context.Context, error)

func (*MongodbStore) CommitTransaction

func (store *MongodbStore) CommitTransaction(ctx context.Context) error

func (*MongodbStore) DeleteEntry

func (store *MongodbStore) DeleteEntry(ctx context.Context, fullpath util.FullPath) error

func (*MongodbStore) DeleteFolderChildren

func (store *MongodbStore) DeleteFolderChildren(ctx context.Context, fullpath util.FullPath) error

func (*MongodbStore) FindEntry

func (store *MongodbStore) FindEntry(ctx context.Context, fullpath util.FullPath) (entry *filer.Entry, err error)

func (*MongodbStore) GetName

func (store *MongodbStore) GetName() string

func (*MongodbStore) Initialize

func (store *MongodbStore) Initialize(configuration util.Configuration, prefix string) (err error)

func (*MongodbStore) InsertEntry

func (store *MongodbStore) InsertEntry(ctx context.Context, entry *filer.Entry) (err error)

func (*MongodbStore) KvDelete

func (store *MongodbStore) KvDelete(ctx context.Context, key []byte) (err error)

func (*MongodbStore) KvGet

func (store *MongodbStore) KvGet(ctx context.Context, key []byte) (value []byte, err error)

func (*MongodbStore) KvPut

func (store *MongodbStore) KvPut(ctx context.Context, key []byte, value []byte) (err error)

func (*MongodbStore) ListDirectoryEntries

func (store *MongodbStore) ListDirectoryEntries(ctx context.Context, dirPath util.FullPath, startFileName string, includeStartFile bool, limit int64, eachEntryFunc filer.ListEachEntryFunc) (lastFileName string, err error)

func (*MongodbStore) ListDirectoryPrefixedEntries

func (store *MongodbStore) ListDirectoryPrefixedEntries(ctx context.Context, dirPath util.FullPath, startFileName string, includeStartFile bool, limit int64, prefix string, eachEntryFunc filer.ListEachEntryFunc) (lastFileName string, err error)

func (*MongodbStore) RollbackTransaction

func (store *MongodbStore) RollbackTransaction(ctx context.Context) error

func (*MongodbStore) Shutdown

func (store *MongodbStore) Shutdown()

func (*MongodbStore) UpdateEntry

func (store *MongodbStore) UpdateEntry(ctx context.Context, entry *filer.Entry) (err error)