Watchers

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

ポリシーストレージアダプタと同様に、私たちはメインライブラリにウォッチャーコードを入れません。 新しいメッセージングシステムのサポートは、ウォッチャーとして実装する必要があります。 Casbinウォッチャーの完全なリストは以下のように提供されています。 新しいウォッチャーに対するサードパーティの貢献を歓迎します。お知らせください。このリストに記載します:)

Go

Watcher	タイプ	作成者	説明
PostgreSQL WatcherEx	Database	@IguteChung	WatcherEx for PostgreSQL
Redis WatcherEx	KV ストア	Casbin	WatcherEx for Redis
Redis Watcher	KV ストア	@billcobbler	Redis のウォッチャー
Etcd Watcher	KV ストア	Casbin	etcd の監視者
TiKVウォッチャー	KV ストア	Casbin	TiKV の監視人
Kafka Watcher	SMSシステム	@wgarunap	Apache Kafka の腕時計
NATS Watcher	SMSシステム	Soluto	NATS の監視人
ZooKeeperウォッチャー	SMSシステム	Grepsr	Apache ZooKeeper の の腕時計
NATS, RabbitMQ, GCP Pub/Sub, AWS SNS & SQS, Kafka, InMemory	SMSシステム	@rusenask	主要なクラウドプロバイダーと自己ホストインフラストラクチャで動作する Go Cloud Dev Kit に基づくウォッチャー
RocketMQウォッチャー	SMSシステム	@fmyxyz	Apache RocketMQ の腕時計

Java

Watcher	タイプ	作成者	説明
Etcd アダプター	KV ストア	@mapleafgo	etcd の監視者
Redis Watcher	KV ストア	Casbin	Redis のウォッチャー
Kafka Watcher	SMSシステム	Casbin	Apache Kafka の腕時計

Node.js

Watcher	タイプ	作成者	説明
Etcd Watcher	KV ストア	Casbin	etcd の監視者
Redis Watcher	KV ストア	Casbin	Redis のウォッチャー
Pub/Sub Watcher	SMSシステム	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 ストア	Casbin	etcd の監視者
Redis Watcher	KV ストア	Casbin	Redis のウォッチャー
Redis Watcher	KV store	ScienceLogic	Watcher for Redis
PostgreSQLウォッチャー	Database	Casbin	PostgreSQL のウォッチャー

.NET

Watcher	タイプ	作成者	説明
Redis Watcher	KV ストア	@Sbou	Redis のウォッチャー

Ruby

Watcher	タイプ	作成者	説明
Redis Watcher	KV ストア	CasbinRuby	Redis のウォッチャー
RabbitMQ ウォッチャー	SMSシステム	CasbinRuby	RabbitMQ の監視人

PHP

Watcher	タイプ	作成者	説明
Redis Watcher	KV ストア	@Tinywan	Redis のウォッチャー

WatcherEx

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

Compared with Watcher interface, WatcherEx can distinguish what type of update action is received, e.g., AddPolicy and RemovePolicy.

WatcherEx Apis:

API	説明
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. これは通常、DB 内のポリシーを変更した後に呼び出されます。例えば 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(), Enforcer.AddNamedGroupingPolicy() および 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.SavePolicy() の後に呼び出されます。
UpdateForAddPolicies(sec string, ptype string, rules ...[]string) error	UpdateForAddPolicies calls the update callback of other instances to synchronize their policy. これは、Enforcer.AddPolicies(), Enforcer.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(), Enforcer.RemoveNamedPolicies(), Enforcer.RemoveGroupingPolicies() および Enforcer.RemoveNamedGroupingPolicies() の後に呼び出されます。