Documentation ¶
Index ¶
- Variables
- func GenerateForwardedHTTPRequest(req *http.Request, addr string) (*http.Request, error)
- func ParseForwardedHTTPRequest(req *http.Request) (*http.Request, error)
- func ParseForwardedRequest(fq *Request) (*http.Request, error)
- type HeaderEntry
- type RPCResponseWriter
- type Request
- func (*Request) Descriptor() ([]byte, []int)deprecated
- func (x *Request) GetBody() []byte
- func (x *Request) GetHeaderEntries() map[string]*HeaderEntry
- func (x *Request) GetHost() string
- func (x *Request) GetMethod() string
- func (x *Request) GetPeerCertificates() [][]byte
- func (x *Request) GetRemoteAddr() string
- func (x *Request) GetUrl() *URL
- func (*Request) ProtoMessage()
- func (x *Request) ProtoReflect() protoreflect.Message
- func (x *Request) Reset()
- func (x *Request) String() string
- type Response
- func (*Response) Descriptor() ([]byte, []int)deprecated
- func (x *Response) GetBody() []byte
- func (x *Response) GetHeaderEntries() map[string]*HeaderEntry
- func (x *Response) GetLastRemoteWal() uint64
- func (x *Response) GetStatusCode() uint32
- func (*Response) ProtoMessage()
- func (x *Response) ProtoReflect() protoreflect.Message
- func (x *Response) Reset()
- func (x *Response) String() string
- type URL
- func (*URL) Descriptor() ([]byte, []int)deprecated
- func (x *URL) GetFragment() string
- func (x *URL) GetHost() string
- func (x *URL) GetOpaque() string
- func (x *URL) GetPath() string
- func (x *URL) GetRawPath() string
- func (x *URL) GetRawQuery() string
- func (x *URL) GetScheme() string
- func (*URL) ProtoMessage()
- func (x *URL) ProtoReflect() protoreflect.Message
- func (x *URL) Reset()
- func (x *URL) String() string
Constants ¶
This section is empty.
Variables ¶
View Source
var File_helper_forwarding_types_proto protoreflect.FileDescriptor
Functions ¶
func GenerateForwardedHTTPRequest ¶
GenerateForwardedRequest generates a new http.Request that contains the original requests's information in the new request's body.
func ParseForwardedHTTPRequest ¶
ParseForwardedRequest generates a new http.Request that is comprised of the values in the given request's body, assuming it correctly parses into a ForwardedRequest.
Types ¶
type HeaderEntry ¶
type HeaderEntry struct { Values []string `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"` // contains filtered or unexported fields }
func (*HeaderEntry) Descriptor
deprecated
func (*HeaderEntry) Descriptor() ([]byte, []int)
Deprecated: Use HeaderEntry.ProtoReflect.Descriptor instead.
func (*HeaderEntry) GetValues ¶ added in v0.6.3
func (x *HeaderEntry) GetValues() []string
func (*HeaderEntry) ProtoMessage ¶
func (*HeaderEntry) ProtoMessage()
func (*HeaderEntry) ProtoReflect ¶ added in v1.5.0
func (x *HeaderEntry) ProtoReflect() protoreflect.Message
func (*HeaderEntry) Reset ¶
func (x *HeaderEntry) Reset()
func (*HeaderEntry) String ¶
func (x *HeaderEntry) String() string
type RPCResponseWriter ¶
type RPCResponseWriter struct {
// contains filtered or unexported fields
}
func NewRPCResponseWriter ¶
func NewRPCResponseWriter() *RPCResponseWriter
NewRPCResponseWriter returns an initialized RPCResponseWriter
func (*RPCResponseWriter) Body ¶
func (w *RPCResponseWriter) Body() *bytes.Buffer
func (*RPCResponseWriter) Header ¶
func (w *RPCResponseWriter) Header() http.Header
func (*RPCResponseWriter) StatusCode ¶
func (w *RPCResponseWriter) StatusCode() int
func (*RPCResponseWriter) WriteHeader ¶
func (w *RPCResponseWriter) WriteHeader(code int)
type Request ¶
type Request struct { // Not used right now but reserving in case it turns out that streaming // makes things more economical on the gRPC side //uint64 id = 1; Method string `protobuf:"bytes,2,opt,name=method,proto3" json:"method,omitempty"` Url *URL `protobuf:"bytes,3,opt,name=url,proto3" json:"url,omitempty"` HeaderEntries map[string]*HeaderEntry `` /* 188-byte string literal not displayed */ Body []byte `protobuf:"bytes,5,opt,name=body,proto3" json:"body,omitempty"` Host string `protobuf:"bytes,6,opt,name=host,proto3" json:"host,omitempty"` RemoteAddr string `protobuf:"bytes,7,opt,name=remote_addr,json=remoteAddr,proto3" json:"remote_addr,omitempty"` PeerCertificates [][]byte `protobuf:"bytes,8,rep,name=peer_certificates,json=peerCertificates,proto3" json:"peer_certificates,omitempty"` // contains filtered or unexported fields }
func (*Request) Descriptor
deprecated
func (*Request) GetHeaderEntries ¶
func (x *Request) GetHeaderEntries() map[string]*HeaderEntry
func (*Request) GetPeerCertificates ¶ added in v0.6.3
func (*Request) GetRemoteAddr ¶ added in v0.6.3
func (*Request) ProtoMessage ¶
func (*Request) ProtoMessage()
func (*Request) ProtoReflect ¶ added in v1.5.0
func (x *Request) ProtoReflect() protoreflect.Message
type Response ¶
type Response struct { // Not used right now but reserving in case it turns out that streaming // makes things more economical on the gRPC side //uint64 id = 1; StatusCode uint32 `protobuf:"varint,2,opt,name=status_code,json=statusCode,proto3" json:"status_code,omitempty"` Body []byte `protobuf:"bytes,3,opt,name=body,proto3" json:"body,omitempty"` // Added in 0.6.2 to ensure that the content-type is set appropriately, as // well as any other information HeaderEntries map[string]*HeaderEntry `` /* 188-byte string literal not displayed */ LastRemoteWal uint64 `protobuf:"varint,5,opt,name=last_remote_wal,json=lastRemoteWal,proto3" json:"last_remote_wal,omitempty"` // contains filtered or unexported fields }
func (*Response) Descriptor
deprecated
func (*Response) GetHeaderEntries ¶ added in v0.6.2
func (x *Response) GetHeaderEntries() map[string]*HeaderEntry
func (*Response) GetLastRemoteWal ¶ added in v0.11.2
func (*Response) GetStatusCode ¶ added in v0.6.3
func (*Response) ProtoMessage ¶
func (*Response) ProtoMessage()
func (*Response) ProtoReflect ¶ added in v1.5.0
func (x *Response) ProtoReflect() protoreflect.Message
type URL ¶
type URL struct { Scheme string `protobuf:"bytes,1,opt,name=scheme,proto3" json:"scheme,omitempty"` Opaque string `protobuf:"bytes,2,opt,name=opaque,proto3" json:"opaque,omitempty"` // This isn't needed now but might be in the future, so we'll skip the // number to keep the ordering in net/url //UserInfo user = 3; Host string `protobuf:"bytes,4,opt,name=host,proto3" json:"host,omitempty"` Path string `protobuf:"bytes,5,opt,name=path,proto3" json:"path,omitempty"` RawPath string `protobuf:"bytes,6,opt,name=raw_path,json=rawPath,proto3" json:"raw_path,omitempty"` // This also isn't needed right now, but we'll reserve the number //bool force_query = 7; RawQuery string `protobuf:"bytes,8,opt,name=raw_query,json=rawQuery,proto3" json:"raw_query,omitempty"` Fragment string `protobuf:"bytes,9,opt,name=fragment,proto3" json:"fragment,omitempty"` // contains filtered or unexported fields }
func (*URL) Descriptor
deprecated
func (*URL) GetFragment ¶ added in v0.6.3
func (*URL) GetRawPath ¶ added in v0.6.3
func (*URL) GetRawQuery ¶ added in v0.6.3
func (*URL) ProtoMessage ¶
func (*URL) ProtoMessage()
func (*URL) ProtoReflect ¶ added in v1.5.0
func (x *URL) ProtoReflect() protoreflect.Message
Click to show internal directories.
Click to hide internal directories.