api

package

Go to main page

Versions in this module

v0

v0.7.0

Apr 2, 2023

Changes in this version

type BaseEntry

+ Size int

+ type Pod struct

+ Name string

+ Namespace string

+ Node *Node

+ type Resolution struct

+ IP string

+ Name string

+ Pod *Pod

+ Port string

v0.6.3

Feb 5, 2023

Changes in this version

type BaseEntry

+ ElapsedTime int64

+ Failed bool

+ Passed bool

type Entry

+ Failed bool

+ Passed bool

v0.6.2

Feb 5, 2023

v0.6.1

Feb 1, 2023

v0.6.0

Jan 10, 2023

Changes in this version

type AppStats

+ DnsPacketsCount uint64

+ func (as *AppStats) IncDnsPacketsCount()

type Protocol

+ Layer4 string

v0.5.1

Jan 8, 2023

Changes in this version

type TcpStream

+ GetIsTargeted func() bool

v0.5.0

Dec 29, 2022

v0.4.0

Dec 26, 2022

Changes in this version

+ type Node struct

+ IP string

+ Name string

v0.3.0

Dec 26, 2022

Changes in this version

type Protocol

+ Abbreviation string

+ Name string

+ Version string

v0.2.0

Dec 24, 2022

Changes in this version

type BaseEntry

+ Outgoing bool

+ Stream string

+ Worker string

type Entry

+ Index int64

+ Node string

+ Stream string

+ Worker string

+ func (e *Entry) BuildId()

type OutputChannelItem

+ Index int64

+ Stream string

type TcpStream

+ GetIndex func() int64

v0.1.9

Dec 21, 2022

v0.1.8

Dec 21, 2022

v0.1.7

Dec 20, 2022

v0.1.6

Dec 20, 2022

Changes in this version

type BaseEntry

+ Tls bool

type Entry

+ Tls bool

v0.1.5

Dec 9, 2022

Changes in this version

type Emitting

+ Stream TcpStream

type OutputChannelItem

+ Id string

type TcpReaderDataMsg

+ GetCaptureInfo func() gopacket.CaptureInfo

type TcpStream

+ GetIsIdentifyMode func() bool

+ GetPcapId func() string

+ IncrementItemCount func()

+ SetAsEmittable func()

v0.1.4

Dec 2, 2022

v0.1.3

Nov 30, 2022

v0.1.2

Nov 30, 2022

Changes in this version

+ const BODY

+ const TABLE

+ const UnknownNamespace

+ var UnknownIp = net.IP

+ var UnknownPort uint16 = 0

+ type AppStats struct

+ DroppedTcpStreams uint64

+ IgnoredLastAckCount uint64

+ IgnoredPacketsCount uint64

+ LiveTcpStreams uint64

+ MatchedPairs uint64

+ PacketsCount uint64

+ ProcessedBytes uint64

+ ReassembledTcpPayloadsCount uint64

+ StartTime time.Time

+ TcpPacketsCount uint64

+ ThrottledPackets uint64

+ TlsConnectionsCount uint64

+ func (as *AppStats) DecLiveTcpStreams()

+ func (as *AppStats) DumpStats() *AppStats

+ func (as *AppStats) IncDroppedTcpStreams()

+ func (as *AppStats) IncIgnoredLastAckCount()

+ func (as *AppStats) IncIgnoredPacketsCount()

+ func (as *AppStats) IncLiveTcpStreams()

+ func (as *AppStats) IncMatchedPairs()

+ func (as *AppStats) IncPacketsCount() uint64

+ func (as *AppStats) IncReassembledTcpPayloadsCount()

+ func (as *AppStats) IncTcpPacketsCount()

+ func (as *AppStats) IncThrottledPackets()

+ func (as *AppStats) IncTlsConnectionsCount()

+ func (as *AppStats) SetStartTime(startTime time.Time)

+ func (as *AppStats) UpdateProcessedBytes(size uint64)

+ type BaseEntry struct

+ Capture Capture

+ Destination *TCP

+ Id string

+ IsOutgoing bool

+ Latency int64

+ Method string

+ MethodQuery string

+ Protocol Protocol

+ Source *TCP

+ Status int

+ StatusQuery string

+ Summary string

+ SummaryQuery string

+ Timestamp int64

+ type Capture string

+ const Ebpf

+ const Envoy

+ const Linkerd

+ const Pcap

+ const UndefinedCapture

+ type ConnectionInfo struct

+ ClientIP string

+ ClientPort string

+ IsOutgoing bool

+ ServerIP string

+ ServerPort string

