edgestream

Documentation

Index

• func Register(s *v1alpha2.EdgeStream, hostnameOverride, nodeIP string)
• type TunnelSession
  • func NewTunnelSession(c *websocket.Conn) *TunnelSession
  • func (s *TunnelSession) AddLocalConnection(id uint64, con stream.EdgedConnection)
  • func (s *TunnelSession) Close()
  • func (s *TunnelSession) DeleteLocalConnection(id uint64)
  • func (s *TunnelSession) GetLocalConnection(id uint64) (stream.EdgedConnection, bool)
  • func (s *TunnelSession) Serve() error
  • func (s *TunnelSession) ServeConnection(m *stream.Message)
  • func (s *TunnelSession) WriteToLocalConnection(m *stream.Message)

Functions

func Register

func Register(s *v1alpha2.EdgeStream, hostnameOverride, nodeIP string)

Register register edgestream

Types

type TunnelSession

type TunnelSession struct {
	Tunnel stream.SafeWriteTunneler
	// contains filtered or unexported fields
}

TunnelSession

func NewTunnelSession

func NewTunnelSession(c *websocket.Conn) *TunnelSession

func (*TunnelSession) AddLocalConnection

func (s *TunnelSession) AddLocalConnection(id uint64, con stream.EdgedConnection)

func (*TunnelSession) Close

func (s *TunnelSession) Close()

func (*TunnelSession) DeleteLocalConnection

func (s *TunnelSession) DeleteLocalConnection(id uint64)

func (*TunnelSession) GetLocalConnection

func (s *TunnelSession) GetLocalConnection(id uint64) (stream.EdgedConnection, bool)

func (*TunnelSession) Serve

func (s *TunnelSession) Serve() error

func (*TunnelSession) ServeConnection

func (s *TunnelSession) ServeConnection(m *stream.Message)

func (*TunnelSession) WriteToLocalConnection

func (s *TunnelSession) WriteToLocalConnection(m *stream.Message)