api

Documentation

Index

• Constants
• type AppStats
  • func (as *AppStats) DecLiveTcpStreams()
  • func (as *AppStats) DumpStats() *AppStats
  • func (as *AppStats) IncDnsPacketsCount()
  • func (as *AppStats) IncDroppedTcpStreams()
  • func (as *AppStats) IncLiveTcpStreams()
  • func (as *AppStats) IncMatchedPairs()
  • func (as *AppStats) IncPacketsCount() uint64
  • func (as *AppStats) IncReassembledTcpPayloadsCount()
  • func (as *AppStats) IncTcpPacketsCount()
  • func (as *AppStats) SetStartTime(startTime time.Time)
  • func (as *AppStats) UpdateProcessedBytes(size uint64)
• type BaseEntry
• type ConnectionInfo
• type CounterPair
• type Dissector
• type Emitter
• type Emitting
  • func (e *Emitting) Emit(item *OutputChannelItem)
• type Entry
  • func (e *Entry) BuildId()
• type EntryWrapper
• type Extension
• type GenericMessage
• type Node
• type OutputChannelItem
• type Protocol
• type ReadProgress
  • func (p *ReadProgress) Current() (n int)
  • func (p *ReadProgress) Feed(n int)
  • func (p *ReadProgress) Reset()
• type RequestResponseMatcher
• type RequestResponsePair
• type Resolution
• type SectionData
• type TableData
• type TcpID
• type TcpReader
• type TcpReaderDataMsg
• type TcpStream
• type TcpStreamMap

Constants

const (
	TABLE string = "table"
	BODY  string = "body"
)

Types

type AppStats

type AppStats struct {
	StartTime                   time.Time `json:"-"`
	ProcessedBytes              uint64    `json:"processedBytes"`
	PacketsCount                uint64    `json:"packetsCount"`
	TcpPacketsCount             uint64    `json:"tcpPacketsCount"`
	DnsPacketsCount             uint64    `json:"dnsPacketsCount"`
	ReassembledTcpPayloadsCount uint64    `json:"reassembledTcpPayloadsCount"`
	MatchedPairs                uint64    `json:"matchedPairs"`
	DroppedTcpStreams           uint64    `json:"droppedTcpStreams"`
	LiveTcpStreams              uint64    `json:"liveTcpStreams"`
}

func (*AppStats) DecLiveTcpStreams

func (as *AppStats) DecLiveTcpStreams()

func (*AppStats) DumpStats

func (as *AppStats) DumpStats() *AppStats

func (*AppStats) IncDnsPacketsCount

func (as *AppStats) IncDnsPacketsCount()

func (*AppStats) IncDroppedTcpStreams

func (as *AppStats) IncDroppedTcpStreams()

func (*AppStats) IncLiveTcpStreams

func (as *AppStats) IncLiveTcpStreams()

func (*AppStats) IncMatchedPairs

func (as *AppStats) IncMatchedPairs()

func (*AppStats) IncPacketsCount

func (as *AppStats) IncPacketsCount() uint64

func (*AppStats) IncReassembledTcpPayloadsCount

func (as *AppStats) IncReassembledTcpPayloadsCount()

func (*AppStats) IncTcpPacketsCount

func (as *AppStats) IncTcpPacketsCount()

func (*AppStats) SetStartTime

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

func (*AppStats) UpdateProcessedBytes

func (as *AppStats) UpdateProcessedBytes(size uint64)

type BaseEntry

type BaseEntry struct {
	Id           string      `json:"id"`
	Stream       string      `json:"stream"`
	Worker       string      `json:"worker"`
	Protocol     Protocol    `json:"proto,omitempty"`
	Tls          bool        `json:"tls"`
	Summary      string      `json:"summary,omitempty"`
	SummaryQuery string      `json:"summaryQuery,omitempty"`
	Status       int         `json:"status"`
	StatusQuery  string      `json:"statusQuery"`
	Method       string      `json:"method,omitempty"`
	MethodQuery  string      `json:"methodQuery,omitempty"`
	Timestamp    int64       `json:"timestamp,omitempty"`
	Source       *Resolution `json:"src"`
	Destination  *Resolution `json:"dst"`
	Outgoing     bool        `json:"outgoing"`
	RequestSize  int         `json:"requestSize"`
	ResponseSize int         `json:"responseSize"`
	ElapsedTime  int64       `json:"elapsedTime"`
	Passed       bool        `json:"passed"`
	Failed       bool        `json:"failed"`
}

{Worker}/{Id} uniquely identifies an item

type ConnectionInfo

type ConnectionInfo struct {
	ClientIP   string
	ClientPort string
	ServerIP   string
	ServerPort string
	IsOutgoing bool
}

type CounterPair

type CounterPair struct {
	Request  uint
	Response uint
	sync.Mutex
}

type Dissector

type Dissector interface {
	Register(*Extension)
	Dissect(b *bufio.Reader, reader TcpReader) error
	Analyze(item *OutputChannelItem, resolvedSource *Resolution, resolvedDestination *Resolution) *Entry
	Summarize(entry *Entry) *BaseEntry
	Represent(request map[string]interface{}, response map[string]interface{}) (object []byte, err error)
	Macros() map[string]string
	NewResponseRequestMatcher() RequestResponseMatcher
}

type Emitter

type Emitter interface {
	Emit(item *OutputChannelItem)
}

type Emitting

type Emitting struct {
	AppStats      *AppStats
	Stream        TcpStream
	OutputChannel chan *OutputChannelItem
}

func (*Emitting) Emit

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

