web_fetch

package
v0.51.2 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: May 7, 2026 License: Apache-2.0 Imports: 15 Imported by: 0

Documentation

Index

Constants

View Source 
const SRPCFetchServiceServiceID = "web.fetch.FetchService"

Variables

This section is empty.

Functions

func BuildHeadersMap 

func BuildHeadersMap(headers http.Header, setDefaults bool) map[string]string

BuildHeadersMap builds the headers proto map from the Headers object.

func Fetch 

func Fetch(
	ctx context.Context,
	caller FetchCaller,
	req *http.Request,
	rw http.ResponseWriter,
) error

Fetch executes a Fetch RPC stream with a remote.

Returns once headers are received. Buffers response data.

func HandleFetch 

func HandleFetch(
	strm SRPCFetchService_FetchStream,
	handler http.HandlerFunc,
) error

HandleFetch handles an incoming Fetch RPC stream with a http handler.

func NewSRPCFetchServiceHandler 

func NewSRPCFetchServiceHandler(impl SRPCFetchServiceServer, serviceID string) srpc.Handler

NewSRPCFetchServiceHandler constructs a new RPC handler. serviceID: if empty, uses default: web.fetch.FetchService

func SRPCRegisterFetchService 

func SRPCRegisterFetchService(mux srpc.Mux, impl SRPCFetchServiceServer) error

SRPCRegisterFetchService registers the implementation with the mux. Uses the default serviceID: web.fetch.FetchService

func SetHeaders 

func SetHeaders(headerMap map[string]string, setTo http.Header)

SetHeaders copies headers from a map to a http.Header.

Types

type FetchBodyReader 

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

FetchBodyReader implements io.Reader with a FetchStream.

func NewFetchBodyReader 

func NewFetchBodyReader(strm SRPCFetchService_FetchStream) *FetchBodyReader

NewFetchBodyReader constructs the FetchBodyReader.

func (*FetchBodyReader) Read 

func (r *FetchBodyReader) Read(p []byte) (n int, err error)

Read reads data from the reader.

type FetchCaller 

type FetchCaller func(ctx context.Context) (SRPCFetchService_FetchClient, error)

FetchCaller is a function which starts the Fetch call.

type FetchRequest 

type FetchRequest struct {

	// Types that are assignable to Body:
	//
	//	*FetchRequest_RequestInfo
	//	*FetchRequest_RequestData
	Body isFetchRequest_Body `protobuf_oneof:"body"`
	// contains filtered or unexported fields
}

FetchRequest is the message to initialize a Fetch request.

Note: many fields are optional.

func NewFetchRequestWithData 

func NewFetchRequestWithData(data []byte, done bool) *FetchRequest

NewFetchRequestWithData constructs a FetchRequest containing some data.

func NewFetchRequestWithInfo 

func NewFetchRequestWithInfo(req *http.Request, clientID string, hasBody bool) *FetchRequest

NewFetchRequestWithInfo constructs a Info FetchRequest from a HTTP request.

func (*FetchRequest) CloneMessageVT 

func (m *FetchRequest) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*FetchRequest) CloneVT 

func (m *FetchRequest) CloneVT() *FetchRequest

func (*FetchRequest) EqualMessageVT 

func (this *FetchRequest) EqualMessageVT(thatMsg any) bool

func (*FetchRequest) EqualVT 

func (this *FetchRequest) EqualVT(that *FetchRequest) bool

func (*FetchRequest) GetBody 

func (m *FetchRequest) GetBody() isFetchRequest_Body

func (*FetchRequest) GetRequestData 

func (x *FetchRequest) GetRequestData() *FetchRequestData

func (*FetchRequest) GetRequestInfo 

func (x *FetchRequest) GetRequestInfo() *FetchRequestInfo

func (*FetchRequest) MarshalJSON 

func (x *FetchRequest) MarshalJSON() ([]byte, error)

MarshalJSON marshals the FetchRequest to JSON.

func (*FetchRequest) MarshalProtoJSON 

func (x *FetchRequest) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the FetchRequest message to JSON.

func (*FetchRequest) MarshalProtoText 

func (x *FetchRequest) MarshalProtoText() string

func (*FetchRequest) MarshalToSizedBufferVT 

func (m *FetchRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*FetchRequest) MarshalToVT 

func (m *FetchRequest) MarshalToVT(dAtA []byte) (int, error)

