apinodeutils

Documentation

Index

• Variables
• func CanUpgrade(apiVersion string, osName string, arch string) (canUpgrade bool, reason string)
• type DeployFile
  • func (this *DeployFile) Read(offset int64) (data []byte, newOffset int64, err error)
  • func (this *DeployFile) Sum() (string, error)
• type DeployManager
  • func NewDeployManager() *DeployManager
  • func (this *DeployManager) LoadNSNodeFiles() []*DeployFile
  • func (this *DeployManager) LoadNodeFiles() []*DeployFile
• type Manager
  • func NewManager() *Manager
  • func (this *Manager) AddUpgrader(upgrader *Upgrader)
  • func (this *Manager) FindUpgrader(apiNodeId int64) *Upgrader
  • func (this *Manager) RemoveUpgrader(upgrader *Upgrader)
• type Progress
• type Upgrader
  • func NewUpgrader(apiNodeId int64) *Upgrader
  • func (this *Upgrader) Progress() *Progress
  • func (this *Upgrader) Upgrade() error

Variables

var SharedManager = NewManager()

Functions

func CanUpgrade

func CanUpgrade(apiVersion string, osName string, arch string) (canUpgrade bool, reason string)

Types

type DeployFile

type DeployFile struct {
	OS      string
	Arch    string
	Version string
	Path    string
}

DeployFile 部署文件描述

func (*DeployFile) Read

func (this *DeployFile) Read(offset int64) (data []byte, newOffset int64, err error)

Read 读取一个片段数据

func (*DeployFile) Sum

func (this *DeployFile) Sum() (string, error)

Sum 计算概要

type DeployManager

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

DeployManager 节点部署文件管理器 如果节点部署文件有变化，需要重启API节点以便于生效

func NewDeployManager

func NewDeployManager() *DeployManager

NewDeployManager 获取新节点部署文件管理器

func (*DeployManager) LoadNSNodeFiles

func (this *DeployManager) LoadNSNodeFiles() []*DeployFile

LoadNSNodeFiles 加载所有NS节点安装文件

func (*DeployManager) LoadNodeFiles

func (this *DeployManager) LoadNodeFiles() []*DeployFile

LoadNodeFiles 加载所有边缘节点文件

type Manager

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

func NewManager

func NewManager() *Manager

func (*Manager) AddUpgrader

func (this *Manager) AddUpgrader(upgrader *Upgrader)

func (*Manager) FindUpgrader

func (this *Manager) FindUpgrader(apiNodeId int64) *Upgrader

func (*Manager) RemoveUpgrader

func (this *Manager) RemoveUpgrader(upgrader *Upgrader)

type Progress

type Progress struct {
	Percent float64
}

type Upgrader

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

func NewUpgrader

func NewUpgrader(apiNodeId int64) *Upgrader

func (*Upgrader) Progress

func (this *Upgrader) Progress() *Progress

Progress 查看升级进程

func (*Upgrader) Upgrade

func (this *Upgrader) Upgrade() error