Method Offline

module/dynamic-module/iml.go:105–134

(ctx context.Context, module string, id string)

}

func (i *imlDynamicModule) Offline(ctx context.Context, module string, id string) error {
	_, has := driver.Get(module)
	if !has {
		return fmt.Errorf("模块【%s】不存在", module)
	}
	return i.transaction.Transaction(ctx, func(ctx context.Context) error {
		id = strings.ToLower(fmt.Sprintf("%s_%s", id, module))
		clusters, err := i.clusterService.List(ctx)
		if err != nil {
			return err
		}
		clusterIds := utils.SliceToSlice(clusters, func(s *cluster.Cluster) string {
			return s.Uuid
		})
		for _, clusterId := range clusterIds {
			err := i.dynamicClient(ctx, clusterId, module, func(dynamicClient gateway.IDynamicClient) error {
				return dynamicClient.Offline(ctx, &gateway.DynamicRelease{
					BasicItem: &gateway.BasicItem{
						ID: id,
					},
				})
			})
			if err != nil {
				return err
			}

		}
		return nil
	})
}

//
//func (i *imlDynamicModule) PartitionStatuses(ctx context.Context, module string, keyword string, page int, pageSize int) (map[string]map[string]string, error) {