settingsstate

Documentation

Index

• type ChangeFactory
  • func NewChangeFactory() ChangeFactory
• type ObjectDeletionState
  • func NewObjectDeletionState(log logger.CtxLogger, storage spacestorage.SpaceStorage) ObjectDeletionState
• type State
  • func NewState() *State
  • func NewStateFromSnapshot(snapshot *spacesyncproto.SpaceSettingsSnapshot, lastIteratedId string) *State
  • func (s *State) Exists(id string) bool
• type StateBuilder
  • func NewStateBuilder() StateBuilder
• type StateUpdateObserver

Types

type ChangeFactory

type ChangeFactory interface {
	CreateObjectDeleteChange(id string, state *State, isSnapshot bool) (res []byte, err error)
	CreateSpaceDeleteChange(peerId string, state *State, isSnapshot bool) (res []byte, err error)
}

func NewChangeFactory

func NewChangeFactory() ChangeFactory

type ObjectDeletionState

type ObjectDeletionState interface {
	AddObserver(observer StateUpdateObserver)
	Add(ids map[string]struct{})
	GetQueued() (ids []string)
	Delete(id string) (err error)
	Exists(id string) bool
	Filter(ids []string) (filtered []string)
}

func NewObjectDeletionState

func NewObjectDeletionState(log logger.CtxLogger, storage spacestorage.SpaceStorage) ObjectDeletionState

type State

type State struct {
	DeletedIds     map[string]struct{}
	DeleterId      string
	LastIteratedId string
}

func NewState

func NewState() *State

func NewStateFromSnapshot

func NewStateFromSnapshot(snapshot *spacesyncproto.SpaceSettingsSnapshot, lastIteratedId string) *State

func (*State) Exists

func (s *State) Exists(id string) bool

type StateBuilder

type StateBuilder interface {
	Build(tree objecttree.ReadableObjectTree, state *State) (*State, error)
}

func NewStateBuilder

func NewStateBuilder() StateBuilder

type StateUpdateObserver

type StateUpdateObserver func(ids []string)