type Entry

type Entry struct {
	Id           string                 `json:"id"`
	Index        int64                  `json:"index"`
	Stream       string                 `json:"stream"`
	Worker       string                 `json:"worker"`
	Node         *Node                  `json:"node"`
	Protocol     Protocol               `json:"protocol"`
	Tls          bool                   `json:"tls"`
	Source       *Resolution            `json:"src"`
	Destination  *Resolution            `json:"dst"`
	Outgoing     bool                   `json:"outgoing"`
	Timestamp    int64                  `json:"timestamp"`
	StartTime    time.Time              `json:"startTime"`
	Request      map[string]interface{} `json:"request"`
	Response     map[string]interface{} `json:"response"`
	RequestSize  int                    `json:"requestSize"`
	ResponseSize int                    `json:"responseSize"`
	ElapsedTime  int64                  `json:"elapsedTime"`
	Passed       bool                   `json:"passed"`
	Failed       bool                   `json:"failed"`
}

{Worker}/{Stream}-{Index} uniquely identifies an item

func (*Entry) BuildId

func (e *Entry) BuildId()

type EntryWrapper

type EntryWrapper struct {
	Protocol       Protocol   `json:"protocol"`
	Representation string     `json:"representation"`
	Data           *Entry     `json:"data"`
	Base           *BaseEntry `json:"base"`
}

type Extension

type Extension struct {
	Protocol  *Protocol
	Path      string
	Dissector Dissector
}

type GenericMessage

type GenericMessage struct {
	IsRequest   bool        `json:"isRequest"`
	CaptureTime time.Time   `json:"captureTime"`
	CaptureSize int         `json:"captureSize"`
	Payload     interface{} `json:"payload"`
}

type Node

type Node struct {
	IP   string `json:"ip"`
	Name string `json:"name"`
}

type OutputChannelItem

type OutputChannelItem struct {
	Index          int64
	Stream         string
	Protocol       Protocol
	Timestamp      int64
	ConnectionInfo *ConnectionInfo
	Pair           *RequestResponsePair
	Tls            bool
}

{Stream}-{Index} uniquely identifies an item `Protocol` is modified in later stages of data propagation. Therefore, it's not a pointer.

type Protocol

type Protocol struct {
	Name            string   `json:"name"`
	Version         string   `json:"version"`
	Abbreviation    string   `json:"abbr"`
	LongName        string   `json:"longName"`
	Macro           string   `json:"macro"`
	BackgroundColor string   `json:"backgroundColor"`
	ForegroundColor string   `json:"foregroundColor"`
	FontSize        int8     `json:"fontSize"`
	ReferenceLink   string   `json:"referenceLink"`
	Ports           []string `json:"ports"`
	Layer4          string   `json:"layer4"`
	Priority        uint8    `json:"priority"`
}

type ReadProgress

type ReadProgress struct {
	// contains filtered or unexported fields
}

func (*ReadProgress) Current

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

func (*ReadProgress) Feed

func (p *ReadProgress) Feed(n int)

func (*ReadProgress) Reset

func (p *ReadProgress) Reset()

type RequestResponseMatcher

type RequestResponseMatcher interface {
	GetMap() *sync.Map
	SetMaxTry(value int)
}

type RequestResponsePair

type RequestResponsePair struct {
	Request  GenericMessage `json:"request"`
	Response GenericMessage `json:"response"`
}

type Resolution

type Resolution struct {
	IP            string            `json:"ip"`
	Port          string            `json:"port"`
	Name          string            `json:"name"`
	Namespace     string            `json:"namespace"`
	Pod           *corev1.Pod       `json:"pod"`
	EndpointSlice *corev1.Endpoints `json:"endpointSlice"`
	Service       *corev1.Service   `json:"service"`
}

type SectionData

type SectionData struct {
	Type     string `json:"type"`
	Title    string `json:"title"`
	Data     string `json:"data"`
	Encoding string `json:"encoding,omitempty"`
	MimeType string `json:"mimeType,omitempty"`
	Selector string `json:"selector,omitempty"`
}

type TableData

type TableData struct {
	Name     string      `json:"name"`
	Value    interface{} `json:"value"`
	Selector string      `json:"selector"`
}

type TcpID

type TcpID struct {
	SrcIP   string
	DstIP   string
	SrcPort string
	DstPort string
	Ident   string
}

type TcpReader

type TcpReader interface {
	Read(p []byte) (int, error)
	GetReqResMatcher() RequestResponseMatcher
	GetIsClient() bool
	GetReadProgress() *ReadProgress
	GetParent() TcpStream
	GetTcpID() *TcpID
	GetCounterPair() *CounterPair
	GetCaptureTime() time.Time
	GetEmitter() Emitter
	GetIsClosed() bool
}

type TcpReaderDataMsg

type TcpReaderDataMsg interface {
	GetBytes() []byte
	GetTimestamp() time.Time
	GetCaptureInfo() gopacket.CaptureInfo
}

type TcpStream

type TcpStream interface {
	SetProtocol(protocol *Protocol)
	GetPcapId() string
	GetIndex() int64
	ShouldWritePackets() bool
	IsSortCapture() bool
	GetReqResMatchers() []RequestResponseMatcher
	GetIsTargeted() bool
	GetIsClosed() bool
	IncrementItemCount()
	GetTls() bool
}

type TcpStreamMap

type TcpStreamMap interface {
	Range(f func(key, value interface{}) bool)
	Store(key, value interface{})
	Delete(key interface{})
	NextId() int64
	CloseTimedoutTcpStreamChannels()
}