func (*FetchRequest) MarshalVT 

func (m *FetchRequest) MarshalVT() (dAtA []byte, err error)

func (*FetchRequest) ProtoMessage 

func (*FetchRequest) ProtoMessage()

func (*FetchRequest) Reset 

func (x *FetchRequest) Reset()

func (*FetchRequest) SizeVT 

func (m *FetchRequest) SizeVT() (n int)

func (*FetchRequest) String 

func (x *FetchRequest) String() string

func (*FetchRequest) UnmarshalJSON 

func (x *FetchRequest) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the FetchRequest from JSON.

func (*FetchRequest) UnmarshalProtoJSON 

func (x *FetchRequest) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the FetchRequest message from JSON.

func (*FetchRequest) UnmarshalVT 

func (m *FetchRequest) UnmarshalVT(dAtA []byte) error

type FetchRequestData 

type FetchRequestData struct {

	// Data is the request data chunk.
	Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// Done indicates the stream is closed after data.
	Done bool `protobuf:"varint,2,opt,name=done,proto3" json:"done,omitempty"`
	// contains filtered or unexported fields
}

FetchRequestData contains a streaming request data packet.

func (*FetchRequestData) CloneMessageVT 

func (m *FetchRequestData) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*FetchRequestData) CloneVT 

func (m *FetchRequestData) CloneVT() *FetchRequestData

func (*FetchRequestData) EqualMessageVT 

func (this *FetchRequestData) EqualMessageVT(thatMsg any) bool

func (*FetchRequestData) EqualVT 

func (this *FetchRequestData) EqualVT(that *FetchRequestData) bool

func (*FetchRequestData) GetData 

func (x *FetchRequestData) GetData() []byte

func (*FetchRequestData) GetDone 

func (x *FetchRequestData) GetDone() bool

func (*FetchRequestData) MarshalJSON 

func (x *FetchRequestData) MarshalJSON() ([]byte, error)

MarshalJSON marshals the FetchRequestData to JSON.

func (*FetchRequestData) MarshalProtoJSON 

func (x *FetchRequestData) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the FetchRequestData message to JSON.

func (*FetchRequestData) MarshalProtoText 

func (x *FetchRequestData) MarshalProtoText() string

func (*FetchRequestData) MarshalToSizedBufferVT 

func (m *FetchRequestData) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*FetchRequestData) MarshalToVT 

func (m *FetchRequestData) MarshalToVT(dAtA []byte) (int, error)

func (*FetchRequestData) MarshalVT 

func (m *FetchRequestData) MarshalVT() (dAtA []byte, err error)

func (*FetchRequestData) ProtoMessage 

func (*FetchRequestData) ProtoMessage()

func (*FetchRequestData) Reset 

func (x *FetchRequestData) Reset()

func (*FetchRequestData) SizeVT 

func (m *FetchRequestData) SizeVT() (n int)

func (*FetchRequestData) String 

func (x *FetchRequestData) String() string

func (*FetchRequestData) UnmarshalJSON 

func (x *FetchRequestData) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the FetchRequestData from JSON.

func (*FetchRequestData) UnmarshalProtoJSON 

func (x *FetchRequestData) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the FetchRequestData message from JSON.

func (*FetchRequestData) UnmarshalVT 

func (m *FetchRequestData) UnmarshalVT(dAtA []byte) error

type FetchRequestInfo 

