flow

package

Go to main page

Versions in this module

v0

v0.28.0

Aug 17, 2021

v0.27.0

Dec 7, 2020

Changes in this version

+ func UnixMilli(t time.Time) int64

v0.26.0

Nov 15, 2019

Changes in this version

+ const EBPFExtFlowType

+ const OperationExtFlowType

+ var ErrIntOverflowFlow = fmt.Errorf("proto: integer overflow")

+ var ErrInvalidLengthFlow = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrUnexpectedEndOfGroupFlow = fmt.Errorf("proto: unexpected end of group")

+ var FlowFinishType_name = map[int32]string

+ var FlowFinishType_value = map[string]int32

+ var ICMPType_name = map[int32]string

+ var ICMPType_value = map[string]int32

+ type ExtFlow struct

+ Obj interface{}

+ Type ExtFlowType

+ type ExtFlowType int

type Flow

+ Application string

+ CaptureID string

+ DHCPv4 *layers.DHCPv4

+ DNS *layers.DNS

+ FinishType FlowFinishType

+ ICMP *ICMPLayer

+ IPMetric *IPMetric

+ L3TrackingID string

+ Last int64

+ LastRawPackets []*RawPacket

+ NodeTID string

+ RawPacketsCaptured int64

+ Start int64

+ TCPMetric *TCPMetric

+ VRRPv2 *layers.VRRPv2

+ XXX_state flowState

+ func NewFlow() *Flow

+ func NewFlowFromGoPacket(p gopacket.Packet, parentUUID string, uuids *UUIDs, opts *Opts) *Flow

+ func (f *Flow) GetField(field string) (interface{}, error)

+ func (f *Flow) GetFieldBool(field string) (bool, error)

+ func (f *Flow) GetFieldKeys() []string

+ func (f *Flow) LinkType() (layers.LinkType, error)

+ func (f *Flow) MatchBool(key string, predicate common.BoolPredicate) bool

+ func (f *Flow) MatchInt64(key string, predicate common.Int64Predicate) bool

+ func (f *Flow) MatchString(key string, predicate common.StringPredicate) bool

+ func (f *Flow) SetUUIDs(key uint64, opts Opts) (uint64, uint64)

+ func (m *Flow) GetApplication() string

+ func (m *Flow) GetCaptureID() string

+ func (m *Flow) GetDHCPv4() *layers.DHCPv4

+ func (m *Flow) GetDNS() *layers.DNS

+ func (m *Flow) GetFinishType() FlowFinishType

+ func (m *Flow) GetICMP() *ICMPLayer

+ func (m *Flow) GetIPMetric() *IPMetric

+ func (m *Flow) GetL3TrackingID() string

+ func (m *Flow) GetLast() int64

+ func (m *Flow) GetLastRawPackets() []*RawPacket

+ func (m *Flow) GetLayersPath() string

+ func (m *Flow) GetNodeTID() string

+ func (m *Flow) GetParentUUID() string

+ func (m *Flow) GetRawPacketsCaptured() int64

+ func (m *Flow) GetStart() int64

+ func (m *Flow) GetTCPMetric() *TCPMetric

+ func (m *Flow) GetTrackingID() string

+ func (m *Flow) GetUUID() string

+ func (m *Flow) GetVRRPv2() *layers.VRRPv2

+ func (m *Flow) Marshal() (dAtA []byte, err error)

+ func (m *Flow) MarshalTo(dAtA []byte) (int, error)

+ func (m *Flow) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Flow) ProtoSize() (n int)

+ func (m *Flow) Unmarshal(dAtA []byte) error

+ func (m *Flow) XXX_DiscardUnknown()

+ func (m *Flow) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Flow) XXX_Merge(src proto.Message)

+ func (m *Flow) XXX_Size() int

+ func (m *Flow) XXX_Unmarshal(b []byte) error

+ func (v *Flow) UnmarshalEasyJSON(l *jlexer.Lexer)

+ func (v *Flow) UnmarshalJSON(data []byte) error

+ func (v Flow) MarshalEasyJSON(w *jwriter.Writer)

+ func (v Flow) MarshalJSON() ([]byte, error)

+ type FlowFinishType int32

+ const FlowFinishType_NOT_FINISHED

+ const FlowFinishType_TCP_FIN

+ const FlowFinishType_TCP_RST

+ const FlowFinishType_TIMEOUT

+ func (FlowFinishType) EnumDescriptor() ([]byte, []int)

+ func (x FlowFinishType) String() string

type FlowLayer

+ ID int64

+ func (m *FlowLayer) GetA() string

+ func (m *FlowLayer) GetB() string

+ func (m *FlowLayer) GetID() int64

+ func (m *FlowLayer) GetProtocol() FlowProtocol

+ func (m *FlowLayer) Marshal() (dAtA []byte, err error)

+ func (m *FlowLayer) MarshalTo(dAtA []byte) (int, error)

+ func (m *FlowLayer) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *FlowLayer) ProtoSize() (n int)

+ func (m *FlowLayer) Unmarshal(dAtA []byte) error

+ func (m *FlowLayer) XXX_DiscardUnknown()

+ func (m *FlowLayer) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *FlowLayer) XXX_Merge(src proto.Message)

+ func (m *FlowLayer) XXX_Size() int

+ func (m *FlowLayer) XXX_Unmarshal(b []byte) error

+ func (obj *FlowLayer) GetFieldBool(key string) (bool, error)

+ func (obj *FlowLayer) GetFieldInt64(key string) (int64, error)

+ func (obj *FlowLayer) GetFieldKeys() []string

+ func (obj *FlowLayer) GetFieldString(key string) (string, error)

+ func (obj *FlowLayer) MatchBool(key string, predicate common.BoolPredicate) bool

+ func (obj *FlowLayer) MatchInt64(key string, predicate common.Int64Predicate) bool

+ func (obj *FlowLayer) MatchString(key string, predicate common.StringPredicate) bool

+ func (v *FlowLayer) UnmarshalEasyJSON(l *jlexer.Lexer)

+ func (v FlowLayer) MarshalEasyJSON(w *jwriter.Writer)

type FlowMetric

+ RTT int64

+ func (fm *FlowMetric) Add(m common.Metric) common.Metric

+ func (fm *FlowMetric) IsZero() bool

+ func (fm *FlowMetric) SetLast(last int64)

+ func (fm *FlowMetric) SetStart(start int64)

+ func (fm *FlowMetric) Split(cut int64) (common.Metric, common.Metric)

+ func (fm *FlowMetric) Sub(m common.Metric) common.Metric

+ func (m *FlowMetric) GetABBytes() int64

+ func (m *FlowMetric) GetABPackets() int64

+ func (m *FlowMetric) GetBABytes() int64

+ func (m *FlowMetric) GetBAPackets() int64

+ func (m *FlowMetric) GetLast() int64

+ func (m *FlowMetric) GetRTT() int64

+ func (m *FlowMetric) GetStart() int64

+ func (m *FlowMetric) Marshal() (dAtA []byte, err error)

+ func (m *FlowMetric) MarshalTo(dAtA []byte) (int, error)

+ func (m *FlowMetric) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *FlowMetric) ProtoSize() (n int)

+ func (m *FlowMetric) Unmarshal(dAtA []byte) error

+ func (m *FlowMetric) XXX_DiscardUnknown()

+ func (m *FlowMetric) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *FlowMetric) XXX_Merge(src proto.Message)

+ func (m *FlowMetric) XXX_Size() int

+ func (m *FlowMetric) XXX_Unmarshal(b []byte) error

+ func (obj *FlowMetric) GetFieldBool(key string) (bool, error)

+ func (obj *FlowMetric) GetFieldInt64(key string) (int64, error)

+ func (obj *FlowMetric) GetFieldKeys() []string

+ func (obj *FlowMetric) GetFieldString(key string) (string, error)

+ func (obj *FlowMetric) MatchBool(key string, predicate common.BoolPredicate) bool

+ func (obj *FlowMetric) MatchInt64(key string, predicate common.Int64Predicate) bool

+ func (obj *FlowMetric) MatchString(key string, predicate common.StringPredicate) bool

+ func (v *FlowMetric) UnmarshalEasyJSON(l *jlexer.Lexer)

+ func (v *FlowMetric) UnmarshalJSON(data []byte) error

+ func (v FlowMetric) MarshalEasyJSON(w *jwriter.Writer)

