kubernetes/src/test/java/org/apache/tamaya/k8s/EtcdAccessorTest.java

///*
// * Licensed to the Apache Software Foundation (ASF) under one
// * or more contributor license agreements.  See the NOTICE file
// * distributed with this work for additional information
// * regarding copyright ownership.  The ASF licenses this file
// * to you under the Apache License, Version 2.0 (the
// * "License"); you may not use this file except in compliance
// * with the License.  You may obtain a copy of the License at
// *
// *   http://www.apache.org/licenses/LICENSE-2.0
// *
// * Unless required by applicable law or agreed to in writing,
// * software distributed under the License is distributed on an
// * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
// * KIND, either express or implied.  See the License for the
// * specific language governing permissions and limitations
// * under the License.
// */
//package org.apache.tamaya.etcd;
//
//import org.junit.BeforeClass;
//import org.junit.Test;
//
//import java.net.MalformedURLException;
//import java.util.Map;
//import java.util.UUID;
//
//import static org.junit.Assert.*;
//
///**
// * Tests for the etcd backend integration. You must have setCurrent a system property so, theses tests are executed, e.g.
// * {@code -Detcd.url=http://127.0.0.1:4001}.
// */
//public class EtcdAccessorTest {
//
//    private static EtcdAccessor accessor;
//    static boolean execute = false;
//
//    @BeforeClass
//    public static void setup() throws MalformedURLException {
//        accessor = new EtcdAccessor("http://192.168.99.105:4001");
//        if(!accessor.getVersion().contains("etcd")){
//            System.out.println("Disabling etcd tests, etcd not accessible at: " + System.getProperty("etcd.server.urls"));
//            System.out.println("Configure etcd with -Detcd.server.urls=http://<IP>:<PORT>");
//        }
//        else{
//            execute = true;
//        }
//    }
//
//    @Test
//    public void testGetVersion() throws Exception {
//        if(!execute)return;
//        assertEquals(accessor.getVersion(), "etcd 0.4.9");
//    }
//
//    @Test
//    public void testGet() throws Exception {
//        if(!execute)return;
//        Map<String,String> result = accessor.get("test1");
//        assertNotNull(result);
//    }
//
//    @Test
//    public void testSetNormal() throws Exception {
//        if(!execute)return;
//        String value = UUID.randomUUID().toString();
//        Map<String,String> result = accessor.set("testSetNormal", value);
//        assertNull(result.get("_testSetNormal.ttl"));
//        assertEquals(value, accessor.get("testSetNormal").get("testSetNormal"));
//    }
//
//    @Test
//    public void testSetNormal2() throws Exception {
//        if(!execute)return;
//        String value = UUID.randomUUID().toString();
//        Map<String,String> result = accessor.set("testSetNormal2", value, null);
//        assertNull(result.get("_testSetNormal2.ttl"));
//        assertEquals(value, accessor.get("testSetNormal2").get("testSetNormal2"));
//    }
//
//    @Test
//    public void testSetWithTTL() throws Exception {
//        if(!execute)return;
//        String value = UUID.randomUUID().toString();
//        Map<String,String> result = accessor.set("testSetWithTTL", value, 1);
//        assertNotNull(result.get("_testSetWithTTL.ttl"));
//        assertEquals(value, accessor.get("testSetWithTTL").get("testSetWithTTL"));
//        Thread.sleep(2000L);
//        result = accessor.get("testSetWithTTL");
//        assertNull(result.get("testSetWithTTL"));
//    }
//
//    @Test
//    public void testDelete() throws Exception {
//        if(!execute)return;
//        String value = UUID.randomUUID().toString();
//        Map<String,String> result = accessor.set("testDelete", value, null);
//        assertEquals(value, accessor.get("testDelete").get("testDelete"));
//        assertNotNull(result.get("_testDelete.createdIndex"));
//        result = accessor.delete("testDelete");
//        assertEquals(value, result.get("_testDelete.prevNode.createValue"));
//        assertNull(accessor.get("testDelete").get("testDelete"));
//    }
//
//    @Test
//    public void testGetProperties() throws Exception {
//        if(!execute)return;
//        String value = UUID.randomUUID().toString();
//        accessor.set("testGetProperties1", value);
//        Map<String,String> result = accessor.getProperties("");
//        assertNotNull(result);
//        assertEquals(value, result.get("testGetProperties1"));
//        assertNotNull(result.get("_testGetProperties1.createdIndex"));
//    }
//}