Method ListCluster

service/plugin-cluster/iml.go:211–254

(ctx context.Context, clusterId string, kind ...plugin_model.Kind)

}

func (i *imlPluginService) ListCluster(ctx context.Context, clusterId string, kind ...plugin_model.Kind) ([]*ConfigPartition, error) {
	
	defines, err := i.Defines(ctx, kind...)
	if err != nil {
		return nil, err
	}
	
	configList, err := i.pluginPartitionStore.List(ctx, map[string]interface{}{
		"partition": clusterId,
	})
	if err != nil {
		return nil, err
	}
	configMap := utils.SliceToMap(configList, func(t *plugin.Partition) string {
		return t.Plugin
	})
	
	return utils.SliceToSlice(defines, func(d *PluginDefine) *ConfigPartition {
		c, has := configMap[d.Name]
		if has {
			return &ConfigPartition{
				Extend: d.Extend,
				Cname:  d.Cname,
				Desc:   d.Name,
				Config: ConfigFromStore(c),
			}
		} else {
			return &ConfigPartition{
				Extend: d.Extend,
				Cname:  d.Cname,
				Desc:   d.Name,
				
				Config: &Config{
					Plugin: d.Name,
					Status: d.Status,
					Config: d.Config,
					
					Operator: "",
				},
			}
		}
	}), nil
	
}