Translate

Watchers

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

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

Go

Java

Node.js

Python

.NET

Ruby

PHP

ウォッチャー	タイプ	作成者	説明
Etcd Watcher	KV ストア	Casbin	etcd の監視者
Redis Watcher	KV ストア	Casbin	Redis のウォッチャー
Redis Watcher	KV ストア	@billcobbler	Redis のウォッチャー
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 の腕時計

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

ウォッチャー	タイプ	作成者	説明
Etcd Watcher	KV ストア	Casbin	etcd の監視者
Redis Watcher	KV ストア	Casbin	Redis のウォッチャー
Pub/Sub Watcher	SMSシステム	Casbin	Google Cloud Pub/Sub のウッチャー
Postgres Watcher	データベース	Matteo Collina	PostgreSQL のウォッチャー

ウォッチャー	タイプ	作成者	説明
Redis Watcher	KV ストア	ScienceLogic	Redis のウォッチャー
PostgreSQLウォッチャー	データベース	Casbin	PostgreSQL のウォッチャー

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

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

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

WatcherEx

In order to support incremental synchronization between multiple instances, we provide the WatcherEx interface. We hope it can notify other instances when the policy changes, but there is currently no implementation of WatcherEx. We recommend that you use dispatcher to achieve this.

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

WatcherEx Apis:

api	description
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. A classic callback is Enforcer.LoadPolicy().
Update() error	Update calls the update callback of other instances to synchronize their policy. It is usually called after changing the policy in DB, like Enforcer.SavePolicy(), Enforcer.AddPolicy(), Enforcer.RemovePolicy(), etc.
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. It is called after a policy is added via Enforcer.AddPolicy(), Enforcer.AddNamedPolicy(), Enforcer.AddGroupingPolicy() and Enforcer.AddNamedGroupingPolicy().
UpdateForRemovePolicy(sec, ptype string, params ...string) error	UPdateForRemovePolicy calls the update callback of other instances to synchronize their policy. It is called after a policy is removed by Enforcer.RemovePolicy(), Enforcer.RemoveNamedPolicy(), Enforcer.RemoveGroupingPolicy() and Enforcer.RemoveNamedGroupingPolicy().
UpdateForRemoveFilteredPolicy(sec, ptype string, fieldIndex int, fieldValues ...string) error	UpdateForRemoveFilteredPolicy calls the update callback of other instances to synchronize their policy. It is called after Enforcer.RemoveFilteredPolicy(), Enforcer.RemoveFilteredNamedPolicy(), Enforcer.RemoveFilteredGroupingPolicy() and Enforcer.RemoveFilteredNamedGroupingPolicy().
UpdateForSavePolicy(model model.Model) error	UpdateForSavePolicy calls the update callback of other instances to synchronize their policy. It is called after Enforcer.SavePolicy()
UpdateForAddPolicies(sec string, ptype string, rules ...[]string) error	UpdateForAddPolicies calls the update callback of other instances to synchronize their policy. It is called after Enforcer.AddPolicies(), Enforcer.AddNamedPolicies(), Enforcer.AddGroupingPolicies() and Enforcer.AddNamedGroupingPolicies().
UpdateForRemovePolicies(sec string, ptype string, rules ...[]string) error	UpdateForRemovePolicies calls the update callback of other instances to synchronize their policy. It is called after Enforcer.RemovePolicies(), Enforcer.RemoveNamedPolicies(), Enforcer.RemoveGroupingPolicies() and Enforcer.RemoveNamedGroupingPolicies().