memory

Documentation

Overview

Package memory provides an in-memory basic implementation of an Endpoint, with nodes stored in a map.

Index

• type DBEvent
• type MemDB
  • func NewMemDB() *MemDB
  • func (c *MemDB) AddIgnore(s string)
  • func (db *MemDB) ComputeChecksum(node *tree.Node) error
  • func (db *MemDB) CreateNode(ctx context.Context, node *tree.Node, updateIfExists bool) (err error)
  • func (db *MemDB) DeleteNode(ctx context.Context, path string) (err error)
  • func (db *MemDB) FindByHash(hash string) (node *tree.Node)
  • func (db *MemDB) FindByUuid(id string) (node *tree.Node)
  • func (db *MemDB) FromJSON(name string) error
  • func (c *MemDB) GetEndpointInfo() model.EndpointInfo
  • func (db *MemDB) LoadNode(ctx context.Context, path string, extendedStats ...bool) (node *tree.Node, err error)
  • func (db *MemDB) MoveNode(ctx context.Context, oldPath string, newPath string) (err error)
  • func (db *MemDB) RegisterEventChannel(out chan DBEvent)
  • func (c *MemDB) SetTestPathURI(s string)
  • func (db *MemDB) Stats() string
  • func (db *MemDB) String() string
  • func (db *MemDB) ToJSON(name string) error
  • func (db *MemDB) Walk(walknFc model.WalkNodesFunc, root string, recursive bool) (err error)
  • func (db *MemDB) Watch(recursivePath string) (*model.WatchObject, error)
• type MemDBWithCacheTest
  • func NewMemDBWithCacheTest() *MemDBWithCacheTest
  • func (m *MemDBWithCacheTest) GetCachedBranches(ctx context.Context, roots ...string) model.PathSyncSource

Types

type DBEvent

type DBEvent struct {
	Type   string
	Source string
	Target string
}

type MemDB

type MemDB struct {
	Nodes []*tree.Node
	// contains filtered or unexported fields
}

func NewMemDB

func NewMemDB() *MemDB

func (*MemDB) AddIgnore

func (c *MemDB) AddIgnore(s string)

AddIgnore register a filename to be ignored (for tests only)

func (*MemDB) ComputeChecksum

func (db *MemDB) ComputeChecksum(node *tree.Node) error

func (*MemDB) CreateNode

func (db *MemDB) CreateNode(ctx context.Context, node *tree.Node, updateIfExists bool) (err error)

func (*MemDB) DeleteNode

func (db *MemDB) DeleteNode(ctx context.Context, path string) (err error)

func (*MemDB) FindByHash

func (db *MemDB) FindByHash(hash string) (node *tree.Node)

func (*MemDB) FindByUuid

func (db *MemDB) FindByUuid(id string) (node *tree.Node)

func (*MemDB) FromJSON

func (db *MemDB) FromJSON(name string) error

func (*MemDB) GetEndpointInfo

func (c *MemDB) GetEndpointInfo() model.EndpointInfo

func (*MemDB) LoadNode

func (db *MemDB) LoadNode(ctx context.Context, path string, extendedStats ...bool) (node *tree.Node, err error)

***********************

Path Sync Target

***********************

func (*MemDB) MoveNode

func (db *MemDB) MoveNode(ctx context.Context, oldPath string, newPath string) (err error)

func (*MemDB) RegisterEventChannel

func (db *MemDB) RegisterEventChannel(out chan DBEvent)

***********************

Event Emitter

***********************

func (*MemDB) SetTestPathURI

func (c *MemDB) SetTestPathURI(s string)

func (*MemDB) Stats

func (db *MemDB) Stats() string

func (*MemDB) String

func (db *MemDB) String() string

func (*MemDB) ToJSON

func (db *MemDB) ToJSON(name string) error

func (*MemDB) Walk

func (db *MemDB) Walk(walknFc model.WalkNodesFunc, root string, recursive bool) (err error)

***********************

Path Sync Source

***********************

func (*MemDB) Watch

func (db *MemDB) Watch(recursivePath string) (*model.WatchObject, error)

type MemDBWithCacheTest

type MemDBWithCacheTest struct {
	MemDB
}

MemDBWithCacheTest provides a structure for testing CachedBranchProvider related functions

func NewMemDBWithCacheTest

func NewMemDBWithCacheTest() *MemDBWithCacheTest

NewMemDBWithCacheTest creates a new MemDB implementing CachedBranchProvider interface

func (*MemDBWithCacheTest) GetCachedBranches

func (m *MemDBWithCacheTest) GetCachedBranches(ctx context.Context, roots ...string) model.PathSyncSource

GetCachedBranches loads branch in memory