service

package

Go to main page

Versions in this module

v0

v0.3.0

Feb 18, 2022

Changes in this version

+ const InstanceDeployStepAfterDeploy

+ const InstanceDeployStepBeforeDeploy

+ const InstanceDeployStepBeforeDownload

+ const InstanceDeployStepDeploy

+ const InstanceDeployStepDownloadExec

+ func InstanceAfterDeploy(ctx context.Context, deployInfo *types.DeployInfo, tmplId int64, db *gorm.DB) (int64, error)

+ func InstanceBeforeDeploy(ctx context.Context, deployInfo *types.DeployInfo, tmplId int64, db *gorm.DB) (int64, error)

+ func InstanceBeforeDownload(ctx context.Context, deployInfo *types.DeployInfo, tmplId int64, db *gorm.DB) (int64, error)

+ func InstanceDeploy(ctx context.Context, deployInfo *types.DeployInfo, tmplId int64, db *gorm.DB) (int64, error)

+ func InstanceDownloadExec(ctx context.Context, deployInfo *types.DeployInfo, tmplId int64, db *gorm.DB) (int64, error)

type BaseEnvInitAsyncSvcReq

+ Cmd string

+ type DeployAsyncReq struct

+ Auth *types.InstanceAuth

+ Cmd string

+ InstanceList []*types.InstanceInfo

+ ServiceClusterId int64

+ TaskId int64

type EnvService

+ func (s *EnvService) AfterDeployAsync(ctx context.Context, svcReq *DeployAsyncReq) error

+ func (s *EnvService) BeforeDeployAsync(ctx context.Context, svcReq *DeployAsyncReq) error

+ func (s *EnvService) DeployAsync(ctx context.Context, svcReq *DeployAsyncReq) error

+ func (s *EnvService) DeployBeforeDownloadInitAsync(ctx context.Context, svcReq *BaseEnvInitAsyncSvcReq) error

+ func (s *EnvService) DeployBeforeDownloadInitSingle(ctx context.Context, taskId int64, cmd string, inst *types.InstanceInfo, ...) error

+ func (s *EnvService) DeployDownloadAsync(ctx context.Context, svcReq *DeployAsyncReq) error

+ func (s *EnvService) ExecCmdWithUpdateInstanceStatus(ctx context.Context, taskId int64, cmd string, inst *types.InstanceInfo, ...) error

+ func (s *EnvService) NodeUpdateDeploy(ctx context.Context, instanceList []*types.InstanceInfo, ...) error

+ type GetServiceByIpResponse struct

+ ClusterName string

+ ServiceName string

type InstanceService

+ func (s *InstanceService) GetServiceByIp(ctx context.Context, ip string) (*GetServiceByIpResponse, error)

type InstrSvc

+ NodeActAfterDeploy types.Action

+ NodeActBeforeDeploy types.Action

+ NodeActBeforeDownload types.Action

+ NodeActDeploy types.Action

+ NodeActDownload types.Action

+ func (s *InstrSvc) CreateInstanceAfterDeploy(ctx context.Context, args *types.DeployInfo, tmpId int64, dbo *gorm.DB) (int64, error)

+ func (s *InstrSvc) CreateInstanceBeforeDeploy(ctx context.Context, args *types.DeployInfo, tmpId int64, dbo *gorm.DB) (int64, error)

+ func (s *InstrSvc) CreateInstanceBeforeDownload(ctx context.Context, args *types.DeployInfo, tmpId int64, dbo *gorm.DB) (int64, error)

+ func (s *InstrSvc) CreateInstanceDeploy(ctx context.Context, args *types.DeployInfo, tmpId int64, dbo *gorm.DB) (int64, error)

+ func (s *InstrSvc) CreateInstanceDownloadExec(ctx context.Context, args *types.DeployInfo, tmpId int64, dbo *gorm.DB) (int64, error)

+ type IntegrationService struct

+ HttpClient *resty.Client

+ ZadigToken string

+ func GetIntegrationService() *IntegrationService

+ func (s *IntegrationService) GetZadigHost(ctx context.Context) string

+ func (s *IntegrationService) GetZadigToken() string

type NodeActSvcReq

+ DownloadFileUrl string

+ InstanceCount int64

type NodeActSvcResp

+ Auth *types.InstanceAuth

type ScheduleSvc

+ Deploy types.Action

type ScheduleSvcReq

+ ServiceDeploySvcReq *ServiceDeploySvcReq

