1
0
mirror of https://github.com/go-micro/go-micro.git synced 2025-08-10 21:52:01 +02:00
Files
go-micro/events/natsjs
Asim Aslam ee9f3afe37 GenAI interface (#2790)
* genai interface

* x

* x

* text to speech

* Re-add events package (#2761)

* Re-add events package

* run redis as a dep

* remove redis events

* fix: data race on event subscriber

* fix: data race in tests

* fix: store errors

* fix: lint issues

* feat: default stream

* Update file.go

---------

Co-authored-by: Brian Ketelsen <bketelsen@gmail.com>

* .

* copilot couldn't make it compile so I did

* copilot couldn't make it compile so I did

* x

---------

Co-authored-by: Brian Ketelsen <bketelsen@gmail.com>
2025-06-20 10:24:31 +01:00
..
2025-06-18 17:12:02 +01:00
2025-06-20 10:24:31 +01:00
2025-06-18 17:12:02 +01:00
2025-06-18 17:12:02 +01:00
2025-06-18 17:12:02 +01:00

NATS JetStream

This plugin uses NATS with JetStream to send and receive events.

Create a stream

ev, err := natsjs.NewStream(
  natsjs.Address("nats://10.0.1.46:4222"),
  natsjs.MaxAge(24*160*time.Minute),
)

Consume a stream

ee, err := events.Consume("test",
  events.WithAutoAck(false, time.Second*30),
  events.WithGroup("testgroup"),
)
if err != nil {
  panic(err)
}
go func() {
  for {
    msg := <-ee
    // Process the message
    logger.Info("Received message:", string(msg.Payload))
    err := msg.Ack()
    if err != nil {
      logger.Error("Error acknowledging message:", err)
    } else {
      logger.Info("Message acknowledged")
    }
  }
}()

Publish an Event to the stream

err = ev.Publish("test", []byte("hello world"))
if err != nil {
  panic(err)
}