store

Aug 10, 2021

Changes in this version

type PolicyOperator

+ func (p *PolicyOperator) UpdateFilteredPolicies(sec, pType string, oldRules, newRules [][]string) error

type Store

+ func (s *Store) UpdateFilteredPolicies(request *command.UpdateFilteredPoliciesRequest) error

Mar 2, 2021

Changes in this version

type Store

+ func (s *Store) Stats() (map[string]interface{}, error)

Mar 1, 2021

Changes in this version

type Config

+ RaftConfig *raft.Config

Feb 21, 2021

Changes in this version

+ type Config struct

+ Dir string

+ Enforcer casbin.IDistributedEnforcer

+ ID string

+ NetworkTransportConfig *raft.NetworkTransportConfig

+ type FSM struct

+ func NewFSM(path string, enforcer casbin.IDistributedEnforcer) (*FSM, error)

+ func (f *FSM) Apply(log *raft.Log) interface{}

+ func (f *FSM) Restore(rc io.ReadCloser) error

+ func (f *FSM) Snapshot() (raft.FSMSnapshot, error)

+ type PolicyOperator struct

+ func NewPolicyOperator(path string, e casbin.IDistributedEnforcer) (*PolicyOperator, error)

+ func (p *PolicyOperator) AddPolicies(sec, pType string, rules [][]string) error

+ func (p *PolicyOperator) Backup() ([]byte, error)

+ func (p *PolicyOperator) ClearPolicy() error

+ func (p *PolicyOperator) LoadPolicy() error

+ func (p *PolicyOperator) RemoveFilteredPolicy(sec string, pType string, fieldIndex int, fieldValues ...string) error

+ func (p *PolicyOperator) RemovePolicies(sec, pType string, rules [][]string) error

+ func (p *PolicyOperator) Restore(rc io.ReadCloser) error

+ func (p *PolicyOperator) UpdatePolicies(sec, pType string, oldRules, newRules [][]string) error

+ func (p *PolicyOperator) UpdatePolicy(sec, pType string, oldRule, newRule []string) error

+ type Rule struct

+ PType string

+ Rule []string

+ Sec string

+ type Store struct

+ func NewStore(config *Config) (*Store, error)

+ func (s *Store) AddPolicies(request *command.AddPoliciesRequest) error

+ func (s *Store) Address() string

+ func (s *Store) ClearPolicy() error

+ func (s *Store) DataDir() string

+ func (s *Store) ID() string

+ func (s *Store) IsInitializedCluster() bool

+ func (s *Store) JoinNode(serverID string, address string) error

+ func (s *Store) Leader() (bool, string)

+ func (s *Store) RemoveFilteredPolicy(request *command.RemoveFilteredPolicyRequest) error

+ func (s *Store) RemoveNode(serverID string) error

+ func (s *Store) RemovePolicies(request *command.RemovePoliciesRequest) error

+ func (s *Store) Start(enableBootstrap bool) error

+ func (s *Store) Stop() error

+ func (s *Store) UpdatePolicies(request *command.UpdatePoliciesRequest) error

+ func (s *Store) UpdatePolicy(request *command.UpdatePolicyRequest) error

+ func (s *Store) WaitLeader() error

+ type TCPStreamLayer struct

+ func NewTCPStreamLayer(address string, tlsConfig *tls.Config) (*TCPStreamLayer, error)

+ func (t *TCPStreamLayer) Accept() (c net.Conn, err error)

+ func (t *TCPStreamLayer) Addr() net.Addr

+ func (t *TCPStreamLayer) Close() (err error)

+ func (t *TCPStreamLayer) Dial(address raft.ServerAddress, timeout time.Duration) (net.Conn, error)