Versions in this module Expand all Collapse all v0 v0.1.0 Apr 19, 2020 Changes in this version + type Client struct + func NewClient(client gresponsewriterproto.WriterClient, broker *plugin.GRPCBroker) *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)
Go to main page