watcher

Dec 6, 2023

Changes in this version

+ var ErrNotConnected = errors.New("pubsub not connected, cannot dispatch update message")

+ func DefaultCallback(e casbin.IEnforcer) func(string)

+ type MSG struct

+ FieldIndex int

+ FieldValues []string

+ ID string

+ Method UpdateType

+ NewRules [][]string

+ OldRules [][]string

+ Ptype string

+ Sec string

+ func (m *MSG) UnmarshalBinary(data []byte) error

+ func (m MSG) MarshalBinary() ([]byte, error)

+ type Option struct

+ LocalID string

+ Verbose bool

+ type UpdateType string

+ const Update

+ const UpdateForAddPolicies

+ const UpdateForAddPolicy

+ const UpdateForRemoveFilteredPolicy

+ const UpdateForRemovePolicies

+ const UpdateForRemovePolicy

+ const UpdateForSavePolicy

+ const UpdateForUpdatePolicies

+ const UpdateForUpdatePolicy

+ type Watcher struct

+ func New(ctx context.Context, url string) (*Watcher, error)

+ func NewWithOption(ctx context.Context, url string, opt Option) (*Watcher, error)

+ func (w *Watcher) Close()

+ func (w *Watcher) GetLocalID() string

+ func (w *Watcher) GetVerbose() bool

+ func (w *Watcher) SetUpdateCallback(callbackFunc func(string)) error

+ func (w *Watcher) Update() error

+ func (w *Watcher) UpdateForAddPolicies(sec string, ptype string, rules ...[]string) error

+ func (w *Watcher) UpdateForAddPolicy(sec string, ptype string, params ...string) error

+ func (w *Watcher) UpdateForRemoveFilteredPolicy(sec string, ptype string, fieldIndex int, fieldValues ...string) error

+ func (w *Watcher) UpdateForRemovePolicies(sec string, ptype string, rules ...[]string) error

+ func (w *Watcher) UpdateForRemovePolicy(sec string, ptype string, params ...string) error

+ func (w *Watcher) UpdateForSavePolicy(model model.Model) error

+ func (w *Watcher) UpdateForUpdatePolicies(sec string, ptype string, oldRules, newRules [][]string) error

+ func (w *Watcher) UpdateForUpdatePolicy(sec string, ptype string, oldRule, newRule []string) error