type FetchRequestInfo struct {

	// Method is the request method.
	// i.e. "GET"
	Method string `protobuf:"bytes,1,opt,name=method,proto3" json:"method,omitempty"`
	// Url is the request url.
	Url string `protobuf:"bytes,2,opt,name=url,proto3" json:"url,omitempty"`
	// Headers is the map of request header key/value pairs.
	Headers map[string]string `` /* 155-byte string literal not displayed */
	// HasBody indicates there will be follow up Data packets.
	HasBody bool `protobuf:"varint,4,opt,name=has_body,json=hasBody,proto3" json:"hasBody,omitempty"`
	// ClientId is the identifier of the client that sent the request.
	ClientId string `protobuf:"bytes,5,opt,name=client_id,json=clientId,proto3" json:"clientId,omitempty"`
	// Destination is the kind of resource requested.
	//
	// "audio" | "audioworklet" | "document" | "embed" | "font" | "frame" |
	// "iframe" | "image" | "manifest" | "object" | "paintworklet" | "report" |
	// "script" | "sharedworker" | "style" | "track" | "video" | "worker" | "xslt"
	Destination string `protobuf:"bytes,6,opt,name=destination,proto3" json:"destination,omitempty"`
	// Integrity contains a cryptographic hash of the resource being fetched.
	//
	// optional
	Integrity string `protobuf:"bytes,7,opt,name=integrity,proto3" json:"integrity,omitempty"`
	// Mode is the request mode, indicating if CORS should be allowed or not.
	//
	// "cors" | "navigate" | "no-cors" | "same-origin"
	// defaults to "cors"
	Mode string `protobuf:"bytes,8,opt,name=mode,proto3" json:"mode,omitempty"`
	// Redirect indicates the redirect policy for the request.
	//
	// "error" | "follow" | "manual"
	// defaults to "follow"
	Redirect string `protobuf:"bytes,9,opt,name=redirect,proto3" json:"redirect,omitempty"`
	// Referrer is the request referrer.
	Referrer string `protobuf:"bytes,10,opt,name=referrer,proto3" json:"referrer,omitempty"`
	// ReferrerPolicy is the request referrer policy.
	//
	// "" | "no-referrer" | "no-referrer-when-downgrade" | "origin" |
	// "origin-when-cross-origin" | "same-origin" | "strict-origin" |
	// "strict-origin-when-cross-origin" | "unsafe-url"
	ReferrerPolicy string `protobuf:"bytes,11,opt,name=referrer_policy,json=referrerPolicy,proto3" json:"referrerPolicy,omitempty"`
	// contains filtered or unexported fields
}

FetchRequestInfo contains all information about the request excluding the body.

func NewFetchRequestInfo 

func NewFetchRequestInfo(req *http.Request, clientID string, hasBody bool) *FetchRequestInfo

NewFetchRequestInfo constructs a FetchRequestInfo from a HTTP request.

func (*FetchRequestInfo) CloneMessageVT 

func (m *FetchRequestInfo) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*FetchRequestInfo) CloneVT 

func (m *FetchRequestInfo) CloneVT() *FetchRequestInfo

func (*FetchRequestInfo) EqualMessageVT 

func (this *FetchRequestInfo) EqualMessageVT(thatMsg any) bool

func (*FetchRequestInfo) EqualVT 

func (this *FetchRequestInfo) EqualVT(that *FetchRequestInfo) bool

func (*FetchRequestInfo) GetClientId 

func (x *FetchRequestInfo) GetClientId() string

func (*FetchRequestInfo) GetDestination 

func (x *FetchRequestInfo) GetDestination() string

func (*FetchRequestInfo) GetHasBody 

func (x *FetchRequestInfo) GetHasBody() bool

func (*FetchRequestInfo) GetHeaders 

func (x *FetchRequestInfo) GetHeaders() map[string]string

func (*FetchRequestInfo) GetIntegrity 

func (x *FetchRequestInfo) GetIntegrity() string

func (*FetchRequestInfo) GetMethod 

func (x *FetchRequestInfo) GetMethod() string

func (*FetchRequestInfo) GetMode 

func (x *FetchRequestInfo) GetMode() string

func (*FetchRequestInfo) GetRedirect 

func (x *FetchRequestInfo) GetRedirect() string

func (*FetchRequestInfo) GetReferrer 

func (x *FetchRequestInfo) GetReferrer() string

func (*FetchRequestInfo) GetReferrerPolicy 

func (x *FetchRequestInfo) GetReferrerPolicy() string

func (*FetchRequestInfo) GetUrl 

func (x *FetchRequestInfo) GetUrl() string

func (*FetchRequestInfo) MarshalJSON 

func (x *FetchRequestInfo) MarshalJSON() ([]byte, error)

MarshalJSON marshals the FetchRequestInfo to JSON.

func (*FetchRequestInfo) MarshalProtoJSON 

func (x *FetchRequestInfo) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the FetchRequestInfo message to JSON.

func (*FetchRequestInfo) MarshalProtoText 

func (x *FetchRequestInfo) MarshalProtoText() string

func (*FetchRequestInfo) MarshalToSizedBufferVT 

func (m *FetchRequestInfo) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*FetchRequestInfo) MarshalToVT 

func (m *FetchRequestInfo) MarshalToVT(dAtA []byte) (int, error)

