The Go implementation of the Couchbase DCP with various features - View it on GitHub