Code

abstract pubsub service via gocloud#1664

Code

Merged

kodiakhq[bot] merged 18 commits intoguacsec:mainguacsec/guac:mainfrom pxp928:poc-pubsubpxp928/artifact-ff:poc-pubsubCopy head branch name to clipboardJan 29, 2024

+814-915

Commits

Commits on Jan 27, 2024

• add new file to emitter package

  Show description for 56af9f8
  pxp928

  committed
  56af9f8

  Copy full SHA for 56af9f8

• add gocloud nats plugin that supports jetstream

  Show description for e0a5f37
  pxp928

  committed
  e0a5f37

  Copy full SHA for e0a5f37

• add publish and subscribe via gocloud

  Show description for 83c6967
  pxp928

  committed
  83c6967

  Copy full SHA for 83c6967

• add support for jetstream and other pubsub services

  Show description for 1b3a8dd
  pxp928

  committed
  1b3a8dd

  Copy full SHA for 1b3a8dd

• add missing initalization for nats and defer sub close

  Show description for 7f74f96
  pxp928

  committed
  7f74f96

  Copy full SHA for 7f74f96

• nats jetstream functional with gocloud

  Show description for 0278671
  pxp928

  committed
  0278671

  Copy full SHA for 0278671

• remove context initalization for jetstream

  Show description for c17b676
  pxp928

  committed
  c17b676

  Copy full SHA for c17b676

• udpate unit tests for emitter

  Show description for 4337636
  pxp928

  committed
  4337636

  Copy full SHA for 4337636

• remove unneeded stream information for publish and subscribe

  Show description for 6c360b1
  pxp928

  committed
  6c360b1

  Copy full SHA for 6c360b1

• change nats-addr to pubsub-addr and add check before nats initializes

  Show description for 5a8e075
  pxp928

  committed
  5a8e075

  Copy full SHA for 5a8e075

• remove storing in context

  Show description for b9548ea
  pxp928

  committed
  b9548ea

  Copy full SHA for b9548ea

• update helper comments for emitter

  Show description for 28aa16c
  pxp928

  committed
  28aa16c

  Copy full SHA for 28aa16c

• updated error message

  Show description for e296180
  pxp928

  committed
  e296180

  Copy full SHA for e296180

• fix err checking to shutdown topic and subscriber

  Show description for a48bcad
  pxp928

  committed
  a48bcad

  Copy full SHA for a48bcad

• remove commented out unused code

  Show description for 86f45ab
  pxp928

  committed
  86f45ab

  Copy full SHA for 86f45ab

• improve nats error messaage with server address

  Show description for 5915eac
  pxp928

  committed
  5915eac

  Copy full SHA for 5915eac

• fix tilt and address comments

  Show description for c16022d
  pxp928

  committed
  c16022d

  Copy full SHA for c16022d

• remove commented out unused code

  Show description for 8a953de
  pxp928

  committed
  8a953de

  Copy full SHA for 8a953de