httpV2

package
v6.0.0-beta.12 Latest Latest
Warning

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

 Go to latest Published: May 16, 2026 License: MIT Imports: 10 Imported by: 1

Documentation

Index

Constants

View Source 
const (
	HttpProxyService_FetchRequest_FullMethodName   = "/http.v2.HttpProxyService/FetchRequest"
	HttpProxyService_StreamRequest_FullMethodName  = "/http.v2.HttpProxyService/StreamRequest"
	HttpProxyService_FetchRequests_FullMethodName  = "/http.v2.HttpProxyService/FetchRequests"
	HttpProxyService_SendResponse_FullMethodName   = "/http.v2.HttpProxyService/SendResponse"
	HttpProxyService_StreamResponse_FullMethodName = "/http.v2.HttpProxyService/StreamResponse"
)

Variables

View Source 
var File_http_v2_http_proto protoreflect.FileDescriptor
View Source 
var File_http_v2_request_proto protoreflect.FileDescriptor
View Source 
var File_http_v2_response_proto protoreflect.FileDescriptor
View Source 
var File_http_v2_service_proto protoreflect.FileDescriptor
View Source 
var HttpProxyService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "http.v2.HttpProxyService",
	HandlerType: (*HttpProxyServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "FetchRequest",
			Handler:    _HttpProxyService_FetchRequest_Handler,
		},
		{
			MethodName: "FetchRequests",
			Handler:    _HttpProxyService_FetchRequests_Handler,
		},
		{
			MethodName: "SendResponse",
			Handler:    _HttpProxyService_SendResponse_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "StreamRequest",
			Handler:       _HttpProxyService_StreamRequest_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "StreamResponse",
			Handler:       _HttpProxyService_StreamResponse_Handler,
			ClientStreams: true,
		},
	},
	Metadata: "http/v2/service.proto",
}

HttpProxyService_ServiceDesc is the grpc.ServiceDesc for HttpProxyService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterHttpProxyServiceServer 

func RegisterHttpProxyServiceServer(s grpc.ServiceRegistrar, srv HttpProxyServiceServer)

Types

type HttpHandlerFetchRequest 

type HttpHandlerFetchRequest struct {
	BatchSize int64 `protobuf:"varint,1,opt,name=batch_size,json=batchSize,proto3" json:"batch_size,omitempty"`
	// contains filtered or unexported fields
}

func (*HttpHandlerFetchRequest) Descriptor deprecated 

func (*HttpHandlerFetchRequest) Descriptor() ([]byte, []int)

Deprecated: Use HttpHandlerFetchRequest.ProtoReflect.Descriptor instead.

func (*HttpHandlerFetchRequest) GetBatchSize 

func (x *HttpHandlerFetchRequest) GetBatchSize() int64

func (*HttpHandlerFetchRequest) ProtoMessage 

func (*HttpHandlerFetchRequest) ProtoMessage()

func (*HttpHandlerFetchRequest) ProtoReflect 

func (x *HttpHandlerFetchRequest) ProtoReflect() protoreflect.Message

func (*HttpHandlerFetchRequest) Reset 

func (x *HttpHandlerFetchRequest) Reset()

func (*HttpHandlerFetchRequest) String 

func (x *HttpHandlerFetchRequest) String() string

type HttpHandlerRequest 