func (*FetchRequestInfo) MarshalVT 

func (m *FetchRequestInfo) MarshalVT() (dAtA []byte, err error)

func (*FetchRequestInfo) ProtoMessage 

func (*FetchRequestInfo) ProtoMessage()

func (*FetchRequestInfo) Reset 

func (x *FetchRequestInfo) Reset()

func (*FetchRequestInfo) SizeVT 

func (m *FetchRequestInfo) SizeVT() (n int)

func (*FetchRequestInfo) String 

func (x *FetchRequestInfo) String() string

func (*FetchRequestInfo) ToHttpRequest 

func (r *FetchRequestInfo) ToHttpRequest(ctx context.Context, body io.Reader) (*http.Request, error)

ToHttpRequest constructs a http request from the FetchRequest.

func (*FetchRequestInfo) UnmarshalJSON 

func (x *FetchRequestInfo) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the FetchRequestInfo from JSON.

func (*FetchRequestInfo) UnmarshalProtoJSON 

func (x *FetchRequestInfo) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the FetchRequestInfo message from JSON.

func (*FetchRequestInfo) UnmarshalVT 

func (m *FetchRequestInfo) UnmarshalVT(dAtA []byte) error

type FetchRequestInfo_HeadersEntry 

type FetchRequestInfo_HeadersEntry struct {
	Key   string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*FetchRequestInfo_HeadersEntry) GetKey 

func (x *FetchRequestInfo_HeadersEntry) GetKey() string

func (*FetchRequestInfo_HeadersEntry) GetValue 

func (x *FetchRequestInfo_HeadersEntry) GetValue() string

func (*FetchRequestInfo_HeadersEntry) MarshalJSON 

func (x *FetchRequestInfo_HeadersEntry) MarshalJSON() ([]byte, error)

MarshalJSON marshals the FetchRequestInfo_HeadersEntry to JSON.

func (*FetchRequestInfo_HeadersEntry) MarshalProtoJSON 

func (x *FetchRequestInfo_HeadersEntry) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the FetchRequestInfo_HeadersEntry message to JSON.

func (*FetchRequestInfo_HeadersEntry) MarshalProtoText 

func (x *FetchRequestInfo_HeadersEntry) MarshalProtoText() string

func (*FetchRequestInfo_HeadersEntry) ProtoMessage 

func (*FetchRequestInfo_HeadersEntry) ProtoMessage()

func (*FetchRequestInfo_HeadersEntry) Reset 

func (x *FetchRequestInfo_HeadersEntry) Reset()

func (*FetchRequestInfo_HeadersEntry) String 

func (x *FetchRequestInfo_HeadersEntry) String() string

func (*FetchRequestInfo_HeadersEntry) UnmarshalJSON 

func (x *FetchRequestInfo_HeadersEntry) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the FetchRequestInfo_HeadersEntry from JSON.

func (*FetchRequestInfo_HeadersEntry) UnmarshalProtoJSON 

func (x *FetchRequestInfo_HeadersEntry) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the FetchRequestInfo_HeadersEntry message from JSON.

type FetchRequest_RequestData 

type FetchRequest_RequestData struct {
	// FetchRequestData contains a request data packet.
	RequestData *FetchRequestData `protobuf:"bytes,2,opt,name=request_data,json=requestData,proto3,oneof"`
}

func (*FetchRequest_RequestData) CloneOneofVT 

func (m *FetchRequest_RequestData) CloneOneofVT() isFetchRequest_Body

func (*FetchRequest_RequestData) CloneVT 

func (m *FetchRequest_RequestData) CloneVT() *FetchRequest_RequestData

func (*FetchRequest_RequestData) EqualVT 

func (this *FetchRequest_RequestData) EqualVT(thatIface isFetchRequest_Body) bool

func (*FetchRequest_RequestData) MarshalToSizedBufferVT 

func (m *FetchRequest_RequestData) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*FetchRequest_RequestData) MarshalToVT 

func (m *FetchRequest_RequestData) MarshalToVT(dAtA []byte) (int, error)

func (*FetchRequest_RequestData) SizeVT 

func (m *FetchRequest_RequestData) SizeVT() (n int)

type FetchRequest_RequestInfo 

type FetchRequest_RequestInfo struct {
	// FetchRequestInfo contains the headers and other request info.
	RequestInfo *FetchRequestInfo `protobuf:"bytes,1,opt,name=request_info,json=requestInfo,proto3,oneof"`
}

