Documentation ¶
Overview ¶
Package store defines etcd's in-memory key/value store.
Index ¶
Constants ¶
View Source
const ( Get = "get" Create = "create" Set = "set" Update = "update" Delete = "delete" CompareAndSwap = "compareAndSwap" CompareAndDelete = "compareAndDelete" Expire = "expire" )
View Source
const ( CompareMatch = iota CompareIndexNotMatch CompareValueNotMatch CompareNotMatch )
explanations of Compare function result
View Source
const ( SetSuccess = iota SetFail DeleteSuccess DeleteFail CreateSuccess CreateFail UpdateSuccess UpdateFail CompareAndSwapSuccess CompareAndSwapFail GetSuccess GetFail ExpireCount CompareAndDeleteSuccess CompareAndDeleteFail )
View Source
const (
GetRecursive = "getRecursive"
)
Variables ¶
View Source
var Permanent time.Time
Functions ¶
This section is empty.
Types ¶
type Event ¶ added in v0.4.5
type Event struct { Action string `json:"action"` Node *NodeExtern `json:"node,omitempty"` PrevNode *NodeExtern `json:"prevNode,omitempty"` EtcdIndex uint64 `json:"-"` Refresh bool `json:"refresh,omitempty"` }
func (*Event) SetRefresh ¶
func (e *Event) SetRefresh()
type EventHistory ¶ added in v0.4.5
type NodeExtern ¶ added in v0.4.5
type NodeExtern struct { Key string `json:"key,omitempty"` Value *string `json:"value,omitempty"` Dir bool `json:"dir,omitempty"` Expiration *time.Time `json:"expiration,omitempty"` TTL int64 `json:"ttl,omitempty"` Nodes NodeExterns `json:"nodes,omitempty"` ModifiedIndex uint64 `json:"modifiedIndex,omitempty"` CreatedIndex uint64 `json:"createdIndex,omitempty"` }
NodeExtern is the external representation of the internal node with additional fields PrevValue is the previous value of the node TTL is time to live in second
func (*NodeExtern) Clone ¶
func (eNode *NodeExtern) Clone() *NodeExtern
type NodeExterns ¶ added in v0.4.5
type NodeExterns []*NodeExtern
func (NodeExterns) Len ¶ added in v0.4.5
func (ns NodeExterns) Len() int
func (NodeExterns) Less ¶ added in v0.4.5
func (ns NodeExterns) Less(i, j int) bool
func (NodeExterns) Swap ¶ added in v0.4.5
func (ns NodeExterns) Swap(i, j int)
type Stats ¶ added in v0.4.5
type Stats struct { GetSuccess uint64 `json:"getsSuccess"` GetFail uint64 `json:"getsFail"` SetSuccess uint64 `json:"setsSuccess"` SetFail uint64 `json:"setsFail"` DeleteSuccess uint64 `json:"deleteSuccess"` DeleteFail uint64 `json:"deleteFail"` UpdateSuccess uint64 `json:"updateSuccess"` UpdateFail uint64 `json:"updateFail"` CreateSuccess uint64 `json:"createSuccess"` CreateFail uint64 `json:"createFail"` CompareAndSwapSuccess uint64 `json:"compareAndSwapSuccess"` CompareAndSwapFail uint64 `json:"compareAndSwapFail"` CompareAndDeleteSuccess uint64 `json:"compareAndDeleteSuccess"` CompareAndDeleteFail uint64 `json:"compareAndDeleteFail"` ExpireCount uint64 `json:"expireCount"` Watchers uint64 `json:"watchers"` }
type Store ¶
type Store interface { Version() int Index() uint64 Get(nodePath string, recursive, sorted bool) (*Event, error) Set(nodePath string, dir bool, value string, expireOpts TTLOptionSet) (*Event, error) Update(nodePath string, newValue string, expireOpts TTLOptionSet) (*Event, error) Create(nodePath string, dir bool, value string, unique bool, expireOpts TTLOptionSet) (*Event, error) CompareAndSwap(nodePath string, prevValue string, prevIndex uint64, value string, expireOpts TTLOptionSet) (*Event, error) Delete(nodePath string, dir, recursive bool) (*Event, error) CompareAndDelete(nodePath string, prevValue string, prevIndex uint64) (*Event, error) Watch(prefix string, recursive, stream bool, sinceIndex uint64) (Watcher, error) Save() ([]byte, error) Recovery(state []byte) error Clone() Store SaveNoCopy() ([]byte, error) JsonStats() []byte DeleteExpiredKeys(cutoff time.Time) HasTTLKeys() bool }
type TTLOptionSet ¶
Click to show internal directories.
Click to hide internal directories.