stream

package
v1.20.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jan 21, 2025 License: Apache-2.0 Imports: 15 Imported by: 6

Documentation

Index

Constants

View Source 
const (
	SessionKeyHostNameOverride = "SessionHostNameOverride"
	SessionKeyInternalIP       = "SessionInternalIP"
)

Variables

This section is empty.

Functions

This section is empty.

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 EdgedAttachConnection added in v1.14.0 

type EdgedAttachConnection struct {
	ReadChan chan *Message `json:"-"`
	Stop     chan struct{} `json:"-"`
	MessID   uint64
	URL      url.URL     `json:"url"`
	Header   http.Header `json:"header"`
	Method   string      `json:"method"`
}

func (*EdgedAttachConnection) CacheTunnelMessage added in v1.14.0 

func (ah *EdgedAttachConnection) CacheTunnelMessage(msg *Message)

func (*EdgedAttachConnection) CleanChannel added in v1.14.0 

func (ah *EdgedAttachConnection) CleanChannel()

func (*EdgedAttachConnection) CloseReadChannel added in v1.14.0 

func (ah *EdgedAttachConnection) CloseReadChannel()

func (*EdgedAttachConnection) CreateConnectMessage added in v1.14.0 

func (ah *EdgedAttachConnection) CreateConnectMessage() (*Message, error)

func (*EdgedAttachConnection) GetMessageID added in v1.14.0 

func (ah *EdgedAttachConnection) GetMessageID() uint64

func (*EdgedAttachConnection) Serve added in v1.14.0 

func (ah *EdgedAttachConnection) Serve(tunnel SafeWriteTunneler) error

func (*EdgedAttachConnection) String added in v1.14.0 

func (ah *EdgedAttachConnection) String() string

type EdgedConnection 

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

EdgedConnection indicate the connection request to the edged

type EdgedExecConnection added in v1.5.0 

type EdgedExecConnection struct {
	ReadChan chan *Message `json:"-"`
	Stop     chan struct{} `json:"-"`
	MessID   uint64
	URL      url.URL     `json:"url"`
	Header   http.Header `json:"header"`
	Method   string      `json:"method"`
}

func (*EdgedExecConnection) CacheTunnelMessage added in v1.5.0 

func (e *EdgedExecConnection) CacheTunnelMessage(msg *Message)

func (*EdgedExecConnection) CleanChannel added in v1.13.0 

func (e *EdgedExecConnection) CleanChannel()

func (*EdgedExecConnection) CloseReadChannel added in v1.13.0 

func (e *EdgedExecConnection) CloseReadChannel()

func (*EdgedExecConnection) CreateConnectMessage added in v1.5.0 

func (e *EdgedExecConnection) CreateConnectMessage() (*Message, error)

func (*EdgedExecConnection) GetMessageID added in v1.5.0 

func (e *EdgedExecConnection) GetMessageID() uint64

func (*EdgedExecConnection) Serve added in v1.5.0 

func (e *EdgedExecConnection) Serve(tunnel SafeWriteTunneler) error

func (*EdgedExecConnection) String added in v1.5.0 

func (e *EdgedExecConnection) String() string

type EdgedLogsConnection 

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

func (*EdgedLogsConnection) CacheTunnelMessage 

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

func (*EdgedLogsConnection) CleanChannel added in v1.13.0 

func (l *EdgedLogsConnection) CleanChannel()

func (*EdgedLogsConnection) CloseReadChannel added in v1.13.0 

func (l *EdgedLogsConnection) CloseReadChannel()

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 EdgedMetricsConnection added in v1.4.0 

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

func (*EdgedMetricsConnection) CacheTunnelMessage added in v1.4.0 

func (ms *EdgedMetricsConnection) CacheTunnelMessage(msg *Message)

func (*EdgedMetricsConnection) CleanChannel added in v1.13.0 

func (ms *EdgedMetricsConnection) CleanChannel()

func (*EdgedMetricsConnection) CloseReadChannel added in v1.13.0 

func (ms *EdgedMetricsConnection) CloseReadChannel()

func (*EdgedMetricsConnection) CreateConnectMessage added in v1.4.0 

func (ms *EdgedMetricsConnection) CreateConnectMessage() (*Message, error)

func (*EdgedMetricsConnection) GetMessageID added in v1.4.0 

func (ms *EdgedMetricsConnection) GetMessageID() uint64

func (*EdgedMetricsConnection) Serve added in v1.4.0 

func (ms *EdgedMetricsConnection) Serve(tunnel SafeWriteTunneler) error

func (*EdgedMetricsConnection) String added in v1.4.0 

func (ms *EdgedMetricsConnection) 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

type MessageType 

type MessageType uint64
const (
	MessageTypeLogsConnect MessageType = iota
	MessageTypeExecConnect
	MessageTypeMetricConnect
	MessageTypeData
	MessageTypeRemoveConnect
	MessageTypeCloseConnect
	MessageTypeAttachConnect
)

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
}

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.