meta_cache

Documentation

Index

• func EnsureVisited(mc *MetaCache, client filer_pb.FilerClient, dirPath util.FullPath) error
• func SubscribeMetaEvents(mc *MetaCache, selfSignature int32, client filer_pb.FilerClient, dir string, ...) error
• type IdMapper
  • func (m *IdMapper) FilerToLocal(id uint32) uint32
  • func (m *IdMapper) LocalToFiler(id uint32) uint32
• type MetaCache
  • func NewMetaCache(dbFolder string, baseDir util.FullPath, uidGidMapper *UidGidMapper) *MetaCache
  • func (mc *MetaCache) AtomicUpdateEntryFromFiler(ctx context.Context, oldPath util.FullPath, newEntry *filer.Entry) error
  • func (mc *MetaCache) DeleteEntry(ctx context.Context, fp util.FullPath) (err error)
  • func (mc *MetaCache) FindEntry(ctx context.Context, fp util.FullPath) (entry *filer.Entry, err error)
  • func (mc *MetaCache) InsertEntry(ctx context.Context, entry *filer.Entry) error
  • func (mc *MetaCache) ListDirectoryEntries(ctx context.Context, dirPath util.FullPath, startFileName string, ...) ([]*filer.Entry, error)
  • func (mc *MetaCache) Shutdown()
  • func (mc *MetaCache) UpdateEntry(ctx context.Context, entry *filer.Entry) error
• type UidGidMapper
  • func NewUidGidMapper(uidPairsStr, gidPairStr string) (*UidGidMapper, error)
  • func (m *UidGidMapper) FilerToLocal(uid, gid uint32) (uint32, uint32)
  • func (m *UidGidMapper) LocalToFiler(uid, gid uint32) (uint32, uint32)

Functions

func EnsureVisited

func EnsureVisited(mc *MetaCache, client filer_pb.FilerClient, dirPath util.FullPath) error

func SubscribeMetaEvents

func SubscribeMetaEvents(mc *MetaCache, selfSignature int32, client filer_pb.FilerClient, dir string, lastTsNs int64) error

Types

type IdMapper

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

func (*IdMapper) FilerToLocal

func (m *IdMapper) FilerToLocal(id uint32) uint32

func (*IdMapper) LocalToFiler

func (m *IdMapper) LocalToFiler(id uint32) uint32

type MetaCache

type MetaCache struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewMetaCache

func NewMetaCache(dbFolder string, baseDir util.FullPath, uidGidMapper *UidGidMapper) *MetaCache

func (*MetaCache) AtomicUpdateEntryFromFiler

func (mc *MetaCache) AtomicUpdateEntryFromFiler(ctx context.Context, oldPath util.FullPath, newEntry *filer.Entry) error

func (*MetaCache) DeleteEntry

func (mc *MetaCache) DeleteEntry(ctx context.Context, fp util.FullPath) (err error)

func (*MetaCache) FindEntry

func (mc *MetaCache) FindEntry(ctx context.Context, fp util.FullPath) (entry *filer.Entry, err error)

func (*MetaCache) InsertEntry

func (mc *MetaCache) InsertEntry(ctx context.Context, entry *filer.Entry) error

func (*MetaCache) ListDirectoryEntries

func (mc *MetaCache) ListDirectoryEntries(ctx context.Context, dirPath util.FullPath, startFileName string, includeStartFile bool, limit int) ([]*filer.Entry, error)

func (*MetaCache) Shutdown

func (mc *MetaCache) Shutdown()

func (*MetaCache) UpdateEntry

func (mc *MetaCache) UpdateEntry(ctx context.Context, entry *filer.Entry) error

type UidGidMapper

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

func NewUidGidMapper

func NewUidGidMapper(uidPairsStr, gidPairStr string) (*UidGidMapper, error)

UidGidMapper translates local uid/gid to filer uid/gid The local storage always persists the same as the filer. The local->filer translation happens when updating the filer first and later saving to meta_cache. And filer->local happens when reading from the meta_cache.

func (*UidGidMapper) FilerToLocal

func (m *UidGidMapper) FilerToLocal(uid, gid uint32) (uint32, uint32)

func (*UidGidMapper) LocalToFiler

func (m *UidGidMapper) LocalToFiler(uid, gid uint32) (uint32, uint32)