+ func (v FlowMetric) MarshalJSON() ([]byte, error)

type FlowProtocol

+ const FlowProtocol_ICMPV4

+ const FlowProtocol_ICMPV6

+ const FlowProtocol_SCTP

+ const FlowProtocol_TCP

+ const FlowProtocol_UDP

+ func (p *FlowProtocol) UnmarshalJSON(b []byte) error

+ func (p FlowProtocol) MarshalJSON() ([]byte, error)

type FlowSearchReply

+ func (m *FlowSearchReply) Marshal() (dAtA []byte, err error)

+ func (m *FlowSearchReply) MarshalTo(dAtA []byte) (int, error)

+ func (m *FlowSearchReply) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *FlowSearchReply) ProtoSize() (n int)

+ func (m *FlowSearchReply) Unmarshal(dAtA []byte) error

+ func (m *FlowSearchReply) XXX_DiscardUnknown()

+ func (m *FlowSearchReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *FlowSearchReply) XXX_Merge(src proto.Message)

+ func (m *FlowSearchReply) XXX_Size() int

+ func (m *FlowSearchReply) XXX_Unmarshal(b []byte) error

+ func (v *FlowSearchReply) UnmarshalEasyJSON(l *jlexer.Lexer)

+ func (v *FlowSearchReply) UnmarshalJSON(data []byte) error

+ func (v FlowSearchReply) MarshalEasyJSON(w *jwriter.Writer)

+ func (v FlowSearchReply) MarshalJSON() ([]byte, error)

type FlowSet

+ func (m *FlowSet) GetEnd() int64

+ func (m *FlowSet) GetStart() int64

+ func (m *FlowSet) Marshal() (dAtA []byte, err error)

+ func (m *FlowSet) MarshalTo(dAtA []byte) (int, error)

+ func (m *FlowSet) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *FlowSet) ProtoSize() (n int)

+ func (m *FlowSet) Unmarshal(dAtA []byte) error

+ func (m *FlowSet) XXX_DiscardUnknown()

+ func (m *FlowSet) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *FlowSet) XXX_Merge(src proto.Message)

+ func (m *FlowSet) XXX_Size() int

+ func (m *FlowSet) XXX_Unmarshal(b []byte) error

+ func (v *FlowSet) UnmarshalEasyJSON(l *jlexer.Lexer)

+ func (v *FlowSet) UnmarshalJSON(data []byte) error

+ func (v FlowSet) MarshalEasyJSON(w *jwriter.Writer)

+ func (v FlowSet) MarshalJSON() ([]byte, error)

+ type ICMPLayer struct

+ Code uint32

+ ID uint32

+ Type ICMPType

+ func (*ICMPLayer) Descriptor() ([]byte, []int)

+ func (*ICMPLayer) ProtoMessage()

+ func (fl *ICMPLayer) Hash(hasher hash.Hash)

+ func (m *ICMPLayer) GetCode() uint32

+ func (m *ICMPLayer) GetID() uint32

+ func (m *ICMPLayer) GetType() ICMPType

+ func (m *ICMPLayer) Marshal() (dAtA []byte, err error)

+ func (m *ICMPLayer) MarshalTo(dAtA []byte) (int, error)

+ func (m *ICMPLayer) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ICMPLayer) ProtoSize() (n int)

+ func (m *ICMPLayer) Reset()

+ func (m *ICMPLayer) String() string

+ func (m *ICMPLayer) Unmarshal(dAtA []byte) error

+ func (m *ICMPLayer) XXX_DiscardUnknown()

+ func (m *ICMPLayer) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ICMPLayer) XXX_Merge(src proto.Message)

+ func (m *ICMPLayer) XXX_Size() int

+ func (m *ICMPLayer) XXX_Unmarshal(b []byte) error

+ func (obj *ICMPLayer) GetField(key string) (interface{}, error)

+ func (obj *ICMPLayer) GetFieldBool(key string) (bool, error)

+ func (obj *ICMPLayer) GetFieldInt64(key string) (int64, error)

+ func (obj *ICMPLayer) GetFieldKeys() []string

+ func (obj *ICMPLayer) GetFieldString(key string) (string, error)

+ func (obj *ICMPLayer) MatchBool(key string, predicate common.BoolPredicate) bool

+ func (obj *ICMPLayer) MatchInt64(key string, predicate common.Int64Predicate) bool

+ func (obj *ICMPLayer) MatchString(key string, predicate common.StringPredicate) bool

+ func (v *ICMPLayer) UnmarshalEasyJSON(l *jlexer.Lexer)

+ func (v *ICMPLayer) UnmarshalJSON(data []byte) error

+ func (v ICMPLayer) MarshalEasyJSON(w *jwriter.Writer)

+ func (v ICMPLayer) MarshalJSON() ([]byte, error)

+ type ICMPType int32

+ const ICMPType_ADDRESS_MASK

+ const ICMPType_DESTINATION_UNREACHABLE

+ const ICMPType_ECHO

+ const ICMPType_INFO

+ const ICMPType_NEIGHBOR

+ const ICMPType_PACKET_TOO_BIG

+ const ICMPType_PARAMETER_PROBLEM

+ const ICMPType_REDIRECT

+ const ICMPType_ROUTER

+ const ICMPType_SOURCE_QUENCH

+ const ICMPType_TIMESTAMP

+ const ICMPType_TIME_EXCEEDED

+ const ICMPType_UNKNOWN

+ func ICMPv4TypeToFlowICMPType(kind uint8) ICMPType

+ func ICMPv6TypeToFlowICMPType(kind uint8) ICMPType

+ func (ICMPType) EnumDescriptor() ([]byte, []int)

+ func (i *ICMPType) UnmarshalJSON(b []byte) error

+ func (i ICMPType) MarshalJSON() ([]byte, error)

+ func (x ICMPType) String() string

+ type IPMetric struct

+ FragmentErrors int64

+ Fragments int64

+ func ProcessGoPacket(packet gopacket.Packet, bpf *BPF, defragger *IPDefragger) (gopacket.Packet, *IPMetric)

+ func (*IPMetric) Descriptor() ([]byte, []int)

+ func (*IPMetric) ProtoMessage()

+ func (m *IPMetric) GetFragmentErrors() int64

+ func (m *IPMetric) GetFragments() int64

+ func (m *IPMetric) Marshal() (dAtA []byte, err error)

+ func (m *IPMetric) MarshalTo(dAtA []byte) (int, error)

+ func (m *IPMetric) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *IPMetric) ProtoSize() (n int)

+ func (m *IPMetric) Reset()

+ func (m *IPMetric) String() string

+ func (m *IPMetric) Unmarshal(dAtA []byte) error

+ func (m *IPMetric) XXX_DiscardUnknown()

+ func (m *IPMetric) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *IPMetric) XXX_Merge(src proto.Message)

+ func (m *IPMetric) XXX_Size() int

+ func (m *IPMetric) XXX_Unmarshal(b []byte) error

+ func (obj *IPMetric) GetField(key string) (interface{}, error)

+ func (obj *IPMetric) GetFieldBool(key string) (bool, error)

+ func (obj *IPMetric) GetFieldInt64(key string) (int64, error)

+ func (obj *IPMetric) GetFieldKeys() []string

+ func (obj *IPMetric) GetFieldString(key string) (string, error)

+ func (obj *IPMetric) MatchBool(key string, predicate common.BoolPredicate) bool

+ func (obj *IPMetric) MatchInt64(key string, predicate common.Int64Predicate) bool

+ func (obj *IPMetric) MatchString(key string, predicate common.StringPredicate) bool

+ func (v *IPMetric) UnmarshalEasyJSON(l *jlexer.Lexer)

+ func (v *IPMetric) UnmarshalJSON(data []byte) error

+ func (v IPMetric) MarshalEasyJSON(w *jwriter.Writer)

+ func (v IPMetric) MarshalJSON() ([]byte, error)

type LayerKeyMode

+ const L3PreferredKeyMode

+ type Message struct

+ Flows []*Flow

+ Stats *Stats

+ func (*Message) Descriptor() ([]byte, []int)

+ func (*Message) ProtoMessage()

+ func (m *Message) GetFlows() []*Flow

+ func (m *Message) GetStats() *Stats

+ func (m *Message) Marshal() (dAtA []byte, err error)

+ func (m *Message) MarshalTo(dAtA []byte) (int, error)

+ func (m *Message) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Message) ProtoSize() (n int)

