Default -

Get returns the value for a key and inserts the key in the txn's read set. If Get fails, it aborts the transaction with an error, never returning.

FileExists check file exist

Get returns the cached result for the endpoint.

Handle interprets r and performs an operation on s.store according to r.Method and other fields. If r.Method is "POST", "PUT", "DELETE", or a "GET" wi

String -

Then takes a list of operations. The Ops list will be executed, if the comparisons passed in If() succeed.

WrapEL wrap eventlog, handle event log before and after process

Delete removes the storage asset that was created by Provision backing the given PV. Does not delete the PV object itself. May return IgnoredError to

Close closes the Storage and performs finalization.

Commit commits outstanding txns into the underlying backend.

Stop halts the main loop of the compactor.

Close releases all resources Lease keeps for efficient communication with the etcd server.

Format 实现 Formatter 接口

Read creates a read transaction.

ErrorAndSolve error create

Open returns a ReadCloser that provides access to the File's contents. Multiple files may be read concurrently.

String -

Step advances the state machine using the given message. ctx.Err() will be returned, if any.

Unlock takes a key returned by Lock and releases the hold on lock. The next Lock caller waiting for the lock will then be woken up and given ownership

Lock acquires a distributed shared lock on a given named lock. On success, it will return a unique key that exists so long as the lock is held by the

* 取消上传 * @returns {Promise<void>}

Do applies a single Op on KV without a transaction. Do is useful when creating arbitrary operations to be issued at a later time; the user can range o

Stop performs any necessary termination of the Node.

PrefixArgs prefixes etcdctl command. Make sure to unset environment variables after tests.

Watch watches on a key or prefix. The watched events will be returned through the returned channel. If revisions waiting to be sent over the watch are

Commit tries to commit the transaction.

Default -

If takes a list of comparison. If all comparisons passed in succeed, the operations passed into Then() will be executed. Or the operations passed into

Terminate stops the member and removes the data dir.

Append the new entries to storage. TODO (xiangli): ensure the entries are continuous and entries[0].Index > ms.entries[0].Index

Decode 解码数据流

Encode return json encode data

Advance notifies the Node that the application has saved progress up to the last Ready. It prepares the node to return the next available Ready. The

newNetwork initializes a network from peers. A nil node will be replaced with a new *stateMachine. A *stateMachine will get its k, id. When using stat

Record publishes an Action (e.g., function call) which will be reflected by Wait() or Chan()

ActiveConnection returns the current in-use connection