diff --git a/couchbase/client.go b/couchbase/client.go index 1430a2d..93e6541 100644 --- a/couchbase/client.go +++ b/couchbase/client.go @@ -469,6 +469,7 @@ func (s *client) DcpClose() { logger.Log.Info("dcp connection closed %s", s.config.Hosts) } +//nolint:funlen func (s *client) GetVBucketSeqNos(awareCollection bool) (*wrapper.ConcurrentSwissMap[uint16, uint64], error) { snapshot, err := s.GetDcpAgentConfigSnapshot() if err != nil {