jetmessage

Documentation

Index

• type TypedMessage
  • func NewMessage[T any](codec peanats.Codec, msg jetstream.Msg) (TypedMessage[T], error)
• type TypedMessageBatch
  • func NewMessageBatch[T any](codec peanats.Codec, batch jetstream.MessageBatch) TypedMessageBatch[T]

Types

type TypedMessage

type TypedMessage[T any] interface {
	jetstream.Msg
	Payload() *T
}

func NewMessage

func NewMessage[T any](codec peanats.Codec, msg jetstream.Msg) (TypedMessage[T], error)

NewMessage is TypedMessage factory function

type TypedMessageBatch

type TypedMessageBatch[T any] interface {
	jetstream.MessageBatch
	Next(ctx context.Context) (TypedMessage[T], error)
}

func NewMessageBatch

func NewMessageBatch[T any](codec peanats.Codec, batch jetstream.MessageBatch) TypedMessageBatch[T]