MCPcopy
hub / github.com/nats-io/nats.go / Metadata

Method Metadata

jetstream/message.go:37–37  ·  view source on GitHub ↗

Metadata returns [MsgMetadata] for a JetStream message.

()

Source from the content-addressed store, hash-verified

35 Msg interface {
36 // Metadata returns [MsgMetadata] for a JetStream message.
37 Metadata() (*MsgMetadata, error)
38
39 // Data returns the message body.
40 Data() []byte

Callers 15

WatchMethod · 0.65
ExampleJetStreamFunction · 0.65
ExampleMsg_MetadataFunction · 0.65
TestNoRaceJetStreamConsumerSlowConsumerFunction · 0.65
TestNoRaceJetStreamPushFlowControlHeartbeats_SubscribeSyncFunction · 0.65
TestNoRaceJetStreamPushFlowControlHeartbeats_ChanSubscribeFunction · 0.65
TestNoRaceJetStreamChanSubscribeStallFunction · 0.65
TestJetStreamSubscribeFunction · 0.65
TestJetStreamAckPending_PushFunction · 0.65
TestJetStreamManagement_DeleteMsgFunction · 0.65
TestJetStreamManagement_SecureDeleteMsgFunction · 0.65
TestJetStreamCrossAccountMirrorsAndSourcesFunction · 0.65

Implementers 1

jetStreamMsgjetstream/message.go

Calls

no outgoing calls

Tested by 15

ExampleJetStreamFunction · 0.52
ExampleMsg_MetadataFunction · 0.52
TestNoRaceJetStreamConsumerSlowConsumerFunction · 0.52
TestNoRaceJetStreamPushFlowControlHeartbeats_SubscribeSyncFunction · 0.52
TestNoRaceJetStreamPushFlowControlHeartbeats_ChanSubscribeFunction · 0.52
TestNoRaceJetStreamChanSubscribeStallFunction · 0.52
TestJetStreamSubscribeFunction · 0.52
TestJetStreamAckPending_PushFunction · 0.52
TestJetStreamManagement_DeleteMsgFunction · 0.52
TestJetStreamManagement_SecureDeleteMsgFunction · 0.52
TestJetStreamCrossAccountMirrorsAndSourcesFunction · 0.52
TestJetStreamSubscribe_AckPolicyFunction · 0.52