type ScheduleSvcResp

+ ServiceDeploySvcResp *ServiceDeploySvcResp

+ type ServiceDeploySvcReq struct

+ Count int64

+ DownloadFileUrl string

+ ExecType string

+ Rollback bool

+ ServiceClusterId int64

+ type ServiceDeploySvcResp struct

+ TaskId int64

type ServiceSvc

+ func (s *ServiceSvc) Delete(ctx context.Context, ids []int64) error

+ func (s *ServiceSvc) Update(ctx context.Context, serviceName, description, domain, port, gitRepo string) (map[string]interface{}, error)

+ type TaskDeployInfo struct

+ DownloadFileUrl string

+ type TaskDetail struct

+ BridgXClusterName string

+ ClusterName string

+ CreateTime string

+ DeployFileUrl string

+ Operator string

+ RunningTaskId string

+ ServiceName string

type TaskService

+ func (s *TaskService) GetRunningTask(ctx context.Context, serviceClusterId, taskId int64) (*TaskDetail, error)

type TemplateSvc

+ func (s *TemplateSvc) ListDeployTemplates(ctx context.Context, serviceName string, page, pageSize, serviceClusterId int) (map[string]interface{}, error)

+ func (s *TemplateSvc) UpdateContainerTemplate(ctx context.Context, svcReq *TmplUpdateSvcReq) (*TemplateSvcResp, error)

+ func (s *TemplateSvc) UpdateInstanceTemplate(ctx context.Context, svcReq *TmplUpdateSvcReq) (*TemplateSvcResp, error)

+ type TmplDeployReq struct

+ DeployInfo *types.DeployInfo

+ TmplInfo *types.TmpInfo

type TmplExpandSvcReq

+ DeployInfo *types.DeployInfo

type TmplExpandSvcResp

+ DeployTmplId string

type TmplInfoSvcResp

+ DeployInfo *types.DeployInfo

type TmplUpdateSvcReq

+ DeployInfo *types.DeployInfo

+ type ZadigResp struct

+ Token string

+ type ZadigSvc struct

+ func GetZadigSvcInst() *ZadigSvc

+ func (s *ZadigSvc) GetWorkflowTasks(ctx context.Context, serviceName, workflowName, fileType string, ...) (int, []*zadigcli.WorkflowTaskResp, error)

+ func (s *ZadigSvc) GetWorkflows(ctx context.Context, serviceName string) ([]*zadigcli.WorkflowResp, error)

v0.2.0

Feb 9, 2022

Changes in this version

type BaseEnvInitAsyncSvcReq

+ ServiceClusterId int64

+ type ClusterInstanceCount struct

+ InstanceCount int

+ ServiceClusterId int64

+ ServiceClusterName string

+ type ClusterListResp struct

+ ClusterList []ServiceClusterInfo

type ExposeUmountSvcReq

+ ServiceClusterId int64

+ type InstanceCountResp struct

+ ServiceClusterList []ClusterInstanceCount

+ type InstanceService struct

+ func GetInstanceService() *InstanceService

+ func (s *InstanceService) InstanceCountByCluster(ctx context.Context, serviceName, serviceClusterName string, clusterId int64) (*InstanceCountResp, error)

type InstrSvcReq

+ ServiceClusterId int64

type NodeActSvcReq

+ ServiceClusterId int64

+ type ServiceClusterInfo struct

+ BridgxCluster string

+ ChargeType string

+ ComputingPowerType string

+ InstanceCount int64

+ InstanceTypeDesc string

+ Provider string

+ ServiceCluster string

+ ServiceClusterId int64

type ServiceSvc

+ func (s *ServiceSvc) GetServiceClusterList(ctx context.Context, serviceName string) (*ClusterListResp, error)

type SvcEnvInitAsyncSvcReq

+ ServiceClusterId int64

type TaskService

+ func (s *TaskService) HasRunningTask(ctx context.Context, serviceName, clusterName string) (bool, error)

v0.1.1

Nov 30, 2021

Changes in this version

+ func IsAlibabaCloudAccountValid(account config.AlibabaCloudAccount) bool

type ScheduleSvcResp

+ ServiceExpandSvcResp *ServiceExpandSvcResp

+ ServiceShrinkSvcResp *ServiceShrinkSvcResp

+ type ServiceExpandSvcResp struct

+ TaskId int64

+ type ServiceShrinkSvcResp struct

+ TaskId int64

