监视器

我们支持使用分布式消息系统，例如 etcd 来保持多个Casbin执行器实例之间的一致性。 因此，我们的用户可以同时使用多个Casbin 执行器来处理大量的权限检查请求。

与策略存储适配器类似，我们没有把watcher的代码放在主库中。 任何对新消息系统的支持都应该作为watcher程序来实现。 完整的Casbin watchers列表如下所示。 欢迎任何第三方对 watcher做出新的贡献，如果有请告知我们，我将把它放在这个列表中:)

Go

Watcher	类型	作者	描述
PostgreSQL WatcherEx	Database	@IguteChung	WatcherEx for PostgreSQL
Redis WatcherEx	KV store	Casbin	WatcherEx for Redis
Redis Watcher	KV store	@billcobbler	Redis的监视器
Etcd Watcher	KV store	Casbin	etcd的监视器
TiKV 监视器	KV store	Casbin	TiKV 的监视器
Kafka 监视器	Messaging system	@wgarunap	Apache Kafka的监视器
NATS Watcher	Messaging system	Soluto	NATS的监视器
ZooKeeper Watcher	Messaging system	Grepsr	Apache ZooKeeper的监视器
NATS, RabbitMQ, GCP Pub/Sub, AWS SNS & SQS, Kafka, InMemory	Messaging System	@rusenask	监视器基于与领先的云供应商和自托管基础设施运作的Go Cloud Dev Kit
RocketMQ 观察器	Messaging system	@fmyxyz	Apache RocketMQ的监视器

Java

Watcher	类型	作者	描述
Etcd Adapter	KV store	@mapleafgo	etcd的监视器
Redis Watcher	KV store	Casbin	Redis的监视器
Kafka 监视器	Messaging system	Casbin	Apache Kafka的监视器

Node.js

Watcher	实现要素	作者	描述
Etcd Watcher	KV store	Casbin	etcd的监视器
Redis Watcher	KV store	Casbin	Redis的监视器
Pub/Sub Watcher	Messaging system	Casbin	Google Cloud Pub/Sub的监视器
MongoDB Change Streams Watcher	数据库	Casbin	Watcher for MongoDB Change Streams
Postgres Watcher	数据库	Matteo Collina	PostgreSQL的监视器

Python

Watcher	类型	作者	描述
Etcd Watcher	KV store	Casbin	etcd的监视器
Redis Watcher	KV store	Casbin	Redis的监视器
Redis Watcher	KV store	ScienceLogic	Redis的监视器
PostgreSQL Watcher	Database	Casbin	PostgreSQL的监视器

.NET

Watcher	类型	作者	描述
Redis Watcher	KV store	@Sbou	Redis的监视器

Ruby

Watcher	类型	作者	描述
Redis Watcher	KV store	CasbinRuby	Redis的监视器
RabbitMQ 监视器	Messaging system	CasbinRuby	RabbitMQ 的监视器

PHP

Watcher	类型	作者	描述
Redis Watcher	KV store	@Tinywan	Redis的监视器

WatcherEx

为了支持多个实例之间的增量同步，我们提供 WatcherEx 接口。 我们希望它能够在策略改变时通知其他实例，但目前尚未实现 WatcherEx。 我们推荐您使用调度器来实现它。

与 个监视器 接口相比， WatcherEx 可以区分收到的更新动作类型。 添加策略 和 删除策略.

WatcherEx 的调用接口:

应用程序接口	描述
SetUpdateCallback(func(string)) error	SetUpdateCallback sets the callback function that the watcher will call, when the policy in DB has been changed by other instances. 一种典型的回调是Enforcer.LoadPolicy()。
Update() error	Update calls the update callback of other instances to synchronize their policy. 它通常是在改变数据库中的策略之后进行的，如Enforcer.SavePolicy(), Enforcer.AddPolicy(), Enforcer.RemovePolicy()等。
Close()	Close stops and releases the watcher, the callback function will not be called any more.
UpdateForAddPolicy(sec, ptype string, params ...string) error	UpdateForAddPolicy calls the update callback of other instances to synchronize their policy. 它是在 Enforcer.AddPolicy(), Enforcer.AddNamedPolicy(), Enforcer.AddGroupingPolicy() 和 Enforcer.AddNamedGroupingPolicy() 后被调用。
UpdateForRemovePolicy(sec, ptype string, params ...string) error	UPdateForRemovePolicy calls the update callback of other instances to synchronize their policy. 它是在政策被Enforcer.RemovePolicy(), Enforcer.RemoveNamedPolicy(), Enforcer.RemoveGroupingPolicy() 和 Enforcer.RemoveNamedGroupingPolicy() 删除后被调用。
UpdateForRemoveFilteredPolicy(sec, ptype string, fieldIndex int, fieldValues ...string) error	UpdateForRemoveFilteredPolicy calls the update callback of other instances to synchronize their policy. 它是在Enforcer.RemoveFilteredPolicy(), Enforcer.RemoveFilteredNamedPolicy(), Enforcer.RemoveFilteredGroupingPolicy() 和 Enforcer.RemoveFilteredNamedGroupingPolicy()之后被调用
UpdateForSavePolicy(model model.Model) error	UpdateForSavePolicy calls the update callback of other instances to synchronize their policy. 它在 Enforcer.AddPolicy()被调用后调用
UpdateForAddPolicies(sec string, ptype string, rules ...[]string) error	UpdateForAddPolicies calls the update callback of other instances to synchronize their policy. 它是在Enforcer.AddPolicies(), Enforcecer.AddNamedPolicies(), Enforcer.AddGroupingPolicies() 和 Enforcer.AddNamedGroupingPolicies()之后被调用
UpdateForRemovePolicies(sec string, ptype string, rules ...[]string) error	UpdateForRemovePolicies calls the update callback of other instances to synchronize their policy. 它是在Enforcer.RemovePolicies(), Enforcecer.RemoveNamedPolicies(), Enforcer.RemoveGroupingPolicies() 和 Enforcer.RemoveNamedGroupingPolicies() 后被调用。