openeth

Documentation

Index

• type Superviser
  • func NewSuperviser(binary string, dataDir string, ipcFilePath string, arguments []string, ...) (*Superviser, error)
  • func (s *Superviser) AddPeer(peer string) error
  • func (s *Superviser) EnsurePeersByDNS(wantedPeersHostnames []string)
  • 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) Monitor()
  • func (s *Superviser) ServerID() (string, error)

Types

type Superviser

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

func NewSuperviser

func NewSuperviser(
	binary string,
	dataDir string,
	ipcFilePath string,
	arguments []string,
	debugDeepMind bool,
	headBlockUpdateFunc nodeManager.HeadBlockUpdater,
	enforcePeersStr string,
	logToZap bool,
	appLogger *zap.Logger,
	nodelogger *zap.Logger,
) (*Superviser, error)

func (*Superviser) AddPeer

func (s *Superviser) AddPeer(peer string) error

AddPeer sends a command through IPC socket to connect geth to the given peer

func (*Superviser) EnsurePeersByDNS

func (s *Superviser) EnsurePeersByDNS(wantedPeersHostnames []string)

EnsurePeersByDNS periodically checks IP addresses on the given FQDNs, calls /v1/server_id on port 8080 and adds them as peers wantedPeersHostnames can point to the headless service name in k8s

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) Monitor

func (s *Superviser) Monitor()

Monitor periodically checks the head block num and block time, as well as the enode string (server ID)

func (*Superviser) ServerID

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