Versions in this module Expand all Collapse all v1 v1.8.4 Feb 22, 2022 v1.8.3 Feb 22, 2022 Changes in this version + func NewLockedWriter(w http.ResponseWriter) http.ResponseWriter + type Client struct + func NewClient(header http.Header, client gresponsewriterproto.WriterClient, ...) *Client + func (c *Client) Flush() + func (c *Client) Header() http.Header + func (c *Client) Hijack() (net.Conn, *bufio.ReadWriter, error) + func (c *Client) Write(payload []byte) (int, error) + func (c *Client) WriteHeader(statusCode int) + type Server struct + func NewServer(writer http.ResponseWriter, broker *plugin.GRPCBroker) *Server + func (s *Server) Flush(ctx context.Context, req *gresponsewriterproto.FlushRequest) (*gresponsewriterproto.FlushResponse, error) + func (s *Server) Hijack(ctx context.Context, req *gresponsewriterproto.HijackRequest) (*gresponsewriterproto.HijackResponse, error) + func (s *Server) Write(ctx context.Context, req *gresponsewriterproto.WriteRequest) (*gresponsewriterproto.WriteResponse, error) + func (s *Server) WriteHeader(ctx context.Context, req *gresponsewriterproto.WriteHeaderRequest) (*gresponsewriterproto.WriteHeaderResponse, error)