NewStore returns a new store. It is useful to create a store inside mvcc pkg. It should only be used for testing externally.

GetClusterHandler returns the default cluster handler.

Launch starts a member based on ServerConfig, PeerListeners and ClientListeners.

Error sends errors while serving proxy.

Registry 注册组件

getAppService if creator is true, will create new app service where not found in store

Delete deletes a key, or optionally using WithRange(end), [key, end).

NewUUID 创建无-的32位uuid

mustNewForm takes a set of Values and constructs a PUT *http.Request, with a URL constructed from appending the given path to the standard keysPrefix

CreateAPIHandleErrorFromDBError from db error create APIHandleError

stop performs any necessary finalization and terminates the peer elegantly.

Add instructs etcd to accept a new Member into the cluster.

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

Desc returns a description of the failure

GetApplicationHandler returns the default tenant application handler.

GetStatefulSet get kubernetes statefulset model

Set assigns a new value to a Node identified by a given key. The caller may define a set of conditions in the SetOptions. If SetOptions.Dir=true then

raft.Node does not have locks in Raft package

waitLeader waits until given members agree on the same leader.

CreateTable creates an empty Table using defaults for style.

Grant creates a new lease.

Send sends out the given messages to the remote peers. Each message has a To field, which is an id that maps to an existing peer in the transport. If

Chan returns a chan. All watch response will be sent to the returned chan.

GetGatewayHandler returns a default GatewayHandler

NewCluster returns an unlaunched cluster of the given size which has been set to use static bootstrap.

Observe streams election proclamations in-order as made by the election's elected leaders.

Close releases all of the Stresser's resources.

DbModel -

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Probe.

End marks the transaction is complete and ready to commit.

Endpoints returns a copy of the current set of API endpoints used by Client to resolve HTTP requests. If Sync has ever been called, this may differ fr

ObjectToJSONORYaml changeType true is json / yaml

Rev returns the revision of the KV at the time of opening the txn.

Watch creates a watcher. The watcher watches the events happening or happened on the given key or range [key, end) from the given startRev. The whole

GetCallbackLoggerOption get callback logger

GetTenantManager get manager

IsClosed is closed

NewBadRequest -

ServeHTTP adds the correct CORS headers based on the origin and returns immediately with a 200 OK if the method is OPTIONS.

cov-enabled binaries emit PASS and coverage count lines

AddMember attempts to add a member into the cluster. It will return ErrIDRemoved if member ID is removed from the cluster, or return ErrIDExists if me

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

GetCommonLabels get common labels

Action returns immediately available Actions