+ type CounterPair struct

+ Request uint

+ Response uint

+ type Dissector interface

+ Analyze func(item *OutputChannelItem, resolvedSource string, resolvedDestination string, ...) *Entry

+ Dissect func(b *bufio.Reader, reader TcpReader, options *TrafficFilteringOptions) error

+ GetProtocols func() map[string]*Protocol

+ Macros func() map[string]string

+ NewResponseRequestMatcher func() RequestResponseMatcher

+ Register func(*Extension)

+ Represent func(request map[string]interface{}, response map[string]interface{}) (object []byte, err error)

+ Summarize func(entry *Entry) *BaseEntry

+ type Emitter interface

+ Emit func(item *OutputChannelItem)

+ type Emitting struct

+ AppStats *AppStats

+ OutputChannel chan *OutputChannelItem

+ func (e *Emitting) Emit(item *OutputChannelItem)

+ type Entry struct

+ Capture Capture

+ Destination *TCP

+ ElapsedTime int64

+ Id string

+ Namespace string

+ Outgoing bool

+ Protocol ProtocolSummary

+ Request map[string]interface{}

+ RequestSize int

+ Response map[string]interface{}

+ ResponseSize int

+ Source *TCP

+ StartTime time.Time

+ Timestamp int64

+ type EntryWrapper struct

+ Base *BaseEntry

+ Data *Entry

+ Protocol Protocol

+ Representation string

+ type Extension struct

+ Dissector Dissector

+ Path string

+ Protocol *Protocol

+ type GenericMessage struct

+ CaptureSize int

+ CaptureTime time.Time

+ IsRequest bool

+ Payload interface{}

+ type OutputChannelItem struct

+ Capture Capture

+ ConnectionInfo *ConnectionInfo

+ Namespace string

+ Pair *RequestResponsePair

+ Protocol Protocol

+ Timestamp int64

+ type Protocol struct

+ BackgroundColor string

+ FontSize int8

+ ForegroundColor string

+ LongName string

+ Macro string

+ Ports []string

+ Priority uint8

+ ReferenceLink string

+ type ProtocolSummary struct

+ Abbreviation string

+ Name string

+ Version string

+ func GetProtocolSummary(inputString string) *ProtocolSummary

+ func (protocol *ProtocolSummary) ToString() string

+ type ReadProgress struct

+ func (p *ReadProgress) Current() (n int)

+ func (p *ReadProgress) Feed(n int)

+ func (p *ReadProgress) Reset()

+ type RequestResponseMatcher interface

+ GetMap func() *sync.Map

+ SetMaxTry func(value int)

+ type RequestResponsePair struct

+ Request GenericMessage

+ Response GenericMessage

+ type SectionData struct

+ Data string

+ Encoding string

+ MimeType string

+ Selector string

+ Title string

+ Type string

+ type SerializableRegexp struct

+ func CompileRegexToSerializableRegexp(expr string) (*SerializableRegexp, error)

+ func (r *SerializableRegexp) MarshalText() ([]byte, error)

+ func (r *SerializableRegexp) UnmarshalText(text []byte) error

+ type TCP struct

+ IP string

+ Name string

+ Port string

+ type TableData struct

+ Name string

+ Selector string

+ Value interface{}

+ type TcpID struct

+ DstIP string

+ DstPort string

+ Ident string

+ SrcIP string

+ SrcPort string

+ type TcpReader interface

+ GetCaptureTime func() time.Time

+ GetCounterPair func() *CounterPair

+ GetEmitter func() Emitter

+ GetIsClient func() bool

+ GetIsClosed func() bool

+ GetParent func() TcpStream

+ GetReadProgress func() *ReadProgress

+ GetReqResMatcher func() RequestResponseMatcher

+ GetTcpID func() *TcpID

+ Read func(p []byte) (int, error)

+ type TcpReaderDataMsg interface

+ GetBytes func() []byte

+ GetTimestamp func() time.Time

+ type TcpStream interface

+ GetIsClosed func() bool

+ GetIsTargetted func() bool

+ GetOrigin func() Capture

+ GetReqResMatchers func() []RequestResponseMatcher

+ SetProtocol func(protocol *Protocol)

+ type TcpStreamMap interface

+ CloseTimedoutTcpStreamChannels func()

+ Delete func(key interface{})

+ NextId func() int64

+ Range func(f func(key, value interface{}) bool)

+ Store func(key, value interface{})

+ type TrafficFilteringOptions struct

+ IgnoredUserAgents []string

v0.1.1

Nov 30, 2022

v0.1.0

Nov 30, 2022

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL