flow

package

Go to main page

Versions in this module

v0

v0.23.0

May 17, 2019

Changes in this version

+ const HoldTimeoutMilliseconds

v0.22.0

Mar 21, 2019

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 Operation struct

+ Flow *Flow

+ Key string

+ Type OperationType

+ type OperationType int

+ const ReplaceOperation

+ const UpdateOperation

+ 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

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 ICMPv6

+ ID uint16

type TableServer

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

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 GetFirstLayerType(encapType string) (gopacket.LayerType, layers.LinkType)

+ 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 Enhancer

+ Start func() error

+ Stop func()

type EnhancerPipeline

+ func (e *EnhancerPipeline) Start()

+ func (e *EnhancerPipeline) Stop()

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 TableClient

+ WSStructServer *shttp.WSStructServer

type TableOpts

+ ExtraTCPMetric bool

+ IPDefrag bool

+ LayerKeyMode LayerKeyMode

+ ReassembleTCP bool

type TableServer

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

v0.16.0

Jan 29, 2018

Changes in this version

+ const DefaultCaptureLength

+ const DefaultProtobufFlowSize

+ const MaxCaptureLength

+ const MaxRawPacketLimit

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

+ func LayerPathFromGoPacket(packet *gopacket.Packet) string

+ 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 Enhancer interface

+ Enhance func(flow *Flow)

+ Name func() string

+ type EnhancerPipeline struct

+ Enhancers map[string]Enhancer

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

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

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

+ func (e *EnhancerPipeline) EnhanceFlow(cfg *EnhancerPipelineConfig, flow *Flow)

+ 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 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 MergeContext

+ SortOrder common.SortOrder

+ type Packet struct

+ 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 PcapTableFeeder struct

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

+ func (p *PcapTableFeeder) Start()

+ func (p *PcapTableFeeder) Stop()

+ type PcapWriter struct

+ func NewPcapWriter(w io.Writer) *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 TableAllocator

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

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

type TableClient

+ WSJSONServer *shttp.WSJSONServer

+ type TableOpts struct

+ RawPacketLimit int64

+ SocketInfo bool

+ TCPMetric bool

type TableServer

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

v0.9.0

Jan 27, 2017

Changes in this version

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

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

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

+ var LayerTypeInMplsEthOrIp = gopacket.RegisterLayerType(55556, 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 MergeContext struct

+ Dedup bool

+ DedupBy string

+ Sort bool

+ SortBy string

type Table

+ PacketsChan chan FlowPackets

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

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

+ func (ft *Table) Run()

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

v0.5.0

Sep 15, 2016

Changes in this version

+ const Namespace

+ var BoolFilterOp_name = map[int32]string

+ var BoolFilterOp_value = map[string]int32

+ var FlowEndpointLayer_name = map[int32]string

+ var FlowEndpointLayer_value = map[string]int32

+ var FlowEndpointType_name = map[int32]string

+ var FlowEndpointType_value = map[string]int32

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

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

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

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

+ 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 ExpireUpdateFunc func(f []*Flow)

+ 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 struct

+ IfDstNodeUUID string

+ IfSrcNodeUUID string

+ LayersPath string

+ MetricRange *FlowMetricRange

+ ProbeNodeUUID string

+ Statistics *FlowStatistics

+ TrackingID string

+ UUID string

+ func FlowFromGoPacket(ft *Table, packet *gopacket.Packet, length uint64, setter FlowProbeNodeSetter) *Flow

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

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

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

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

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

+ func (*Flow) ProtoMessage()

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

+ func (flow *Flow) GetLayerHash(layer FlowEndpointLayer) string

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

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

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

+ func (m *Flow) Reset()

+ func (m *Flow) String() string

+ type FlowEndpointLayer int32

+ const FlowEndpointLayer_LINK

+ const FlowEndpointLayer_NETWORK

+ const FlowEndpointLayer_TRANSPORT

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

+ func (x FlowEndpointLayer) String() string

+ type FlowEndpointStatistics struct

+ Bytes uint64

+ Packets uint64

+ 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_IPV6

+ 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

+ Hash []byte

+ Type FlowEndpointType

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

+ func (*FlowEndpointsStatistics) ProtoMessage()

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

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

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

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

+ func (m *FlowEndpointsStatistics) Reset()

+ func (m *FlowEndpointsStatistics) String() string

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

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

+ type FlowHandler struct

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

+ type FlowKey string

+ func FlowKeyFromGoPacket(p *gopacket.Packet) FlowKey

+ func (f FlowKey) String() string

+ 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 FlowProbeNodeSetter interface

+ SetProbeNode func(flow *Flow) bool

+ type FlowSearchQuery struct

+ 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 struct

+ FlowSet *FlowSet

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

+ func (*FlowSearchReply) ProtoMessage()

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

+ func (m *FlowSearchReply) Reset()

+ func (m *FlowSearchReply) String() string

+ type FlowSet struct

+ End int64

+ Flows []*Flow

+ Start int64

+ func NewFlowSet() *FlowSet

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

+ func (*FlowSet) ProtoMessage()

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

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

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

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

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

+ func (m *FlowSet) Reset()

+ func (m *FlowSet) String() string

+ type FlowSetBandwidth struct

+ ABbytes uint64

+ ABpackets uint64

+ BAbytes uint64

+ BApackets uint64

+ Duration int64

+ NBFlow uint64

+ func (fsbw FlowSetBandwidth) String() string

+ type FlowStatistics struct

+ Endpoints []*FlowEndpointsStatistics

+ Last int64

+ Start int64

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

+ func (*FlowStatistics) ProtoMessage()

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

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

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

+ func (fs *FlowStatistics) GetLayerHash(layer FlowEndpointLayer) (hash []byte)

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

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

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

+ func (m *FlowStatistics) Reset()

+ func (m *FlowStatistics) String() string

+ 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 HostNodeIDMap map[string][]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 ProtocolType int

+ const ETH

+ const IPv4

+ const IPv6

+ const TCP

+ const UDP

+ 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 NewTestFlowTableSimple(t *testing.T) *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(filter *Filter) *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, expire 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) LookupFlows(filter *Filter) (*FlowSet, error)

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

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

+ type TableQuery struct

+ Obj []byte

+ Type string

+ type TableReply struct

+ Obj [][]byte

+ 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)

+ 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

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