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

Method getPinID

jetstream/pull.go:1214–1218  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

1212}
1213
1214func (c *pullConsumer) getPinID() string {
1215 c.Lock()
1216 defer c.Unlock()
1217 return c.pinID
1218}
1219
1220func (c *pullConsumer) setPinID(pinID string) {
1221 c.Lock()

Callers 3

ConsumeMethod · 0.95
fetchMethod · 0.95
checkPendingMethod · 0.80

Calls

no outgoing calls

Tested by

no test coverage detected