+ type TaskInfoSvcReq struct

+ TaskId int64

+ type TaskInfoSvcResp struct

+ TaskInfo *types.TaskInfo

type TaskService

+ func (s *TaskService) Info(ctx context.Context, svcReq *TaskInfoSvcReq) (*TaskInfoSvcResp, error)

+ func (s *TaskService) InstanceList(ctx context.Context, page, pageSize, taskId int, ...) (int64, []types.InstInfoResp, error)

v0.1.0

Nov 25, 2021

Changes in this version

+ const ExpandStepBaseEnv

+ const ExpandStepMount

+ const ExpandStepServiceEnv

+ const ExpandStepTmplInfo

+ func RemoteCmdExec(ctx context.Context, localCmd string, remoteScript string, ...) ([]byte, error)

+ type ActionSvc interface

+ ExecAct func(ctx context.Context, args interface{}, act types.Action) (interface{}, error)

+ type BaseEnvInitAsyncSvcReq struct

+ Auth *types.InstanceAuth

+ InstanceList []*types.InstanceInfo

+ TaskId int64

+ type BridgXSvc struct

+ Expand types.Action

+ GetCluster types.Action

+ PoolQueryExpand types.Action

+ PoolQueryShrink types.Action

+ Shrink types.Action

+ func GetBridgXSvcInst() *BridgXSvc

+ func (s *BridgXSvc) ExecAct(ctx context.Context, args interface{}, act types.Action) (resp interface{}, err error)

+ func (s *BridgXSvc) RatePass(rate string) bool

+ type BridgXSvcReq struct

+ ClusterName string

+ Count int64

+ InstGroup *nodeact.InstanceGroup

+ TaskId int64

+ type BridgXSvcResp struct

+ Auth *types.InstanceAuth

+ InstGroup *nodeact.InstanceGroup

+ TaskId int64

+ type CallBackNodeInitSvcReq struct

+ Instance *types.InstanceMeta

+ Msg string

+ type EnvService struct

+ func GetEnvOpsSvcInst() *EnvService

+ func (s *EnvService) BaseEnvInitAsync(ctx context.Context, svcReq *BaseEnvInitAsyncSvcReq) error

+ func (s *EnvService) BaseEnvInitSingle(ctx context.Context, taskId int64, inst *types.InstanceInfo, ...) error

+ func (s *EnvService) CallBackSvc(ctx context.Context, taskId int64, instId string, ...) error

+ func (s *EnvService) IsNotHttpOk(res []byte) bool

+ func (s *EnvService) IsNotRemoteCmdOk(res []byte) bool

+ func (s *EnvService) NodeUpdateStore(ctx context.Context, instanceList []*types.InstanceInfo, taskId int64) error

+ func (s *EnvService) ServiceEnvInitAsync(ctx context.Context, svcReq *SvcEnvInitAsyncSvcReq) error

+ func (s *EnvService) ServiceEnvInitSingle(ctx context.Context, taskId int64, inst *types.InstanceInfo, ...) error

+ type ExposeMountSvcReq struct

+ InstanceList []*types.InstanceInfo

+ MountType string

+ MountValue string

+ TaskId int64

+ type ExposeMountSvcResp struct

+ InstanceList []*types.InstanceInfo

+ TaskId int64

+ type ExposeUmountSvcReq struct

+ Count int64

+ MountType string

+ MountValue string

+ TaskId int64

+ type ExposeUmountSvcResp struct

+ InstanceList []*types.InstanceInfo

+ TaskId int64

+ type InitServicSvcReq struct

+ Cmd string

+ Params *types.ParamsServiceEnv

+ type InstrSvc struct

+ BridgXExpand types.Action

+ BridgXShrink types.Action

+ MountNginx types.Action

+ MountSLB types.Action

+ NodeActInitBase types.Action

+ NodeActInitSvc types.Action

+ UmountNginx types.Action

+ UmountSLB types.Action

+ func GetInstrSvcInst() *InstrSvc

+ func (s *InstrSvc) CreateBaseEnvInstr(ctx context.Context, args *types.BaseEnv, tmpId int64, needReverse bool, ...) (int64, int64, error)

+ func (s *InstrSvc) CreateBridgxExpandInstr(ctx context.Context, tmplId int64, revTmplId int64, needReverse bool, ...) (int64, int64, error)

+ func (s *InstrSvc) CreateBridgxShrinkInstr(ctx context.Context, tmplId int64, dbo *gorm.DB) (int64, error)

