Versions in this module Expand all Collapse all v1 v1.19.1 Oct 25, 2022 Changes in this version + const DefaultRescheduleDelayTime + type Backend interface + CancelUpdateDeployment func(string, string) error + CheckVersion func(*types.Version) error + ClusterId func() string + CommitImage func(string, string, string) (*types.BcsMessage, error) + CreateCustomResource func(*commtypes.Crd) error + CreateDeployment func(*types.DeploymentDef) (int, error) + DeleteAdmissionWebhook func(ns, name string) error + DeleteApplication func(string, string, bool, commtypes.BcsDataType) error + DeleteCommand func(ID string) error + DeleteConfigMap func(ns string, name string) error + DeleteCustomResource func(string, string, string) error + DeleteDaemonset func(namespace, name string, force bool) error + DeleteDeployment func(string, string, bool) (int, error) + DeleteSecret func(ns string, name string) error + DeleteService func(ns string, name string) error + DisableAgent func(string) error + DisableAgentList func(IPs []string) (int, error) + DoCommand func(command *commtypes.BcsCommandInfo) error + EnableAgent func(string) error + EnableAgentList func(IPs []string) (int, error) + FetchAdmissionWebhook func(ns, name string) (*commtypes.AdmissionWebhookConfiguration, error) + FetchAllAdmissionWebhooks func() ([]*commtypes.AdmissionWebhookConfiguration, error) + FetchApplication func(string, string) (*types.Application, error) + FetchApplicationVersion func(string, string, string) (*types.Version, error) + FetchConfigMap func(ns, name string) (*commtypes.BcsConfigMap, error) + FetchCustomResourceDefinition func(kind, ns, name string) (*commtypes.Crd, error) + FetchSecret func(ns, name string) (*commtypes.BcsSecret, error) + FetchService func(ns, name string) (*commtypes.BcsService, error) + GetClusterEndpoints func() *commtypes.ClusterEndpoints + GetClusterResources func() (*commtypes.BcsClusterResource, error) + GetCommand func(ID string) (*commtypes.BcsCommandInfo, error) + GetCurrentOffers func() []*mesos.Offer + GetDeployment func(string, string) (*types.Deployment, error) + GetRole func() string + GetVersion func(string, string) (*types.Version, error) + HealthyReport func(*commtypes.HealthCheckResult) + LaunchApplication func(*types.Version) error + LaunchDaemonset func(def *types.BcsDaemonsetDef) error + ListAllCrds func(kind string) ([]*commtypes.Crd, error) + ListApplicationTaskGroups func(string, string) ([]*types.TaskGroup, error) + ListApplicationVersions func(string, string) ([]string, error) + ListApplications func(string) ([]*types.Application, error) + ListCustomResourceDefinition func(kind, ns string) ([]*commtypes.Crd, error) + PauseUpdateDeployment func(string, string) error + QueryAgentSetting func(string) (*commtypes.BcsClusterAgentSetting, error) + QueryAgentSettingList func([]string) ([]*commtypes.BcsClusterAgentSetting, int, error) + RegisterCustomResource func(*commtypes.Crr) error + ReloadTaskGroup func(taskGroupID string) (*types.BcsMessage, error) + RescheduleTaskgroup func(string, int64) error + RestartTaskGroup func(taskGroupID string) (*types.BcsMessage, error) + ResumeUpdateDeployment func(string, string) error + SaveAdmissionWebhook func(configmap *commtypes.AdmissionWebhookConfiguration) error + SaveApplication func(*types.Application) error + SaveConfigMap func(configmap *commtypes.BcsConfigMap) error + SaveSecret func(secret *commtypes.BcsSecret) error + SaveService func(service *commtypes.BcsService) error + SaveVersion func(string, string, *types.Version) error + ScaleApplication func(string, string, uint64, commtypes.BcsDataType, bool) error + ScaleDeployment func(string, string, uint64) error + SendToApplication func(string, string, *types.BcsMessage) ([]*types.TaskGroupOpResult, []*types.TaskGroupOpResult, error) + SendToApplicationTaskGroup func(string, string, string, *types.BcsMessage) error + SetAgentSettingList func([]*commtypes.BcsClusterAgentSetting) (int, error) + TaintAgents func([]*commtypes.BcsClusterAgentSetting) error + UnregisterCustomResource func(string) error + UpdateAdmissionWebhook func(admission *commtypes.AdmissionWebhookConfiguration) error + UpdateApplication func(string, string, string, int, *types.Version) error + UpdateCustomResource func(*commtypes.Crd) error + UpdateDeployment func(*types.DeploymentDef) (int, error) + UpdateExtendedResources func(ex *commtypes.ExtendedResource) error + func NewBackend(sched *scheduler.Scheduler, zkStore store.Store) Backend + type TaskSorter []*types.TaskGroup + func (s TaskSorter) Len() int + func (s TaskSorter) Less(i, j int) bool + func (s TaskSorter) Swap(i, j int)
Go to main page