mafei-dev

kubernetes Java Client leader election example with RBAC related manifests

Creates RBAC related manifests

apiVersion: v1
kind: ServiceAccount
metadata:
  name: sample-app-user

mafei-dev

zone-id: ${ZONE_ID:southern}
gateway-host: ${API_HOST:localhost:8080}
instance-id: ${HOSTNAME:${random.uuid}}
#all external server names
services:
  url:
    delivery-service: delivery-service
    payment-service: payment-service
    user-service: user-service
server:

mafei-dev

server:
  port: 8082
spring:
  application:
    name: general-api-gateway
  cloud:
    gateway:
      default-filters:
        #        - StackSagaAdminRequestFilter
        - DedupeResponseHeader=Access-Control-Allow-Credentials Access-Control-Allow-Origin

mafei-dev

<dependency>
    <groupId>com.stacksaga</groupId>
    <artifactId>stack-saga-cloud-gateway-adapter</artifactId>
    <version>0.0.1</version>
</dependency>

mafei-dev

<dependency>
    <groupId>org.mono.stacksaga</groupId>
    <artifactId>stack-saga-discovery-client</artifactId>
    <version>0.0.1</version>
</dependency>

mafei-dev

<dependency>
    <groupId>org.mono.stacksaga</groupId>
    <artifactId>stack-saga-spring-boot-starter-mysql</artifactId>
    <version>1.0-SNAPSHOT</version>
</dependency>

mafei-dev

<dependency>
     <groupId>org.mono.stacksaga</groupId>
     <artifactId>stack-saga-spring-boot-starter-core</artifactId>
     <version>1.0-SNAPSHOT</version>
</dependency>

mafei-dev

docker run -d \
-p 4444:4444 \
-e DB_URL=jdbc:mysql://localhost:3306/stacksaga_admin_db?createDatabaseIfNotExist=true  \
-e DB_R2DBC_URL=r2dbc:mysql://localhost:3306/stacksaga_admin_db \
-e DB_USERNAME=root \
-e DB_PASSWORD=*** \
-e DROP_FIRST_DB=your-config \
-e SECRET=*** \
-e TOKEN_EXPIRATION_TIME=60000 \
--name stacksaga-admin-server \

mafei-dev

version: '3'
services:
  stacksaga_admin_mysql:
    container_name: stacksaga_admin_mysql
    image: "stacksaga/stacksaga_admin_mysql:1.0.0"
    ports:
      - "4444:4444"
    restart: always
    environment:
      - DB_URL=jdbc:mysql://host.docker.internal:3306/stacksaga_admin_db?createDatabaseIfNotExist=true

mafei-dev

package org.mono.stacksaga.security.adapter.cloud;

import io.r2dbc.pool.ConnectionPool;
import io.r2dbc.pool.ConnectionPoolConfiguration;
import io.r2dbc.spi.ConnectionFactories;
import io.r2dbc.spi.ConnectionFactory;
import io.r2dbc.spi.ConnectionFactoryOptions;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;