mirror

Documentation

Index

• type Coordinator
  • func NewCoordinator(dedup *trie.Dedup) *Coordinator
  • func (c *Coordinator) Fetch(ctx context.Context, conn *wire.KeyTreeClient, parallelism int, ...) (*trie.Node, error)
• type Mirror
  • func NewMirror(ctx context.Context, coordinator *Coordinator, conn *wire.KeyTreeClient, ...) *Mirror
  • func (m *Mirror) Run() error
• type TrieFollower

Types

type Coordinator

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

func NewCoordinator

func NewCoordinator(dedup *trie.Dedup) *Coordinator

func (*Coordinator) Fetch

func (c *Coordinator) Fetch(ctx context.Context, conn *wire.KeyTreeClient, parallelism int, hash crypto.Hash, old *trie.Node) (*trie.Node, error)

type Mirror

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

func NewMirror

func NewMirror(ctx context.Context, coordinator *Coordinator, conn *wire.KeyTreeClient, address, publicKey string, initial *trie.Node, follower TrieFollower) *Mirror

func (*Mirror) Run

func (m *Mirror) Run() error

type TrieFollower

type TrieFollower interface {
	FullSync(*wire.SignedRoot, *trie.Node)
	PartialSync(*wire.SignedRoot, *trie.Node)
	Updated(*wire.SignedRoot, *trie.Node, []*wire.TrieLeaf)
}