MCPcopy
hub / github.com/segmentio/kafka-go / grabState

Method grabState

transport.go:312–315  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

310}
311
312func (p *connPool) grabState() connPoolState {
313 state, _ := p.state.Load().(connPoolState)
314 return state
315}
316
317func (p *connPool) setState(state connPoolState) {
318 p.state.Store(state)

Callers 3

roundTripMethod · 0.95
refreshMetadataMethod · 0.95
updateMethod · 0.95

Calls

no outgoing calls

Tested by

no test coverage detected