type HttpHandlerRequest struct {
	Id         string                      `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	RemoteAddr string                      `protobuf:"bytes,2,opt,name=remote_addr,json=remoteAddr,proto3" json:"remote_addr,omitempty"`
	Protocol   string                      `protobuf:"bytes,3,opt,name=protocol,proto3" json:"protocol,omitempty"`
	Method     string                      `protobuf:"bytes,4,opt,name=method,proto3" json:"method,omitempty"`
	Uri        string                      `protobuf:"bytes,5,opt,name=uri,proto3" json:"uri,omitempty"`
	Header     map[string]*HttpHeaderValue `` /* 139-byte string literal not displayed */
	Cookies    map[string]*HttpHeaderValue `` /* 141-byte string literal not displayed */
	RawQuery   string                      `protobuf:"bytes,8,opt,name=raw_query,json=rawQuery,proto3" json:"raw_query,omitempty"`
	Parsed     bool                        `protobuf:"varint,9,opt,name=parsed,proto3" json:"parsed,omitempty"`
	Uploads    []byte                      `protobuf:"bytes,10,opt,name=uploads,proto3" json:"uploads,omitempty"`
	Attributes map[string]*HttpHeaderValue `` /* 148-byte string literal not displayed */
	Body       []byte                      `protobuf:"bytes,12,opt,name=body,proto3" json:"body,omitempty"`
	// contains filtered or unexported fields
}

func (*HttpHandlerRequest) Descriptor deprecated 

func (*HttpHandlerRequest) Descriptor() ([]byte, []int)

Deprecated: Use HttpHandlerRequest.ProtoReflect.Descriptor instead.

func (*HttpHandlerRequest) GetAttributes 

func (x *HttpHandlerRequest) GetAttributes() map[string]*HttpHeaderValue

func (*HttpHandlerRequest) GetBody 

func (x *HttpHandlerRequest) GetBody() []byte

func (*HttpHandlerRequest) GetCookies 

func (x *HttpHandlerRequest) GetCookies() map[string]*HttpHeaderValue

func (*HttpHandlerRequest) GetHeader 

func (x *HttpHandlerRequest) GetHeader() map[string]*HttpHeaderValue

func (*HttpHandlerRequest) GetId 

func (x *HttpHandlerRequest) GetId() string

func (*HttpHandlerRequest) GetMethod 

func (x *HttpHandlerRequest) GetMethod() string

func (*HttpHandlerRequest) GetParsed 

func (x *HttpHandlerRequest) GetParsed() bool

func (*HttpHandlerRequest) GetProtocol 

func (x *HttpHandlerRequest) GetProtocol() string

func (*HttpHandlerRequest) GetRawQuery 

func (x *HttpHandlerRequest) GetRawQuery() string

func (*HttpHandlerRequest) GetRemoteAddr 

func (x *HttpHandlerRequest) GetRemoteAddr() string

func (*HttpHandlerRequest) GetUploads 

func (x *HttpHandlerRequest) GetUploads() []byte

func (*HttpHandlerRequest) GetUri 

func (x *HttpHandlerRequest) GetUri() string

func (*HttpHandlerRequest) ProtoMessage 

func (*HttpHandlerRequest) ProtoMessage()

func (*HttpHandlerRequest) ProtoReflect 

func (x *HttpHandlerRequest) ProtoReflect() protoreflect.Message

func (*HttpHandlerRequest) Reset 

func (x *HttpHandlerRequest) Reset()

func (*HttpHandlerRequest) String 

func (x *HttpHandlerRequest) String() string

type HttpHandlerRequests 

type HttpHandlerRequests struct {
	Requests []*HttpHandlerRequest `protobuf:"bytes,1,rep,name=requests,proto3" json:"requests,omitempty"`
	// contains filtered or unexported fields
}

func (*HttpHandlerRequests) Descriptor deprecated 

func (*HttpHandlerRequests) Descriptor() ([]byte, []int)

Deprecated: Use HttpHandlerRequests.ProtoReflect.Descriptor instead.

func (*HttpHandlerRequests) GetRequests 

func (x *HttpHandlerRequests) GetRequests() []*HttpHandlerRequest

func (*HttpHandlerRequests) ProtoMessage 

func (*HttpHandlerRequests) ProtoMessage()

func (*HttpHandlerRequests) ProtoReflect 

func (x *HttpHandlerRequests) ProtoReflect() protoreflect.Message

func (*HttpHandlerRequests) Reset 

func (x *HttpHandlerRequests) Reset()

func (*HttpHandlerRequests) String 

func (x *HttpHandlerRequests) String() string

type HttpHandlerResponse 

type HttpHandlerResponse struct {
	Id      string                      `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Status  int64                       `protobuf:"varint,2,opt,name=status,proto3" json:"status,omitempty"`
	Body    []byte                      `protobuf:"bytes,3,opt,name=body,proto3" json:"body,omitempty"`
	Headers map[string]*HttpHeaderValue `` /* 141-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*HttpHandlerResponse) Descriptor deprecated 

func (*HttpHandlerResponse) Descriptor() ([]byte, []int)

Deprecated: Use HttpHandlerResponse.ProtoReflect.Descriptor instead.

func (*HttpHandlerResponse) GetBody 

func (x *HttpHandlerResponse) GetBody() []byte

func (*HttpHandlerResponse) GetHeaders 

func (x *HttpHandlerResponse) GetHeaders() map[string]*HttpHeaderValue

func (*HttpHandlerResponse) GetId 

func (x *HttpHandlerResponse) GetId() string

func (*HttpHandlerResponse) GetStatus 

func (x *HttpHandlerResponse) GetStatus() int64

func (*HttpHandlerResponse) ProtoMessage 

func (*HttpHandlerResponse) ProtoMessage()

func (*HttpHandlerResponse) ProtoReflect 

func (x *HttpHandlerResponse) ProtoReflect() protoreflect.Message

func (*HttpHandlerResponse) Reset 

func (x *HttpHandlerResponse) Reset()

func (*HttpHandlerResponse) String 

func (x *HttpHandlerResponse) String() string

type HttpHeader 

type HttpHeader struct {
	Header map[string]*HttpHeaderValue `` /* 139-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*HttpHeader) Descriptor deprecated 

func (*HttpHeader) Descriptor() ([]byte, []int)

Deprecated: Use HttpHeader.ProtoReflect.Descriptor instead.

func (*HttpHeader) GetHeader 

func (x *HttpHeader) GetHeader() map[string]*HttpHeaderValue

func (*HttpHeader) ProtoMessage 

func (*HttpHeader) ProtoMessage()

func (*HttpHeader) ProtoReflect 

func (x *HttpHeader) ProtoReflect() protoreflect.Message

func (*HttpHeader) Reset 

func (x *HttpHeader) Reset()

func (*HttpHeader) String 

func (x *HttpHeader) String() string

type HttpHeaderValue 

type HttpHeaderValue struct {
	Values []string `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

func (*HttpHeaderValue) Descriptor deprecated 

func (*HttpHeaderValue) Descriptor() ([]byte, []int)

Deprecated: Use HttpHeaderValue.ProtoReflect.Descriptor instead.

func (*HttpHeaderValue) GetValues 

func (x *HttpHeaderValue) GetValues() []string

func (*HttpHeaderValue) ProtoMessage 

func (*HttpHeaderValue) ProtoMessage()

func (*HttpHeaderValue) ProtoReflect 

func (x *HttpHeaderValue) ProtoReflect() protoreflect.Message

func (*HttpHeaderValue) Reset 

func (x *HttpHeaderValue) Reset()

func (*HttpHeaderValue) String 

func (x *HttpHeaderValue) String() string

type HttpProxyServiceClient 

type HttpProxyServiceClient interface {
	FetchRequest(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*HttpHandlerRequest, error)
	StreamRequest(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (grpc.ServerStreamingClient[HttpHandlerRequest], error)
	FetchRequests(ctx context.Context, in *HttpHandlerFetchRequest, opts ...grpc.CallOption) (*HttpHandlerRequests, error)
	SendResponse(ctx context.Context, in *HttpHandlerResponse, opts ...grpc.CallOption) (*emptypb.Empty, error)
	StreamResponse(ctx context.Context, opts ...grpc.CallOption) (grpc.ClientStreamingClient[HttpHandlerResponse, emptypb.Empty], error)
}

HttpProxyServiceClient is the client API for HttpProxyService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewHttpProxyServiceClient 

func NewHttpProxyServiceClient(cc grpc.ClientConnInterface) HttpProxyServiceClient

type HttpProxyServiceServer 

type HttpProxyServiceServer interface {
	FetchRequest(context.Context, *emptypb.Empty) (*HttpHandlerRequest, error)
	StreamRequest(*emptypb.Empty, grpc.ServerStreamingServer[HttpHandlerRequest]) error
	FetchRequests(context.Context, *HttpHandlerFetchRequest) (*HttpHandlerRequests, error)
	SendResponse(context.Context, *HttpHandlerResponse) (*emptypb.Empty, error)
	StreamResponse(grpc.ClientStreamingServer[HttpHandlerResponse, emptypb.Empty]) error
	// contains filtered or unexported methods
}

HttpProxyServiceServer is the server API for HttpProxyService service. All implementations must embed UnimplementedHttpProxyServiceServer for forward compatibility.

type HttpProxyService_StreamRequestClient 

type HttpProxyService_StreamRequestClient = grpc.ServerStreamingClient[HttpHandlerRequest]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type HttpProxyService_StreamRequestServer 

type HttpProxyService_StreamRequestServer = grpc.ServerStreamingServer[HttpHandlerRequest]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type HttpProxyService_StreamResponseClient 

type HttpProxyService_StreamResponseClient = grpc.ClientStreamingClient[HttpHandlerResponse, emptypb.Empty]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type HttpProxyService_StreamResponseServer 

type HttpProxyService_StreamResponseServer = grpc.ClientStreamingServer[HttpHandlerResponse, emptypb.Empty]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type UnimplementedHttpProxyServiceServer 

type UnimplementedHttpProxyServiceServer struct{}

UnimplementedHttpProxyServiceServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedHttpProxyServiceServer) FetchRequest 

func (UnimplementedHttpProxyServiceServer) FetchRequest(context.Context, *emptypb.Empty) (*HttpHandlerRequest, error)

func (UnimplementedHttpProxyServiceServer) FetchRequests 

func (UnimplementedHttpProxyServiceServer) FetchRequests(context.Context, *HttpHandlerFetchRequest) (*HttpHandlerRequests, error)

func (UnimplementedHttpProxyServiceServer) SendResponse 

func (UnimplementedHttpProxyServiceServer) SendResponse(context.Context, *HttpHandlerResponse) (*emptypb.Empty, error)

func (UnimplementedHttpProxyServiceServer) StreamRequest 

func (UnimplementedHttpProxyServiceServer) StreamRequest(*emptypb.Empty, grpc.ServerStreamingServer[HttpHandlerRequest]) error

func (UnimplementedHttpProxyServiceServer) StreamResponse 

func (UnimplementedHttpProxyServiceServer) StreamResponse(grpc.ClientStreamingServer[HttpHandlerResponse, emptypb.Empty]) error

type UnsafeHttpProxyServiceServer 

type UnsafeHttpProxyServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeHttpProxyServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to HttpProxyServiceServer will result in compilation errors.

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.