Etcd Watcher is the Etcd watcher for Casbin. With this library, Casbin can synchronize the policy with the database in multiple enforcer instances.
go get github.com/casbin/etcd-watcher
package main
import (
"github.com/casbin/casbin"
"github.com/casbin/casbin/util"
"github.com/casbin/etcd-watcher"
)
func updateCallback(rev string) {
util.LogPrint("New revision detected:", rev)
}
func main() {
// Initialize the watcher.
// Use the endpoint of etcd cluster as parameter.
w := etcdwatcher.NewWatcher("http://127.0.0.1:2379")
// Initialize the enforcer.
e := casbin.NewEnforcer("examples/rbac_model.conf", "examples/rbac_policy.csv")
// Set the watcher for the enforcer.
e.SetWatcher(w)
// By default, the watcher's callback is automatically set to the
// enforcer's LoadPolicy() in the SetWatcher() call.
// We can change it by explicitly setting a callback.
w.SetUpdateCallback(updateCallback)
// Update the policy to test the effect.
// You should see "[New revision detected: X]" in the log.
e.SavePolicy()
}
This project is under Apache 2.0 License. See the LICENSE file for the full license text.