Passer au contenu principal

Watchers

Nous soutenons l'utilisation de systèmes de messagerie distribués comme etcd pour maintenir la cohérence entre plusieurs instances de l'exécuteur Casbin. Cela permet à nos utilisateurs d'utiliser simultanément plusieurs exécuteurs Casbin pour gérer un grand nombre de demandes de vérification des autorisations.

Semblable aux adaptateurs de stockage de politiques, nous n'incluons pas le code du watcher dans la bibliothèque principale. Tout support pour un nouveau système de messagerie doit être implémenté en tant que watcher. Une liste complète des watchers Casbin est fournie ci-dessous. Nous accueillons toute contribution de tiers pour un nouveau watcher, veuillez nous en informer et nous l'ajouterons à cette liste :

WatcherTypeAuthorDescription
PostgreSQL WatcherExDatabase@IguteChungWatcherEx for PostgreSQL
Redis WatcherExKV storeCasbinWatcherEx for Redis
Redis WatcherKV store@billcobblerWatcher for Redis
Etcd WatcherKV storeCasbinWatcher for etcd
TiKV WatcherKV storeCasbinWatcher for TiKV
Kafka WatcherMessaging system@wgarunapWatcher for Apache Kafka
NATS WatcherMessaging systemSolutoWatcher for NATS
ZooKeeper WatcherMessaging systemGrepsrWatcher for Apache ZooKeeper
NATS, RabbitMQ, GCP Pub/Sub, AWS SNS & SQS, Kafka, InMemoryMessaging System@rusenaskWatcher 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, InMemoryMessaging System@bartventerWatcherEx based on Go Cloud Dev Kit that works with leading cloud providers and self-hosted infrastructure
RocketMQ WatcherMessaging system@fmyxyzWatcher for Apache RocketMQ

WatcherEx

Afin de soutenir la synchronisation incrémentielle entre plusieurs instances, nous fournissons l'interface WatcherEx. Nous espérons qu'il peut notifier les autres instances lorsque la politique change, mais il n'y a actuellement aucune implémentation de WatcherEx. Nous vous recommandons d'utiliser le dispatcher pour y parvenir.

Comparé à l'interface Watcher, WatcherEx peut distinguer quel type d'action de mise à jour est reçu, par exemple, AddPolicy et RemovePolicy.

Apis WatcherEx :

APIDescription
SetUpdateCallback(func(string)) errorSetUpdateCallback définit la fonction de rappel que le watcher appellera, lorsque la politique dans la base de données a été modifiée par d'autres instances. Un rappel classique est Enforcer.LoadPolicy().
Update() errorUpdate appelle la fonction de rappel de mise à jour des autres instances pour synchroniser leur politique. Il est généralement appelé après avoir modifié la politique dans la base de données, comme Enforcer.SavePolicy(), Enforcer.AddPolicy(), Enforcer.RemovePolicy(), etc.
Close()Close arrête et libère le watcher, la fonction de rappel ne sera plus appelée.
UpdateForAddPolicy(sec, ptype string, params ...string) errorUpdateForAddPolicy appelle la fonction de rappel de mise à jour des autres instances pour synchroniser leur politique. Il est appelé après qu'une politique a été ajoutée via Enforcer.AddPolicy(), Enforcer.AddNamedPolicy(), Enforcer.AddGroupingPolicy() et Enforcer.AddNamedGroupingPolicy().
UpdateForRemovePolicy(sec, ptype string, params ...string) errorUpdateForRemovePolicy appelle la fonction de rappel de mise à jour des autres instances pour synchroniser leur politique. Il est appelé après qu'une politique a été supprimée par Enforcer.RemovePolicy(), Enforcer.RemoveNamedPolicy(), Enforcer.RemoveGroupingPolicy() et Enforcer.RemoveNamedGroupingPolicy().
UpdateForRemoveFilteredPolicy(sec, ptype string, fieldIndex int, fieldValues ...string) errorUpdateForRemoveFilteredPolicy appelle la fonction de rappel de mise à jour des autres instances pour synchroniser leur politique. Il est appelé après Enforcer.RemoveFilteredPolicy(), Enforcer.RemoveFilteredNamedPolicy(), Enforcer.RemoveFilteredGroupingPolicy() et Enforcer.RemoveFilteredNamedGroupingPolicy().
UpdateForSavePolicy(model model.Model) errorUpdateForSavePolicy appelle la fonction de rappel de mise à jour des autres instances pour synchroniser leur politique. Il est appelé après Enforcer.SavePolicy()
UpdateForAddPolicies(sec string, ptype string, rules ...[]string) errorUpdateForAddPolicies appelle la fonction de rappel de mise à jour des autres instances pour synchroniser leur politique. Il est appelé après Enforcer.AddPolicies(), Enforcer.AddNamedPolicies(), Enforcer.AddGroupingPolicies() et Enforcer.AddNamedGroupingPolicies().
UpdateForRemovePolicies(sec string, ptype string, rules ...[]string) errorUpdateForRemovePolicies appelle la fonction de rappel de mise à jour des autres instances pour synchroniser leur politique. Il est appelé après Enforcer.RemovePolicies(), Enforcer.RemoveNamedPolicies(), Enforcer.RemoveGroupingPolicies() et Enforcer.RemoveNamedGroupingPolicies().