grpc_proxy

package

v0.0.0-...-a47d0c2 Latest Latest Go to latest Published: Sep 24, 2022 License: MIT Imports: 9 Imported by: 1

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

github.com/lengzhao/proxy

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func GetServerOptions(director StreamDirector) []grpc.ServerOption
func TransparentHandler(director StreamDirector) grpc.StreamHandler
type MessageCodec
type ProxyCodec
type ProxyData
- func (d *ProxyData) Marshal() ([]byte, error)
- func (d *ProxyData) Unmarshal(data []byte) error
type StreamDirector

Constants ¶

View Source

const Name = "proxy"

Name is the name registered for the proto compressor.

Variables ¶

This section is empty.

Functions ¶

func GetServerOptions ¶

func GetServerOptions(director StreamDirector) []grpc.ServerOption

func TransparentHandler ¶

func TransparentHandler(director StreamDirector) grpc.StreamHandler

TransparentHandler returns a handler that attempts to proxy all requests that are not registered in the server. The indented use here is as a transparent proxy, where the server doesn't know about the services implemented by the backends. It should be used as a `grpc.UnknownServiceHandler`.

Types ¶

type MessageCodec ¶

type MessageCodec interface {
	// Marshal returns the wire format of v.
	Marshal() ([]byte, error)
	// Unmarshal parses the wire format into v.
	Unmarshal(data []byte) error
}

type ProxyCodec ¶

type ProxyCodec struct{}

ProxyCodec is a Codec implementation with protobuf. It is the default ProxyCodec for gRPC.

func (ProxyCodec) Marshal ¶

func (ProxyCodec) Marshal(v interface{}) ([]byte, error)

func (ProxyCodec) Name ¶

func (ProxyCodec) Name() string

func (ProxyCodec) String ¶

func (ProxyCodec) String() string

func (ProxyCodec) Unmarshal ¶

func (ProxyCodec) Unmarshal(data []byte, v interface{}) error

type ProxyData ¶

type ProxyData struct {
	Data []byte
}

func (*ProxyData) Marshal ¶

func (d *ProxyData) Marshal() ([]byte, error)

func (*ProxyData) Unmarshal ¶

func (d *ProxyData) Unmarshal(data []byte) error

type StreamDirector ¶

type StreamDirector func(ctx context.Context, fullMethodName string) (*grpc.ClientConn, error)

Source Files ¶

View all Source files

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