processmanager

Documentation

Index

• func AddGoPathToDollarPath(path string) error
• func GetBinaryVersion(binaryPath string) (string, error)
• func GetHomePath() (string, error)
• func ReloadDaemon() error
• func StartProcess(process string) error
• func ValidateMismatch(incoming *protocoltypes.Version, current string) bool
• type ProtocolBinaryFetcher
  • func (pbf *ProtocolBinaryFetcher) FetchProtocolBinary(autoDownload bool, protocolConsensusVersion *protocoltypes.Version) (selectedBinaryPath string, err error)
  • func (pbf *ProtocolBinaryFetcher) SetupLavavisorDir(dir string) error
  • func (pbf *ProtocolBinaryFetcher) ValidateLavavisorDir(dir string) (lavavisorPath string, err error)
  • func (pbf *ProtocolBinaryFetcher) VerifyGoInstallation() (string, error)
• type ProtocolBinaryLinker
  • func (pbl *ProtocolBinaryLinker) CreateLink(binaryPath string) error
  • func (pbl *ProtocolBinaryLinker) FindLavaProtocolPath(binaryPath string) (string, error)
• type VersionMonitor
  • func NewVersionMonitor(initVersion string, lavavisorPath string, processes []string, ...) *VersionMonitor
  • func (vm *VersionMonitor) ValidateProtocolVersion(incoming *statetracker.ProtocolVersionResponse) error

Functions

func AddGoPathToDollarPath

func AddGoPathToDollarPath(path string) error

func GetBinaryVersion

func GetBinaryVersion(binaryPath string) (string, error)

func GetHomePath

func GetHomePath() (string, error)

func ReloadDaemon

func ReloadDaemon() error

func StartProcess

func StartProcess(process string) error

func ValidateMismatch

func ValidateMismatch(incoming *protocoltypes.Version, current string) bool

Types

type ProtocolBinaryFetcher

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

func (*ProtocolBinaryFetcher) FetchProtocolBinary

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

func (*ProtocolBinaryFetcher) SetupLavavisorDir

func (pbf *ProtocolBinaryFetcher) SetupLavavisorDir(dir string) error

func (*ProtocolBinaryFetcher) ValidateLavavisorDir

func (pbf *ProtocolBinaryFetcher) ValidateLavavisorDir(dir string) (lavavisorPath string, err error)

func (*ProtocolBinaryFetcher) VerifyGoInstallation

func (pbf *ProtocolBinaryFetcher) VerifyGoInstallation() (string, error)

type ProtocolBinaryLinker

type ProtocolBinaryLinker struct {
	Fetcher *ProtocolBinaryFetcher
}

func (*ProtocolBinaryLinker) CreateLink

func (pbl *ProtocolBinaryLinker) CreateLink(binaryPath string) error

func (*ProtocolBinaryLinker) FindLavaProtocolPath

func (pbl *ProtocolBinaryLinker) FindLavaProtocolPath(binaryPath string) (string, error)

type VersionMonitor

type VersionMonitor struct {
	BinaryPath    string
	LavavisorPath string

	LaunchedServices bool // indicates whether version was matching or not so we can decide wether to launch services
	// contains filtered or unexported fields
}

func NewVersionMonitor

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

func (*VersionMonitor) ValidateProtocolVersion

func (vm *VersionMonitor) ValidateProtocolVersion(incoming *statetracker.ProtocolVersionResponse) error