kubernetes/vendor/go.etcd.io/etcd/server/v3/etcdserver/v2_server.go

type RequestV2 …

type RequestV2Handler …

type reqV2HandlerEtcdServer …

type reqV2HandlerStore …

func NewStoreRequestV2Handler(s v2store.Store, applier ApplierV2) RequestV2Handler { … }

func (a *reqV2HandlerStore) Post(ctx context.Context, r *RequestV2) (Response, error) { … }

func (a *reqV2HandlerStore) Put(ctx context.Context, r *RequestV2) (Response, error) { … }

func (a *reqV2HandlerStore) Delete(ctx context.Context, r *RequestV2) (Response, error) { … }

func (a *reqV2HandlerStore) QGet(ctx context.Context, r *RequestV2) (Response, error) { … }

func (a *reqV2HandlerStore) Get(ctx context.Context, r *RequestV2) (Response, error) { … }

func (a *reqV2HandlerStore) Head(ctx context.Context, r *RequestV2) (Response, error) { … }

func (a *reqV2HandlerEtcdServer) Post(ctx context.Context, r *RequestV2) (Response, error) { … }

func (a *reqV2HandlerEtcdServer) Put(ctx context.Context, r *RequestV2) (Response, error) { … }

func (a *reqV2HandlerEtcdServer) Delete(ctx context.Context, r *RequestV2) (Response, error) { … }

func (a *reqV2HandlerEtcdServer) QGet(ctx context.Context, r *RequestV2) (Response, error) { … }

func (a *reqV2HandlerEtcdServer) processRaftRequest(ctx context.Context, r *RequestV2) (Response, error) { … }

func (s *EtcdServer) Do(ctx context.Context, r pb.Request) (Response, error) { … }

// 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" with
// Quorum == true, r will be sent through consensus before performing its
// respective operation. Do will block until an action is performed or there is
// an error.
func (r *RequestV2) Handle(ctx context.Context, v2api RequestV2Handler) (Response, error) { … }

func (r *RequestV2) String() string { … }