Watchers

etcdのような分散メッセージングシステムの使用をサポートしており、複数のCasbinエンフォーサーインスタンス間で一貫性を維持します。 これにより、ユーザーは複数のCasbinエンフォーサーを同時に使用して、大量の権限チェックリクエストを処理することができます。

ポリシーストレージアダプターと同様に、メインライブラリにウォッチャーコードは含まれていません。 新しいメッセージングシステムのサポートは、ウォッチャーとして実装する必要があります。 Casbinウォッチャーの完全なリストは以下に提供されています。 新しいウォッチャーのための第三者からの貢献を歓迎します、私たちに知らせてください、そして私たちはそれをこのリストに追加します：

Go

Watcher	Type	Author	Description
PostgreSQL WatcherEx	Database	@IguteChung	WatcherEx for PostgreSQL
Redis WatcherEx	KV store	Casbin	WatcherEx for Redis
Redis Watcher	KV store	@billcobbler	Watcher for Redis
Etcd Watcher	KV store	Casbin	Watcher for etcd
TiKV Watcher	KV store	Casbin	Watcher for TiKV
Kafka Watcher	Messaging system	@wgarunap	Watcher for Apache Kafka
NATS Watcher	Messaging system	Soluto	Watcher for NATS
ZooKeeper Watcher	Messaging system	Grepsr	Watcher for Apache ZooKeeper
NATS, RabbitMQ, GCP Pub/Sub, AWS SNS & SQS, Kafka, InMemory	Messaging System	@rusenask	Watcher based on Go Cloud Dev Kit that works with leading cloud providers and self-hosted infrastructure
NATS, RabbitMQ, GCP Pub/Sub, AWS SNS & SQS, Kafka, InMemory	Messaging System	@bartventer	WatcherEx based on Go Cloud Dev Kit that works with leading cloud providers and self-hosted infrastructure
RocketMQ Watcher	Messaging system	@fmyxyz	Watcher for Apache RocketMQ

Java

Watcher	Type	Author	Description
Etcd Adapter	KV store	@mapleafgo	Watcher for etcd
Redis Watcher	KV store	Casbin	Watcher for Redis
Lettuce-Based Redis Watcher	KV store	Casbin	Watcher for Redis based on Lettuce)
Kafka Watcher	Messaging system	Casbin	Watcher for Apache Kafka

Node.js

Watcher	Type	Author	Description
Etcd Watcher	KV store	Casbin	Watcher for etcd
Redis Watcher	KV store	Casbin	Watcher for Redis
Pub/Sub Watcher	Messaging system	Casbin	Watcher for Google Cloud Pub/Sub
MongoDB Change Streams Watcher	Database	Casbin	Watcher for MongoDB Change Streams
Postgres Watcher	Database	@mcollina	Watcher for PostgreSQL

Python

Watcher	Type	Author	Description
Etcd Watcher	KV store	Casbin	Watcher for etcd
Redis Watcher	KV store	Casbin	Watcher for Redis
Redis Watcher	KV store	ScienceLogic	Watcher for Redis
Redis Async Watcher	KV store	@kevinkelin	Watcher for Redis
PostgreSQL Watcher	Database	Casbin	Watcher for PostgreSQL
RabbitMQ Watcher	Messaging system	Casbin	Watcher for RabbitMQ

.NET

Watcher	Type	Author	Description
Redis Watcher	KV store	@Sbou	Watcher for Redis

Ruby

Watcher	Type	Author	Description
Redis Watcher	KV store	CasbinRuby	Watcher for Redis
RabbitMQ Watcher	Messaging system	CasbinRuby	Watcher for RabbitMQ

PHP

Watcher	Type	Author	Description
Redis Watcher	KV store	@Tinywan	Watcher for Redis

WatcherEx

複数のインスタンス間での増分同期をサポートするために、WatcherExインターフェースを提供します。 ポリシーが変更されたときに他のインスタンスに通知できることを期待していますが、現在WatcherExの実装はありません。 これを達成するためにはディスパッチャーの使用をお勧めします。

Watcherインターフェースと比較して、WatcherExは受信した更新アクションのタイプを区別することができます。例えば、AddPolicyやRemovePolicyなどです。

WatcherEx Apis:

API	説明
SetUpdateCallback(func(string)) error	SetUpdateCallbackは、他のインスタンスによってDBのポリシーが変更されたときにウォッチャーが呼び出すコールバック関数を設定します。 典型的なコールバックはEnforcer.LoadPolicy()です。
Update() error	Updateは他のインスタンスの更新コールバックを呼び出してポリシーを同期します。 通常、DBのポリシーを変更した後に呼び出されます。例えば、Enforcer.SavePolicy()、Enforcer.AddPolicy()、Enforcer.RemovePolicy()などです。
Close()	Closeはウォッチャーを停止し解放し、コールバック関数はこれ以上呼び出されません。
UpdateForAddPolicy(sec, ptype string, params ...string) error	UpdateForAddPolicyは他のインスタンスの更新コールバックを呼び出してポリシーを同期します。 ポリシーがEnforcer.AddPolicy()、Enforcer.AddNamedPolicy()、Enforcer.AddGroupingPolicy()、Enforcer.AddNamedGroupingPolicy()を介して追加された後に呼び出されます。
UpdateForRemovePolicy(sec, ptype string, params ...string) error	UpdateForRemovePolicyは他のインスタンスの更新コールバックを呼び出してポリシーを同期します。 ポリシーがEnforcer.RemovePolicy()、Enforcer.RemoveNamedPolicy()、Enforcer.RemoveGroupingPolicy()、Enforcer.RemoveNamedGroupingPolicy()によって削除された後に呼び出されます。
UpdateForRemoveFilteredPolicy(sec, ptype string, fieldIndex int, fieldValues ...string) error	UpdateForRemoveFilteredPolicyは他のインスタンスの更新コールバックを呼び出してポリシーを同期します。 これは、Enforcer.RemoveFilteredPolicy()、Enforcer.RemoveFilteredNamedPolicy()、Enforcer.RemoveFilteredGroupingPolicy()、Enforcer.RemoveFilteredNamedGroupingPolicy()の後に呼び出されます。
UpdateForSavePolicy(model model.Model) error	UpdateForSavePolicyは、他のインスタンスの更新コールバックを呼び出してポリシーを同期します。 これは、Enforcer.SavePolicy()の後に呼び出されます。
UpdateForAddPolicies(sec string, ptype string, rules ...[]string) error	UpdateForAddPoliciesは、他のインスタンスの更新コールバックを呼び出してポリシーを同期します。 これは、Enforcer.AddPolicies()、Enforcer.AddNamedPolicies()、Enforcer.AddGroupingPolicies()、Enforcer.AddNamedGroupingPolicies()の後に呼び出されます。
UpdateForRemovePolicies(sec string, ptype string, rules ...[]string) error	UpdateForRemovePoliciesは、他のインスタンスの更新コールバックを呼び出してポリシーを同期します。 これは、Enforcer.RemovePolicies()、Enforcer.RemoveNamedPolicies()、Enforcer.RemoveGroupingPolicies()、Enforcer.RemoveNamedGroupingPolicies()の後に呼び出されます。