+ func (m *Message) Reset()

+ func (m *Message) String() string

+ func (m *Message) Unmarshal(dAtA []byte) error

+ func (m *Message) XXX_DiscardUnknown()

+ func (m *Message) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Message) XXX_Merge(src proto.Message)

+ func (m *Message) XXX_Size() int

+ func (m *Message) XXX_Unmarshal(b []byte) error

+ func (v *Message) UnmarshalEasyJSON(l *jlexer.Lexer)

+ func (v *Message) UnmarshalJSON(data []byte) error

+ func (v Message) MarshalEasyJSON(w *jwriter.Writer)

+ func (v Message) MarshalJSON() ([]byte, error)

+ type RawPacket struct

+ Data []byte

+ Index int64

+ LinkType github_com_google_gopacket_layers.LinkType

+ Timestamp int64

+ func (*RawPacket) Descriptor() ([]byte, []int)

+ func (*RawPacket) ProtoMessage()

+ func (m *RawPacket) GetData() []byte

+ func (m *RawPacket) GetIndex() int64

+ func (m *RawPacket) GetLinkType() github_com_google_gopacket_layers.LinkType

+ func (m *RawPacket) GetTimestamp() int64

+ func (m *RawPacket) Marshal() (dAtA []byte, err error)

+ func (m *RawPacket) MarshalTo(dAtA []byte) (int, error)

+ func (m *RawPacket) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *RawPacket) ProtoSize() (n int)

+ func (m *RawPacket) Reset()

+ func (m *RawPacket) String() string

+ func (m *RawPacket) Unmarshal(dAtA []byte) error

+ func (m *RawPacket) XXX_DiscardUnknown()

+ func (m *RawPacket) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *RawPacket) XXX_Merge(src proto.Message)

+ func (m *RawPacket) XXX_Size() int

+ func (m *RawPacket) XXX_Unmarshal(b []byte) error

+ func (v *RawPacket) UnmarshalEasyJSON(l *jlexer.Lexer)

+ func (v *RawPacket) UnmarshalJSON(data []byte) error

+ func (v RawPacket) MarshalEasyJSON(w *jwriter.Writer)

+ func (v RawPacket) MarshalJSON() ([]byte, error)

type Sender

+ SendStats func(stats Stats)

+ type Stats struct

+ CaptureID string

+ FlowCount int64

+ FlowDropped int64

+ KernelFlowDropped int64

+ PacketsDropped int64

+ PacketsReceived int64

+ func (*Stats) Descriptor() ([]byte, []int)

+ func (*Stats) ProtoMessage()

+ func (m *Stats) GetCaptureID() string

+ func (m *Stats) GetFlowCount() int64

+ func (m *Stats) GetFlowDropped() int64

+ func (m *Stats) GetKernelFlowDropped() int64

+ func (m *Stats) GetPacketsDropped() int64

+ func (m *Stats) GetPacketsReceived() int64

+ func (m *Stats) Marshal() (dAtA []byte, err error)

+ func (m *Stats) MarshalTo(dAtA []byte) (int, error)

+ func (m *Stats) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Stats) ProtoSize() (n int)

+ func (m *Stats) Reset()

+ func (m *Stats) String() string

+ func (m *Stats) Unmarshal(dAtA []byte) error

+ func (m *Stats) XXX_DiscardUnknown()

+ func (m *Stats) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Stats) XXX_Merge(src proto.Message)

+ func (m *Stats) XXX_Size() int

+ func (m *Stats) XXX_Unmarshal(b []byte) error

+ func (v *Stats) UnmarshalEasyJSON(l *jlexer.Lexer)

+ func (v *Stats) UnmarshalJSON(data []byte) error

+ func (v Stats) MarshalEasyJSON(w *jwriter.Writer)

+ func (v Stats) MarshalJSON() ([]byte, error)

+ type TCPMetric struct

+ ABBytes int64

+ ABFinStart int64

+ ABPackets int64

+ ABRstStart int64

+ ABSawEnd int64

+ ABSawStart int64

+ ABSegmentOutOfOrder int64

+ ABSegmentSkipped int64

+ ABSegmentSkippedBytes int64

+ ABSynStart int64

+ ABSynTTL uint32

+ BABytes int64

+ BAFinStart int64

+ BAPackets int64

+ BARstStart int64

+ BASawEnd int64

+ BASawStart int64

+ BASegmentOutOfOrder int64

+ BASegmentSkipped int64

+ BASegmentSkippedBytes int64

+ BASynStart int64

+ BASynTTL uint32

+ func (*TCPMetric) Descriptor() ([]byte, []int)

+ func (*TCPMetric) ProtoMessage()

+ func (m *TCPMetric) GetABBytes() int64

+ func (m *TCPMetric) GetABFinStart() int64

+ func (m *TCPMetric) GetABPackets() int64

+ func (m *TCPMetric) GetABRstStart() int64

+ func (m *TCPMetric) GetABSawEnd() int64

+ func (m *TCPMetric) GetABSawStart() int64

+ func (m *TCPMetric) GetABSegmentOutOfOrder() int64

+ func (m *TCPMetric) GetABSegmentSkipped() int64

+ func (m *TCPMetric) GetABSegmentSkippedBytes() int64

+ func (m *TCPMetric) GetABSynStart() int64

+ func (m *TCPMetric) GetABSynTTL() uint32

+ func (m *TCPMetric) GetBABytes() int64

+ func (m *TCPMetric) GetBAFinStart() int64

+ func (m *TCPMetric) GetBAPackets() int64

+ func (m *TCPMetric) GetBARstStart() int64

+ func (m *TCPMetric) GetBASawEnd() int64

+ func (m *TCPMetric) GetBASawStart() int64

+ func (m *TCPMetric) GetBASegmentOutOfOrder() int64

+ func (m *TCPMetric) GetBASegmentSkipped() int64

+ func (m *TCPMetric) GetBASegmentSkippedBytes() int64

+ func (m *TCPMetric) GetBASynStart() int64

+ func (m *TCPMetric) GetBASynTTL() uint32

+ func (m *TCPMetric) Marshal() (dAtA []byte, err error)

+ func (m *TCPMetric) MarshalTo(dAtA []byte) (int, error)

+ func (m *TCPMetric) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *TCPMetric) ProtoSize() (n int)

+ func (m *TCPMetric) Reset()

+ func (m *TCPMetric) String() string

+ func (m *TCPMetric) Unmarshal(dAtA []byte) error

+ func (m *TCPMetric) XXX_DiscardUnknown()

+ func (m *TCPMetric) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *TCPMetric) XXX_Merge(src proto.Message)

+ func (m *TCPMetric) XXX_Size() int

+ func (m *TCPMetric) XXX_Unmarshal(b []byte) error

+ func (obj *TCPMetric) GetField(key string) (interface{}, error)

+ func (obj *TCPMetric) GetFieldBool(key string) (bool, error)

+ func (obj *TCPMetric) GetFieldInt64(key string) (int64, error)

+ func (obj *TCPMetric) GetFieldKeys() []string

+ func (obj *TCPMetric) GetFieldString(key string) (string, error)

+ func (obj *TCPMetric) MatchBool(key string, predicate common.BoolPredicate) bool

+ func (obj *TCPMetric) MatchInt64(key string, predicate common.Int64Predicate) bool

+ func (obj *TCPMetric) MatchString(key string, predicate common.StringPredicate) bool

+ func (v *TCPMetric) UnmarshalEasyJSON(l *jlexer.Lexer)

+ func (v *TCPMetric) UnmarshalJSON(data []byte) error

+ func (v TCPMetric) MarshalEasyJSON(w *jwriter.Writer)

+ func (v TCPMetric) MarshalJSON() ([]byte, error)

type TableQuery

+ Query *filters.SearchQuery

+ func (*TableQuery) Descriptor() ([]byte, []int)

+ func (*TableQuery) ProtoMessage()

+ func (m *TableQuery) GetQuery() *filters.SearchQuery

+ func (m *TableQuery) GetType() string

+ func (m *TableQuery) Marshal() (dAtA []byte, err error)

+ func (m *TableQuery) MarshalTo(dAtA []byte) (int, error)

+ func (m *TableQuery) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *TableQuery) ProtoSize() (n int)

+ func (m *TableQuery) Reset()

+ func (m *TableQuery) String() string

+ func (m *TableQuery) Unmarshal(dAtA []byte) error

