Cadence

# macOS
brew install cadence-workflow
# Docker
docker run --rm ubercadence/cli:master

# CADENCE_CLI_ADDRESS --address
# CADENCE_CLI_DOMAIN --domain

# 使用 postgres
curl -o docker-compose.yml https://raw.githubusercontent.com/uber/cadence/master/docker/docker-compose-postgres.yml
curl -O https://raw.githubusercontent.com/uber/cadence/master/docker/prometheus_config.yml
# UI http://localhost:8088
# Grafana http://localhost:3000
# postgres :5432,prometheus :9090,grafana :3000,cadence 8000-8003,7933-3935,7939,cadence-web :8088
docker-compose up

# 注册 domain
# --address=host.docker.internal:7932
docker run --network=host --rm ubercadence/cli:master --do test-domain domain register -rd 1 --global_domain=false
# domian 信息
docker run --network=host --rm ubercadence/cli:master --do test-domain domain describe

// 流程接口
public interface TransferWorkflow {
  @WorkflowMethod(executionStartToCloseTimeoutSeconds = WEEK_SECOND)
  void execute(String fromAccountId, String toAccountId, Money amount);

  @SignalMethod // 信号方法
  void doCount(int n);
  @QueryMethod // 查询方法
  int void getCount();
}
// 事件接口
public interface Account {
  @ActivityMethod(scheduleToCloseTimeoutSeconds = 300)
  void debit(String fromAccountId, Money amount);
  @ActivityMethod(scheduleToCloseTimeoutSeconds = 300)
  void credit(String toAccountId, Money amount);
}
public interface TransferWorkflowImpl implements TransferWorkflow {
  // 支持配置自动重试
  private final Account account = Workflow.newActivityStub(Account.class);
  @Override
  public void execute(String fromAccountId, String toAccountId, Money amount){
    // 触发事件 - 阻塞该流程
    // 事件可能执行非常久 - 例如几天
    account.debit(fromAccountId,amount);
    try {
      account.credit(toAccountId,amount);
    } catch (IllegalArgumentException e){
      // 业务补偿逻辑
      account.credit(fromAccountId,amount);
    }

    // 可手动阻塞
    Workflow.sleep(Duration.ofDays(7));
  }

  // 本地状态 - 持久化的
  private int counter;
  @Override
  public void doCount(int n){
    counter += n;
  }
  @QueryMethod
  public int void getCount(){
    return counter;
  }
}

curl -LO https://raw.githubusercontent.com/uber/cadence/master/docker/config_template.yaml
docker run --rm -it \
  -v $PWD/config_template.yaml:/etc/cadence/config/config_template.yaml \
  -e DB=postgres -e POSTGRES_SEEDS=127.0.0.1 -e POSTGRES_USER=cadence -e POSTGRES_PWD=cadence \
  --name cadence ubercadence/server

history:
  # 2K -> SQL
  # 8K -> Cassandra
  numHistoryShards: 4

  # 存储引用
  defaultStore: default
  visibilityStore: visibility
  advancedVisibilityStore: es-visibility
  # 存储配置
  datastores:
    default:
      nosql:
        pluginName: "cassandra"
      sql:
        pluginName: "postgres"
        encodingType: "thriftrw"
        decodingTypes: ["thriftrw"]
        databaseName: {{ default .Env.DBNAME "cadence" }}
        connectAddr: "{{ default .Env.POSTGRES_SEEDS "" }}:{{ default .Env.DB_PORT "5432" }}"
        connectProtocol: "tcp"
        user: {{ default .Env.POSTGRES_USER "" }}
        password: {{ default .Env.POSTGRES_PWD "" }}
        maxConns: 20
        maxIdleConns: 20
        maxConnLifetime: "1h"
        tls:
          enabled: true
          sslmode: require
      elasticsearch:
        version: {{ default .Env.ES_VERSION "" }}
        username: {{ default .Env.ES_USER "" }}
        password: {{ default .Env.ES_PWD "" }}
        url:
          scheme: "http"
          host: "{{ default .Env.ES_SEEDS "" }}:{{ default .Env.ES_PORT "9200" }}"
        indices:
          visibility: {{ default .Env.VISIBILITY_NAME "cadence-visibility-dev" }}
    visibility:
      sql:
        # 一般会用不同的库
        databaseName: {{ default .Env.VISIBILITY_DBNAME "cadence_visibility" }}
    es-visibility:
dynamicConfigClient:
  filepath: /etc/cadence/config/dynamicconfig/config.yaml
  pollInterval: 10s

# 动态配置
frontend.visibilityListMaxQPS:
  - value: 1000
    constraints:
      domainName: 'domainA'
  - value: 2000
    constraints:
      domainName: 'domainB'

# 单节点
frontend.persistenceMaxQPS: 2000
# 全局
frontend.persistenceGlobalMaxQPS: 2000
# visibility db
frontend.visibilityListMaxQPS: 10
frontend.esVisibilityListMaxQPS: 30

matching.persistenceMaxQPS: 3000
matching.persistenceGlobalMaxQPS: 3000
matching.persistenceGlobalMaxQPS: 2000

history.persistenceMaxQPS: 9000
history.persistenceGlobalMaxQPS: 9000
history.historyVisibilityOpenMaxQPS:
history.historyVisibilityClosedMaxQPS:

go build -o cadence-sql-tool github.com/uber/cadence/cmd/tools/sql
# 默认存储 和 visibility 都需要
env $(cat .env | xargs) ./cadence-sql-tool setup-schema -v 0.0
env $(cat .vis | xargs) ./cadence-sql-tool setup-schema -v 0.0
# update - 注意 默认 和 visibility 路径不同
env $(cat .env | xargs) go run ./cmd/tools/sql/ update-schema -d schema/postgres/cadence/versioned/
env $(cat .vis | xargs) go run ./cmd/tools/sql/ update-schema -d schema/postgres/visibility/versioned/

SQL_PLUGIN=postgres
SQL_HOST=192.168.1.1
SQL_PORT=5432
SQL_DATABASE=cadence
SQL_USER=cadence
SQL_PASSWORD=
SQL_CONNECT_ATTRIBUTES=sslmode=require