Documentation ¶
Index ¶
- type EtcdServer
- func (k *EtcdServer) DeleteRange(ctx context.Context, r *etcdserverpb.DeleteRangeRequest) (*etcdserverpb.DeleteRangeResponse, error)
- func (k *EtcdServer) Put(ctx context.Context, r *etcdserverpb.PutRequest) (*etcdserverpb.PutResponse, error)
- func (k *EtcdServer) Range(ctx context.Context, r *etcdserverpb.RangeRequest) (*etcdserverpb.RangeResponse, error)
- func (svr *EtcdServer) Register(server *grpc.Server)
- func (s *EtcdServer) Watch(ws etcdserverpb.Watch_WatchServer) (err error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type EtcdServer ¶
type EtcdServer struct { *server.KVServerBridge // contains filtered or unexported fields }
func NewEtcdServer ¶
func NewEtcdServer(backend server.Backend) *EtcdServer
func (*EtcdServer) DeleteRange ¶ added in v0.2.1
func (k *EtcdServer) DeleteRange(ctx context.Context, r *etcdserverpb.DeleteRangeRequest) (*etcdserverpb.DeleteRangeResponse, error)
Only one deletion is supported, and range deletion is not supported. TODO: support delete range
func (*EtcdServer) Put ¶
func (k *EtcdServer) Put(ctx context.Context, r *etcdserverpb.PutRequest) (*etcdserverpb.PutResponse, error)
func (*EtcdServer) Range ¶
func (k *EtcdServer) Range(ctx context.Context, r *etcdserverpb.RangeRequest) (*etcdserverpb.RangeResponse, error)
func (*EtcdServer) Register ¶
func (svr *EtcdServer) Register(server *grpc.Server)
func (*EtcdServer) Watch ¶
func (s *EtcdServer) Watch(ws etcdserverpb.Watch_WatchServer) (err error)
Click to show internal directories.
Click to hide internal directories.