propagator

Documentation

Index

• type AsyncPropagator
  • func NewAsyncPropagator(treeSizeAccounting, treeTimeAccounting bool, o options.AsyncPropagatorOptions, ...) AsyncPropagator
  • func (p AsyncPropagator) Propagate(ctx context.Context, n *node.Node, sizeDiff int64) error
• type Change
• type Propagator
  • func New(lookup node.PathLookup, o *options.Options) Propagator
• type SyncPropagator
  • func NewSyncPropagator(treeSizeAccounting, treeTimeAccounting bool, lookup node.PathLookup) SyncPropagator
  • func (p SyncPropagator) Propagate(ctx context.Context, n *node.Node, sizeDiff int64) error

Types

type AsyncPropagator

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

AsyncPropagator implements asynchronous treetime & treesize propagation

func NewAsyncPropagator

func NewAsyncPropagator(treeSizeAccounting, treeTimeAccounting bool, o options.AsyncPropagatorOptions, lookup node.PathLookup) AsyncPropagator

NewAsyncPropagator returns a new AsyncPropagator instance

func (AsyncPropagator) Propagate

func (p AsyncPropagator) Propagate(ctx context.Context, n *node.Node, sizeDiff int64) error

Propagate triggers a propagation

type Change

type Change struct {
	SyncTime time.Time
	SizeDiff int64
}

Change represents a change to the tree

type Propagator

type Propagator interface {
	Propagate(ctx context.Context, node *node.Node, sizediff int64) error
}

func New

func New(lookup node.PathLookup, o *options.Options) Propagator

type SyncPropagator

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

SyncPropagator implements synchronous treetime & treesize propagation

func NewSyncPropagator

func NewSyncPropagator(treeSizeAccounting, treeTimeAccounting bool, lookup node.PathLookup) SyncPropagator

NewSyncPropagator returns a new AsyncPropagator instance

func (SyncPropagator) Propagate

func (p SyncPropagator) Propagate(ctx context.Context, n *node.Node, sizeDiff int64) error

Propagate triggers a propagation