func (*FetchRequest_RequestInfo) CloneOneofVT 

func (m *FetchRequest_RequestInfo) CloneOneofVT() isFetchRequest_Body

func (*FetchRequest_RequestInfo) CloneVT 

func (m *FetchRequest_RequestInfo) CloneVT() *FetchRequest_RequestInfo

func (*FetchRequest_RequestInfo) EqualVT 

func (this *FetchRequest_RequestInfo) EqualVT(thatIface isFetchRequest_Body) bool

func (*FetchRequest_RequestInfo) MarshalToSizedBufferVT 

func (m *FetchRequest_RequestInfo) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*FetchRequest_RequestInfo) MarshalToVT 

func (m *FetchRequest_RequestInfo) MarshalToVT(dAtA []byte) (int, error)

func (*FetchRequest_RequestInfo) SizeVT 

func (m *FetchRequest_RequestInfo) SizeVT() (n int)

type FetchResponse 

type FetchResponse struct {

	// Types that are assignable to Body:
	//
	//	*FetchResponse_ResponseInfo
	//	*FetchResponse_ResponseData
	Body isFetchResponse_Body `protobuf_oneof:"body"`
	// contains filtered or unexported fields
}

FetchResponse is a message in a Fetch response stream.

The first message in the stream has the ResponseInfo Subsequent messages contain response data.

func BuildFetchResponse_Data 

func BuildFetchResponse_Data(data []byte, done bool) *FetchResponse

BuildFetchResponse_Data builds a FetchResponse from http response data.

func BuildFetchResponse_Info 

func BuildFetchResponse_Info(header http.Header, statusCode int) *FetchResponse

BuildFetchResponse_Info builds a FetchResponse from http response info.

func (*FetchResponse) CloneMessageVT 

func (m *FetchResponse) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*FetchResponse) CloneVT 

func (m *FetchResponse) CloneVT() *FetchResponse

func (*FetchResponse) EqualMessageVT 

func (this *FetchResponse) EqualMessageVT(thatMsg any) bool

func (*FetchResponse) EqualVT 

func (this *FetchResponse) EqualVT(that *FetchResponse) bool

func (*FetchResponse) GetBody 

func (m *FetchResponse) GetBody() isFetchResponse_Body

func (*FetchResponse) GetResponseData 

func (x *FetchResponse) GetResponseData() *ResponseData

func (*FetchResponse) GetResponseInfo 

func (x *FetchResponse) GetResponseInfo() *ResponseInfo

func (*FetchResponse) MarshalJSON 

func (x *FetchResponse) MarshalJSON() ([]byte, error)

MarshalJSON marshals the FetchResponse to JSON.

func (*FetchResponse) MarshalProtoJSON 

func (x *FetchResponse) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the FetchResponse message to JSON.

func (*FetchResponse) MarshalProtoText 

func (x *FetchResponse) MarshalProtoText() string

func (*FetchResponse) MarshalToSizedBufferVT 

func (m *FetchResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*FetchResponse) MarshalToVT 

func (m *FetchResponse) MarshalToVT(dAtA []byte) (int, error)

func (*FetchResponse) MarshalVT 

func (m *FetchResponse) MarshalVT() (dAtA []byte, err error)

func (*FetchResponse) ProtoMessage 

func (*FetchResponse) ProtoMessage()

func (*FetchResponse) Reset 

func (x *FetchResponse) Reset()

func (*FetchResponse) SizeVT 

func (m *FetchResponse) SizeVT() (n int)

func (*FetchResponse) String 

func (x *FetchResponse) String() string

func (*FetchResponse) UnmarshalJSON 

func (x *FetchResponse) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the FetchResponse from JSON.

func (*FetchResponse) UnmarshalProtoJSON 

func (x *FetchResponse) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the FetchResponse message from JSON.

func (*FetchResponse) UnmarshalVT 

func (m *FetchResponse) UnmarshalVT(dAtA []byte) error

type FetchResponseWriter 

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

FetchResponseWriter implements ResponseWriter with a Fetch stream.

func NewFetchResponseWriter 

func NewFetchResponseWriter(strm SRPCFetchService_FetchStream) *FetchResponseWriter

NewFetchResponseWriter constructs the FetchResponseWriter.

