MCPcopy
hub / github.com/kubeedge/kubeedge / CacheTunnelMessage

Method CacheTunnelMessage

pkg/stream/edgedconnection.go:9–9  ·  view source on GitHub ↗
(msg *Message)

Source from the content-addressed store, hash-verified

7 CreateConnectMessage() (*Message, error)
8 Serve(tunnel SafeWriteTunneler) error
9 CacheTunnelMessage(msg *Message)
10 GetMessageID() uint64
11 CloseReadChannel()
12 CleanChannel()

Callers 1

WriteToLocalConnectionMethod · 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