Affected by GO-2024-2528 and 2 other vulnerabilities

GO-2024-2528: Etcd Gateway TLS endpoint validation only confirms TCP reachability in go.etcd.io/etcd

GO-2024-2529: Etcd embed auto compaction retention negative value causing a compaction loop or a crash in go.etcd.io/etcd

GO-2024-2530: Etcd auth Inaccurate logging of authentication attempts for users with CN-based auth only in go.etcd.io/etcd

The highest tagged major version is v3.

grpcproxy

package

v3.1.7+incompatible Latest Latest Go to latest Published: Apr 27, 2017 License: Apache-2.0 Imports: 15 Imported by: 10

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/etcd-io/etcd

Links

Open Source Insights

Documentation ¶

Overview ¶

Package grpcproxy is an OSI level 7 proxy for etcd v3 API requests.

Index ¶

func DelRequestToOp(r *pb.DeleteRangeRequest) clientv3.Op
func KvServerToKvClient(kvs pb.KVServer) pb.KVClient
func NewAuthProxy(c *clientv3.Client) pb.AuthServer
func NewClusterProxy(c *clientv3.Client) pb.ClusterServer
func NewKvProxy(c *clientv3.Client) (pb.KVServer, <-chan struct{})
func NewLeaseProxy(c *clientv3.Client) pb.LeaseServer
func NewMaintenanceProxy(c *clientv3.Client) pb.MaintenanceServer
func NewWatchProxy(c *clientv3.Client) (pb.WatchServer, <-chan struct{})
func PutRequestToOp(r *pb.PutRequest) clientv3.Op
func RangeRequestToOp(r *pb.RangeRequest) clientv3.Op
func WatchServerToWatchClient(wserv pb.WatchServer) pb.WatchClient
type AuthProxy

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func DelRequestToOp ¶

func DelRequestToOp(r *pb.DeleteRangeRequest) clientv3.Op

func KvServerToKvClient ¶

func KvServerToKvClient(kvs pb.KVServer) pb.KVClient

func NewAuthProxy ¶

func NewAuthProxy(c *clientv3.Client) pb.AuthServer

func NewClusterProxy ¶

func NewClusterProxy(c *clientv3.Client) pb.ClusterServer

func NewKvProxy ¶

func NewKvProxy(c *clientv3.Client) (pb.KVServer, <-chan struct{})

func NewLeaseProxy ¶

func NewLeaseProxy(c *clientv3.Client) pb.LeaseServer

func NewMaintenanceProxy ¶

func NewMaintenanceProxy(c *clientv3.Client) pb.MaintenanceServer

func NewWatchProxy ¶

func NewWatchProxy(c *clientv3.Client) (pb.WatchServer, <-chan struct{})

func PutRequestToOp ¶

func PutRequestToOp(r *pb.PutRequest) clientv3.Op

func RangeRequestToOp ¶

func RangeRequestToOp(r *pb.RangeRequest) clientv3.Op

func WatchServerToWatchClient ¶

func WatchServerToWatchClient(wserv pb.WatchServer) pb.WatchClient

Types ¶

type AuthProxy ¶

type AuthProxy struct {
	// contains filtered or unexported fields
}

func (*AuthProxy) AuthDisable ¶

func (ap *AuthProxy) AuthDisable(ctx context.Context, r *pb.AuthDisableRequest) (*pb.AuthDisableResponse, error)

func (*AuthProxy) AuthEnable ¶

func (ap *AuthProxy) AuthEnable(ctx context.Context, r *pb.AuthEnableRequest) (*pb.AuthEnableResponse, error)

func (*AuthProxy) Authenticate ¶

func (ap *AuthProxy) Authenticate(ctx context.Context, r *pb.AuthenticateRequest) (*pb.AuthenticateResponse, error)

func (*AuthProxy) RoleAdd ¶

func (ap *AuthProxy) RoleAdd(ctx context.Context, r *pb.AuthRoleAddRequest) (*pb.AuthRoleAddResponse, error)

func (*AuthProxy) RoleDelete ¶

func (ap *AuthProxy) RoleDelete(ctx context.Context, r *pb.AuthRoleDeleteRequest) (*pb.AuthRoleDeleteResponse, error)

func (*AuthProxy) RoleGet ¶

func (ap *AuthProxy) RoleGet(ctx context.Context, r *pb.AuthRoleGetRequest) (*pb.AuthRoleGetResponse, error)

func (*AuthProxy) RoleGrantPermission ¶

func (ap *AuthProxy) RoleGrantPermission(ctx context.Context, r *pb.AuthRoleGrantPermissionRequest) (*pb.AuthRoleGrantPermissionResponse, error)

func (*AuthProxy) RoleList ¶

func (ap *AuthProxy) RoleList(ctx context.Context, r *pb.AuthRoleListRequest) (*pb.AuthRoleListResponse, error)

func (*AuthProxy) RoleRevokePermission ¶

func (ap *AuthProxy) RoleRevokePermission(ctx context.Context, r *pb.AuthRoleRevokePermissionRequest) (*pb.AuthRoleRevokePermissionResponse, error)

func (*AuthProxy) UserAdd ¶

func (ap *AuthProxy) UserAdd(ctx context.Context, r *pb.AuthUserAddRequest) (*pb.AuthUserAddResponse, error)

func (*AuthProxy) UserChangePassword ¶

func (ap *AuthProxy) UserChangePassword(ctx context.Context, r *pb.AuthUserChangePasswordRequest) (*pb.AuthUserChangePasswordResponse, error)

func (*AuthProxy) UserDelete ¶

func (ap *AuthProxy) UserDelete(ctx context.Context, r *pb.AuthUserDeleteRequest) (*pb.AuthUserDeleteResponse, error)

func (*AuthProxy) UserGet ¶

func (ap *AuthProxy) UserGet(ctx context.Context, r *pb.AuthUserGetRequest) (*pb.AuthUserGetResponse, error)

func (*AuthProxy) UserGrantRole ¶

func (ap *AuthProxy) UserGrantRole(ctx context.Context, r *pb.AuthUserGrantRoleRequest) (*pb.AuthUserGrantRoleResponse, error)

func (*AuthProxy) UserList ¶

func (ap *AuthProxy) UserList(ctx context.Context, r *pb.AuthUserListRequest) (*pb.AuthUserListResponse, error)

func (*AuthProxy) UserRevokeRole ¶

func (ap *AuthProxy) UserRevokeRole(ctx context.Context, r *pb.AuthUserRevokeRoleRequest) (*pb.AuthUserRevokeRoleResponse, error)

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
cache

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL