本文整理汇总了Java中io.fabric8.kubernetes.api.model.ConfigMap类的典型用法代码示例。如果您正苦于以下问题:Java ConfigMap类的具体用法?Java ConfigMap怎么用?Java ConfigMap使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
ConfigMap类属于io.fabric8.kubernetes.api.model包,在下文中一共展示了ConfigMap类的20个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: getData
import io.fabric8.kubernetes.api.model.ConfigMap; //导入依赖的package包/类
private static Map<String, String> getData(KubernetesClient client, String name, String namespace) {
Map<String, String> result = new HashMap<>();
try {
ConfigMap map = namespace == null || namespace.isEmpty()
? client.configMaps().withName(name).get()
: client.configMaps().inNamespace(namespace).withName(name).get();
if (map != null) {
for (Map.Entry<String, String> entry : map.getData().entrySet()) {
String key = entry.getKey();
String value = entry.getValue();
if (key.equals(APPLICATION_YAML) || key.equals(APPLICATION_YML)) {
result.putAll(YAML_TO_PROPETIES.andThen(PROPERTIES_TO_MAP).apply(value));
} else if (key.equals(APPLICATION_PROPERTIES)) {
result.putAll(KEY_VALUE_TO_PROPERTIES.andThen(PROPERTIES_TO_MAP).apply(value));
} else {
result.put(key, value);
}
}
}
} catch (Exception e) {
LOGGER.warn("Can't read configMap with name: [" + name + "] in namespace:[" + namespace + "]. Ignoring");
}
return result;
}
开发者ID:fabric8io,项目名称:spring-cloud-kubernetes,代码行数:26,代码来源:ConfigMapPropertySource.java
示例2: testClusterIsCreated
import io.fabric8.kubernetes.api.model.ConfigMap; //导入依赖的package包/类
@Test
public void testClusterIsCreated() throws Exception {
Address queue = createAddress("myqueue", StandardType.QUEUE);
KubernetesList resources = new KubernetesList();
resources.setItems(Arrays.asList(new ConfigMap()));
AddressCluster cluster = new AddressCluster("myqueue", resources);
when(mockHelper.listClusters()).thenReturn(Collections.emptyList());
when(mockGenerator.generateCluster("myqueue", Collections.singleton(queue))).thenReturn(cluster);
ArgumentCaptor<Set<io.enmasse.address.model.Address>> arg = ArgumentCaptor.forClass(Set.class);
controller.resourcesUpdated(Collections.singleton(queue));
verify(mockGenerator).generateCluster(eq("myqueue"), arg.capture());
assertThat(arg.getValue(), hasItem(queue));
verify(mockHelper).create(resources);
}
开发者ID:EnMasseProject,项目名称:enmasse,代码行数:17,代码来源:AddressControllerTest.java
示例3: testNodesAreRetained
import io.fabric8.kubernetes.api.model.ConfigMap; //导入依赖的package包/类
@Test
public void testNodesAreRetained() throws Exception {
Address queue = createAddress("myqueue", StandardType.QUEUE);
KubernetesList resources = new KubernetesList();
resources.setItems(Arrays.asList(new ConfigMap()));
AddressCluster existing = new AddressCluster(queue.getAddress(), resources);
when(mockHelper.listClusters()).thenReturn(Collections.singletonList(existing));
Address newQueue = createAddress("newqueue", StandardType.QUEUE);
AddressCluster newCluster = new AddressCluster(newQueue.getAddress(), resources);
when(mockGenerator.generateCluster("newqueue", Collections.singleton(newQueue))).thenReturn(newCluster);
ArgumentCaptor<Set<io.enmasse.address.model.Address>> arg = ArgumentCaptor.forClass(Set.class);
controller.resourcesUpdated(Sets.newSet(queue, newQueue));
verify(mockGenerator).generateCluster(anyString(), arg.capture());
assertThat(arg.getValue(), is(Sets.newSet(newQueue)));
verify(mockHelper).create(resources);
}
开发者ID:EnMasseProject,项目名称:enmasse,代码行数:22,代码来源:AddressControllerTest.java
示例4: testAddressesAreGrouped
import io.fabric8.kubernetes.api.model.ConfigMap; //导入依赖的package包/类
@Test
public void testAddressesAreGrouped() throws Exception {
Address addr0 = createAddress("myqueue0", StandardType.QUEUE);
Address addr1 = createAddress("myqueue1", StandardType.QUEUE, "pooled-inmemory");
Address addr2 = createAddress("myqueue2", StandardType.QUEUE, "pooled-inmemory");
Address addr3 = createAddress("myqueue3", StandardType.QUEUE);
KubernetesList resources = new KubernetesList();
resources.setItems(Arrays.asList(new ConfigMap()));
AddressCluster existing = new AddressCluster("myqueue0", resources);
when(mockHelper.listClusters()).thenReturn(Collections.singletonList(existing));
ArgumentCaptor<Set<io.enmasse.address.model.Address>> arg = ArgumentCaptor.forClass(Set.class);
when(mockGenerator.generateCluster(anyString(), arg.capture())).thenReturn(new AddressCluster("foo", resources));
controller.resourcesUpdated(Sets.newSet(addr0, addr1, addr2, addr3));
Set<io.enmasse.address.model.Address> generated = arg.getAllValues().stream().flatMap(Collection::stream).collect(Collectors.toSet());
assertThat(generated.size(), is(3));
}
开发者ID:EnMasseProject,项目名称:enmasse,代码行数:21,代码来源:AddressControllerTest.java
示例5: getConfigMapTest
import io.fabric8.kubernetes.api.model.ConfigMap; //导入依赖的package包/类
@Test
public void getConfigMapTest() throws Exception {
if (ObjectHelper.isEmpty(authToken)) {
return;
}
Exchange ex = template.request("direct:getConfigMap", new Processor() {
@Override
public void process(Exchange exchange) throws Exception {
exchange.getIn().setHeader(
KubernetesConstants.KUBERNETES_NAMESPACE_NAME,
"default");
exchange.getIn().setHeader(
KubernetesConstants.KUBERNETES_CONFIGMAP_NAME,
"elasticsearch-7015o");
}
});
ConfigMap result = ex.getOut().getBody(ConfigMap.class);
assertNull(result);
}
开发者ID:HydAu,项目名称:Camel,代码行数:23,代码来源:KubernetesConfigMapsProducerTest.java
示例6: getRequestId
import io.fabric8.kubernetes.api.model.ConfigMap; //导入依赖的package包/类
public String getRequestId(final OpenShiftClient client, final String namespace) throws MultiTenantMigrationException {
ConfigMap cm = getConfigMap(client, namespace);
if (cm == null) {
throw new MultiTenantMigrationException(MIGRATION_CONFIG_MAP_NAME + " config map does not exist");
}
return cm.getData().get(REQUEST_ID);
}
开发者ID:redhat-developer,项目名称:che-starter,代码行数:8,代码来源:MigrationConfigMap.java
示例7: build
import io.fabric8.kubernetes.api.model.ConfigMap; //导入依赖的package包/类
@Override
public ConfigMap build() {
return new io.fabric8.kubernetes.api.model.ConfigMapBuilder()
.withMetadata(metadataBuilder().build())
.withData(fileMap.entrySet().stream().collect(Collectors.toMap(
Map.Entry::getKey,
x -> x.getValue().entrySet().stream().map(y -> y.getKey() + "=" + y.getValue() + "\n").collect(Collectors.joining()))))
.build();
}
开发者ID:xtf-cz,项目名称:xtf,代码行数:10,代码来源:ConfigMapWithPropertyFilesBuilder.java
示例8: build
import io.fabric8.kubernetes.api.model.ConfigMap; //导入依赖的package包/类
@Override
public ConfigMap build() {
return new io.fabric8.kubernetes.api.model.ConfigMapBuilder()
.withMetadata(metadataBuilder().build())
.withData(config.entrySet().stream().collect(Collectors.toMap(x -> nameTransformationFunction.apply(x.getKey()), Map.Entry::getValue)))
.build();
}
开发者ID:xtf-cz,项目名称:xtf,代码行数:8,代码来源:ConfigMapBuilder.java
示例9: exec
import io.fabric8.kubernetes.api.model.ConfigMap; //导入依赖的package包/类
@TaskAction
public void exec() {
ImmutableDeploymentExtension config =
getProject().getExtensions().getByType(DeploymentExtension.class);
final ImmutableDeploymentConfiguration deploymentConfig = config.getTypes().getByName(type);
Map<String, RpcAcl> aclMap =
deploymentConfig
.rpcAcls()
.entrySet()
.stream()
.map(
entry ->
new SimpleImmutableEntry<>(
entry.getKey(), ImmutableRpcAcl.builder().rate(entry.getValue()).build()))
.collect(toImmutableMap(Entry::getKey, Entry::getValue));
final String serializedAcls;
try {
serializedAcls = OBJECT_MAPPER.writeValueAsString(aclMap);
} catch (JsonProcessingException e) {
throw new UncheckedIOException("Could not serialize acls.", e);
}
ConfigMap configMap =
new ConfigMapBuilder()
.withMetadata(
new ObjectMetaBuilder()
.withName("rpcacls")
.withNamespace(deploymentConfig.namespace())
.build())
.withData(ImmutableMap.of("rpcacls.json", serializedAcls))
.build();
KubernetesClient client = new DefaultKubernetesClient();
client.resource(configMap).createOrReplace();
}
开发者ID:curioswitch,项目名称:curiostack,代码行数:36,代码来源:DeployConfigMapTask.java
示例10: onInitialConfigMaps
import io.fabric8.kubernetes.api.model.ConfigMap; //导入依赖的package包/类
private synchronized void onInitialConfigMaps(ConfigMapList configMaps) {
if (configMaps == null)
return;
if (trackedConfigMaps == null) {
trackedConfigMaps = new ConcurrentHashMap<>(configMaps.getItems()
.size());
}
List<ConfigMap> items = configMaps.getItems();
if (items != null) {
for (ConfigMap configMap : items) {
try {
if (containsSlave(configMap)
&& !trackedConfigMaps.containsKey(configMap
.getMetadata().getUid())) {
List<PodTemplate> templates = podTemplatesFromConfigMap(configMap);
trackedConfigMaps.put(configMap.getMetadata().getUid(),
templates);
for (PodTemplate podTemplate : templates) {
JenkinsUtils.addPodTemplate(podTemplate);
}
}
} catch (Exception e) {
logger.log(SEVERE,
"Failed to update ConfigMap PodTemplates", e);
}
}
}
}
开发者ID:jenkinsci,项目名称:openshift-sync-plugin,代码行数:29,代码来源:ConfigMapWatcher.java
示例11: subscribe
import io.fabric8.kubernetes.api.model.ConfigMap; //导入依赖的package包/类
public SubscribeResponse subscribe(SubscribeRequest request) throws InternalException {
String namespace = request.getNamespace();
Objects.notNull(namespace, "namespace");
ConfigMap configMap = createSubscriptionResource(request, namespace);
kubernetesClient.configMaps().inNamespace(namespace).create(configMap);
return new SubscribeResponse(namespace, KubernetesHelper.getName(configMap));
}
开发者ID:funktionio,项目名称:funktion-connectors,代码行数:9,代码来源:Agent.java
示例12: onEvent
import io.fabric8.kubernetes.api.model.ConfigMap; //导入依赖的package包/类
private void onEvent(ConfigMap configMap) {
MapPropertySource currentConfigMapSource = findPropertySource(ConfigMapPropertySource.class);
if (currentConfigMapSource != null) {
MapPropertySource newConfigMapSource = configMapPropertySourceLocator.locate(environment);
if (changed(currentConfigMapSource, newConfigMapSource)) {
log.info("Detected change in config maps");
reloadProperties();
}
}
}
开发者ID:fabric8io,项目名称:spring-cloud-kubernetes,代码行数:11,代码来源:EventBasedConfigurationChangeDetector.java
示例13: start
import io.fabric8.kubernetes.api.model.ConfigMap; //导入依赖的package包/类
public void start() {
ConfigMap map = Strings.isNullOrEmpty(namespace)
? client.configMaps().withName(name).get()
: client.configMaps().inNamespace(namespace).withName(name).get();
if (map != null) {
currentData.set(asObjectMap(map.getData()));
}
watch = Strings.isNullOrEmpty(namespace)
? client.configMaps().withName(name).watch(watcher)
: client.configMaps().inNamespace(namespace).withName(namespace).watch(watcher);
started.set(true);
}
开发者ID:fabric8io,项目名称:spring-cloud-kubernetes,代码行数:14,代码来源:ArchaiusConfigMapSourceConfiguration.java
示例14: start
import io.fabric8.kubernetes.api.model.ConfigMap; //导入依赖的package包/类
public void start() {
ConfigMap initial = openshiftClient.configMaps().withName(configName).get();
if (initial != null) {
eventReceived(Action.ADDED, initial);
}
watch = openshiftClient.configMaps().withName(configName).watch(this);
}
开发者ID:EnMasseProject,项目名称:enmasse,代码行数:8,代码来源:ConfigAdapter.java
示例15: eventReceived
import io.fabric8.kubernetes.api.model.ConfigMap; //导入依赖的package包/类
@Override
public void eventReceived(Action action, ConfigMap resource) {
try {
configSubscriber.configUpdated(action, resource);
} catch (Exception e) {
log.warn("Error handling config update", e);
}
}
开发者ID:EnMasseProject,项目名称:enmasse,代码行数:9,代码来源:ConfigAdapter.java
示例16: getAddressSpaceWithName
import io.fabric8.kubernetes.api.model.ConfigMap; //导入依赖的package包/类
@Override
public Optional<AddressSpace> getAddressSpaceWithName(String name) {
ConfigMap map = client.configMaps().withName(getConfigMapName(name)).get();
if (map == null) {
return Optional.empty();
} else {
return Optional.of(getAddressSpaceFromConfig(map));
}
}
开发者ID:EnMasseProject,项目名称:enmasse,代码行数:10,代码来源:ConfigMapAddressSpaceApi.java
示例17: replaceAddressSpace
import io.fabric8.kubernetes.api.model.ConfigMap; //导入依赖的package包/类
@Override
public void replaceAddressSpace(AddressSpace addressSpace) throws Exception {
String name = KubeUtil.sanitizeName("address-space-" + addressSpace.getName());
ConfigMap previous = client.configMaps().withName(name).get();
if (previous == null) {
return;
}
try {
create(client.configMaps().createOrReplaceWithNew(), addressSpace);
} catch (Exception e) {
log.error("Error replacing {}", addressSpace.getName());
throw e;
}
}
开发者ID:EnMasseProject,项目名称:enmasse,代码行数:15,代码来源:ConfigMapAddressSpaceApi.java
示例18: listAddressSpaces
import io.fabric8.kubernetes.api.model.ConfigMap; //导入依赖的package包/类
@Override
public Set<AddressSpace> listAddressSpaces() {
Set<AddressSpace> instances = new LinkedHashSet<>();
ConfigMapList list = client.configMaps().withLabel(LabelKeys.TYPE, "address-space").list();
for (ConfigMap map : list.getItems()) {
instances.add(getAddressSpaceFromConfig(map));
}
return instances;
}
开发者ID:EnMasseProject,项目名称:enmasse,代码行数:10,代码来源:ConfigMapAddressSpaceApi.java
示例19: getAddressSpaceFromConfig
import io.fabric8.kubernetes.api.model.ConfigMap; //导入依赖的package包/类
private AddressSpace getAddressSpaceFromConfig(ConfigMap map) {
try {
AddressSpace addressSpace = mapper.readValue(map.getData().get("config.json"), AddressSpace.class);
return new AddressSpace.Builder(addressSpace).setUid(map.getMetadata().getUid()).build();
} catch (Exception e) {
log.error("Error decoding address space", e);
throw new RuntimeException(e);
}
}
开发者ID:EnMasseProject,项目名称:enmasse,代码行数:10,代码来源:ConfigMapAddressSpaceApi.java
示例20: getAddressWithName
import io.fabric8.kubernetes.api.model.ConfigMap; //导入依赖的package包/类
@Override
public Optional<Address> getAddressWithName(String name) {
ConfigMap map = client.configMaps().inNamespace(namespace).withName(KubeUtil.sanitizeName("address-config-" + name)).get();
if (map == null) {
return Optional.empty();
} else {
return Optional.of(getAddressFromConfig(map));
}
}
开发者ID:EnMasseProject,项目名称:enmasse,代码行数:10,代码来源:ConfigMapAddressApi.java
注:本文中的io.fabric8.kubernetes.api.model.ConfigMap类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论