Documentation
¶
Index ¶
- Variables
- func NewControlStream(session *session, str *smux.Stream) api.ControlStream
- func NewPort(session *session, id string, assignedPort int) *port
- func NewPortProvider(portMin, portMax int) (api.PortProvider, error)
- func NewServer(listenAddress string, options ...ServerOption) (api.Server, error)
- func NewSession(srv *server, sess *smux.Session) *session
- type ListenerWrapperFunc
- type ServerOption
- func ServerWithKeepaliveTimeout(timeout time.Duration) ServerOption
- func ServerWithListenerWrapperFunc(listenerWrapperFunc ListenerWrapperFunc) ServerOption
- func ServerWithLogger(logger logr.Logger) ServerOption
- func ServerWithPortProvider(provider api.PortProvider) ServerOption
- func ServerWithSessionTimeout(timeout time.Duration) ServerOption
Constants ¶
This section is empty.
Variables ¶
View Source
var ErrInvalidPortRange = errors.New("invalid port range")
Functions ¶
func NewControlStream ¶
func NewControlStream(session *session, str *smux.Stream) api.ControlStream
func NewPortProvider ¶
func NewPortProvider(portMin, portMax int) (api.PortProvider, error)
func NewSession ¶
Types ¶
type ServerOption ¶
type ServerOption func(*server)
func ServerWithKeepaliveTimeout ¶
func ServerWithKeepaliveTimeout(timeout time.Duration) ServerOption
func ServerWithListenerWrapperFunc ¶
func ServerWithListenerWrapperFunc(listenerWrapperFunc ListenerWrapperFunc) ServerOption
func ServerWithLogger ¶
func ServerWithLogger(logger logr.Logger) ServerOption
func ServerWithPortProvider ¶
func ServerWithPortProvider(provider api.PortProvider) ServerOption
func ServerWithSessionTimeout ¶
func ServerWithSessionTimeout(timeout time.Duration) ServerOption
Source Files
Click to show internal directories.
Click to hide internal directories.