ReplicateHealDelete = "replicate:heal:delete"
)

var (
	globalReplicationPool  = once.NewSingleton[ReplicationPool]()
	globalReplicationStats atomic.Pointer[ReplicationStats]
)

// ReplicationPool describes replication pool
type ReplicationPool struct {
	// atomic ops:
	activeWorkers    int32
	activeLrgWorkers int32
	activeMRFWorkers int32

		req.Header.Set(k, v[0])
	}

	// execute the request.
	response, err = s.client.Do(req)
	c.Assert(err, nil)

	// out, err = httputil.DumpResponse(response, true)
	// fmt.Println("RESPONSE ===\n", string(out), err)

	// assert the http response status code.
	c.Assert(response.StatusCode, http.StatusBadRequest)
}

func (s *TestSuiteCommon) TestBucketSQSNotificationAMQP(c *check) {