+ func (m *TableQuery) XXX_DiscardUnknown()

+ func (m *TableQuery) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *TableQuery) XXX_Merge(src proto.Message)

+ func (m *TableQuery) XXX_Size() int

+ func (m *TableQuery) XXX_Unmarshal(b []byte) error

+ func (v *TableQuery) UnmarshalEasyJSON(l *jlexer.Lexer)

+ func (v *TableQuery) UnmarshalJSON(data []byte) error

+ func (v TableQuery) MarshalEasyJSON(w *jwriter.Writer)

+ func (v TableQuery) MarshalJSON() ([]byte, error)

type TableReply

+ FlowSetBytes [][]byte

+ func (*TableReply) Descriptor() ([]byte, []int)

+ func (*TableReply) ProtoMessage()

+ func (m *TableReply) GetFlowSetBytes() [][]byte

+ func (m *TableReply) GetStatus() int32

+ func (m *TableReply) Marshal() (dAtA []byte, err error)

+ func (m *TableReply) MarshalTo(dAtA []byte) (int, error)

+ func (m *TableReply) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *TableReply) ProtoSize() (n int)

+ func (m *TableReply) Reset()

+ func (m *TableReply) String() string

+ func (m *TableReply) Unmarshal(dAtA []byte) error

+ func (m *TableReply) XXX_DiscardUnknown()

+ func (m *TableReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *TableReply) XXX_Merge(src proto.Message)

+ func (m *TableReply) XXX_Size() int

+ func (m *TableReply) XXX_Unmarshal(b []byte) error

+ func (v *TableReply) UnmarshalEasyJSON(l *jlexer.Lexer)

+ func (v *TableReply) UnmarshalJSON(data []byte) error

+ func (v TableReply) MarshalEasyJSON(w *jwriter.Writer)

+ func (v TableReply) MarshalJSON() ([]byte, error)

+ type TransportLayer struct

+ A int64

+ B int64

+ ID int64

+ Protocol FlowProtocol

+ func (*TransportLayer) Descriptor() ([]byte, []int)

+ func (*TransportLayer) ProtoMessage()

+ func (m *TransportLayer) GetA() int64

+ func (m *TransportLayer) GetB() int64

+ func (m *TransportLayer) GetID() int64

+ func (m *TransportLayer) GetProtocol() FlowProtocol

+ func (m *TransportLayer) Marshal() (dAtA []byte, err error)

+ func (m *TransportLayer) MarshalTo(dAtA []byte) (int, error)

+ func (m *TransportLayer) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *TransportLayer) ProtoSize() (n int)

+ func (m *TransportLayer) Reset()

+ func (m *TransportLayer) String() string

+ func (m *TransportLayer) Unmarshal(dAtA []byte) error

+ func (m *TransportLayer) XXX_DiscardUnknown()

+ func (m *TransportLayer) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *TransportLayer) XXX_Merge(src proto.Message)

+ func (m *TransportLayer) XXX_Size() int

+ func (m *TransportLayer) XXX_Unmarshal(b []byte) error

+ func (obj *TransportLayer) GetField(key string) (interface{}, error)

+ func (obj *TransportLayer) GetFieldBool(key string) (bool, error)

+ func (obj *TransportLayer) GetFieldInt64(key string) (int64, error)

+ func (obj *TransportLayer) GetFieldKeys() []string

+ func (obj *TransportLayer) GetFieldString(key string) (string, error)

+ func (obj *TransportLayer) MatchBool(key string, predicate common.BoolPredicate) bool

+ func (obj *TransportLayer) MatchInt64(key string, predicate common.Int64Predicate) bool

+ func (obj *TransportLayer) MatchString(key string, predicate common.StringPredicate) bool

+ func (tl *TransportLayer) Hash(hasher hash.Hash, swap bool)

+ func (v *TransportLayer) UnmarshalEasyJSON(l *jlexer.Lexer)

+ func (v *TransportLayer) UnmarshalJSON(data []byte) error

+ func (v TransportLayer) MarshalEasyJSON(w *jwriter.Writer)

+ func (v TransportLayer) MarshalJSON() ([]byte, error)

v0.25.0

Sep 12, 2019

v0.24.0

Jul 16, 2019

Changes in this version

+ var LayerTypeERSPanII = gopacket.RegisterLayerType(55557, gopacket.LayerTypeMetadata{ ... })

+ func SetEBPFKernFlow(ebpfFlow *EBPFFlow, kernFlow unsafe.Pointer) — linux/amd64

+ type EBPFFlow struct

+ KernFlow *C.struct_flow

+ KernFlow interface{}

+ Last time.Time

+ Start time.Time

+ StartKTimeNs int64

type Packet

+ func (p *Packet) Keys(parentUUID string, uuids *UUIDs, opts *Opts) (uint64, uint64, uint64)

+ type Sender interface

+ SendFlows func(flows []*Flow)

type TableAllocator

+ func (a *TableAllocator) ExpireAfter() time.Duration

type UUIDs

+ CaptureID string

+ NodeTID string

v0.23.0

May 17, 2019

Changes in this version

+ const HoldTimeoutMilliseconds

v0.22.0

Mar 21, 2019

Changes in this version

+ type Operation struct

+ Flow *Flow

+ Key string

+ Type OperationType

+ type OperationType int

+ const ReplaceOperation

+ const UpdateOperation

v0.21.0

Dec 3, 2018

Changes in this version

+ type ExtraLayers int

+ const ALLLayer

+ const DHCPv4Layer

+ const DNSLayer

+ const VRRPLayer

+ func (e *ExtraLayers) Parse(s ...string) error

+ func (e *ExtraLayers) UnmarshalJSON(data []byte) error

+ func (e ExtraLayers) Extract() []string

+ func (e ExtraLayers) MarshalJSON() ([]byte, error)

+ func (e ExtraLayers) String() string

+ type Opts struct

+ AppPortMap *ApplicationPortMap

+ ExtraLayers ExtraLayers

+ IPDefrag bool

+ LayerKeyMode LayerKeyMode

+ TCPMetric bool

type TableOpts

+ ExtraLayers ExtraLayers

+ type UUIDs struct

+ L2ID int64

+ L3ID int64

+ ParentUUID string

v0.20.1

Dec 17, 2018

v0.20.0

Oct 9, 2018

Changes in this version

type Table

+ func (ft *Table) State() int64

+ type WSTableClient struct

+ func NewWSTableClient(w *ws.StructServer) *WSTableClient

+ func (f *WSTableClient) LookupFlows(flowSearchQuery filters.SearchQuery) (*FlowSet, error)

+ func (f *WSTableClient) LookupFlowsByNodes(hnmap topology.HostNodeTIDMap, flowSearchQuery filters.SearchQuery) (*FlowSet, error)

+ type WSTableServer struct

+ TableAllocator *TableAllocator

+ func NewWSTableServer(allocator *TableAllocator, pool ws.StructSpeakerPool) *WSTableServer

+ func (s *WSTableServer) OnStructMessage(c ws.Speaker, msg *ws.StructMessage)

+ func (s *WSTableServer) OnTableQuery(c ws.Speaker, msg *ws.StructMessage)

v0.19.1

Sep 14, 2018

Changes in this version

type TableServer

+ func (s *TableServer) OnStructMessage(c ws.Speaker, msg *ws.StructMessage)

v0.19.0

Aug 8, 2018

Changes in this version

type ICMPv6

+ ID uint16

v0.18.0

Jun 21, 2018

Changes in this version

+ var ErrLayerNotFound = errors.New("Layer not found")

+ var LayerTypeRawIP = gopacket.RegisterLayerType(55555, gopacket.LayerTypeMetadata{ ... })

+ func DefaultLayerKeyModeName() string

+ func LayersPath(ls []gopacket.Layer) (string, string)

+ type ApplicationPortMap struct

+ TCP map[int]string

+ UDP map[int]string

+ func NewApplicationPortMapFromConfig() *ApplicationPortMap

+ func (a *ApplicationPortMap) TCPApplication(srcPort, dstPort int) (string, bool)

+ func (a *ApplicationPortMap) UDPApplication(srcPort, dstPort int) (string, bool)

type FlowOpts

+ AppPortMap *ApplicationPortMap

+ IPDefrag bool

+ LayerKeyMode LayerKeyMode

+ type IPDefragger struct

+ func NewIPDefragger() *IPDefragger

