小编Ton*_*ark的帖子

使用TitanDB是"安全的"吗?

在DataStax收购Aurelius之后,由于Titan 1.0.0于2015年9月发布并且此后收到的提交很少,我想知道在生产中使用TitanDB是否安全.任何人都可以请一些见解?

titan

8
推荐指数
4
解决办法
4234
查看次数

让 Kubernetes 等待 Pod 终止,然后再从服务端点中删除

根据Termination of Pods,步骤 7 与 3 同时发生。有什么办法可以防止这种情况发生,并且只有在步骤7之后才发生Pod(或宽限期到期)

\n

我需要这个的原因是我的Pod终止例程需要在整个过程中my-service-X.my-namespace.svc.cluster.local解析到\的IP,但是一旦我在/上运行,相应的就会被删除PodEndpointkubectl deletePodDeployment上运行时,相应的IP就会被删除。

\n

注意:如果它有助于澄清这一点,我正在运行一堆集群 VerneMQ (Erlang) 节点,这些节点在终止时将其内容转储到集群 \xe2\x80\x94 上的其他节点,因此需要节点名在整个终止过程中正确解决。只有这样才应该有相应的Endpoint删除相应的 s。

\n

kubernetes

5
推荐指数
1
解决办法
2281
查看次数

法兰绒应该在Kubernetes大师身上运行吗?

我已成功在1个主节点+6个节点(所有运行的CentOS)上部署了Kubernetes 1.3.5集群,包括DNS和Kubernetes Dashboard插件.一开始似乎一切正常.但是,当我试图跑

kubectl proxy --address=<master-external-ip> --port=9090 --disable-filter
Run Code Online (Sandbox Code Playgroud)

和访问http://<master-external-ip>:9090/ui我得到以下输出

Error: 'dial tcp 172.16.38.2:9090: i/o timeout'
Trying to reach: 'http://172.16.38.2:9090/'
Run Code Online (Sandbox Code Playgroud)

但是,如果我从flanneld主人开始一切正常,我可以实际到达仪表板.现在,我已经习惯kube-up.sh安装集群,并没有systemd为法兰绒安装任何配置或服务,这让我感到困惑 - 如果法兰绒也在主人身上运行?

kubernetes flannel

3
推荐指数
1
解决办法
965
查看次数

使用TitanDB进行UPSERTing

我作为TitanDB用户迈出了第一步.那就是,我想知道如何在一个顶点/有条件地插入一个顶点TitanTransaction(以"获取或创建"的方式).

我有一个关于我想要创建/查找的顶点/属性的唯一索引.

titan

1
推荐指数
1
解决办法
677
查看次数

使用 AtomicBoolean 控制实例的状态

我需要确保特定的启动和停止代码在每个实例生命周期只执行一次,并且实例不能“重新启动”。以下代码是否适用于多个线程可能作用于实例的场景?

public final class MyRunnable {
    private final AtomicBoolean active = new AtomicBoolean(false);
    private final AtomicBoolean closed = new AtomicBoolean(false);

    public void start() {
      if (closed.get()) {
        throw new IllegalStateException("Already closed!");
      }
      if (active.get()) {
        throw new IllegalStateException("Already running!");
      }

      active.set(true);

      // My one-time start code.

      // My runnable code.
    }

    public void stop() {
      if (closed.get()) {
        throw new IllegalStateException("Already stopped!");
      }
      if (!active.get()) {
        throw new IllegalStateException("Stopping or already stopped!");
      }

      active.set(false);

      // My one-time stop code.

      closed.set(true); …
Run Code Online (Sandbox Code Playgroud)

java concurrency lifecycle atomic-values

0
推荐指数
1
解决办法
338
查看次数