package spdy

import "k8s.io/kubernetes/pkg/util/httpstream/spdy"

Index ¶

• Constants
• func NewClientConnection(conn net.Conn) (httpstream.Connection, error)
• func NewResponseUpgrader() httpstream.ResponseUpgrader
• func NewRoundTripper(tlsConfig *tls.Config) httpstream.UpgradeRoundTripper
• func NewServerConnection(conn net.Conn, newStreamHandler httpstream.NewStreamHandler) (httpstream.Connection, error)
• type SpdyRoundTripper
• func (s *SpdyRoundTripper) NewConnection(resp *http.Response) (httpstream.Connection, error)
• func (s *SpdyRoundTripper) RoundTrip(req *http.Request) (*http.Response, error)

Constants ¶

const HeaderSpdy31 = "SPDY/3.1"

Functions ¶

func NewClientConnection ¶

func NewClientConnection(conn net.Conn) (httpstream.Connection, error)

NewClientConnection creates a new SPDY client connection.

func NewResponseUpgrader ¶

func NewResponseUpgrader() httpstream.ResponseUpgrader

NewResponseUpgrader returns a new httpstream.ResponseUpgrader that is capable of upgrading HTTP responses using SPDY/3.1 via the spdystream package.

func NewRoundTripper ¶

func NewRoundTripper(tlsConfig *tls.Config) httpstream.UpgradeRoundTripper

NewSpdyRoundTripper creates a new SpdyRoundTripper that will use the specified tlsConfig.

func NewServerConnection ¶

func NewServerConnection(conn net.Conn, newStreamHandler httpstream.NewStreamHandler) (httpstream.Connection, error)

NewServerConnection creates a new SPDY server connection. newStreamHandler will be invoked when the server receives a newly created stream from the client.

Types ¶

type SpdyRoundTripper ¶

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

SpdyRoundTripper knows how to upgrade an HTTP request to one that supports multiplexed streams. After RoundTrip() is invoked, Conn will be set and usable. SpdyRoundTripper implements the UpgradeRoundTripper interface.

func (*SpdyRoundTripper) NewConnection ¶

func (s *SpdyRoundTripper) NewConnection(resp *http.Response) (httpstream.Connection, error)

NewConnection validates the upgrade response, creating and returning a new httpstream.Connection if there were no errors.

func (*SpdyRoundTripper) RoundTrip ¶

func (s *SpdyRoundTripper) RoundTrip(req *http.Request) (*http.Response, error)

RoundTrip executes the Request and upgrades it. After a successful upgrade, clients may call SpdyRoundTripper.Connection() to retrieve the upgraded connection.

Source Files ¶

connection.go roundtripper.go upgrade.go