proxy

Documentation

Overview

Package proxy provides server and codec for proxying gRPC requests.

Index

• type Matcher
• type Option
  • func Debug() Option
  • func Version(v string) Option
  • func WithGRPCServerOptions(opts ...grpc.ServerOption) Option
  • func WithReflection() Option
  • func WithSignature() Option
• type Server
  • func NewServer(m Matcher, opts ...Option) *Server
  • func (s *Server) Close()
  • func (s *Server) Listen(addr string) (err error)
• type ServerStream

Types

type Matcher

type Matcher interface {
	MatchMetadata(string, metadata.MD) discovery.Matches
	Upstreams() []discovery.Upstream
}

Matcher matches the request URI and incoming metadata to the registered rules.

type Option

type Option func(*Server)

Option is a functional option for the server.

func Debug

func Debug() Option

Debug sets the debug mode.

func Version

func Version(v string) Option

Version sets the version of the server.

func WithGRPCServerOptions

func WithGRPCServerOptions(opts ...grpc.ServerOption) Option

WithGRPCServerOptions sets the gRPC server options.

func WithReflection

func WithReflection() Option

WithReflection enables the gRPC server reflection merger.

func WithSignature

func WithSignature() Option

WithSignature enables the gRPC server signature metadata.

type Server

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

Server is a gRPC server.

func NewServer

func NewServer(m Matcher, opts ...Option) *Server

NewServer creates a new server.

func (*Server) Close

func (s *Server) Close()

Close stops the server.

func (*Server) Listen

func (s *Server) Listen(addr string) (err error)

Listen starts the server on the given address. Blocking call.

type ServerStream

type ServerStream grpc.ServerStream

ServerStream is a gRPC server stream.