flow

package

Go to main page

Versions in this module

v0

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