README
¶
This package defines a remote transport for Beam services using http2/spdy and tls.
Uses https://github.com/docker/spdystream
Pointers:
* Low-level protocol framer: http://code.google.com/p/go.net/spdy
* (incomplete) high-level server implementation: https://github.com/shykes/spdy-go
Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NoAuthenticator ¶
func NoAuthenticator(conn net.Conn) (spdystream.AuthHandler, error)
Types ¶
type Authenticator ¶
type Authenticator func(conn net.Conn) (spdystream.AuthHandler, error)
type ListenSession ¶
type ListenSession struct {
// contains filtered or unexported fields
}
func NewListenSession ¶
func NewListenSession(listener net.Listener, auth Authenticator) (*ListenSession, error)
func (*ListenSession) Serve ¶
func (l *ListenSession) Serve()
func (*ListenSession) Shutdown ¶
func (l *ListenSession) Shutdown() error
type Server ¶
type Server struct {
// contains filtered or unexported fields
}
Serve a Beam endpoint over a single HTTP2 connection
type StreamReceiver ¶
type StreamReceiver struct {
// contains filtered or unexported fields
}
type StreamSender ¶
type StreamSender struct {
// contains filtered or unexported fields
}
func (*StreamSender) Close ¶
func (s *StreamSender) Close() error
type StreamSession ¶
type StreamSession struct {
// contains filtered or unexported fields
}
Only allows sending, no parent stream
func NewStreamSession ¶
func NewStreamSession(conn net.Conn) (*StreamSession, error)
func (*StreamSession) Close ¶
func (s *StreamSession) Close() error
Source Files
Click to show internal directories.
Click to hide internal directories.