obproxy

package
v0.0.0-...-61ee147 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: May 8, 2026 License: Apache-2.0 Imports: 38 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	WORK_MODE_RS_LIST    = "rsList"
	WORK_MODE_CONFIG_URL = "configUrl"
)

Variables

View Source 
var (
	// task name for obproxy
	DAG_ADD_OBPROXY     = "Add obproxy"
	DAG_START_OBPROXY   = "Start obproxy"
	DAG_STOP_OBPROXY    = "Stop obproxy"
	DAG_UPGRADE_OBPROXY = "Upgrade obproxy"
	DAG_DELETE_OBPROXY  = "Delete obproxy"

	TASK_START_OBPROXY             = "Start obproxy"
	TASK_START_OBPROXYD            = "Start obproxyd"
	TASK_SET_OBPROXY_SYS_PASSWORD  = "Set obproxy sys password"
	TASK_SET_OBPROXY_USER_PASSWORD = "Set proxyro password for connect"
	TASK_PERSIST_OBPROXY_INFP      = "Persist obproxy info"
	TASK_STOP_OBPROXY              = "Stop obproxy"
	TASK_CHECK_OBPROXY_STATUS      = "Check obproxy status"
	TASK_CHECK_PROXYRO_PASSWORD    = "Check proxyro password"
	TASK_DELETE_OBPROXY            = "Delete obproxy"
	TASK_CLEAN_OBPROXY_DIR         = "Clean obproxy dir"

	TASK_COPY_CONFIG_DB_FILE             = "Copy obproxy config db file"
	TASK_HOT_RESTART_OBPROXY             = "Hot restart obproxy"
	TASK_WAIT_HOT_RESTART_OBPROXY_FINISH = "Wait hot restart obproxy finish"
	TASK_RECORD_OBPROXY_INFO             = "Record obproxy info"
	TASK_REINSTALL_OBPROXY_BIN           = "Reinstall obproxy bin"
	TASK_DOWNLOAD_RPM_FROM_SQLITE        = "Download obproxy pkg from sqlite"
	TASK_CHECK_OBPROXY_PKG               = "Check obproxy pkg"
	TASK_INSTALL_ALL_REQUIRED_PKGS       = "Install all required pkgs"
	TASK_BACKUP_FOR_UPGRADE              = "Backup for upgrade"
	TASK_REMOVE_UPGRADE_DIR              = "Remove upgrade dir"
	TASK_CREATE_UPGRADE_DIR              = "Create upgrade dir"

	PARAM_ADD_OBPROXY_OPTION         = "addObproxyOption"
	PARAM_OBPROXY_HOME_PATH          = "homePath"
	PARAM_OBPROXY_SQL_PORT           = "sqlPort"
	PARAM_OBPROXY_EXPORTER_PORT      = "exporterPort"
	PARAM_OBPROXY_VERSION            = "version"
	PARAM_OBPROXY_START_PARAMS       = "startParams"
	PARAM_OBPROXY_START_WITH_OPTIONS = "startWithOptions"
	PARAM_OBPROXY_APP_NAME           = "appName"
	PARAM_OBPROXY_WORK_MODE          = "workMode"
	PARAM_OBPROXY_RS_LIST            = "rsList"
	PARAM_OBPROXY_CONFIG_URL         = "configUrl"
	PARAM_OBPROXY_SYS_PASSWORD       = "obproxySysPassword"
	PARAM_OBPROXY_PROXYRO_PASSWORD   = "proxyroPassword"
	PARAM_OBPROXY_CLUSTER_NAME       = "clusterName"
	PARAM_PERSIST_OBPROXY_INFO_PARAM = "persistObproxyInfoParam"
	PARAM_EXPECT_OBPROXY_AGENT       = "expectObproxyAgent"

	PARAM_HOT_UPGRADE_ROLLBACK_TIMEOUT = "hotUpgradeRollbackTimeout"
	PARAM_HOT_UPGRADE_EXIT_TIMEOUT     = "hotUpgradeExitTimeout"
	PARAM_OLD_OBPROXY_PID              = "oldObproxyPid"

	// for upgrade
	PARAM_VERSION                 = "version"
	PARAM_BUILD_NUMBER            = "buildNumber"
	PARAM_DISTRIBUTION            = "distribution"
	PARAM_RELEASE_DISTRIBUTION    = "releaseDistribution"
	PARAM_UPGRADE_DIR             = "upgradeDir"
	PARAM_TASK_TIME               = "taskTime"
	PARAM_ONLY_FOR_AGENT          = "onlyForAgent"
	PARAM_SCRIPT_FILE             = "scriptFile"
	PARAM_OBPROXY_RPM_PKG_PATH    = "obproxyRpmPkgPath"
	PARAM_CREATE_UPGRADE_DIR_FLAG = "createUpgradeDirFlag"

	// stop obproxy or obproxyd retry times
	STOP_PROCESS_MAX_RETRY_TIME = 15
	STOP_PROCESS_RETRY_INTERVAL = 5
)

Functions

func AddObproxy 

func AddObproxy(param param.AddObproxyParam) (*task.DagDetailDTO, error)

func DeleteObproxy 

func DeleteObproxy() (*task.DagDetailDTO, error)

func GenerateRpmPkgPath 

func GenerateRpmPkgPath(rpmDir, rpmName string) string

func GenerateUpgradeRpmDir 

func GenerateUpgradeRpmDir(upgradeDir, version, arch string) string

func NewSetObproxyUserPasswordForObNode 

func NewSetObproxyUserPasswordForObNode(encryptedProxyroPassword string) *task.Node

func RegisterTaskType 

func RegisterTaskType()

func StartObproxy 

func StartObproxy() (*task.DagDetailDTO, error)

