Versions in this module Expand all Collapse all v1 v1.0.1 Aug 15, 2024 Changes in this version + var DeleteNotFound = errors.New("not found") + var LastConfigUpdateTimeKey = "lastConfigUpdateTime" + var LastRestartTimeKey = "lastRestartTime" + type Namespace string + type ServiceGroup interface + Cancel func(namespace string, name string) error + ConfigUpdate func(sg apistructs.ServiceGroup) error + Create func(sg apistructs.ServiceGroupCreateV2Request) (apistructs.ServiceGroup, error) + Delete func(namespace, name string, force bool, extra map[string]string) error + Info func(ctx context.Context, namespace string, name string) (apistructs.ServiceGroup, error) + InspectRuntimeServicePods func(namespace, name, serviceName, runtimeID string) (*apistructs.ServiceGroup, error) + InspectServiceGroupWithTimeout func(namespace, name string) (*apistructs.ServiceGroup, error) + KillPod func(ctx context.Context, namespace string, name string, podname string) error + Precheck func(sg apistructs.ServiceGroupPrecheckRequest) (apistructs.ServiceGroupPrecheckData, error) + Restart func(namespace string, name string) error + Scale func(sg *apistructs.ServiceGroup) (interface{}, error) + Update func(sg apistructs.ServiceGroupUpdateV2Request) (apistructs.ServiceGroup, error) + func NewServiceGroupImpl(js jsonstore.JsonStore, sched *task.Sched, clusterinfo clusterinfo.ClusterInfo) ServiceGroup + func NewServiceGroupImplInit() ServiceGroup + type ServiceGroupImpl struct + Clusterinfo clusterinfo.ClusterInfo + Js jsonstore.JsonStore + Sched *task.Sched + func (s *ServiceGroupImpl) Scale(sg *apistructs.ServiceGroup) (interface{}, error) + func (s ServiceGroupImpl) Cancel(namespace string, name string) error + func (s ServiceGroupImpl) ConfigUpdate(sg apistructs.ServiceGroup) error + func (s ServiceGroupImpl) Create(req apistructs.ServiceGroupCreateV2Request) (apistructs.ServiceGroup, error) + func (s ServiceGroupImpl) Delete(namespace, name string, force bool, sgExtra map[string]string) error + func (s ServiceGroupImpl) Info(ctx context.Context, namespace string, name string) (apistructs.ServiceGroup, error) + func (s ServiceGroupImpl) InspectRuntimeServicePods(namespace, name, serviceName, runtimeID string) (*apistructs.ServiceGroup, error) + func (s ServiceGroupImpl) InspectServiceGroupWithTimeout(namespace, name string) (*apistructs.ServiceGroup, error) + func (s ServiceGroupImpl) KillPod(ctx context.Context, namespace string, name string, containerID string) error + func (s ServiceGroupImpl) Precheck(req apistructs.ServiceGroupPrecheckRequest) (apistructs.ServiceGroupPrecheckData, error) + func (s ServiceGroupImpl) Restart(namespace string, name string) error + func (s ServiceGroupImpl) Update(req apistructs.ServiceGroupUpdateV2Request) (apistructs.ServiceGroup, error)
Go to main page