+ func (s *InstrSvc) CreateMountSlbInstr(ctx context.Context, args *types.ParamsMount, tmplId, revTmplId int64, ...) (int64, int64, error)

+ func (s *InstrSvc) CreateServiceEnvInstr(ctx context.Context, args *types.ServiceEnv, tmplId int64, needReverse bool, ...) (int64, int64, error)

+ func (s *InstrSvc) CreateUMountSlbInstr(ctx context.Context, args *types.ParamsMount, tmplId int64, dbo *gorm.DB) (int64, error)

+ func (s *InstrSvc) ExecAct(ctx context.Context, args interface{}, act types.Action) (svcResp interface{}, err error)

+ type InstrSvcReq struct

+ BridgXSvcReq *BridgXSvcReq

+ InstrId int64

+ Instruction *db.Instruction

+ NodeActSvcReq *NodeActSvcReq

+ ScheduleTaskId int64

+ ServiceName string

+ type InstrSvcResp struct

+ BridgXSvcResp *BridgXSvcResp

+ NodeActSvcResp *NodeActSvcResp

+ type MountService struct

+ func GetMountSvcInst() *MountService

+ func (mou *MountService) Mount(ctx context.Context, svcReq *ExposeMountSvcReq) (*ExposeMountSvcResp, error)

+ func (mou *MountService) Umount(ctx context.Context, svcReq *ExposeUmountSvcReq) (*ExposeUmountSvcResp, error)

+ type NodeActSvc struct

+ InitBase types.Action

+ InitService types.Action

+ MountSlb types.Action

+ PollQueryInitBase types.Action

+ PollQueryInitService types.Action

+ UmountSlb types.Action

+ func GetNodeActSvcInst() *NodeActSvc

+ func (s *NodeActSvc) ExecAct(ctx context.Context, args interface{}, act types.Action) (svcResp interface{}, err error)

+ func (s *NodeActSvc) InitBaseAction(ctx context.Context, instGroup *nodeact.InstanceGroup, ...) (*NodeActSvcResp, error)

+ func (s *NodeActSvc) InitServiceAction(ctx context.Context, instGroup *nodeact.InstanceGroup, ...) (*NodeActSvcResp, error)

+ func (s *NodeActSvc) MountInstAction(ctx context.Context, instGroup *nodeact.InstanceGroup, ...) (*ExposeMountSvcResp, error)

+ func (s *NodeActSvc) PollQueryBaseNode(ctx context.Context, taskId int64) (*NodeActSvcResp, error)

+ func (s *NodeActSvc) PoolQueryServiceNode(ctx context.Context, taskId int64) (*NodeActSvcResp, error)

+ func (s *NodeActSvc) RatePass(rate string) bool

+ func (s *NodeActSvc) UmountInstAction(ctx context.Context, taskId int64, umountSlbSvcReq *UmountSlbSvcReq) (*ExposeUmountSvcResp, error)

+ type NodeActSvcReq struct

+ Auth *types.InstanceAuth

+ InitServicSvcReq *InitServicSvcReq

+ InstGroup *nodeact.InstanceGroup

+ SlbMountInfo *nodeact.ParamsMountInfo

+ TaskId int64

+ UmountSlbSvcReq *UmountSlbSvcReq

+ type NodeActSvcResp struct

+ InstGroup *nodeact.InstanceGroup

+ type NodeService struct

+ func GetNodeSvcInst() *NodeService

+ func (s *NodeService) UpdateNode(ctx context.Context, svcReq *CallBackNodeInitSvcReq) error

+ type ScheduleSvc struct

+ Expand types.Action

+ Shrink types.Action

+ func GetScheduleSvcInst() *ScheduleSvc

+ func (s *ScheduleSvc) ExecAct(ctx context.Context, args interface{}, act types.Action) (svcResp interface{}, err error)

+ type ScheduleSvcReq struct

+ InstrId int64

+ ServiceExpandSvcReq *ServiceExpandSvcReq

+ ServiceShrinkSvcReq *ServiceShrinkSvcReq

+ type ScheduleSvcResp struct

+ type ServiceCreateSvcRequest struct

+ ServiceInfo *types.ServiceInfo

+ type ServiceCreateSvcResponse struct

+ ServiceClusterId int64

+ type ServiceExpandSvcReq struct

+ Count int64

+ ExecType string

+ ServiceClusterId int64

