stream

Documentation

Index

• Constants
• type DefaultTunnel
  • func NewDefaultTunnel(con *websocket.Conn) *DefaultTunnel
  • func (t *DefaultTunnel) Close() error
  • func (t *DefaultTunnel) NextReader() (messageType int, r io.Reader, err error)
  • func (t *DefaultTunnel) WriteControl(messageType int, data []byte, deadline time.Time) (e error)
  • func (t *DefaultTunnel) WriteMessage(m *Message) (e error)
• type EdgedConnection
• type EdgedLogsConnection
  • func (l *EdgedLogsConnection) CacheTunnelMessage(msg *Message)
  • func (l *EdgedLogsConnection) CreateConnectMessage() (*Message, error)
  • func (l *EdgedLogsConnection) GetMessageID() uint64
  • func (l *EdgedLogsConnection) Serve(tunnel SafeWriteTunneler) error
  • func (l *EdgedLogsConnection) String() string
• type Message
  • func NewMessage(id uint64, messType MessageType, data []byte) *Message
  • func ReadMessageFromTunnel(r io.Reader) (*Message, error)
  • func (m *Message) Bytes() []byte
  • func (m *Message) String() string
  • func (m *Message) WriteTo(tunneler SafeWriteTunneler) error
• type MessageType
  • func (m MessageType) String() string
• type SafeWriteTunneler

Constants

const (
	SessionKeyHostNameOveride = "SessionHostNameOveride"
	SessionKeyInternalIP      = "SessionInternalIP"
)

Types

type DefaultTunnel

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

func NewDefaultTunnel

func NewDefaultTunnel(con *websocket.Conn) *DefaultTunnel

func (*DefaultTunnel) Close

func (t *DefaultTunnel) Close() error

func (*DefaultTunnel) NextReader

func (t *DefaultTunnel) NextReader() (messageType int, r io.Reader, err error)

func (*DefaultTunnel) WriteControl

func (t *DefaultTunnel) WriteControl(messageType int, data []byte, deadline time.Time) (e error)

func (*DefaultTunnel) WriteMessage

func (t *DefaultTunnel) WriteMessage(m *Message) (e error)

type EdgedConnection

type EdgedConnection interface {
	CreateConnectMessage() (*Message, error)
	Serve(tunnel SafeWriteTunneler) error
	CacheTunnelMessage(msg *Message)
	GetMessageID() uint64
	fmt.Stringer
}

EdgedConnection indicate the connection request to the edged

type EdgedLogsConnection

type EdgedLogsConnection struct {
	MessID   uint64        // message id
	Url      url.URL       `json:"url"`
	Header   http.Header   `json:"header"`
	ReadChan chan *Message `json:"-"`
}

func (*EdgedLogsConnection) CacheTunnelMessage

func (l *EdgedLogsConnection) CacheTunnelMessage(msg *Message)

func (*EdgedLogsConnection) CreateConnectMessage

func (l *EdgedLogsConnection) CreateConnectMessage() (*Message, error)

func (*EdgedLogsConnection) GetMessageID

func (l *EdgedLogsConnection) GetMessageID() uint64

func (*EdgedLogsConnection) Serve

func (l *EdgedLogsConnection) Serve(tunnel SafeWriteTunneler) error

func (*EdgedLogsConnection) String

func (l *EdgedLogsConnection) String() string

type Message

type Message struct {
	// ConnectID indicate the apiserver connection id
	ConnectID   uint64
	MessageType MessageType
	Data        []byte
}

func NewMessage

func NewMessage(id uint64, messType MessageType, data []byte) *Message

func ReadMessageFromTunnel

func ReadMessageFromTunnel(r io.Reader) (*Message, error)

func (*Message) Bytes

func (m *Message) Bytes() []byte

func (*Message) String

func (m *Message) String() string

func (*Message) WriteTo

func (m *Message) WriteTo(tunneler SafeWriteTunneler) error

type MessageType

type MessageType uint64

const (
	MessageTypeLogsConnect   MessageType = iota
	MessageTypeExecConnect   MessageType = iota
	MessageTypeMetricConnect MessageType = iota
	MessageTypeData
	MessageTypeRemoveConnect
)

func (MessageType) String

func (m MessageType) String() string

type SafeWriteTunneler

type SafeWriteTunneler interface {
	WriteMessage(message *Message) error
	WriteControl(messageType int, data []byte, deadline time.Time) error
	NextReader() (messageType int, r io.Reader, err error)
	io.Closer
}