processmanager

Documentation

Index

• func CreateLink(binaryPath string)
• func FetchProtocolBinary(lavavisorPath string, autoDownload bool, ...) (selectedBinaryPath string, err error)
• func GetBinaryVersion(binaryPath string) (string, error)
• func SetupLavavisorDir(dir string) (lavavisorPath string, err error)
• func ValidateLavavisorDir(dir string) (lavavisorPath string, err error)
• type ServiceProcess
  • func StartProcess(processes []*ServiceProcess, process string, serviceDir string) []*ServiceProcess
• type VersionMonitor
  • func NewVersionMonitor(initVersion string, lavavisorPath string, processes []*ServiceProcess, ...) *VersionMonitor
  • func (vm *VersionMonitor) MonitorVersionUpdates(ctx context.Context)
  • func (vm *VersionMonitor) ValidateProtocolVersion(incoming *protocoltypes.Version) error

Functions

func CreateLink

func CreateLink(binaryPath string)

func FetchProtocolBinary

func FetchProtocolBinary(lavavisorPath string, autoDownload bool, protocolConsensusVersion *protocoltypes.Version) (selectedBinaryPath string, err error)

func GetBinaryVersion

func GetBinaryVersion(binaryPath string) (string, error)

func SetupLavavisorDir

func SetupLavavisorDir(dir string) (lavavisorPath string, err error)

func ValidateLavavisorDir

func ValidateLavavisorDir(dir string) (lavavisorPath string, err error)

Types

type ServiceProcess

type ServiceProcess struct {
	Name    string
	ChainID string
}

func StartProcess

func StartProcess(processes []*ServiceProcess, process string, serviceDir string) []*ServiceProcess

type VersionMonitor

type VersionMonitor struct {
	BinaryPath    string
	LavavisorPath string
	// contains filtered or unexported fields
}

func NewVersionMonitor

func NewVersionMonitor(initVersion string, lavavisorPath string, processes []*ServiceProcess, autoDownload bool) *VersionMonitor

func (*VersionMonitor) MonitorVersionUpdates

func (vm *VersionMonitor) MonitorVersionUpdates(ctx context.Context)

func (*VersionMonitor) ValidateProtocolVersion

func (vm *VersionMonitor) ValidateProtocolVersion(incoming *protocoltypes.Version) error