func (*FetchResponseWriter) Header 

func (w *FetchResponseWriter) Header() http.Header

Header returns the header map that will be sent by WriteHeader.

func (*FetchResponseWriter) Write 

func (w *FetchResponseWriter) Write(p []byte) (int, error)

Write writes the data to the connection as part of an HTTP reply.

func (*FetchResponseWriter) WriteHeader 

func (w *FetchResponseWriter) WriteHeader(statusCode int)

WriteHeader sends an HTTP response header with the provided status code.

type FetchResponse_ResponseData 

type FetchResponse_ResponseData struct {
	// ResponseData contains a response data packet.
	ResponseData *ResponseData `protobuf:"bytes,2,opt,name=response_data,json=responseData,proto3,oneof"`
}

func (*FetchResponse_ResponseData) CloneOneofVT 

func (m *FetchResponse_ResponseData) CloneOneofVT() isFetchResponse_Body

func (*FetchResponse_ResponseData) CloneVT 

func (m *FetchResponse_ResponseData) CloneVT() *FetchResponse_ResponseData

func (*FetchResponse_ResponseData) EqualVT 

func (this *FetchResponse_ResponseData) EqualVT(thatIface isFetchResponse_Body) bool

func (*FetchResponse_ResponseData) MarshalToSizedBufferVT 

func (m *FetchResponse_ResponseData) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*FetchResponse_ResponseData) MarshalToVT 

func (m *FetchResponse_ResponseData) MarshalToVT(dAtA []byte) (int, error)

func (*FetchResponse_ResponseData) SizeVT 

func (m *FetchResponse_ResponseData) SizeVT() (n int)

type FetchResponse_ResponseInfo 

type FetchResponse_ResponseInfo struct {
	// ResponseInfo contains the headers and other response info.
	ResponseInfo *ResponseInfo `protobuf:"bytes,1,opt,name=response_info,json=responseInfo,proto3,oneof"`
}

func (*FetchResponse_ResponseInfo) CloneOneofVT 

func (m *FetchResponse_ResponseInfo) CloneOneofVT() isFetchResponse_Body

func (*FetchResponse_ResponseInfo) CloneVT 

func (m *FetchResponse_ResponseInfo) CloneVT() *FetchResponse_ResponseInfo

func (*FetchResponse_ResponseInfo) EqualVT 

func (this *FetchResponse_ResponseInfo) EqualVT(thatIface isFetchResponse_Body) bool

func (*FetchResponse_ResponseInfo) MarshalToSizedBufferVT 

func (m *FetchResponse_ResponseInfo) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*FetchResponse_ResponseInfo) MarshalToVT 

func (m *FetchResponse_ResponseInfo) MarshalToVT(dAtA []byte) (int, error)

func (*FetchResponse_ResponseInfo) SizeVT 

func (m *FetchResponse_ResponseInfo) SizeVT() (n int)

type FetchServer 

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

FetchServer is a srpc server implementing FetchService.

func NewFetchServer 

func NewFetchServer(handler http.HandlerFunc) *FetchServer

NewFetchServer constructs a new FetchServer with a handler.

func (*FetchServer) Fetch 

func (s *FetchServer) Fetch(strm SRPCFetchService_FetchStream) error

Fetch executes the fetch request.

type ResponseData 

type ResponseData struct {

	// Data is the response data chunk.
	Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// Done indicates the stream is closed after data.
	Done bool `protobuf:"varint,2,opt,name=done,proto3" json:"done,omitempty"`
	// contains filtered or unexported fields
}

ResponseData contains a streaming response data packet.

func (*ResponseData) CloneMessageVT 

func (m *ResponseData) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*ResponseData) CloneVT 

func (m *ResponseData) CloneVT() *ResponseData

func (*ResponseData) EqualMessageVT 

func (this *ResponseData) EqualMessageVT(thatMsg any) bool

func (*ResponseData) EqualVT 

func (this *ResponseData) EqualVT(that *ResponseData) bool

func (*ResponseData) GetData 

func (x *ResponseData) GetData() []byte

func (*ResponseData) GetDone 

func (x *ResponseData) GetDone() bool

func (*ResponseData) MarshalJSON 

func (x *ResponseData) MarshalJSON() ([]byte, error)

MarshalJSON marshals the ResponseData to JSON.

func (*ResponseData) MarshalProtoJSON 

