Code

Implement Stream Controller#1

Code

Draft

adriandieter wants to merge 39 commits intocontroller-runtimeaqube/nats-io-nack:controller-runtimefrom stream-controlleraqube/nats-io-nack:stream-controllerCopy head branch name to clipboard

+2,633-1,041

Commits

Commits on Dec 6, 2024

• Bump alpine from 3.20.3 to 3.21.0 in /cicd (nats-io#210)

  Show description for fb7b77c
  dependabot[bot]

  authored
  fb7b77c

• Bump golang from 1.23.3-bullseye to 1.23.4-bullseye in /cicd (nats-io#209)

  Show description for 90ac54c
  dependabot[bot]

  authored
  90ac54c

Commits on Dec 9, 2024

• Migrate to kube_codegen.sh

  samuelattwood

  committed
  b751988

• Migrate to reconciliation loop using controller-runtime (nats-io#208)

  Show description for 895dc1c
  

  adriandieter

  authored and

  samuelattwood

  committed
  895dc1c

Commits on Dec 11, 2024

• Add account, consumer and stream controller stubs to be implemented

  Show description for 38a7db2
  adriandieter

  committed
  38a7db2

• Add logs to Reconcile functions

  adriandieter

  committed
  52c5d9f

• Add jsClient to test suit variables

  adriandieter

  committed
  25f3fa0

• Remove format from log string

  adriandieter

  committed
  60a28f5

• Make upsertCondition public to be used in new controllers

  adriandieter

  committed
  bffc435

• Implement basic cases for stream reconciliation

  Show description for ac84508
  adriandieter

  committed
  ac84508

• refactor to use shared base controller

  adriandieter

  committed
  d041edc

• Support jetstream connection options in stream spec

  adriandieter

  committed
  4d57584

• implement stream deletion

  adriandieter

  committed
  814e243

• update observedGeneration of status

  adriandieter

  committed
  fb431bc

• check Spec.PreventDelete before stream deletion

  adriandieter

  committed
  1f6be77

• remove base js client

  Show description for 37f44fc
  adriandieter

  committed
  37f44fc

• move asJsonString to jetstream_controller

  adriandieter

  committed
  00c98e5

• check namespace read only and prevent update mode

  adriandieter

  committed
  7e2006b

• Update comments and log

  adriandieter

  committed
  1b8b96d

• Fix test docs and check precondition

  adriandieter

  committed
  8ddea8d

• Add preventUpdate test cases

  adriandieter

  committed
  5a5a7f5

• Add tests for read-only or namespace restricted mode

  adriandieter

  committed
  6f90932

• fix empty ca when no ca set

  Show description for 19c6beb
  adriandieter

  committed
  19c6beb

• simplify error message

  adriandieter

  committed
  9418bcd

• fix error loop when the underlying stream was deleted

  adriandieter

  committed
  f7abcc6

• refactor each phase into separate method

  adriandieter

  committed
  84619b5

• Fix errors during parallel reconciliation & Refactor tests

  Show description for 28cb7b0
  adriandieter

  committed
  28cb7b0

• make test description strings more uniform

  adriandieter

  committed
  8331720

• Update docs and log messages

  adriandieter

  committed
  2f04e7f

• extract configuration to buildNatsConfig method

  adriandieter

  committed
  ffdc4c7

• fix checking for preventDelete in the update step

  Show description for 617f3c0
  adriandieter

  committed
  617f3c0

Commits on Dec 12, 2024

• fix k8s binaries not downloaded for tests

  adriandieter

  committed
  d603c91

• add /bin to gitignore

  adriandieter

  committed
  ce91d08

Commits on Dec 17, 2024

• rename stream helper functions

  Show description for 684a3b2
  adriandieter

  committed
  684a3b2

Commits on Dec 18, 2024

• update naming as suggested

  adriandieter

  committed
  0fd239d

• fix assumed reason in log message

  adriandieter

  committed
  a7a341e

• Update todo comments marked with review

  Show description for 0b21494
  adriandieter

  committed
  0b21494

• separate CA config from client cert and key

  adriandieter

  committed
  2bf9162

• set streamName and consumerName fields once on logger

  Show description for d93aa63
  adriandieter

  committed
  d93aa63