grpcproxy

package

v0.0.0-...-518322d Latest Latest Go to latest Published: Mar 22, 2020 License: Apache-2.0 Imports: 34 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

gitee.com/liuzhiqiang9696/clientv3

Links

Open Source Insights

Documentation ¶

Overview ¶

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

Index ¶

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 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(c *clientv3.Client) (pb.LeaseServer, <-chan struct{})
func NewLockProxy(client *clientv3.Client) v3lockpb.LockServer
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 Register(lg *zap.Logger, c *clientv3.Client, prefix string, addr string, ttl int) <-chan struct{}
func TxnRequestToOp(r *pb.TxnRequest) clientv3.Op
type AuthProxy

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func AuthStreamClientInterceptor ¶

func AuthStreamClientInterceptor(ctx context.Context, desc *grpc.StreamDesc, cc *grpc.ClientConn, method string, streamer grpc.Streamer, opts ...grpc.CallOption) (grpc.ClientStream, error)

func AuthUnaryClientInterceptor ¶

func AuthUnaryClientInterceptor(ctx context.Context, method string, req, reply interface{}, cc *grpc.ClientConn, invoker grpc.UnaryInvoker, opts ...grpc.CallOption) error

func DelRequestToOp ¶

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

func HandleHealth ¶

func HandleHealth(lg *zap.Logger, mux *http.ServeMux, c *clientv3.Client)

HandleHealth registers health handler on '/health'.

func HandleMetrics ¶

func HandleMetrics(mux *http.ServeMux, c *http.Client, eps []string)

HandleMetrics performs a GET request against etcd endpoint and returns '/metrics'.

func NewAuthProxy ¶

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

func NewClusterProxy ¶

func NewClusterProxy(lg *zap.Logger, c *clientv3.Client, advaddr string, prefix string) (pb.ClusterServer, <-chan struct{})

NewClusterProxy takes optional prefix to fetch grpc-proxy member endpoints. The returned channel is closed when there is grpc-proxy endpoint registered and the client's context is canceled so the 'register' loop returns.

func NewElectionProxy ¶

func NewElectionProxy(client *clientv3.Client) v3electionpb.ElectionServer

func NewKvProxy ¶

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

func NewLeaseProxy ¶

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

func NewLockProxy ¶

func NewLockProxy(client *clientv3.Client) v3lockpb.LockServer

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 Register ¶

func Register(lg *zap.Logger, c *clientv3.Client, prefix string, addr string, ttl int) <-chan struct{}

Register registers itself as a grpc-proxy server by writing prefixed-key with session of specified TTL (in seconds). The returned channel is closed when the client's context is canceled.

func TxnRequestToOp ¶

func TxnRequestToOp(r *pb.TxnRequest) clientv3.Op

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) AuthStatus ¶

func (ap *AuthProxy) AuthStatus(ctx context.Context, r *pb.AuthStatusRequest) (*pb.AuthStatusResponse, 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)

Directories ¶

Path	Synopsis
adapter Package adapter provides gRPC adapters between client and server gRPC interfaces without needing to go through a gRPC connection.	Package adapter provides gRPC adapters between client and server gRPC interfaces without needing to go through a gRPC connection.
cache Package cache exports functionality for efficiently caching and mapping `RangeRequest`s to corresponding `RangeResponse`s.	Package cache exports functionality for efficiently caching and mapping `RangeRequest`s to corresponding `RangeResponse`s.

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