func (x *ResponseData) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the ResponseData message to JSON.

func (*ResponseData) MarshalProtoText 

func (x *ResponseData) MarshalProtoText() string

func (*ResponseData) MarshalToSizedBufferVT 

func (m *ResponseData) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ResponseData) MarshalToVT 

func (m *ResponseData) MarshalToVT(dAtA []byte) (int, error)

func (*ResponseData) MarshalVT 

func (m *ResponseData) MarshalVT() (dAtA []byte, err error)

func (*ResponseData) ProtoMessage 

func (*ResponseData) ProtoMessage()

func (*ResponseData) Reset 

func (x *ResponseData) Reset()

func (*ResponseData) SizeVT 

func (m *ResponseData) SizeVT() (n int)

func (*ResponseData) String 

func (x *ResponseData) String() string

func (*ResponseData) UnmarshalJSON 

func (x *ResponseData) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the ResponseData from JSON.

func (*ResponseData) UnmarshalProtoJSON 

func (x *ResponseData) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the ResponseData message from JSON.

func (*ResponseData) UnmarshalVT 

func (m *ResponseData) UnmarshalVT(dAtA []byte) error

type ResponseInfo 

type ResponseInfo struct {

	// Headers is the map of response header key/value pairs.
	Headers map[string]string `` /* 155-byte string literal not displayed */
	// Ok indicates if the response was ok.
	Ok bool `protobuf:"varint,2,opt,name=ok,proto3" json:"ok,omitempty"`
	// Redirected indicates if the request was redirected
	Redirected bool `protobuf:"varint,3,opt,name=redirected,proto3" json:"redirected,omitempty"`
	// Status is the HTTP status code.
	Status uint32 `protobuf:"varint,4,opt,name=status,proto3" json:"status,omitempty"`
	// StatusText is the HTTP status text.
	StatusText string `protobuf:"bytes,5,opt,name=status_text,json=statusText,proto3" json:"statusText,omitempty"`
	// ResponseType is the type of response.
	// "basic" | "cors" | "default" | "error" | "opaque" | "opaqueredirect"
	ResponseType string `protobuf:"bytes,6,opt,name=response_type,json=responseType,proto3" json:"responseType,omitempty"`
	// contains filtered or unexported fields
}

ResponseInfo contains information about the response.

func (*ResponseInfo) CloneMessageVT 

func (m *ResponseInfo) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*ResponseInfo) CloneVT 

func (m *ResponseInfo) CloneVT() *ResponseInfo

func (*ResponseInfo) EqualMessageVT 

func (this *ResponseInfo) EqualMessageVT(thatMsg any) bool

func (*ResponseInfo) EqualVT 

func (this *ResponseInfo) EqualVT(that *ResponseInfo) bool

func (*ResponseInfo) GetHeaders 

func (x *ResponseInfo) GetHeaders() map[string]string

func (*ResponseInfo) GetOk 

func (x *ResponseInfo) GetOk() bool

func (*ResponseInfo) GetRedirected 

func (x *ResponseInfo) GetRedirected() bool

func (*ResponseInfo) GetResponseType 

func (x *ResponseInfo) GetResponseType() string

func (*ResponseInfo) GetStatus 

func (x *ResponseInfo) GetStatus() uint32

func (*ResponseInfo) GetStatusText 

func (x *ResponseInfo) GetStatusText() string

func (*ResponseInfo) MarshalJSON 

func (x *ResponseInfo) MarshalJSON() ([]byte, error)

MarshalJSON marshals the ResponseInfo to JSON.

func (*ResponseInfo) MarshalProtoJSON 

func (x *ResponseInfo) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the ResponseInfo message to JSON.

func (*ResponseInfo) MarshalProtoText 

func (x *ResponseInfo) MarshalProtoText() string

func (*ResponseInfo) MarshalToSizedBufferVT 

func (m *ResponseInfo) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ResponseInfo) MarshalToVT 

func (m *ResponseInfo) MarshalToVT(dAtA []byte) (int, error)

func (*ResponseInfo) MarshalVT 

func (m *ResponseInfo) MarshalVT() (dAtA []byte, err error)

func (*ResponseInfo) ProtoMessage 

func (*ResponseInfo) ProtoMessage()

func (*ResponseInfo) Reset 

func (x *ResponseInfo) Reset()

func (*ResponseInfo) SizeVT 

