feat: announce replica ip using POD_IP

opencdk8s · Dec 20, 2021 · e6f7e1f · e6f7e1f
1 parent e1abfb8
commit e6f7e1f
Show file tree

Hide file tree

Showing 4 changed files with 52 additions and 0 deletions.
diff --git a/API.md b/API.md
@@ -31784,6 +31784,19 @@ The size of volume to use.
 
 ---
 
+##### `annouceReplicaIp`<sup>Optional</sup> <a name="cdk8s-redis-cluster.RedisOptions.property.annouceReplicaIp"></a>
+
+```typescript
+public readonly annouceReplicaIp: boolean;
+```
+
+- *Type:* `boolean`
+- *Default:* undefined
+
+Annouce replica ip.
+
+---
+
 ##### `announceIps`<sup>Optional</sup> <a name="cdk8s-redis-cluster.RedisOptions.property.announceIps"></a>
 
 ```typescript

diff --git a/src/index.ts b/src/index.ts
@@ -85,6 +85,11 @@ export interface RedisOptions {
    *
    */
   readonly kumaMeshName?: string;
+  /**
+   * Annouce replica ip
+   * @default undefined
+   */
+  readonly annouceReplicaIp?: boolean;
 }
 
 export class Redis extends Construct {
@@ -112,6 +117,12 @@ export class Redis extends Construct {
 
     }
 
+    var b: string = '';
+
+    if (opts?.annouceReplicaIp) {
+      b = 'echo "replica-announce-ip $POD_IP" >> /opt/bitnami/redis/etc/redis.conf"';
+    }
+
 
     const storageClass = new k8s.KubeStorageClass(this, 'storageClass', {
       metadata: {
@@ -339,6 +350,7 @@ export class Redis extends Construct {
                 export REDIS_CLUSTER_CREATOR="yes"
                 export REDIS_CLUSTER_REPLICAS="1"
               fi
+              ${b}
               /opt/bitnami/scripts/redis-cluster/entrypoint.sh /opt/bitnami/scripts/redis-cluster/run.sh`],
               env: [
                 {
@@ -383,6 +395,14 @@ export class Redis extends Construct {
                   name: 'REDIS_PORT',
                   value: '6379',
                 },
+                {
+                  name: 'POD_IP',
+                  valueFrom: {
+                    fieldRef: {
+                      fieldPath: 'status.podIP',
+                    },
+                  },
+                },
               ],
               ports: [
                 {

diff --git a/test/__snapshots__/hello.test.ts.snap b/test/__snapshots__/hello.test.ts.snap
diff --git a/test/hello.test.ts b/test/hello.test.ts
@@ -11,6 +11,7 @@ test('with cm', () => {
     volumeSize: '10Gi',
     redisPassword: 'test',
     kumaMesh: false,
+    annouceReplicaIp: true,
   });
 
   expect(Testing.synth(chart)).toMatchSnapshot();