internal

Documentation

Index

• func GetTimeout(header *fasthttp.RequestHeader, defaultTimeout time.Duration) time.Duration
• func NewRequestParser(r *fasthttp.RequestCtx, resolver jsonpb.AnyResolver) (grpcurl.RequestParser, error)
• func ProcessHeaders(header *fasthttp.RequestHeader) []string
• type EventHandler
  • func NewEventHandler(writer io.Writer, resolver jsonpb.AnyResolver) *EventHandler
  • func (h *EventHandler) OnReceiveHeaders(_ metadata.MD)
  • func (h *EventHandler) OnReceiveResponse(message proto.Message)
  • func (h *EventHandler) OnReceiveTrailers(status *status.Status, _ metadata.MD)
  • func (h *EventHandler) OnResolveMethod(_ *desc.MethodDescriptor)
  • func (h *EventHandler) OnSendHeaders(_ metadata.MD)
• type Method
  • func GetMethods(source grpcurl.DescriptorSource) ([]Method, error)

Functions

func GetTimeout

func GetTimeout(header *fasthttp.RequestHeader, defaultTimeout time.Duration) time.Duration

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

func NewRequestParser

func NewRequestParser(r *fasthttp.RequestCtx, resolver jsonpb.AnyResolver) (grpcurl.RequestParser, error)

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

func ProcessHeaders

func ProcessHeaders(header *fasthttp.RequestHeader) []string

ProcessHeaders builds the headers for the gateway from HTTP headers.

Types

type EventHandler

type EventHandler struct {
	Status *status.Status
	// contains filtered or unexported fields
}

func NewEventHandler

func NewEventHandler(writer io.Writer, resolver jsonpb.AnyResolver) *EventHandler

func (*EventHandler) OnReceiveHeaders

func (h *EventHandler) OnReceiveHeaders(_ metadata.MD)

func (*EventHandler) OnReceiveResponse

func (h *EventHandler) OnReceiveResponse(message proto.Message)

func (*EventHandler) OnReceiveTrailers

func (h *EventHandler) OnReceiveTrailers(status *status.Status, _ metadata.MD)

func (*EventHandler) OnResolveMethod

func (h *EventHandler) OnResolveMethod(_ *desc.MethodDescriptor)

func (*EventHandler) OnSendHeaders

func (h *EventHandler) OnSendHeaders(_ metadata.MD)

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.