func StopObproxy 

func StopObproxy() (*task.DagDetailDTO, error)

func UpgradeObproxy 

func UpgradeObproxy(param param.UpgradeObproxyParam) (*task.DagDetailDTO, error)

func UpgradePkgUpload 

func UpgradePkgUpload(input multipart.File) (*sqlite.UpgradePkgInfo, error)

Types

type BackupObproxyForUpgradeTask 

type BackupObproxyForUpgradeTask struct {
	task.Task
	// contains filtered or unexported fields
}

func (*BackupObproxyForUpgradeTask) BackupObproxyForUpgrade 

func (t *BackupObproxyForUpgradeTask) BackupObproxyForUpgrade() error

func (*BackupObproxyForUpgradeTask) Execute 

func (t *BackupObproxyForUpgradeTask) Execute() (err error)

func (*BackupObproxyForUpgradeTask) Rollback 

func (t *BackupObproxyForUpgradeTask) Rollback() (err error)

type CheckObproxyPkgTask 

type CheckObproxyPkgTask struct {
	task.Task
	// contains filtered or unexported fields
}

func (*CheckObproxyPkgTask) Execute 

func (t *CheckObproxyPkgTask) Execute() (err error)

type CleanObproxyDirTask 

type CleanObproxyDirTask struct {
	task.Task
	// contains filtered or unexported fields
}

func (*CleanObproxyDirTask) Execute 

func (t *CleanObproxyDirTask) Execute() (err error)

type CopyConfigDbFileTask 

type CopyConfigDbFileTask struct {
	task.Task
	// contains filtered or unexported fields
}

func (*CopyConfigDbFileTask) Execute 

func (t *CopyConfigDbFileTask) Execute() error

func (*CopyConfigDbFileTask) Rollback 

func (t *CopyConfigDbFileTask) Rollback() error

type CreateObproxyUpgradeDirTask 

type CreateObproxyUpgradeDirTask struct {
	task.Task
	// contains filtered or unexported fields
}

func (*CreateObproxyUpgradeDirTask) Execute 

func (t *CreateObproxyUpgradeDirTask) Execute() (err error)

func (*CreateObproxyUpgradeDirTask) Rollback 

func (t *CreateObproxyUpgradeDirTask) Rollback() (err error)

type DeleteObproxyTask 

type DeleteObproxyTask struct {
	task.Task
}

DeleteObproxyTask will delete the obproxy home path

func (*DeleteObproxyTask) Execute 

func (t *DeleteObproxyTask) Execute() (err error)

type GetObproxyPkgTask 

type GetObproxyPkgTask struct {
	task.Task
	// contains filtered or unexported fields
}

func (*GetObproxyPkgTask) CheckDiskFreeSpace 

func (t *GetObproxyPkgTask) CheckDiskFreeSpace() error

func (*GetObproxyPkgTask) Execute 

func (t *GetObproxyPkgTask) Execute() (err error)

func (*GetObproxyPkgTask) Rollback 

func (t *GetObproxyPkgTask) Rollback() (err error)

type HotRestartObproxyTask 

type HotRestartObproxyTask struct {
	task.Task
}

func (*HotRestartObproxyTask) Execute 

func (t *HotRestartObproxyTask) Execute() error

type PersistObproxyInfoTask 

type PersistObproxyInfoTask struct {
	task.Task
	// contains filtered or unexported fields
}

func (*PersistObproxyInfoTask) Execute 

func (t *PersistObproxyInfoTask) Execute() error

type PrepareForAddObproxyTask 

type PrepareForAddObproxyTask struct {
	task.Task
	// contains filtered or unexported fields
}

func (*PrepareForAddObproxyTask) Execute 

func (t *PrepareForAddObproxyTask) Execute() error

type RecordObproxyInfoTask 

type RecordObproxyInfoTask struct {
	task.Task
}

func (*RecordObproxyInfoTask) Execute 

func (t *RecordObproxyInfoTask) Execute() error

type ReinstallObproxyBinTask 

type ReinstallObproxyBinTask struct {
	task.Task
	// contains filtered or unexported fields
}

func (*ReinstallObproxyBinTask) Execute 

func (t *ReinstallObproxyBinTask) Execute() error

func (*ReinstallObproxyBinTask) Rollback 

func (t *ReinstallObproxyBinTask) Rollback() (err error)

type RemoveUpgradeObproxyDirTask 

type RemoveUpgradeObproxyDirTask struct {
	task.Task
	// contains filtered or unexported fields
}

RemoveUpgradeObproxyDirTask remove upgrade dir

func (*RemoveUpgradeObproxyDirTask) Execute 

func (t *RemoveUpgradeObproxyDirTask) Execute() (err error)

type SetObproxyUserPasswordForObTask 

type SetObproxyUserPasswordForObTask struct {
	task.Task
	// contains filtered or unexported fields
}

Only support set global proxyro password currently

func (*SetObproxyUserPasswordForObTask) Execute 

func (t *SetObproxyUserPasswordForObTask) Execute() error

type StartObproxyTask 

type StartObproxyTask struct {
	task.Task
	// contains filtered or unexported fields
}

func (*StartObproxyTask) Execute 

func (t *StartObproxyTask) Execute() error

type StopObproxyTask 

type StopObproxyTask struct {
	task.Task
}

StopObproxyTask will stop obproyxd and obproxy.

func (*StopObproxyTask) Execute 

func (t *StopObproxyTask) Execute() error

type WaitHotRestartObproxyFinishTask 

type WaitHotRestartObproxyFinishTask struct {
	task.Task
	// contains filtered or unexported fields
}

func (*WaitHotRestartObproxyFinishTask) Execute 

func (t *WaitHotRestartObproxyFinishTask) Execute() error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.