grpctool

type AggregateServer []GRPCServer

type CheckHeader func(statusCode int32, header http.Header) error

type ClientLimiter interface {
	// Wait blocks until limiter permits an event to happen.
	// It returns an error if the Context is
	// canceled, or the expected wait time exceeds the Context's Deadline.
	Wait(context.Context) error
}

type DoResponse struct {
	// Resp is the server's response to a request.
	Resp *http.Response
	// UpgradeConn is the underlying network connection to the server.
	// May be nil if request was not an Upgrade request or if server decided not to switch protocols
	// (non-101 response status code).
	UpgradeConn net.Conn
	// ConnReader is a buffered reader, wrapping UpgradeConn. Is set when UpgradeConn is set.
	// Must be used for reading as it may contain buffered bytes that are no longer available directly via UpgradeConn.
	ConnReader *bufio.Reader
}

type ErrResp struct {
	StatusCode int32
	Msg        string
	// Err can be nil.
	Err error
}

type GRPCServer interface {
	grpc.ServiceRegistrar
	reflection.ServiceInfoProvider
}

type HTTPDo func(ctx context.Context, header *HttpRequest_Header, body io.Reader) (DoResponse, error)

type HTTPRequestClient = grpc.BidiStreamingClient[HttpRequest, HttpResponse]

type HTTPRoundTripperToOutboundGRPC struct {
	HTTP2GRPC   HTTPToOutboundGRPC
	NewClient   func(context.Context) (HTTPRequestClient, error)
	HeaderExtra proto.Message
}

type HTTPToOutboundGRPC struct {
	Log         *slog.Logger
	ErrRep      errz.ErrReporter
	CheckHeader CheckHeader
}

type HandleIOErrorFunc func(msg string, err error) error

type HttpRequest struct {

	// Types that are valid to be assigned to Message:
	//
	//	*HttpRequest_Header_
	//	*HttpRequest_Data_
	//	*HttpRequest_Trailer_
	//	*HttpRequest_UpgradeData_
	Message isHttpRequest_Message `protobuf_oneof:"message"`
	// contains filtered or unexported fields
}

type HttpRequest_Data struct {
	Data []byte `protobuf:"bytes,1,opt,name=data" json:"data,omitempty"`
	// contains filtered or unexported fields
}

type HttpRequest_Data_ struct {
	Data *HttpRequest_Data `protobuf:"bytes,2,opt,name=data,oneof"`
}

type HttpRequest_Header struct {
	Request       *prototool.HttpRequest `protobuf:"bytes,1,opt,name=request" json:"request,omitempty"`
	Extra         *anypb.Any             `protobuf:"bytes,2,opt,name=extra" json:"extra,omitempty"`
	ContentLength *int64                 `protobuf:"varint,3,opt,name=content_length,json=contentLength" json:"content_length,omitempty"`
	// contains filtered or unexported fields
}

type HttpRequest_Header_ struct {
	Header *HttpRequest_Header `protobuf:"bytes,1,opt,name=header,oneof"`
}

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

type HttpRequest_Trailer_ struct {
	Trailer *HttpRequest_Trailer `protobuf:"bytes,3,opt,name=trailer,oneof"`
}

type HttpRequest_UpgradeData struct {
	Data []byte `protobuf:"bytes,1,opt,name=data" json:"data,omitempty"`
	// contains filtered or unexported fields
}

type HttpRequest_UpgradeData_ struct {
	UpgradeData *HttpRequest_UpgradeData `protobuf:"bytes,4,opt,name=upgradeData,oneof"`
}

type HttpResponse struct {

	// Types that are valid to be assigned to Message:
	//
	//	*HttpResponse_Header_
	//	*HttpResponse_Data_
	//	*HttpResponse_Trailer_
	//	*HttpResponse_UpgradeData_
	Message isHttpResponse_Message `protobuf_oneof:"message"`
	// contains filtered or unexported fields
}

type HttpResponse_Data struct {
	Data []byte `protobuf:"bytes,1,opt,name=data" json:"data,omitempty"`
	// contains filtered or unexported fields
}

type HttpResponse_Data_ struct {
	Data *HttpResponse_Data `protobuf:"bytes,2,opt,name=data,oneof"`
}

type HttpResponse_Header struct {
	Response *prototool.HttpResponse `protobuf:"bytes,1,opt,name=response" json:"response,omitempty"`
	// contains filtered or unexported fields
}

type HttpResponse_Header_ struct {
	Header *HttpResponse_Header `protobuf:"bytes,1,opt,name=header,oneof"`
}

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

type HttpResponse_Trailer_ struct {
	Trailer *HttpResponse_Trailer `protobuf:"bytes,3,opt,name=trailer,oneof"`
}

type HttpResponse_UpgradeData struct {
	Data []byte `protobuf:"bytes,1,opt,name=data" json:"data,omitempty"`
	// contains filtered or unexported fields
}

type HttpResponse_UpgradeData_ struct {
	UpgradeData *HttpResponse_UpgradeData `protobuf:"bytes,4,opt,name=upgradeData,oneof"`
}

type InboundGRPCToOutboundHTTP struct {
	Log           *slog.Logger
	ErrRep        errz.ErrReporter
	HandleIOError HandleIOErrorFunc
	HTTPDo        HTTPDo
}

type InboundGRPCToOutboundHTTPStream = grpc.ServerStreamingServer[HttpResponse]

type InboundHTTPToOutboundGRPC struct {
	HTTP2GRPC          HTTPToOutboundGRPC
	NewClient          func(context.Context) (HTTPRequestClient, error)
	WriteErrorResponse WriteErrorResponse
	MergeHeaders       MergeHeadersFunc
	TrackResponse      TrackResponseFunc
}

type InboundStreamToOutboundStream struct {
	PipeInboundToOutbound func() error
	PipeOutboundToInbound func() error
}

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

type JWTCredentials struct {
	SigningMethod jwt.SigningMethod
	// Type depends on the SigningMethod:
	// - []byte for HMAC.
	// - *ecdsa.PrivateKey for ECDSA.
	// - *rsa.PrivateKey for RSA.
	// - crypto.Signer for EdDSA.
	SigningKey any
	Audience   jwt.ClaimStrings
	Issuer     string
	Insecure   bool
}

type Logger struct {
	Handler slog.Handler
}

type MergeHeadersFunc func(outboundResponse, inboundResponse http.Header)

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

type ResponseWriter interface {
	io.Writer
	WriteHeader(statusCode int32, status string, header http.Header) (successfulUpgrade bool, hasContentTypeHeader bool, err error)
}

type ServerLimiter interface {
	// Allow should return true and consume one "limitable event" if the limit has not been exceeded. Otherwise, it returns false and does not count towards the limit
	Allow(ctx context.Context) bool
}

type TrackResponseFunc func(statusCode int)

type WriteErrorResponse func(*ErrResp)