- 778f24a fix: prevent Kafka pending loop dieing on disconnection
- f289249 refactor: container killer refactor
- 7e793bf fix: improved dedupe
- Alex Collins
- Alex Collins
- 972ebf0 fix: increased default CPU resources requests to 250m
- 786bc05 fix: move patching step status earlier in shutdown sequence
- 2f9898b config: removed invalid resource
- 3645436 fix: correct metrics
- 8a169ca feat: fix test
- 752086b feat: re-order logging
- 4b6a9d6 feat: pass GODEBUG to runner
- 7a08e5e feat: dedupe
- 6904aa7 feat: add
sha1func
- Alex Collins
- ed68cb0 config: ARGO_DATAFLOW_UPDATE_INTERVAL=10s for dev
- c564148 fix(controller): correct service name
- Alex Collins
- e5fa079 feat: pprof sidecar
- 3c0d169 fix: Kafka pending wrong when re-using pipeline
- f37aea4 fix: revert to auto-commit
- 24d91a1 fix: negative Kafka pending
- 32a73a7 fix: expose stan monitoring port (#78)
- Alex Collins
- Derek Wang
- 0d68892 feat: add HTTP source service name
- e2728c6 feat(sidecar): disable Kafka auto-commit
- 2b90f11 fix(sidecar): fix Kafka pending tiny over-estimate
- f296a83 config: added natsMonitoringUrl
- 04fe2f8 feat(sidecar): added sidecar readiness probe
- b395ffe feat(sidecar): set kafka max-processing time to 30s
- 0fc71c2 chore(sidecar): Refactor sidecar (#70)
- 994e80e ok
- efb20b1 feat: smaller binaries without DWARF/symbols
- 2332aeb feat: smaller binaries without DWARF/symbols
- Alex Collins
- Alex Collins
- Derek Wang
- 12a98cd fix: stan manual ack
- Derek Wang
- Alex Collins
- 6f7bb50 config: change argo-server to HTTP
- 4770ed6 config: change argo-server to HTTP
- 8d4ee45 config: change argo-server to HTTP
- 7679590 config: change argo-server to HTTP
- c63a715 refactor: rename variables
- 316abc9 Update README.md (#68)
- Alex Collins
- wanghong230
- 23fc919 fix: Add missing kubernetes requirement in setup.py (#64)
- dbc403d fix: fix Python
- a2fdaaf feat: publish Python library
- a411be8 feat: publish Python library
- 72b3484 feat: publish Python library
- 361c47c feat: add a method to run pipelines in DSL
- Alex Collins
- Yuan Tang
- e61c307 feat: add context to Java runtime
- 5becca6 feat: add context to Git example
- 6b922eb feat: add context to Python runtime
- Alex Collins
- Alex Collins
- 268b1ec fix: removed parallel
- 4cd5e8b feat: switch to manual ack
- e09e8e9 fix: clean up parallel for stan
- Alex Collins
- Derek Wang
- b8e88fe fix: nats pending messages type assersion error
- Derek Wang
- Alex Collins
- Derek Wang
- a03615d ok
- Alex Collins
- d2f219f ok
- abbf7d0 fix: various issues
- c6a9e6e feat: add retryPolicy
- 8170a88 feat: more work on Python DLS
- e306739 feat: more work on Python DLS
- Alex Collins
- cd2082e feat: simplify so only replica 0 report metrics
- Alex Collins
- da6a1e0 fix: fix permissions
- Alex Collins
- Alex Collins
- fcfb45f fix: bugs in grouping
- bf55468 refactor: de-couple scaling
- 2695c7a feat: more Python DSL
- f6a6d0d feat: more Python DSL
- 85908bb feat: add Python DSL
- Alex Collins
- Alex Collins
- ca7edf1 feat: add in_flight metric
- 009731a refactor: made code more testable
- a3142eb fix: add bearer token
- Alex Collins
- Alex Collins
- Alex Collins
- Derek Wang
- 60eab31 fix: prevent violent scale-up and scale-down by only scaling by 1 each time
- Alex Collins
- Alex Collins
- 3dd39f1 fix(sidecar): updated to use fixed counters
- 6bef420 fix: removed scrape annotations
- 3a7ab5c ok
- Alex Collins
- c6763e5 feat(runner): Request Bearer token
- 9d8676b feat(runner): Emit Prometheus metrics (#57)
- 869e492 ok
- af151b6 fix: correct STAN durable name
- Alex Collins
- 6156b57 fix: bug where we were not getting kafka secret
- Alex Collins
- 57567e3 fix!: change rate to resource.Quantity
- Alex Collins
- 98eadec fix!: change rate to resource.Quantity
- Alex Collins
- Alex Collins
- 980c741 fix: try and avoid partition changes
- Alex Collins
- a561027 fix: fixed bug with pipeline conditions and messages computation
- 45f51fa feat: implement an ordered shutdown sequence
- Alex Collins
- 2ad2f52 feat: allow messages to be return to request
- 59669ca fix: correct http POST to use keep-alives
- Alex Collins
- 22b0b8b fix: fix bouncy scaling bug
- Alex Collins
- de8a19f fix: enhanced shutdown
- Alex Collins
- f3ba148 fix: correct metrics over restart
- 3c0b7fd config: pump more data thorough Kafka topic
- f753b2d feat: update examples
- 5c6832b feat: report rate
- b28c3a3 fix: report back errors
- Alex Collins
- 9d04dcd refactor: change from
for {}towait.JitterUntil - e17f961 feat: only check Kafka partition for pending
- d3e02ea feat: reduced update interval to every 30s
- 72f0aeb feat(runner): change name of queue
- e25a33c feat: report Kubernetes API errors related to pod/servic creation/deletion
- 36dae38 feat: only update pending for replica zero to prevent disagreement
- Alex Collins
- e4a4b1a feat: longer status messages
- Alex Collins
- 9bef0df feat: expose pod failure reason
- Alex Collins
- 2a23cb8 fix: scale to 1 rather than 0 on start
- Alex Collins
- Alex Collins
- 3089119 fix: only terminate sidecars if the main container exit with code 0
- 6dc28a2 fix: failed to record sink status
- 3db2fbc fix: add missing RBAC for manager
- Alex Collins
- b22e9fd fix: correct changelog order
- Alex Collins
- dd8efe3 feat: and support for stateless sources and sinks with HTTP
- Alex Collins
- 940632a feat: and 1st-class support for expand and flatten
- 9e6ab3d feat: support layout of cron source messages
- 290cde4 feat: support HPA
- d6920cf refactor: move replicas to top level
- Alex Collins
- 7e3a574 config: increase stan-default storage to 16Gi
- 9166870 config: increase stan-default storage to 16Gi
- Alex Collins
- Alex Collins
- 1fbfbd1 fix: correct
errortolastError
- Alex Collins
- 0d0c6d5 fix: remove version file
- 99bfd15 refactor: move api/util to ../shared/
- e26c3a9 refactor: move containerkiller
- cc175fc refactor: move controller files
- 8d8c2ae feat: add errors to step/status
- 9172dc7 fix: only calculate installed hash after changes have been applied
- Alex Collins
- f341a7d config: change argo-server to secure
- fd75eb3 config: change argo-server to secure
- dcb24d5 config: change argo-server to secure
- Alex Collins