grpcproxy

package

v3.3.27 Latest Latest Go to latest Published: Oct 15, 2021 License: Apache-2.0 Imports: 31 Imported by: 0

Details

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

Repository

github.com/coreos/etcd

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(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(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(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 ¶ added in v3.3.0

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

func AuthUnaryClientInterceptor ¶ added in v3.3.0

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 ¶ added in v3.3.0

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

HandleHealth registers health handler on '/health'.

func HandleMetrics ¶ added in v3.3.13

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

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

func NewAuthProxy ¶ added in v3.1.0

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

func NewClusterProxy ¶ added in v3.1.0

func NewClusterProxy(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 ¶ added in v3.2.0

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

func NewKvProxy ¶

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

func NewLeaseProxy ¶ added in v3.1.0

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

func NewLockProxy ¶ added in v3.2.0

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

func NewMaintenanceProxy ¶ added in v3.1.0

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

func NewWatchProxy ¶ added in v3.1.0

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 ¶ added in v3.2.0

func Register(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 ¶ added in v3.3.0

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

Types ¶

type AuthProxy ¶ added in v3.1.0

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

func (*AuthProxy) AuthDisable ¶ added in v3.1.0

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

func (*AuthProxy) AuthEnable ¶ added in v3.1.0

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

func (*AuthProxy) Authenticate ¶ added in v3.1.0

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

func (*AuthProxy) RoleAdd ¶ added in v3.1.0

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

func (*AuthProxy) RoleDelete ¶ added in v3.1.0

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

func (*AuthProxy) RoleGet ¶ added in v3.1.0

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

func (*AuthProxy) RoleGrantPermission ¶ added in v3.1.0

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

func (*AuthProxy) RoleList ¶ added in v3.1.0

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

func (*AuthProxy) RoleRevokePermission ¶ added in v3.1.0

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

func (*AuthProxy) UserAdd ¶ added in v3.1.0

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

func (*AuthProxy) UserChangePassword ¶ added in v3.1.0

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

func (*AuthProxy) UserDelete ¶ added in v3.1.0

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

func (*AuthProxy) UserGet ¶ added in v3.1.0

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

func (*AuthProxy) UserGrantRole ¶ added in v3.1.0

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

func (*AuthProxy) UserList ¶ added in v3.1.0

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

func (*AuthProxy) UserRevokeRole ¶ added in v3.1.0

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