elastic

Documentation

Index

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

Types

type ESEntry

type ESEntry struct {
	ParentId string `json:"ParentId"`
	Entry    *filer.Entry
}

type ESKVEntry

type ESKVEntry struct {
	Value []byte `json:"Value"`
}

type ElasticStore

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

func (*ElasticStore) BeginTransaction

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

func (*ElasticStore) CommitTransaction

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

func (*ElasticStore) DeleteEntry

func (store *ElasticStore) DeleteEntry(ctx context.Context, fullpath weed_util.FullPath) (err error)

func (*ElasticStore) DeleteFolderChildren

func (store *ElasticStore) DeleteFolderChildren(ctx context.Context, fullpath weed_util.FullPath) (err error)

func (*ElasticStore) FindEntry

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

func (*ElasticStore) GetName

func (store *ElasticStore) GetName() string

func (*ElasticStore) Initialize

func (store *ElasticStore) Initialize(configuration weed_util.Configuration, prefix string) (err error)

func (*ElasticStore) InsertEntry

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

func (*ElasticStore) KvDelete

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

func (*ElasticStore) KvGet

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

func (*ElasticStore) KvPut

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

func (*ElasticStore) ListDirectoryEntries

func (store *ElasticStore) ListDirectoryEntries(
	ctx context.Context, fullpath weed_util.FullPath, startFileName string, inclusive bool, limit int,
) (entries []*filer.Entry, err error)

func (*ElasticStore) ListDirectoryPrefixedEntries

func (store *ElasticStore) ListDirectoryPrefixedEntries(ctx context.Context, fullpath weed_util.FullPath, startFileName string, inclusive bool, limit int, prefix string) (entries []*filer.Entry, err error)

func (*ElasticStore) RollbackTransaction

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

func (*ElasticStore) Shutdown

func (store *ElasticStore) Shutdown()

func (*ElasticStore) UpdateEntry

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