natsmiddleware

Documentation

Index

• func ExtractJetStreamMetadata(next xpubsub.Handler) xpubsub.Handler
• func ExtractJetStreamMsgSequence(next xpubsub.Handler) xpubsub.Handler
• func ExtractJetStreamMsgTimestamp(next xpubsub.Handler) xpubsub.Handler
• type JetStreamMetadataCtxKey

Functions

func ExtractJetStreamMetadata

func ExtractJetStreamMetadata(next xpubsub.Handler) xpubsub.Handler

ExtractJetStreamMetadata is a middleware that extracts JetStream message metadata and stores in the context with the key JetStreamMetadataCtxKey.

func ExtractJetStreamMsgSequence

func ExtractJetStreamMsgSequence(next xpubsub.Handler) xpubsub.Handler

ExtractJetStreamMsgSequence extracts the timestamp from the JetStream Message metadata and stores it in the context.

func ExtractJetStreamMsgTimestamp

func ExtractJetStreamMsgTimestamp(next xpubsub.Handler) xpubsub.Handler

ExtractJetStreamMsgTimestamp extracts the timestamp from the JetStream Message metadata and stores it in the context.

Types

type JetStreamMetadataCtxKey

type JetStreamMetadataCtxKey struct{}

JetStreamMetadataCtxKey is the key to the JetStream Message metadata.