Documentation ¶
Overview ¶
The pcapdump binary implements a tcpdump-like command line tool with gopacket using pcap as a backend data collection mechanism.
Index ¶
- Constants
- func GetCloseTimedoutTcpChannelsInterval() time.Duration
- func GetMaxBufferedPagesPerConnection() int
- func GetMaxBufferedPagesTotal() int
- func GetMemoryProfilingEnabled() bool
- func GetTcpChannelTimeoutMs() time.Duration
- func NewConnectionId(c string) connectionId
- func NewTcpAssembler(outputItems chan *api.OutputChannelItem, streamsMap api.TcpStreamMap, ...) (*tcpAssembler, error)
- func NewTcpReader(ident string, tcpId *api.TcpID, parent *tcpStream, isClient bool, ...) *tcpReader
- func NewTcpReaderDataMsg(data []byte, timestamp time.Time) api.TcpReaderDataMsg
- func NewTcpReassemblyStream(ident string, tcp *layers.TCP, fsmOptions reassembly.TCPSimpleFSMOptions, ...) reassembly.Stream
- func NewTcpStream(isTapTarget bool, streamsMap api.TcpStreamMap, capture api.Capture, ...) *tcpStream
- func NewTcpStreamFactory(emitter api.Emitter, streamsMap api.TcpStreamMap, opts *TapOpts, ...) *tcpStreamFactory
- func NewTcpStreamMap() api.TcpStreamMap
- func StartPassiveTapper(opts *TapOpts, outputItems chan *api.OutputChannelItem, ...)
- func UpdateTapTargets(newTapTargets []v1.Pod)
- type AssemblerStats
- type Cleaner
- type CleanerStats
- type TapOpts
Constants ¶
View Source
const ( MemoryProfilingEnabledEnvVarName = "MEMORY_PROFILING_ENABLED" MemoryProfilingDumpPath = "MEMORY_PROFILING_DUMP_PATH" MemoryProfilingTimeIntervalSeconds = "MEMORY_PROFILING_TIME_INTERVAL" MaxBufferedPagesTotalEnvVarName = "MAX_BUFFERED_PAGES_TOTAL" MaxBufferedPagesPerConnectionEnvVarName = "MAX_BUFFERED_PAGES_PER_CONNECTION" MaxBufferedPagesTotalDefaultValue = 5000 MaxBufferedPagesPerConnectionDefaultValue = 5000 TcpStreamChannelTimeoutMsEnvVarName = "TCP_STREAM_CHANNEL_TIMEOUT_MS" TcpStreamChannelTimeoutMsDefaultValue = 10000 CloseTimedoutTcpChannelsIntervalMsEnvVarName = "CLOSE_TIMEDOUT_TCP_STREAM_CHANNELS_INTERVAL_MS" CloseTimedoutTcpChannelsIntervalMsDefaultValue = 1000 CloseTimedoutTcpChannelsIntervalMsMinValue = 10 CloseTimedoutTcpChannelsIntervalMsMaxValue = 10000 )
Variables ¶
This section is empty.
Functions ¶
func GetMaxBufferedPagesPerConnection ¶
func GetMaxBufferedPagesPerConnection() int
func GetMaxBufferedPagesTotal ¶
func GetMaxBufferedPagesTotal() int
func GetMemoryProfilingEnabled ¶
func GetMemoryProfilingEnabled() bool
func GetTcpChannelTimeoutMs ¶
func NewConnectionId ¶
func NewConnectionId(c string) connectionId
func NewTcpAssembler ¶
func NewTcpAssembler(outputItems chan *api.OutputChannelItem, streamsMap api.TcpStreamMap, opts *TapOpts) (*tcpAssembler, error)
func NewTcpReader ¶
func NewTcpReaderDataMsg ¶
func NewTcpReaderDataMsg(data []byte, timestamp time.Time) api.TcpReaderDataMsg
func NewTcpReassemblyStream ¶
func NewTcpReassemblyStream(ident string, tcp *layers.TCP, fsmOptions reassembly.TCPSimpleFSMOptions, stream *tcpStream) reassembly.Stream
func NewTcpStream ¶
func NewTcpStream(isTapTarget bool, streamsMap api.TcpStreamMap, capture api.Capture, connectionId connectionId, callbacks tcpStreamCallbacks) *tcpStream
func NewTcpStreamFactory ¶
func NewTcpStreamFactory(emitter api.Emitter, streamsMap api.TcpStreamMap, opts *TapOpts, streamsCallbacks tcpStreamCallbacks) *tcpStreamFactory
func NewTcpStreamMap ¶
func NewTcpStreamMap() api.TcpStreamMap
func StartPassiveTapper ¶
func StartPassiveTapper(opts *TapOpts, outputItems chan *api.OutputChannelItem, extensionsRef []*api.Extension, options *api.TrafficFilteringOptions)
func UpdateTapTargets ¶
Types ¶
type AssemblerStats ¶
type AssemblerStats struct {
// contains filtered or unexported fields
}
type CleanerStats ¶
type CleanerStats struct {
// contains filtered or unexported fields
}
Source Files ¶
Click to show internal directories.
Click to hide internal directories.