+ func (d *IPDefragger) Defrag(packet gopacket.Packet) (*IPMetric, bool)

+ func (d *IPDefragger) FlushAll()

+ func (d *IPDefragger) FlushOlderThan(t time.Time)

+ type IPDefraggerMetric struct

+ type LayerKeyMode int

+ const DefaultLayerKeyMode

+ const L2KeyMode

+ const L3PreferedKeyMode

+ func LayerKeyModeByName(name string) (LayerKeyMode, error)

+ func (l LayerKeyMode) String() string

type Packet

+ Data []byte

+ GoPacket gopacket.Packet

+ IPMetric *IPMetric

+ Layers []gopacket.Layer

+ Length int64

+ func (p *Packet) ApplicationFlow() (gopacket.Flow, error)

+ func (p *Packet) Key(parentUUID string, opts FlowOpts) string

+ func (p *Packet) Layer(t gopacket.LayerType) gopacket.Layer

+ func (p *Packet) LinkLayer() gopacket.LinkLayer

+ func (p *Packet) NetworkLayer() gopacket.NetworkLayer

+ func (p *Packet) TransportFlow() (gopacket.Flow, error)

+ func (p *Packet) TransportLayer() gopacket.TransportLayer

+ type TCPAssembler struct

+ func NewTCPAssembler() *TCPAssembler

+ func (t *TCPAssembler) Assemble(packet gopacket.Packet)

+ func (t *TCPAssembler) FlushAll()

+ func (t *TCPAssembler) FlushOlderThan(tm time.Time)

+ func (t *TCPAssembler) New(network, transport gopacket.Flow) tcpassembly.Stream

+ func (t *TCPAssembler) RegisterFlow(flow *Flow, packet gopacket.Packet)

+ type TCPAssemblerStream struct

+ func (s *TCPAssemblerStream) Reassembled(reassemblies []tcpassembly.Reassembly)

+ func (s *TCPAssemblerStream) ReassemblyComplete()

type Table

+ func (ft *Table) FeedWithGoPacket(packet gopacket.Packet, bpf *BPF)

+ func (ft *Table) FeedWithSFlowSample(sample *layers.SFlowFlowSample, bpf *BPF)

+ func (ft *Table) IPDefragger() *IPDefragger

type TableOpts

+ ExtraTCPMetric bool

+ IPDefrag bool

+ LayerKeyMode LayerKeyMode

+ ReassembleTCP bool

v0.17.0

Apr 12, 2018

Changes in this version

+ func GetFirstLayerType(encapType string) (gopacket.LayerType, layers.LinkType)

type Enhancer

+ Start func() error

+ Stop func()

type EnhancerPipeline

+ func (e *EnhancerPipeline) Start()

+ func (e *EnhancerPipeline) Stop()

type TableClient

+ WSStructServer *shttp.WSStructServer

type TableServer

+ func (s *TableServer) OnWSStructMessage(c shttp.WSSpeaker, msg *shttp.WSStructMessage)

v0.16.0

Jan 29, 2018

v0.15.0

Dec 6, 2017

Changes in this version

+ func LayerPathFromGoPacket(packet *gopacket.Packet) string

+ type PacketSequence struct

+ Packets []Packet

+ Timestamp int64

+ func PacketSeqFromGoPacket(packet *gopacket.Packet, outerLength int64, t int64, bpf *BPF) *PacketSequence

+ func PacketSeqFromSFlowSample(sample *layers.SFlowFlowSample, t int64, bpf *BPF) []*PacketSequence

type TableAllocator

+ func (a *TableAllocator) Expire() time.Duration

+ func (a *TableAllocator) Update() time.Duration

v0.14.0

Nov 14, 2017

v0.13.0

Oct 12, 2017

Changes in this version

type Enhancer

+ Name func() string

+ type EnhancerPipelineConfig struct

+ func NewEnhancerPipelineConfig() *EnhancerPipelineConfig

+ func (epc *EnhancerPipelineConfig) Disable(name string)

+ func (epc *EnhancerPipelineConfig) Enable(name string)

+ func (epc *EnhancerPipelineConfig) IsEnabled(name string) bool

+ type FlowOpts struct

+ TCPMetric bool

+ type FlowUUIDs struct

+ L2ID int64

+ L3ID int64

+ ParentUUID string

type TableClient

+ WSJSONServer *shttp.WSJSONServer

type TableOpts

+ SocketInfo bool

+ TCPMetric bool

type TableServer

+ func (s *TableServer) OnWSJSONMessage(c shttp.WSSpeaker, msg *shttp.WSJSONMessage)

v0.12.0

Aug 1, 2017

Changes in this version

+ const DefaultCaptureLength

+ const DefaultProtobufFlowSize

+ const MaxCaptureLength

+ const MaxRawPacketLimit

+ type Enhancer interface

+ Enhance func(flow *Flow)

+ type EnhancerPipeline struct

+ Enhancers []Enhancer

+ func NewEnhancerPipeline(enhancers ...Enhancer) *EnhancerPipeline

+ func (e *EnhancerPipeline) AddEnhancer(en Enhancer)

+ func (e *EnhancerPipeline) Enhance(flows []*Flow)

+ func (e *EnhancerPipeline) EnhanceFlow(flow *Flow)

+ type Handler struct

+ type ICMPv4 struct

+ Type ICMPType

+ func (i *ICMPv4) Payload() []byte

+ type ICMPv6 struct

+ Id uint16

+ Type ICMPType

+ func (i *ICMPv6) Payload() []byte

+ type Key string

+ func KeyFromGoPacket(p *gopacket.Packet, parentUUID string) Key

+ func (f Key) String() string

+ type Packet struct

+ type Packets struct

+ Packets []Packet

+ Timestamp int64

+ func PacketsFromGoPacket(packet *gopacket.Packet, outerLength int64, t int64, bpf *BPF) *Packets

+ func PacketsFromSFlowSample(sample *layers.SFlowFlowSample, t int64, bpf *BPF) []*Packets

+ type PcapTableFeeder struct

+ func NewPcapTableFeeder(r io.ReadCloser, packetsChan chan *Packets, replay bool, bpfFilter string) (*PcapTableFeeder, error)

+ func (p *PcapTableFeeder) Start()

+ func (p *PcapTableFeeder) Stop()

type PcapWriter

+ func (p *PcapWriter) WriteRawPacket(r *RawPacket) error

+ func (p *PcapWriter) WriteRawPackets(fr *RawPackets) error

+ type RawPackets struct

+ LinkType layers.LinkType

+ RawPackets []*RawPacket

type Table

+ Opts TableOpts

+ type TableOpts struct

+ RawPacketLimit int64

v0.11.0

May 5, 2017

v0.10.0

Mar 31, 2017

Changes in this version

+ const CaptureLength

+ func BPFFilterToRaw(linkType layers.LinkType, captureLength uint32, filter string) ([]bpf.RawInstruction, error)

+ func NewFilterForFlowSet(flowset *FlowSet) *filters.Filter

+ func NewFilterForNodeTIDs(uuids []string) *filters.Filter

+ type BPF struct

+ func NewBPF(linkType layers.LinkType, captureLength uint32, filter string) (*BPF, error)

+ func (b *BPF) Matches(data []byte) bool

+ type FlowEnhancer interface

+ Enhance func(flow *Flow)

+ type FlowEnhancerPipeline struct

+ Enhancers []FlowEnhancer

+ func NewFlowEnhancerPipeline(enhancers ...FlowEnhancer) *FlowEnhancerPipeline

+ func (fe *FlowEnhancerPipeline) AddEnhancer(e FlowEnhancer)

+ func (fe *FlowEnhancerPipeline) Enhance(flows []*Flow)

+ func (fe *FlowEnhancerPipeline) EnhanceFlow(flow *Flow)

type FlowPackets

+ Packets []FlowPacket

+ Timestamp int64

type MergeContext

+ SortOrder common.SortOrder

+ type PcapWriter struct

+ func NewPcapWriter(r io.ReadCloser, packetsChan chan *FlowPackets, replay bool, bpfFilter string) (*PcapWriter, error)

+ func (p *PcapWriter) FeedFlowTable()

+ func (p *PcapWriter) Start()

+ func (p *PcapWriter) Stop()

type TableServer

+ WSAsyncClientPool *shttp.WSAsyncClientPool

v0.9.0

Jan 27, 2017

Changes in this version

+ var LayerTypeInMplsEthOrIp = gopacket.RegisterLayerType(55556, gopacket.LayerTypeMetadata{ ... })

type MergeContext

+ DedupBy string

+ Sort bool

+ SortBy string

type Table

+ func (ft *Table) SetNodeTID(tid string)

v0.8.0

Dec 9, 2016

Changes in this version

+ var LayerTypeInGRE = gopacket.RegisterLayerType(55555, gopacket.LayerTypeMetadata{ ... })

+ type FlowPacket struct

+ type FlowPackets []FlowPacket

+ func FlowPacketsFromGoPacket(packet *gopacket.Packet, outerLength int64) FlowPackets

+ func FlowPacketsFromSFlowSample(sample *layers.SFlowFlowSample) []FlowPackets

+ type InGRELayer struct

+ StrangeHeader []byte

+ func (m InGRELayer) LayerContents() []byte

+ func (m InGRELayer) LayerPayload() []byte

+ func (m InGRELayer) LayerType() gopacket.LayerType

type ProtocolType

+ const MPLS

+ const UDP_MPLS

type Table

+ PacketsChan chan FlowPackets

+ func (ft *Table) FlowPacketToFlow(packet *FlowPacket, parentUUID string) *Flow

+ func (ft *Table) FlowPacketsToFlow(flowPackets FlowPackets)

+ func (ft *Table) SetNodeUUID(uuid string)

v0.7.0

Nov 8, 2016

Changes in this version

+ var ErrFieldNotFound = errors.New("Flow field not found")

+ var ErrFlowProtocol = errors.New("FlowProtocol invalid")

+ var FlowProtocol_name = map[int32]string

+ var FlowProtocol_value = map[string]int32

type Flow

+ ANodeUUID string

+ BNodeUUID string

+ LastUpdateMetric *FlowMetric

+ Link *FlowLayer

+ Metric *FlowMetric

+ Network *FlowLayer

+ NodeUUID string

+ ParentUUID string

+ Transport *FlowLayer

+ func FlowsFromGoPacket(ft *Table, packet *gopacket.Packet, length int64, setter FlowProbeNodeSetter) []*Flow

+ func (f *Flow) DumpInfo(layerSeparator ...string) string

+ func (f *Flow) GetFieldInt64(field string) (int64, error)

+ func (f *Flow) GetFieldString(field string) (string, error)

+ func (f *Flow) Init(now int64, packet *gopacket.Packet, length int64)

+ func (f *Flow) Update(now int64, packet *gopacket.Packet, length int64)

+ func (m *Flow) GetLastUpdateMetric() *FlowMetric

+ func (m *Flow) GetLink() *FlowLayer

+ func (m *Flow) GetMetric() *FlowMetric

+ func (m *Flow) GetNetwork() *FlowLayer

+ func (m *Flow) GetTransport() *FlowLayer

+ type FlowLayer struct

+ A string

+ B string

+ Protocol FlowProtocol

+ func (*FlowLayer) Descriptor() ([]byte, []int)

+ func (*FlowLayer) ProtoMessage()

+ func (f *FlowLayer) GetField(fields []string) (string, error)

+ func (fl *FlowLayer) Hash() []byte

+ func (fl *FlowLayer) HashStr() string

+ func (m *FlowLayer) Reset()

+ func (m *FlowLayer) String() string

+ func (s *FlowLayer) MarshalJSON() ([]byte, error)

+ func (s *FlowLayer) UnmarshalJSON(b []byte) error

+ type FlowMetric struct

+ ABBytes int64

+ ABPackets int64

+ BABytes int64

+ BAPackets int64

+ Last int64

+ Start int64

+ func (*FlowMetric) Descriptor() ([]byte, []int)

+ func (*FlowMetric) ProtoMessage()

+ func (f *FlowMetric) GetField(fields []string) (int64, error)

+ func (fm *FlowMetric) Copy() *FlowMetric

+ func (m *FlowMetric) Reset()

+ func (m *FlowMetric) String() string

+ type FlowProtocol int32

+ const FlowProtocol_ETHERNET

+ const FlowProtocol_IPV4

+ const FlowProtocol_IPV6

+ const FlowProtocol_SCTPPORT

+ const FlowProtocol_TCPPORT

+ const FlowProtocol_UDPPORT

+ func (FlowProtocol) EnumDescriptor() ([]byte, []int)

+ func (x FlowProtocol) String() string

+ func (x FlowProtocol) Value() int32

type FlowSearchQuery

+ Dedup bool

+ Sort bool

type FlowSet

+ func (fs *FlowSet) Dedup()

+ func (fs *FlowSet) Slice(from, to int)

+ func (fs *FlowSet) Sort()

+ type MergeContext struct

+ Dedup bool

+ Sorted bool

type ProtocolType

+ const GRE

+ const SCTP

type Table

+ func (ft *Table) Run()

v0.6.0

Oct 6, 2016

Changes in this version

type FlowSearchQuery

+ Range *Range

+ func (m *FlowSearchQuery) GetRange() *Range

+ type Range struct

+ From int64

+ To int64

+ func (*Range) Descriptor() ([]byte, []int)

+ func (*Range) ProtoMessage()

+ func (m *Range) Reset()

+ func (m *Range) String() string

v0.5.0

Sep 15, 2016

Changes in this version

+ var BoolFilterOp_name = map[int32]string

+ var BoolFilterOp_value = map[string]int32

+ func GetAttribute(intf interface{}, name string) interface

+ func GetFields(intf interface{}, fields []string) interface

+ type BoolFilter struct

+ Filters []*Filter

+ Op BoolFilterOp

+ func (*BoolFilter) Descriptor() ([]byte, []int)

+ func (*BoolFilter) ProtoMessage()

+ func (b *BoolFilter) Eval(value interface{}) bool

+ func (b *BoolFilter) Expression() string

+ func (m *BoolFilter) GetFilters() []*Filter

+ func (m *BoolFilter) Reset()

+ func (m *BoolFilter) String() string

+ type BoolFilterOp int32

+ const BoolFilterOp_AND

+ const BoolFilterOp_NOT

+ const BoolFilterOp_OR

+ func (BoolFilterOp) EnumDescriptor() ([]byte, []int)

+ func (x BoolFilterOp) String() string

+ type Filter struct

+ BoolFilter *BoolFilter

+ GtInt64Filter *GtInt64Filter

+ GteInt64Filter *GteInt64Filter

+ LtInt64Filter *LtInt64Filter

+ LteInt64Filter *LteInt64Filter

+ TermInt64Filter *TermInt64Filter

+ TermStringFilter *TermStringFilter

+ func NewFilterForNodes(uuids []string) *Filter

+ func (*Filter) Descriptor() ([]byte, []int)

+ func (*Filter) ProtoMessage()

+ func (f *Filter) Eval(value interface{}) bool

+ func (f *Filter) Expression() string

+ func (m *Filter) GetBoolFilter() *BoolFilter

+ func (m *Filter) GetGtInt64Filter() *GtInt64Filter

+ func (m *Filter) GetGteInt64Filter() *GteInt64Filter

+ func (m *Filter) GetLtInt64Filter() *LtInt64Filter

+ func (m *Filter) GetLteInt64Filter() *LteInt64Filter

+ func (m *Filter) GetTermInt64Filter() *TermInt64Filter

+ func (m *Filter) GetTermStringFilter() *TermStringFilter

+ func (m *Filter) Reset()

+ func (m *Filter) String() string

type Flow

+ MetricRange *FlowMetricRange

+ func (m *Flow) GetMetricRange() *FlowMetricRange

type FlowEndpointsStatistics

+ func (fes *FlowEndpointsStatistics) GetAttr(name string) interface{}

+ func (fs *FlowEndpointsStatistics) Copy() *FlowEndpointsStatistics

+ type FlowMetricRange struct

+ ABBytes uint64

+ ABPackets uint64

+ BABytes uint64

+ BAPackets uint64

+ Last int64

+ Start int64

+ func (*FlowMetricRange) Descriptor() ([]byte, []int)

+ func (*FlowMetricRange) ProtoMessage()

+ func (m *FlowMetricRange) Reset()

+ func (m *FlowMetricRange) String() string

type FlowSearchQuery

+ Filter *Filter

+ func (*FlowSearchQuery) Descriptor() ([]byte, []int)

+ func (*FlowSearchQuery) ProtoMessage()

+ func (m *FlowSearchQuery) GetFilter() *Filter

+ func (m *FlowSearchQuery) Reset()

+ func (m *FlowSearchQuery) String() string

type FlowSearchReply

+ func (*FlowSearchReply) Descriptor() ([]byte, []int)

+ func (*FlowSearchReply) ProtoMessage()

+ func (m *FlowSearchReply) GetFlowSet() *FlowSet

+ func (m *FlowSearchReply) Reset()

+ func (m *FlowSearchReply) String() string

type FlowSet

+ func (*FlowSet) Descriptor() ([]byte, []int)

+ func (*FlowSet) ProtoMessage()

+ func (fs *FlowSet) AvgBandwidth() (fsbw FlowSetBandwidth)

+ func (fs *FlowSet) Filter(filter *Filter) *FlowSet

+ func (m *FlowSet) GetFlows() []*Flow

+ func (m *FlowSet) Reset()

+ func (m *FlowSet) String() string

type FlowStatistics

+ func (fs *FlowStatistics) GetLayer(layer FlowEndpointLayer) *FlowEndpointsStatistics

+ type GetAttr interface

+ GetAttr func(name string) interface{}

+ type GtInt64Filter struct

+ Key string

+ Value int64

+ func (*GtInt64Filter) Descriptor() ([]byte, []int)

+ func (*GtInt64Filter) ProtoMessage()

+ func (m *GtInt64Filter) Reset()

+ func (m *GtInt64Filter) String() string

+ func (r *GtInt64Filter) Eval(value interface{}) bool

+ func (r *GtInt64Filter) Expression() string

+ type GteInt64Filter struct

+ Key string

+ Value int64

+ func (*GteInt64Filter) Descriptor() ([]byte, []int)

+ func (*GteInt64Filter) ProtoMessage()

+ func (m *GteInt64Filter) Reset()

+ func (m *GteInt64Filter) String() string

+ func (r *GteInt64Filter) Eval(value interface{}) bool

+ func (r *GteInt64Filter) Expression() string

+ type LtInt64Filter struct

+ Key string

+ Value int64

+ func (*LtInt64Filter) Descriptor() ([]byte, []int)

+ func (*LtInt64Filter) ProtoMessage()

+ func (m *LtInt64Filter) Reset()

+ func (m *LtInt64Filter) String() string

+ func (r *LtInt64Filter) Eval(value interface{}) bool

+ func (r *LtInt64Filter) Expression() string

+ type LteInt64Filter struct

+ Key string

+ Value int64

+ func (*LteInt64Filter) Descriptor() ([]byte, []int)

+ func (*LteInt64Filter) ProtoMessage()

+ func (m *LteInt64Filter) Reset()

+ func (m *LteInt64Filter) String() string

+ func (r *LteInt64Filter) Eval(value interface{}) bool

+ func (r *LteInt64Filter) Expression() string

+ type NeInt64Filter struct

+ Key string

+ Value int64

+ func (*NeInt64Filter) Descriptor() ([]byte, []int)

+ func (*NeInt64Filter) ProtoMessage()

+ func (m *NeInt64Filter) Reset()

+ func (m *NeInt64Filter) String() string

+ type NeStringFilter struct

+ Key string

+ Value string

+ func (*NeStringFilter) Descriptor() ([]byte, []int)

+ func (*NeStringFilter) ProtoMessage()

+ func (m *NeStringFilter) Reset()

+ func (m *NeStringFilter) String() string

type TableClient

+ func (f *TableClient) LookupFlows(filter *Filter) (*FlowSet, error)

type TableQuery

+ Type string

type TableServer

+ func (s *TableServer) OnTableQuery(msg shttp.WSMessage)

+ type TermInt64Filter struct

+ Key string

+ Value int64

+ func (*TermInt64Filter) Descriptor() ([]byte, []int)

+ func (*TermInt64Filter) ProtoMessage()

+ func (m *TermInt64Filter) Reset()

+ func (m *TermInt64Filter) String() string

+ func (t *TermInt64Filter) Eval(value interface{}) bool

+ func (t *TermInt64Filter) Expression() string

+ type TermStringFilter struct

+ Key string

+ Value string

+ func (*TermStringFilter) Descriptor() ([]byte, []int)

+ func (*TermStringFilter) ProtoMessage()

+ func (m *TermStringFilter) Reset()

+ func (m *TermStringFilter) String() string

+ func (t *TermStringFilter) Eval(value interface{}) bool

+ func (t *TermStringFilter) Expression() string

v0.4.0

Aug 4, 2016

Changes in this version

+ const Namespace

+ func HashFromValues(ab interface{}, ba interface{}) []byte

type Flow

+ IfDstNodeUUID string

+ IfSrcNodeUUID string

+ ProbeNodeUUID string

+ TrackingID string

+ func (flow *Flow) GetLayerHash(ltype FlowEndpointType) string

+ func (flow *Flow) UpdateUUIDs(key string)

type FlowEndpointType

+ const FlowEndpointType_IPV6

+ type FlowHandler struct

+ func NewFlowHandler(callback ExpireUpdateFunc, every time.Duration, duration time.Duration) *FlowHandler

type FlowKey

+ func FlowKeyFromGoPacket(p *gopacket.Packet) FlowKey

+ type FlowProbeNodeSetter interface

+ SetProbeNode func(flow *Flow) bool

+ type FlowQueryFilter struct

+ NodeUUIDs []string

+ type FlowSearchQuery struct

+ NodeUUIDs []string

+ type FlowSearchReply struct

+ FlowSet *FlowSet

+ type FlowSet struct

+ End int64

+ Flows []*Flow

+ Start int64

+ func NewFlowSet() *FlowSet

+ func (fs *FlowSet) Bandwidth() (fsbw FlowSetBandwidth)

+ func (fs *FlowSet) Merge(ofs *FlowSet)

+ type FlowSetBandwidth struct

+ ABbytes uint64

+ ABpackets uint64

+ BAbytes uint64

+ BApackets uint64

+ Duration int64

+ NBFlow uint64

+ func (fsbw FlowSetBandwidth) String() string

type FlowStatistics

+ func (fs *FlowStatistics) GetLayerHash(ltype FlowEndpointType) (hash []byte)

+ func (fs *FlowStatistics) Init(now int64, packet *gopacket.Packet, length uint64)

+ type HostNodeIDMap map[string][]string

+ type Table struct

+ func NewTable(updateHandler *FlowHandler, expireHandler *FlowHandler) *Table

+ func NewTableFromFlows(flows []*Flow, updateHandler *FlowHandler, expireHandler *FlowHandler) *Table

+ func NewTestFlowTableComplex(t *testing.T, updateHandler *FlowHandler, expireHandler *FlowHandler) *Table

+ func (ft *Table) Expire(now time.Time)

+ func (ft *Table) FilterLast(last time.Duration) []*Flow

+ func (ft *Table) Flush()

+ func (ft *Table) GetFlow(key string) *Flow

+ func (ft *Table) GetFlows(filters ...FlowQueryFilter) *FlowSet

+ func (ft *Table) GetOrCreateFlow(key string) (*Flow, bool)

+ func (ft *Table) GetTime() int64

+ func (ft *Table) Query(query *TableQuery) *TableReply

+ func (ft *Table) RegisterDefault(fn func())

+ func (ft *Table) SelectLayer(endpointType FlowEndpointType, list []string) *FlowSet

+ func (ft *Table) Start()

+ func (ft *Table) Stop()

+ func (ft *Table) String() string

+ func (ft *Table) Update(flows []*Flow)

+ func (ft *Table) Updated(now time.Time)

+ func (ft *Table) Window(start, end int64) *FlowSet

+ type TableAllocator struct

+ func NewTableAllocator(update, updateWindow, expire, expireWindow time.Duration) *TableAllocator

+ func (a *TableAllocator) Alloc(flowCallBack ExpireUpdateFunc) *Table

+ func (a *TableAllocator) Flush()

+ func (a *TableAllocator) QueryTable(query *TableQuery) *TableReply

+ func (a *TableAllocator) Release(t *Table)

+ type TableClient struct

+ WSServer *shttp.WSServer

+ func NewTableClient(w *shttp.WSServer) *TableClient

+ func (f *TableClient) LookupFlowsByNodes(hnmap HostNodeIDMap) (*FlowSet, error)

+ func (f *TableClient) OnMessage(c *shttp.WSClient, m shttp.WSMessage)

