Versions in this module Expand all Collapse all v0 v0.1.1 May 20, 2016 v0.1.0 May 12, 2016 Changes in this version + const PackageName + type FilterFun func(MsgItem) []MsgItem + type HTTP2Client struct + func NewHTTP2Client(connectionConnectTimeout time.Duration, connectionExpiry time.Duration) (*HTTP2Client, error) + func (client *HTTP2Client) KeepAlive(addr string) + func (client *HTTP2Client) NewStream(addr string) (*HTTP2Stream, error) + type HTTP2Server struct + func NewHTTP2Server() *HTTP2Server + func (server *HTTP2Server) Serve(protocol string, listenAddr string, streamHandler StreamHandler) (net.Listener, chan struct{}, error) + func (server *HTTP2Server) Stop() + type HTTP2Stream struct + func (stream *HTTP2Stream) Closed() <-chan struct{} + func (stream *HTTP2Stream) GetHeaders() map[string][]string + func (stream *HTTP2Stream) GetReceiveBuffer() *leverutil.UnboundedChannel + func (stream *HTTP2Stream) ProxyTo(destStream *HTTP2Stream, filterTo FilterFun, filterFrom FilterFun) + func (stream *HTTP2Stream) Write(item MsgItem) + type MsgBytes struct + AfterRead func() + Data []byte + EndStream bool + type MsgEOF struct + type MsgError struct + Err error + type MsgHeaders struct + EndStream bool + Headers map[string][]string + type MsgItem interface + type StreamHandler func(stream *HTTP2Stream)
Go to main page