nodemanager

Documentation

Index

• type Bootstrapper
  • func NewBootstrapper(dataURL string, dataDirPath string, logger *zap.Logger) *Bootstrapper
  • func (b *Bootstrapper) Bootstrap() error
• type Options
• type Snapshotter
  • func NewSnapshotter(localDir, genesisURL string, snapshotStore, mergedBlockStore dstore.Store) *Snapshotter
  • func (s *Snapshotter) Backup(lastSeenBlockNum uint32) (string, error)
  • func (s *Snapshotter) List(params map[string]string) ([]string, error)
  • func (s *Snapshotter) RequiresStop() bool
  • func (s *Snapshotter) Restore(snapshotName string) error
• type Superviser
  • func NewSuperviser(supervisorName string, appLogger *zap.Logger, nodelogger *zap.Logger, ...) (*Superviser, error)
  • func (s *Superviser) GetCommand() string
  • func (s *Superviser) GetName() string
  • func (s *Superviser) HasData() bool
  • func (s *Superviser) LastSeenBlockNum() uint64
  • func (s *Superviser) MarshalLogObject(enc zapcore.ObjectEncoder) error
  • func (s *Superviser) ServerID() (string, error)
  • func (s *Superviser) Start(options ...nodeManager.StartOption) error

Types

type Bootstrapper

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

func NewBootstrapper

func NewBootstrapper(dataURL string, dataDirPath string, logger *zap.Logger) *Bootstrapper

func (*Bootstrapper) Bootstrap

func (b *Bootstrapper) Bootstrap() error

type Options

type Options struct {
	BinaryPath          string
	Arguments           []string
	DataDirPath         string
	RCPPort             string
	LogToZap            bool
	DebugFirehoseLogs   bool
	HeadBlockUpdateFunc nodeManager.HeadBlockUpdater
}

type Snapshotter

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

func NewSnapshotter

func NewSnapshotter(localDir, genesisURL string, snapshotStore, mergedBlockStore dstore.Store) *Snapshotter

func (*Snapshotter) Backup

func (s *Snapshotter) Backup(lastSeenBlockNum uint32) (string, error)

func (*Snapshotter) List

func (s *Snapshotter) List(params map[string]string) ([]string, error)

func (*Snapshotter) RequiresStop

func (s *Snapshotter) RequiresStop() bool

func (*Snapshotter) Restore

func (s *Snapshotter) Restore(snapshotName string) error

type Superviser

type Superviser struct {
	*superviser.Superviser
	// contains filtered or unexported fields
}

func NewSuperviser

func NewSuperviser(supervisorName string, appLogger *zap.Logger, nodelogger *zap.Logger, options *Options) (*Superviser, error)

func (*Superviser) GetCommand

func (s *Superviser) GetCommand() string

func (*Superviser) GetName

func (s *Superviser) GetName() string

func (*Superviser) HasData

func (s *Superviser) HasData() bool

func (*Superviser) LastSeenBlockNum

func (s *Superviser) LastSeenBlockNum() uint64

func (*Superviser) MarshalLogObject

func (s *Superviser) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*Superviser) ServerID

func (s *Superviser) ServerID() (string, error)

func (*Superviser) Start

func (s *Superviser) Start(options ...nodeManager.StartOption) error