Versions in this module Expand all Collapse all v3 v3.4.15 Feb 24, 2021 Changes in this version + func AuthStreamClientInterceptor(ctx context.Context, desc *grpc.StreamDesc, cc *grpc.ClientConn, method string, ...) (grpc.ClientStream, error) + func AuthUnaryClientInterceptor(ctx context.Context, method string, req, reply interface{}, ...) error + func DelRequestToOp(r *pb.DeleteRangeRequest) clientv3.Op + func HandleHealth(lg *zap.Logger, mux *http.ServeMux, c *clientv3.Client) + func HandleMetrics(mux *http.ServeMux, c *http.Client, eps []string) + func HandleProxyHealth(lg *zap.Logger, mux *http.ServeMux, c *clientv3.Client) + func HandleProxyMetrics(mux *http.ServeMux) + func NewAuthProxy(c *clientv3.Client) pb.AuthServer + func NewClusterProxy(lg *zap.Logger, c *clientv3.Client, advaddr string, prefix string) (pb.ClusterServer, <-chan struct{}) + func NewElectionProxy(client *clientv3.Client) v3electionpb.ElectionServer + func NewKvProxy(c *clientv3.Client) (pb.KVServer, <-chan struct{}) + func NewLeaseProxy(ctx context.Context, c *clientv3.Client) (pb.LeaseServer, <-chan struct{}) + func NewLockProxy(client *clientv3.Client) v3lockpb.LockServer + func NewMaintenanceProxy(c *clientv3.Client) pb.MaintenanceServer + func NewWatchProxy(ctx context.Context, lg *zap.Logger, c *clientv3.Client) (pb.WatchServer, <-chan struct{}) + func PutRequestToOp(r *pb.PutRequest) clientv3.Op + func RangeRequestToOp(r *pb.RangeRequest) clientv3.Op + func Register(lg *zap.Logger, c *clientv3.Client, prefix string, addr string, ttl int) <-chan struct + func TxnRequestToOp(r *pb.TxnRequest) clientv3.Op + type AuthProxy struct + func (ap *AuthProxy) AuthDisable(ctx context.Context, r *pb.AuthDisableRequest) (*pb.AuthDisableResponse, error) + func (ap *AuthProxy) AuthEnable(ctx context.Context, r *pb.AuthEnableRequest) (*pb.AuthEnableResponse, error) + func (ap *AuthProxy) AuthStatus(ctx context.Context, r *pb.AuthStatusRequest) (*pb.AuthStatusResponse, error) + func (ap *AuthProxy) Authenticate(ctx context.Context, r *pb.AuthenticateRequest) (*pb.AuthenticateResponse, error) + func (ap *AuthProxy) RoleAdd(ctx context.Context, r *pb.AuthRoleAddRequest) (*pb.AuthRoleAddResponse, error) + func (ap *AuthProxy) RoleDelete(ctx context.Context, r *pb.AuthRoleDeleteRequest) (*pb.AuthRoleDeleteResponse, error) + func (ap *AuthProxy) RoleGet(ctx context.Context, r *pb.AuthRoleGetRequest) (*pb.AuthRoleGetResponse, error) + func (ap *AuthProxy) RoleGrantPermission(ctx context.Context, r *pb.AuthRoleGrantPermissionRequest) (*pb.AuthRoleGrantPermissionResponse, error) + func (ap *AuthProxy) RoleList(ctx context.Context, r *pb.AuthRoleListRequest) (*pb.AuthRoleListResponse, error) + func (ap *AuthProxy) RoleRevokePermission(ctx context.Context, r *pb.AuthRoleRevokePermissionRequest) (*pb.AuthRoleRevokePermissionResponse, error) + func (ap *AuthProxy) UserAdd(ctx context.Context, r *pb.AuthUserAddRequest) (*pb.AuthUserAddResponse, error) + func (ap *AuthProxy) UserChangePassword(ctx context.Context, r *pb.AuthUserChangePasswordRequest) (*pb.AuthUserChangePasswordResponse, error) + func (ap *AuthProxy) UserDelete(ctx context.Context, r *pb.AuthUserDeleteRequest) (*pb.AuthUserDeleteResponse, error) + func (ap *AuthProxy) UserGet(ctx context.Context, r *pb.AuthUserGetRequest) (*pb.AuthUserGetResponse, error) + func (ap *AuthProxy) UserGrantRole(ctx context.Context, r *pb.AuthUserGrantRoleRequest) (*pb.AuthUserGrantRoleResponse, error) + func (ap *AuthProxy) UserList(ctx context.Context, r *pb.AuthUserListRequest) (*pb.AuthUserListResponse, error) + func (ap *AuthProxy) UserRevokeRole(ctx context.Context, r *pb.AuthUserRevokeRoleRequest) (*pb.AuthUserRevokeRoleResponse, error)
Go to main page