Versions in this module Expand all Collapse all v1 v1.5.1 Jan 20, 2020 v1.5.0 Jan 8, 2020 Changes in this version + const AuthRootKey + const AuthSecretKey + const AuthService + const CfgRetainLogs + const ClusterName + const DefaultRetainLogs + const EnableHTTPS + const GroupID + const ID + const IP + const LRUCacheSize + const LogLevel + const ModuleName + const Port + const StoreDir + const WalDir + const WriteBufferSize + var AddrDatabase = make(map[uint64]string) + type AuthProxy struct + type Cluster struct + AuthRootKey []byte + AuthSecretKey []byte + DisableAutoAllocate bool + Name string + PKIKey PKIKey + func (c *Cluster) AddCaps(id string, keyInfo *keystore.KeyInfo) (res *keystore.KeyInfo, err error) + func (c *Cluster) CreateNewKey(id string, keyInfo *keystore.KeyInfo) (res *keystore.KeyInfo, err error) + func (c *Cluster) DeleteCaps(id string, keyInfo *keystore.KeyInfo) (res *keystore.KeyInfo, err error) + func (c *Cluster) DeleteKey(id string) (res *keystore.KeyInfo, err error) + func (c *Cluster) GetAKInfo(accessKey string) (akInfo *keystore.AccessKeyInfo, err error) + func (c *Cluster) GetKey(id string) (res *keystore.KeyInfo, err error) + type KeystoreFsm struct + func (mf *KeystoreFsm) Apply(command []byte, index uint64) (resp interface{}, err error) + func (mf *KeystoreFsm) ApplyMemberChange(confChange *proto.ConfChange, index uint64) (interface{}, error) + func (mf *KeystoreFsm) ApplySnapshot(peers []proto.Peer, iterator proto.SnapIterator) (err error) + func (mf *KeystoreFsm) Del(key interface{}) (interface{}, error) + func (mf *KeystoreFsm) DeleteAKInfo(accessKey string) + func (mf *KeystoreFsm) DeleteKey(id string) + func (mf *KeystoreFsm) Get(key interface{}) (interface{}, error) + func (mf *KeystoreFsm) GetAKInfo(accessKey string) (akInfo *keystore.AccessKeyInfo, err error) + func (mf *KeystoreFsm) GetKey(id string) (u *keystore.KeyInfo, err error) + func (mf *KeystoreFsm) HandleFatalEvent(err *raft.FatalError) + func (mf *KeystoreFsm) HandleLeaderChange(leader uint64) + func (mf *KeystoreFsm) Put(key, val interface{}) (interface{}, error) + func (mf *KeystoreFsm) PutAKInfo(akInfo *keystore.AccessKeyInfo) + func (mf *KeystoreFsm) PutKey(k *keystore.KeyInfo) + func (mf *KeystoreFsm) Snapshot() (proto.Snapshot, error) + type KeystoreSnapshot struct + func (ms *KeystoreSnapshot) ApplyIndex() uint64 + func (ms *KeystoreSnapshot) Close() + func (ms *KeystoreSnapshot) Next() (data []byte, err error) + type LeaderInfo struct + type PKIKey struct + AuthRootPrivateKey []byte + AuthRootPublicKey []byte + EnableHTTPS bool + type RaftCmd struct + K string + Op uint32 + V []byte + func (m *RaftCmd) Marshal() ([]byte, error) + func (m *RaftCmd) Unmarshal(data []byte) (err error) + type Server struct + func NewServer() *Server + func (m *Server) ServeHTTP(w http.ResponseWriter, r *http.Request) + func (m *Server) Shutdown() + func (m *Server) Start(cfg *config.Config) (err error) + func (m *Server) Sync() Incompatible versions in this module v2.0.0+incompatible Apr 10, 2020 v2.0.0-rc.1+incompatible Apr 9, 2020