snapshot

Documentation

Overview

Package snapshot provides fast in-memory or on-file implementations of endpoint for storing snapshots

Index

• type BoltSnapshot
  • func NewBoltSnapshot(folderPath, name string) (*BoltSnapshot, error)
  • func (s *BoltSnapshot) Capture(ctx context.Context, source model.PathSyncSource, paths ...string) error
  • func (s *BoltSnapshot) Close(delete ...bool)
  • func (s *BoltSnapshot) ComputeChecksum(node *tree.Node) error
  • func (s *BoltSnapshot) CreateNode(ctx context.Context, node *tree.Node, updateIfExists bool) (err error)
  • func (s *BoltSnapshot) DeleteNode(ctx context.Context, path string) (err error)
  • func (s *BoltSnapshot) FinishSession(ctx context.Context, sessionUuid string) error
  • func (s *BoltSnapshot) FlushSession(ctx context.Context, sessionUuid string) error
  • func (s *BoltSnapshot) GetEndpointInfo() model.EndpointInfo
  • func (s *BoltSnapshot) IsEmpty() bool
  • func (s *BoltSnapshot) LoadNode(ctx context.Context, path string, extendedStats ...bool) (node *tree.Node, err error)
  • func (s *BoltSnapshot) MoveNode(ctx context.Context, oldPath string, newPath string) (err error)
  • func (s *BoltSnapshot) StartSession(ctx context.Context, rootNode *tree.Node, silent bool) (*tree.IndexationSession, error)
  • func (s *BoltSnapshot) Walk(walknFc model.WalkNodesFunc, root string, recursive bool) (err error)
  • func (s *BoltSnapshot) Watch(recursivePath string) (*model.WatchObject, error)

Types

type BoltSnapshot

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

func NewBoltSnapshot

func NewBoltSnapshot(folderPath, name string) (*BoltSnapshot, error)

func (*BoltSnapshot) Capture

func (s *BoltSnapshot) Capture(ctx context.Context, source model.PathSyncSource, paths ...string) error

func (*BoltSnapshot) Close

func (s *BoltSnapshot) Close(delete ...bool)

func (*BoltSnapshot) ComputeChecksum

func (s *BoltSnapshot) ComputeChecksum(node *tree.Node) error

func (*BoltSnapshot) CreateNode

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

func (*BoltSnapshot) DeleteNode

func (s *BoltSnapshot) DeleteNode(ctx context.Context, path string) (err error)

func (*BoltSnapshot) FinishSession

func (s *BoltSnapshot) FinishSession(ctx context.Context, sessionUuid string) error

func (*BoltSnapshot) FlushSession

func (s *BoltSnapshot) FlushSession(ctx context.Context, sessionUuid string) error

func (*BoltSnapshot) GetEndpointInfo

func (s *BoltSnapshot) GetEndpointInfo() model.EndpointInfo

func (*BoltSnapshot) IsEmpty

func (s *BoltSnapshot) IsEmpty() bool

func (*BoltSnapshot) LoadNode

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

func (*BoltSnapshot) MoveNode

func (s *BoltSnapshot) MoveNode(ctx context.Context, oldPath string, newPath string) (err error)

func (*BoltSnapshot) StartSession

func (s *BoltSnapshot) StartSession(ctx context.Context, rootNode *tree.Node, silent bool) (*tree.IndexationSession, error)

func (*BoltSnapshot) Walk

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

func (*BoltSnapshot) Watch

func (s *BoltSnapshot) Watch(recursivePath string) (*model.WatchObject, error)