Documentation
¶
Index ¶
- func BuildEnvoyGRPCHeaders(header http.Header, rawValue bool, endofstream bool) *pb.HttpHeaders
- type EppClient
- func (c *EppClient) Close()
- func (c *EppClient) CloseRespBody()
- func (c *EppClient) ProcRespBody(d []byte)
- func (c *EppClient) ProcRespHeader(header http.Header, endofstream bool)
- func (c *EppClient) Recv() (*extprocv3.ProcessingResponse, error)
- func (c *EppClient) Send(req *extprocv3.ProcessingRequest) error
- type EppGrpcClient
- type EppResponseBodyFilter
- type SimpleGrpcClient
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func BuildEnvoyGRPCHeaders ¶
Types ¶
type EppClient ¶
type EppClient struct {
// contains filtered or unexported fields
}
func NewEppClient ¶
func NewEppClient(conn *grpc.ClientConn) (*EppClient, error)
func (*EppClient) CloseRespBody ¶
func (c *EppClient) CloseRespBody()
func (*EppClient) ProcRespBody ¶
func (*EppClient) ProcRespHeader ¶
type EppGrpcClient ¶
type EppGrpcClient interface {
Conn() *grpc.ClientConn
Close()
}
func NewSimpleGrpcClient ¶
func NewSimpleGrpcClient(addr string, timeout time.Duration) (EppGrpcClient, error)
type EppResponseBodyFilter ¶
type EppResponseBodyFilter struct {
// contains filtered or unexported fields
}
func NewEppResponseBodyFilter ¶
func NewEppResponseBodyFilter(source io.ReadCloser, c *EppClient) *EppResponseBodyFilter
func (*EppResponseBodyFilter) Close ¶
func (f *EppResponseBodyFilter) Close() error
type SimpleGrpcClient ¶
type SimpleGrpcClient struct {
// contains filtered or unexported fields
}
func (*SimpleGrpcClient) Close ¶
func (c *SimpleGrpcClient) Close()
func (*SimpleGrpcClient) Conn ¶
func (c *SimpleGrpcClient) Conn() *grpc.ClientConn
Source Files
Click to show internal directories.
Click to hide internal directories.