const defaultVersion … var minExpireTime … func init() { … } type Store … type TTLOptionSet … type store … // New creates a store where the given namespaces will be created as initial directories. func New(namespaces ...string) Store { … } func newStore(namespaces ...string) *store { … } // Version retrieves current version of the store. func (s *store) Version() int { … } // Index retrieves the current index of the store. func (s *store) Index() uint64 { … } // Get returns a get event. // If recursive is true, it will return all the content under the node path. // If sorted is true, it will sort the content by keys. func (s *store) Get(nodePath string, recursive, sorted bool) (*Event, error) { … } // Create creates the node at nodePath. Create will help to create intermediate directories with no ttl. // If the node has already existed, create will fail. // If any node on the path is a file, create will fail. func (s *store) Create(nodePath string, dir bool, value string, unique bool, expireOpts TTLOptionSet) (*Event, error) { … } // Set creates or replace the node at nodePath. func (s *store) Set(nodePath string, dir bool, value string, expireOpts TTLOptionSet) (*Event, error) { … } // returns user-readable cause of failed comparison func getCompareFailCause(n *node, which int, prevValue string, prevIndex uint64) string { … } func (s *store) CompareAndSwap(nodePath string, prevValue string, prevIndex uint64, value string, expireOpts TTLOptionSet) (*Event, error) { … } // Delete deletes the node at the given path. // If the node is a directory, recursive must be true to delete it. func (s *store) Delete(nodePath string, dir, recursive bool) (*Event, error) { … } func (s *store) CompareAndDelete(nodePath string, prevValue string, prevIndex uint64) (*Event, error) { … } func (s *store) Watch(key string, recursive, stream bool, sinceIndex uint64) (Watcher, error) { … } // walk walks all the nodePath and apply the walkFunc on each directory func (s *store) walk(nodePath string, walkFunc func(prev *node, component string) (*node, *v2error.Error)) (*node, *v2error.Error) { … } // Update updates the value/ttl of the node. // If the node is a file, the value and the ttl can be updated. // If the node is a directory, only the ttl can be updated. func (s *store) Update(nodePath string, newValue string, expireOpts TTLOptionSet) (*Event, error) { … } func (s *store) internalCreate(nodePath string, dir bool, value string, unique, replace bool, expireTime time.Time, action string) (*Event, *v2error.Error) { … } // InternalGet gets the node of the given nodePath. func (s *store) internalGet(nodePath string) (*node, *v2error.Error) { … } // DeleteExpiredKeys will delete all expired keys func (s *store) DeleteExpiredKeys(cutoff time.Time) { … } // checkDir will check whether the component is a directory under parent node. // If it is a directory, this function will return the pointer to that node. // If it does not exist, this function will create a new directory and return the pointer to that node. // If it is a file, this function will return error. func (s *store) checkDir(parent *node, dirName string) (*node, *v2error.Error) { … } // Save saves the static state of the store system. // It will not be able to save the state of watchers. // It will not save the parent field of the node. Or there will // be cyclic dependencies issue for the json package. func (s *store) Save() ([]byte, error) { … } func (s *store) SaveNoCopy() ([]byte, error) { … } func (s *store) Clone() Store { … } // Recovery recovers the store system from a static state // It needs to recover the parent field of the nodes. // It needs to delete the expired nodes since the saved time and also // needs to create monitoring goroutines. func (s *store) Recovery(state []byte) error { … } func (s *store) JsonStats() []byte { … } func (s *store) HasTTLKeys() bool { … }
Codebase Browser
kubernetes