func (m *ResponseInfo) SizeVT() (n int)

func (*ResponseInfo) String 

func (x *ResponseInfo) String() string

func (*ResponseInfo) UnmarshalJSON 

func (x *ResponseInfo) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the ResponseInfo from JSON.

func (*ResponseInfo) UnmarshalProtoJSON 

func (x *ResponseInfo) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the ResponseInfo message from JSON.

func (*ResponseInfo) UnmarshalVT 

func (m *ResponseInfo) UnmarshalVT(dAtA []byte) error

type ResponseInfo_HeadersEntry 

type ResponseInfo_HeadersEntry struct {
	Key   string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*ResponseInfo_HeadersEntry) GetKey 

func (x *ResponseInfo_HeadersEntry) GetKey() string

func (*ResponseInfo_HeadersEntry) GetValue 

func (x *ResponseInfo_HeadersEntry) GetValue() string

func (*ResponseInfo_HeadersEntry) MarshalJSON 

func (x *ResponseInfo_HeadersEntry) MarshalJSON() ([]byte, error)

MarshalJSON marshals the ResponseInfo_HeadersEntry to JSON.

func (*ResponseInfo_HeadersEntry) MarshalProtoJSON 

func (x *ResponseInfo_HeadersEntry) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the ResponseInfo_HeadersEntry message to JSON.

func (*ResponseInfo_HeadersEntry) MarshalProtoText 

func (x *ResponseInfo_HeadersEntry) MarshalProtoText() string

func (*ResponseInfo_HeadersEntry) ProtoMessage 

func (*ResponseInfo_HeadersEntry) ProtoMessage()

func (*ResponseInfo_HeadersEntry) Reset 

func (x *ResponseInfo_HeadersEntry) Reset()

func (*ResponseInfo_HeadersEntry) String 

func (x *ResponseInfo_HeadersEntry) String() string

func (*ResponseInfo_HeadersEntry) UnmarshalJSON 

func (x *ResponseInfo_HeadersEntry) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the ResponseInfo_HeadersEntry from JSON.

func (*ResponseInfo_HeadersEntry) UnmarshalProtoJSON 

func (x *ResponseInfo_HeadersEntry) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the ResponseInfo_HeadersEntry message from JSON.

type SRPCFetchServiceClient 

type SRPCFetchServiceClient interface {
	// SRPCClient returns the underlying SRPC client.
	SRPCClient() srpc.Client

	// Fetch performs a Fetch request with a streaming response.
	Fetch(ctx context.Context) (SRPCFetchService_FetchClient, error)
}

func NewSRPCFetchServiceClient 

func NewSRPCFetchServiceClient(cc srpc.Client) SRPCFetchServiceClient

func NewSRPCFetchServiceClientWithServiceID 

func NewSRPCFetchServiceClientWithServiceID(cc srpc.Client, serviceID string) SRPCFetchServiceClient

type SRPCFetchServiceHandler 

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

func (SRPCFetchServiceHandler) GetMethodIDs 

func (SRPCFetchServiceHandler) GetMethodIDs() []string

func (*SRPCFetchServiceHandler) GetServiceID 

func (d *SRPCFetchServiceHandler) GetServiceID() string

func (*SRPCFetchServiceHandler) InvokeMethod 

func (d *SRPCFetchServiceHandler) InvokeMethod(
	serviceID, methodID string,
	strm srpc.Stream,
) (bool, error)

func (SRPCFetchServiceHandler) InvokeMethod_Fetch 

func (SRPCFetchServiceHandler) InvokeMethod_Fetch(impl SRPCFetchServiceServer, strm srpc.Stream) error

type SRPCFetchServiceServer 

type SRPCFetchServiceServer interface {
	// Fetch performs a Fetch request with a streaming response.
	Fetch(SRPCFetchService_FetchStream) error
}

type SRPCFetchService_FetchClient 

type SRPCFetchService_FetchClient interface {
	srpc.Stream
	Send(*FetchRequest) error
	Recv() (*FetchResponse, error)
	RecvTo(*FetchResponse) error
}

type SRPCFetchService_FetchStream 

type SRPCFetchService_FetchStream interface {
	srpc.Stream
	Send(*FetchResponse) error
	SendAndClose(*FetchResponse) error
	Recv() (*FetchRequest, error)
	RecvTo(*FetchRequest) error
}

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.