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

Method GetMsg

jetstream/stream.go:48–48  ·  view source on GitHub ↗

GetMsg retrieves a raw stream message stored in JetStream by sequence number.

(ctx context.Context, seq uint64, opts ...GetMsgOpt)

Source from the content-addressed store, hash-verified

46
47 // GetMsg retrieves a raw stream message stored in JetStream by sequence number.
48 GetMsg(ctx context.Context, seq uint64, opts ...GetMsgOpt) (*RawStreamMsg, error)
49
50 // GetLastMsgForSubject retrieves the last raw stream message stored in
51 // JetStream on a given subject.

Callers 13

getMethod · 0.65
TestPublishWithTTLFunction · 0.65
TestPublishAsyncWithTTLFunction · 0.65
TestPublishWithScheduleAtFunction · 0.65
TestPublishWithScheduleEveryFunction · 0.65
TestPublishWithScheduleCronFunction · 0.65
TestPublishWithScheduleSourceFunction · 0.65
TestPublishWithScheduleTTLFunction · 0.65
TestPublishWithScheduleTimeZoneFunction · 0.65
TestPublishAsyncWithScheduleFunction · 0.65
TestGetMsgFunction · 0.65
TestDeleteMsgFunction · 0.65

Implementers 1

streamjetstream/stream.go

Calls

no outgoing calls

Tested by 12

TestPublishWithTTLFunction · 0.52
TestPublishAsyncWithTTLFunction · 0.52
TestPublishWithScheduleAtFunction · 0.52
TestPublishWithScheduleEveryFunction · 0.52
TestPublishWithScheduleCronFunction · 0.52
TestPublishWithScheduleSourceFunction · 0.52
TestPublishWithScheduleTTLFunction · 0.52
TestPublishWithScheduleTimeZoneFunction · 0.52
TestPublishAsyncWithScheduleFunction · 0.52
TestGetMsgFunction · 0.52
TestDeleteMsgFunction · 0.52
TestSecureDeleteMsgFunction · 0.52