class CloudConfigServiceK8sImpl extends TimerTask implements CloudConfigService {
    final ApiClient client;
    final CoreV1Api configApi;

    private long refreshInterval;

    public CloudConfigServiceK8sImpl(CloudProps cloudProps) {
        try {
            client = ClientBuilder.defaultClient();
            configApi = new CoreV1Api(client);

            refreshInterval = IntervalUtils.getInterval(cloudProps.getConfigRefreshInterval("5s"));
        } catch (Exception e) {
            throw new IllegalStateException(e);
        }
    }


    public long getRefreshInterval() {
        return refreshInterval;
    }

    @Override
    public Config pull(String group, String name) {<FILL_FUNCTION_BODY>}

    @Override
    public boolean push(String group, String name, String value) {
        return false;
    }

    @Override
    public boolean remove(String group, String name) {
        return false;
    }

    @Override
    public void attention(String group, String name, CloudConfigHandler observer) {

    }

    @Override
    public void run() {

    }
}

        try {
            V1ConfigMap v1ConfigMap = configApi.readNamespacedConfigMap(name, group, null);

            if(v1ConfigMap == null){
                return null;
            }

            StringBuilder kvs = new StringBuilder();
            v1ConfigMap.getData().forEach((k, v) -> {
                kvs.append(k).append("=").append(v).append("\n");
            });

            return new Config(group, name, kvs.toString(), 0);
        } catch (Exception e) {
            throw new IllegalStateException(e);
        }
    
<methods>public boolean cancel() ,public abstract void run() ,public long scheduledExecutionTime() <variables>static final int CANCELLED,static final int EXECUTED,static final int SCHEDULED,static final int VIRGIN,final java.lang.Object lock,long nextExecutionTime,long period,int state