Versions in this module Expand all Collapse all v1 v1.6.1 May 4, 2021 Changes in this version + func Register(controller *v1alpha1.CloudStream) + type APIServerConnection interface + EdgePeerDone func() <-chan struct{} + GetMessageID func() uint64 + SendConnection func() (stream.EdgedConnection, error) + Serve func() error + SetEdgePeerDone func() + SetMessageID func(id uint64) + WriteToAPIServer func(p []byte) (n int, err error) + WriteToTunnel func(m *stream.Message) error + type ContainerExecConnection struct + Conn net.Conn + MessageID uint64 + func (c *ContainerExecConnection) EdgePeerDone() <-chan struct{} + func (c *ContainerExecConnection) GetMessageID() uint64 + func (c *ContainerExecConnection) SendConnection() (stream.EdgedConnection, error) + func (c *ContainerExecConnection) Serve() error + func (c *ContainerExecConnection) SetEdgePeerDone() + func (c *ContainerExecConnection) SetMessageID(id uint64) + func (c *ContainerExecConnection) String() string + func (c *ContainerExecConnection) WriteToAPIServer(p []byte) (n int, err error) + func (c *ContainerExecConnection) WriteToTunnel(m *stream.Message) error + type ContainerLogsConnection struct + MessageID uint64 + func (l *ContainerLogsConnection) EdgePeerDone() <-chan struct{} + func (l *ContainerLogsConnection) GetMessageID() uint64 + func (l *ContainerLogsConnection) SendConnection() (stream.EdgedConnection, error) + func (l *ContainerLogsConnection) Serve() error + func (l *ContainerLogsConnection) SetEdgePeerDone() + func (l *ContainerLogsConnection) SetMessageID(id uint64) + func (l *ContainerLogsConnection) String() string + func (l *ContainerLogsConnection) WriteToAPIServer(p []byte) (n int, err error) + func (l *ContainerLogsConnection) WriteToTunnel(m *stream.Message) error + type ContainerMetricsConnection struct + MessageID uint64 + func (ms *ContainerMetricsConnection) EdgePeerDone() <-chan struct{} + func (ms *ContainerMetricsConnection) GetMessageID() uint64 + func (ms *ContainerMetricsConnection) SendConnection() (stream.EdgedConnection, error) + func (ms *ContainerMetricsConnection) Serve() error + func (ms *ContainerMetricsConnection) SetEdgePeerDone() + func (ms *ContainerMetricsConnection) SetMessageID(id uint64) + func (ms *ContainerMetricsConnection) String() string + func (ms *ContainerMetricsConnection) WriteToAPIServer(p []byte) (n int, err error) + func (ms *ContainerMetricsConnection) WriteToTunnel(m *stream.Message) error + type Session struct + func (s *Session) AddAPIServerConnection(ss *StreamServer, connection APIServerConnection) (APIServerConnection, error) + func (s *Session) Close() + func (s *Session) DeleteAPIServerConnection(con APIServerConnection) + func (s *Session) ProxyTunnelMessageToApiserver(message *stream.Message) error + func (s *Session) Serve() + func (s *Session) String() string + func (s *Session) WriteMessageToTunnel(m *stream.Message) error + type StreamServer struct + func (s *StreamServer) Start() + type TunnelServer struct + func (s *TunnelServer) Start()
Go to main page