+ type TableQuery struct

+ Obj interface{}

+ type TableReply struct

+ Obj json.RawMessage

+ Status int

+ type TableServer struct

+ TableAllocator *TableAllocator

+ WSAsyncClient *shttp.WSAsyncClient

+ func NewServer(allocator *TableAllocator, client *shttp.WSAsyncClient) *TableServer

+ func (s *TableServer) OnMessage(msg shttp.WSMessage)

v0.3.0

Apr 26, 2016

Changes in this version

+ var FlowEndpointLayer_name = map[int32]string

+ var FlowEndpointLayer_value = map[string]int32

+ func Var8bin(v []byte) []byte

+ type ExpireUpdateFunc func(f []*Flow)

type Flow

+ FlowUUID string

+ func FlowFromGoPacket(ft *FlowTable, packet *gopacket.Packet, setter FlowProbePathSetter) *Flow

+ func FlowsFromSFlowSample(ft *FlowTable, sample *layers.SFlowFlowSample, setter FlowProbePathSetter) []*Flow

+ func GenerateTestFlows(t *testing.T, ft *FlowTable, baseSeed int64, probePath string) []*Flow

+ func GenerateTestFlowsSymmetric(t *testing.T, ft *FlowTable, baseSeed int64, probePath string) []*Flow

+ type FlowEndpointLayer int32

+ const FlowEndpointLayer_LINK

+ const FlowEndpointLayer_NETWORK

+ const FlowEndpointLayer_TRANSPORT

+ func (FlowEndpointLayer) EnumDescriptor() ([]byte, []int)

+ func (x FlowEndpointLayer) String() string

type FlowEndpointsStatistics

+ Hash []byte

type FlowKey

+ func NewFlowKeyFromGoPacket(p *gopacket.Packet) *FlowKey

+ type FlowProbePathSetter interface

+ SetProbePath func(flow *Flow) bool

type FlowStatistics

+ func (fs *FlowStatistics) DumpInfo(layerSeparator ...string) string

+ func (fs *FlowStatistics) GetEndpointsType(eptype FlowEndpointType) *FlowEndpointsStatistics

+ func (fs *FlowStatistics) Update(packet *gopacket.Packet)

type FlowTable

+ func NewFlowTableComplex(t *testing.T) *FlowTable

+ func NewFlowTableFromFlows(flows []*Flow) *FlowTable

+ func NewTestFlowTableSimple(t *testing.T) *FlowTable

+ func (ft *FlowTable) Expire(now time.Time)

+ func (ft *FlowTable) ExpireNow()

+ func (ft *FlowTable) GetExpireTicker() <-chan time.Time

+ func (ft *FlowTable) GetFlows() []*Flow

+ func (ft *FlowTable) GetOrCreateFlow(key string) (*Flow, bool)

+ func (ft *FlowTable) GetUpdatedTicker() <-chan time.Time

+ func (ft *FlowTable) LookupFlowsByProbePath(p string) []*Flow

+ func (ft *FlowTable) RegisterExpire(fn ExpireUpdateFunc, every time.Duration)

+ func (ft *FlowTable) RegisterUpdated(fn ExpireUpdateFunc, since time.Duration)

+ func (ft *FlowTable) UnregisterAll()

+ func (ft *FlowTable) Updated(now time.Time)

+ type FlowTableManager struct

+ type FlowTableManagerAsync struct

+ func (ftma *FlowTableManagerAsync) Register(p *FlowTableManagerAsyncParam)

+ func (ftma *FlowTableManagerAsync) Unregister()

+ type FlowTableManagerAsyncFunction func(fn ExpireUpdateFunc, updateFrom int64)

+ type FlowTableManagerAsyncParam struct

+ type ProtocolType int

+ const ETH

+ const IPv4

+ const IPv6

+ const TCP

+ const UDP

v0.2.0

Feb 23, 2016

Changes in this version

type Flow

+ func (flow *Flow) ID() string

type FlowEndpointStatistics

+ func (s *FlowEndpointStatistics) MarshalJSON() ([]byte, error)

+ func (s *FlowEndpointStatistics) UnmarshalJSON(b []byte) error

type FlowEndpointsStatistics

+ func (s *FlowEndpointsStatistics) MarshalJSON() ([]byte, error)

+ func (s *FlowEndpointsStatistics) UnmarshalJSON(b []byte) error

type FlowStatistics

+ func (s *FlowStatistics) MarshalJSON() ([]byte, error)

+ func (s *FlowStatistics) UnmarshalJSON(b []byte) error

type FlowTable

+ func (ft *FlowTable) SelectLayer(endpointType FlowEndpointType, list []string) []*Flow

v0.1.0

Feb 10, 2016

Changes in this version

+ var FlowEndpointType_name = map[int32]string

+ var FlowEndpointType_value = map[string]int32

+ func LayerFlow(l gopacket.Layer) gopacket.Flow

+ type ExpireFunc func(f *Flow)

+ type Flow struct

+ IfDstGraphPath string

+ IfSrcGraphPath string

+ LayersPath string

+ ProbeGraphPath string

+ Statistics *FlowStatistics

+ UUID string

+ func FLowsFromSFlowSample(ft *FlowTable, sample *layers.SFlowFlowSample, probePath *string) []*Flow

+ func FromData(data []byte) (*Flow, error)

+ func (*Flow) Descriptor() ([]byte, []int)

+ func (*Flow) ProtoMessage()

+ func (flow *Flow) GetData() ([]byte, error)

+ func (m *Flow) GetStatistics() *FlowStatistics

+ func (m *Flow) Reset()

+ func (m *Flow) String() string

+ type FlowEndpointStatistics struct

+ Bytes uint64

+ Packets uint64

+ Type FlowEndpointType

+ Value string

+ func (*FlowEndpointStatistics) Descriptor() ([]byte, []int)

+ func (*FlowEndpointStatistics) ProtoMessage()

+ func (m *FlowEndpointStatistics) Reset()

+ func (m *FlowEndpointStatistics) String() string

+ type FlowEndpointType int32

+ const FlowEndpointType_ETHERNET

+ const FlowEndpointType_IPV4

+ const FlowEndpointType_SCTPPORT

+ const FlowEndpointType_TCPPORT

+ const FlowEndpointType_UDPPORT

+ func (FlowEndpointType) EnumDescriptor() ([]byte, []int)

+ func (x FlowEndpointType) String() string

+ func (x FlowEndpointType) Value() int32

+ type FlowEndpointsStatistics struct

+ AB *FlowEndpointStatistics

+ BA *FlowEndpointStatistics

+ Type FlowEndpointType

+ func (*FlowEndpointsStatistics) Descriptor() ([]byte, []int)

+ func (*FlowEndpointsStatistics) ProtoMessage()

+ func (m *FlowEndpointsStatistics) GetAB() *FlowEndpointStatistics

+ func (m *FlowEndpointsStatistics) GetBA() *FlowEndpointStatistics

+ func (m *FlowEndpointsStatistics) Reset()

+ func (m *FlowEndpointsStatistics) String() string

+ type FlowKey struct

+ func (key FlowKey) String() string

+ type FlowStatistics struct

+ Endpoints map[int32]*FlowEndpointsStatistics

+ Last int64

+ Start int64

+ func NewFlowStatistics() *FlowStatistics

+ func (*FlowStatistics) Descriptor() ([]byte, []int)

+ func (*FlowStatistics) ProtoMessage()

+ func (m *FlowStatistics) GetEndpoints() map[int32]*FlowEndpointsStatistics

+ func (m *FlowStatistics) Reset()

+ func (m *FlowStatistics) String() string

+ type FlowTable struct

+ func NewFlowTable() *FlowTable

+ func (ft *FlowTable) AsyncExpire(fn ExpireFunc, every time.Duration)

+ func (ft *FlowTable) FilterLast(last time.Duration) []*Flow

+ func (ft *FlowTable) GetFlow(key string) (flow *Flow, new bool)

+ func (ft *FlowTable) IsExist(f *Flow) bool

+ func (ft *FlowTable) JSONFlowConversationEthernetPath() string

+ func (ft *FlowTable) NewFlowTableFromFlows(flows []*Flow) *FlowTable

+ func (ft *FlowTable) String() string

+ func (ft *FlowTable) Update(flows []*Flow)

+ type FlowTableAsyncNotificationUpdate interface

+ AsyncNotificationUpdate func(every time.Duration)

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