+ type ServiceShrinkSvcReq struct

+ Count int64

+ ExecType string

+ ServiceClusterId int64

+ type ServiceSvc struct

+ func GetServiceIns() *ServiceSvc

+ func (s *ServiceSvc) CreateService(ctx context.Context, svcReq *ServiceCreateSvcRequest) (*ServiceCreateSvcResponse, error)

+ func (s *ServiceSvc) Detail(ctx context.Context, serviceName string) (map[string]interface{}, error)

+ func (s *ServiceSvc) GetExpandHistory(ctx context.Context, page, pageSize, serviceClusterId int) (map[string]interface{}, error)

+ func (s *ServiceSvc) GetServiceList(ctx context.Context, page, pageSize int, serviceName, lang string) (map[string]interface{}, error)

+ func (s *ServiceSvc) UpdateDesc(ctx context.Context, serviceName, description string) (map[string]interface{}, error)

+ type SvcEnvInitAsyncSvcReq struct

+ Auth *types.InstanceAuth

+ Cmd string

+ InstanceList []*types.InstanceInfo

+ Params *types.ParamsServiceEnv

+ TaskId int64

+ type TaskDescribeSvcReq struct

+ InstanceStatus types.InstanceStatus

+ TaskId int64

+ type TaskDescribeSvcResp struct

+ TaskDescribe *types.TaskDescribe

+ type TaskInstancesSvcReq struct

+ InstanceStatus types.InstanceStatus

+ PageNumber int

+ PageSize int

+ TaskId int64

+ type TaskInstancesSvcResp struct

+ InstancesList []*types.Instance

+ Pager *types.Pager

+ type TaskService struct

+ func GetTaskSvcInst() *TaskService

+ func (s *TaskService) Describe(ctx context.Context, svcReq *TaskDescribeSvcReq) (*TaskDescribeSvcResp, error)

+ func (s *TaskService) Instances(ctx context.Context, svcReq *TaskInstancesSvcReq) (*TaskInstancesSvcResp, error)

+ type TemplateSvc struct

+ Create types.Action

+ Info types.Action

+ Update types.Action

+ func GetTemplateSvcInst() *TemplateSvc

+ func (s *TemplateSvc) Delete(ctx context.Context, tmpExpandIds []int64) (int64, error)

+ func (s *TemplateSvc) ExecAct(ctx context.Context, args interface{}, act types.Action) (svcResp interface{}, err error)

+ func (s *TemplateSvc) InfoAction(ctx context.Context, svcReq *TmplInfoSvcReq) (*TemplateSvcResp, error)

+ func (s *TemplateSvc) List(ctx context.Context, serviceName string, page, pageSize, serviceClusterId int) (map[string]interface{}, error)

+ func (s *TemplateSvc) UpdateAction(ctx context.Context, svcReq *TmplUpdateSvcReq) (*TemplateSvcResp, error)

+ type TemplateSvcReq struct

+ TmplExpandSvcReq *TmplExpandSvcReq

+ TmplInfoSvcReq *TmplInfoSvcReq

+ TmplUpdateSvcReq *TmplUpdateSvcReq

+ type TemplateSvcResp struct

+ TmplExpandSvcResp *TmplExpandSvcResp

+ TmplInfoSvcResp *TmplInfoSvcResp

+ TmplUpdateSvcResp *TmplUpdateSvcResp

+ type TmplExpandSvcReq struct

+ BaseEnv *types.BaseEnv

+ EndStep string

+ Mount *types.ParamsMount

+ ServiceEnv *types.ServiceEnv

+ TmplInfo *types.TmpInfo

+ type TmplExpandSvcResp struct

+ TmplId string

+ type TmplInfoSvcReq struct

+ TmplExpandId int64

+ type TmplInfoSvcResp struct

+ BaseEnv *types.BaseEnv

+ Mount *types.ParamsMount

+ ServiceEnv *types.ServiceEnv

+ TmplInfo *types.TmpInfo

+ type TmplUpdateSvcReq struct

+ BaseEnv *types.BaseEnv

+ EndStep string

+ Mount *types.ParamsMount

+ ServiceEnv *types.ServiceEnv

+ TmplExpandId int64

+ TmplInfo *types.TmpInfo

+ type TmplUpdateSvcResp struct

+ TmplExpandId int64

+ type UmountSlbSvcReq struct

+ SlbInfo *nodeact.ParamsMountInfo

+ UmountInstCnt int64

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL