abhirockzz

AWSTemplateFormatVersion: '2010-09-09'
Parameters:
  DatabasePassword:
    AllowedPattern: '[a-zA-Z0-9]+'
    ConstraintDescription: must contain only alphanumeric characters. Must have length 8-41.
    Description: Database admin account password.
    MaxLength: '41'
    MinLength: '8'
    Default: 'S3cretPwd99'
    Type: String

abhirockzz

//exception handling excluded to avoid verbosity

RsaJsonWebKey rsaJsonWebKey = RsaKeyProducer.produce();

JwtClaims claims = new JwtClaims();
claims.setSubject("user1");

JsonWebSignature jws = new JsonWebSignature();
jws.setPayload(claims.toJson());
jws.setKey(rsaJsonWebKey.getPrivateKey());

abhirockzz

#------------ bootstrap the cluster nodes --------------------

start_cmd='redis-server --port 6379 --cluster-enabled yes --cluster-config-file nodes.conf --cluster-node-timeout 5000 --appendonly yes'
redis_image='redis:5.0-rc'
network_name='redis_cluster_net'

docker network create $network_name
echo $network_name " created"

#---------- create the cluster ------------------------

abhirockzz

import java.util.Collections;
import java.util.List;
import java.util.Objects;
import java.util.function.Predicate;

public class RandomGist {

    public static <T> T requireNonEmpty(T object, Predicate<T> predicate, String msgToCaller){
        Objects.requireNonNull(object);
        Objects.requireNonNull(predicate);

abhirockzz

Dapr NATS Streaming pubsub component config

Configuration parameters

• natsURL

  • description: NATS server URL
  • required: yes
  • sample value: nats://demo.nats.io:4222

• natsStreamingClusterID

abhirockzz

apiVersion: v1
kind: PersistentVolumeClaim
metadata:
  name: azure-disk-pvc
spec:
  storageClassName: ""
  accessModes:
    - ReadWriteOnce
  resources:
    requests:

abhirockzz

apiVersion: v1
kind: PersistentVolume
metadata:
  name: azure-disk-pv
spec:
  capacity:
    storage: 2Gi
  storageClassName: ""
  volumeMode: Filesystem
  accessModes:

abhirockzz

spec:
containers:
- name: kstreams-lower-to-upper
    image: [REPLACE_ACR_NAME].azurecr.io/kstreams-lower-to-upper:v1
    env:
    - name: KAFKA_BROKER
        value: [to be filled]

abhirockzz

apiVersion: v1
kind: ConfigMap
metadata:
  name: config3
data:
  appconfig.json: |
    {
      "array": [
        1,
        2,

abhirockzz

apiVersion: apps/v1
kind: Deployment
metadata:
  name: kin-stateless-depl
spec:
  replicas: 2
  selector:
    matchLabels:
      app: kin-stateless-depl
  template: