internal

package

v1.0.1 Latest Latest Go to latest Published: Jul 17, 2023 License: MIT Imports: 18 Imported by: 0

Details

This section is empty.

This section is empty.

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(r *http.Request, resolver jsonpb.AnyResolver) (grpcurl.RequestParser, error)

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

func ProcessHeaders(header http.Header) []string

ProcessHeaders builds the headers for the gateway from HTTP headers.

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

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 struct {
	HttpMethod string
	HttpPath   string
	RpcPath    string
}

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

GetMethods returns all methods of the given grpcurl.DescriptorSource.