internal

Documentation

Index

• Variables
• func GetTimeout(header http.Header, defaultTimeout time.Duration) time.Duration
• func NewRequestParser(r *http.Request, resolver jsonpb.AnyResolver) (grpcurl.RequestParser, error)
• func ProcessHeaders(header http.Header) []string
• type JSONRequestParser
  • func NewJSONRequestParser(r *http.Request, resolver jsonpb.AnyResolver) (*JSONRequestParser, error)
  • func (f *JSONRequestParser) Next(m proto.Message) error
  • func (f *JSONRequestParser) NumRequests() int
• type Method
  • func GetMethods(source grpcurl.DescriptorSource) ([]Method, error)

Variables

var (
	ParamErr = fmt.Errorf("param error")
)

Functions

func GetTimeout

func GetTimeout(header http.Header, defaultTimeout time.Duration) time.Duration

GetTimeout returns the timeout from the header, if not set, returns the default timeout.

func NewRequestParser

func NewRequestParser(r *http.Request, resolver jsonpb.AnyResolver) (grpcurl.RequestParser, error)

NewRequestParser creates a new request parser from the given http.Request and resolver.

func ProcessHeaders

func ProcessHeaders(header http.Header) []string

ProcessHeaders builds the headers for the gateway from HTTP headers.

Types

type JSONRequestParser

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

func NewJSONRequestParser

func NewJSONRequestParser(r *http.Request, resolver jsonpb.AnyResolver) (*JSONRequestParser, error)

func (*JSONRequestParser) Next

func (f *JSONRequestParser) Next(m proto.Message) error

func (*JSONRequestParser) NumRequests

func (f *JSONRequestParser) NumRequests() int

type Method

type Method struct {
	HttpMethod string
	HttpPath   string
	RpcPath    string
}

func GetMethods

func GetMethods(source grpcurl.DescriptorSource) ([]Method, error)

GetMethods returns all methods of the given grpcurl.DescriptorSource.