node

Documentation

Overview

This package will expose some internal capability and is subject to change, use at your own risk

Index

• func InitializeFollowerFromSeed(workDir string, expectedPartitionType protocol.PartitionType, ...) error
• func SubscribeSync[T Event](b *Bus, sub func(T) error)
• type Bus
• type Daemon
  • func NewNode(workDir string, logWriter logger.LogWriter, nodeIndex int) (*Daemon, error)
• type DidCommitBlock
• type DidSaveSnapshot
• type Event
• type FatalError

Functions

func InitializeFollowerFromSeed

func InitializeFollowerFromSeed(workDir string, expectedPartitionType protocol.PartitionType, seedNodeUrl string) error

func SubscribeSync

func SubscribeSync[T Event](b *Bus, sub func(T) error)

SubscribeSync will expose the internal subscribe sync

Types

type Bus

type Bus = events.Bus

type Daemon

type Daemon = accumulated.Daemon

func NewNode

func NewNode(workDir string, logWriter logger.LogWriter, nodeIndex int) (*Daemon, error)

CreateNode specify working directory of configuration, a log writer callback, and nodeIndex (usually zero unless running a devnet with more than one node on the same BVN)

type DidCommitBlock

type DidCommitBlock = events.DidCommitBlock

type DidSaveSnapshot

type DidSaveSnapshot = events.DidSaveSnapshot

type Event

type Event = events.Event

type FatalError

type FatalError = events.FatalError