MCPcopy
hub / github.com/kubeedge/kubeedge / EdgedConnection

Interface EdgedConnection

pkg/stream/edgedconnection.go:6–14  ·  view source on GitHub ↗

EdgedConnection indicate the connection request to the edged

Source from the content-addressed store, hash-verified

4
5// EdgedConnection indicate the connection request to the edged
6type EdgedConnection interface {
7 CreateConnectMessage() (*Message, error)
8 Serve(tunnel SafeWriteTunneler) error
9 CacheTunnelMessage(msg *Message)
10 GetMessageID() uint64
11 CloseReadChannel()
12 CleanChannel()
13 fmt.Stringer
14}

Callers 11

TestSendConnection_LogFunction · 0.65
TestSendConnectionFunction · 0.65
TestSendConnection_ExecFunction · 0.65
runUDSMasterServerMethod · 0.65
runMTLSMasterServerMethod · 0.65
runAgentServerMethod · 0.65
StartDMIServerFunction · 0.65
StartMethod · 0.65
DeleteLocalConnectionMethod · 0.65
DeleteLocalConnectionMethod · 0.65

Implementers 4

EdgedMetricsConnectionpkg/stream/edgedmetricsconnection.go
EdgedAttachConnectionpkg/stream/edgedattachconnection.go
EdgedLogsConnectionpkg/stream/edgedlogconnection.go
EdgedExecConnectionpkg/stream/edgedexecconnection.go

Calls

no outgoing calls

Tested by

no test coverage detected