chf

package
v1.0.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 6, 2022 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Index

Constants

View Source 
const CHF_TypeID = 0xa7ab5c68e4bc7b62

CHF_TypeID is the unique identifier for the type CHF.

View Source 
const Custom_TypeID = 0xed5d37861203d027

Custom_TypeID is the unique identifier for the type Custom.

View Source 
const PackedCHF_TypeID = 0xb158a6a28e2d29c2

PackedCHF_TypeID is the unique identifier for the type PackedCHF.

Variables

This section is empty.

Functions

This section is empty.

Types

type CHF 

type CHF struct{ capnp.Struct }

func NewCHF 

func NewCHF(s *capnp.Segment) (CHF, error)

func NewRootCHF 

func NewRootCHF(s *capnp.Segment) (CHF, error)

func ReadRootCHF 

func ReadRootCHF(msg *capnp.Message) (CHF, error)

func (CHF) AppProtocol 

func (s CHF) AppProtocol() uint32

func (CHF) Big 

func (s CHF) Big() bool

func (CHF) Custom 

func (s CHF) Custom() (Custom_List, error)

func (CHF) DeviceId 

func (s CHF) DeviceId() uint32

func (CHF) DstAs 

func (s CHF) DstAs() uint32

func (CHF) DstBgpAsPath 

func (s CHF) DstBgpAsPath() (string, error)

func (CHF) DstBgpAsPathBytes 

func (s CHF) DstBgpAsPathBytes() ([]byte, error)

func (CHF) DstBgpCommunity 

func (s CHF) DstBgpCommunity() (string, error)

func (CHF) DstBgpCommunityBytes 

func (s CHF) DstBgpCommunityBytes() ([]byte, error)

func (CHF) DstEthMac 

func (s CHF) DstEthMac() uint64

func (CHF) DstFlowTags 

func (s CHF) DstFlowTags() (string, error)

func (CHF) DstFlowTagsBytes 

func (s CHF) DstFlowTagsBytes() ([]byte, error)

func (CHF) DstGeo 

func (s CHF) DstGeo() uint32

func (CHF) DstGeoCity 

func (s CHF) DstGeoCity() uint32

func (CHF) DstGeoRegion 

func (s CHF) DstGeoRegion() uint32

func (CHF) DstMac 

func (s CHF) DstMac() uint32

func (CHF) DstNextHopAs 

func (s CHF) DstNextHopAs() uint32

func (CHF) DstRouteLength 

func (s CHF) DstRouteLength() uint8

func (CHF) DstRoutePrefix 

func (s CHF) DstRoutePrefix() uint32

func (CHF) DstSecondAsn 

func (s CHF) DstSecondAsn() uint32

func (CHF) DstThirdAsn 

func (s CHF) DstThirdAsn() uint32

func (CHF) FlowTags 

func (s CHF) FlowTags() (string, error)

func (CHF) FlowTagsBytes 

func (s CHF) FlowTagsBytes() ([]byte, error)

func (CHF) HasCustom 

func (s CHF) HasCustom() bool

func (CHF) HasDstBgpAsPath 

func (s CHF) HasDstBgpAsPath() bool

func (CHF) HasDstBgpCommunity 

func (s CHF) HasDstBgpCommunity() bool

func (CHF) HasDstFlowTags 

func (s CHF) HasDstFlowTags() bool

func (CHF) HasFlowTags 

func (s CHF) HasFlowTags() bool

func (CHF) HasIpv6DstAddr 

func (s CHF) HasIpv6DstAddr() bool

func (CHF) HasIpv6DstNextHop 

func (s CHF) HasIpv6DstNextHop() bool

func (CHF) HasIpv6DstRoutePrefix 

func (s CHF) HasIpv6DstRoutePrefix() bool

func (CHF) HasIpv6SrcAddr 

func (s CHF) HasIpv6SrcAddr() bool

func (CHF) HasIpv6SrcNextHop 

func (s CHF) HasIpv6SrcNextHop() bool

func (CHF) HasIpv6SrcRoutePrefix 

func (s CHF) HasIpv6SrcRoutePrefix() bool

func (CHF) HasSrcBgpAsPath 

func (s CHF) HasSrcBgpAsPath() bool

func (CHF) HasSrcBgpCommunity 

func (s CHF) HasSrcBgpCommunity() bool

func (CHF) HasSrcFlowTags 

func (s CHF) HasSrcFlowTags() bool

func (CHF) HeaderLen 

func (s CHF) HeaderLen() uint32

func (CHF) InBytes 

func (s CHF) InBytes() uint64

func (CHF) InPkts 

func (s CHF) InPkts() uint64

func (CHF) InputPort 

func (s CHF) InputPort() uint32

func (CHF) IpSize 

func (s CHF) IpSize() uint32

func (CHF) Ipv4DstAddr 

func (s CHF) Ipv4DstAddr() uint32

func (CHF) Ipv4DstNextHop 

func (s CHF) Ipv4DstNextHop() uint32

func (CHF) Ipv4NextHop 

func (s CHF) Ipv4NextHop() uint32

func (CHF) Ipv4SrcAddr 

func (s CHF) Ipv4SrcAddr() uint32

func (CHF) Ipv4SrcNextHop 

func (s CHF) Ipv4SrcNextHop() uint32

func (CHF) Ipv6DstAddr 

func (s CHF) Ipv6DstAddr() ([]byte, error)

func (CHF) Ipv6DstNextHop 

func (s CHF) Ipv6DstNextHop() ([]byte, error)

func (CHF) Ipv6DstRoutePrefix 

func (s CHF) Ipv6DstRoutePrefix() ([]byte, error)

func (CHF) Ipv6SrcAddr 

func (s CHF) Ipv6SrcAddr() ([]byte, error)

func (CHF) Ipv6SrcNextHop 

func (s CHF) Ipv6SrcNextHop() ([]byte, error)

func (CHF) Ipv6SrcRoutePrefix 

func (s CHF) Ipv6SrcRoutePrefix() ([]byte, error)

func (CHF) IsMetric 

func (s CHF) IsMetric() bool

func (CHF) L4DstPort 

func (s CHF) L4DstPort() uint32

func (CHF) L4SrcPort 

func (s CHF) L4SrcPort() uint32

func (CHF) MplsType 

func (s CHF) MplsType() uint32

func (CHF) NewCustom 

func (s CHF) NewCustom(n int32) (Custom_List, error)

NewCustom sets the custom field to a newly allocated Custom_List, preferring placement in s's segment.

func (CHF) OutBytes 

func (s CHF) OutBytes() uint64

func (CHF) OutPkts 

func (s CHF) OutPkts() uint64

func (CHF) OutputPort 

func (s CHF) OutputPort() uint32

func (CHF) Protocol 

func (s CHF) Protocol() uint32

func (CHF) SampleAdj 

func (s CHF) SampleAdj() bool

func (CHF) SampleRate 

func (s CHF) SampleRate() uint32

func (CHF) SampledPacketSize 

func (s CHF) SampledPacketSize() uint32

func (CHF) SetAppProtocol 

func (s CHF) SetAppProtocol(v uint32)

func (CHF) SetBig 

func (s CHF) SetBig(v bool)

func (CHF) SetCustom 

func (s CHF) SetCustom(v Custom_List) error

func (CHF) SetDeviceId 

func (s CHF) SetDeviceId(v uint32)

func (CHF) SetDstAs 

func (s CHF) SetDstAs(v uint32)

func (CHF) SetDstBgpAsPath 

func (s CHF) SetDstBgpAsPath(v string) error

func (CHF) SetDstBgpCommunity 

func (s CHF) SetDstBgpCommunity(v string) error

func (CHF) SetDstEthMac 

func (s CHF) SetDstEthMac(v uint64)

func (CHF) SetDstFlowTags 

func (s CHF) SetDstFlowTags(v string) error

func (CHF) SetDstGeo 

func (s CHF) SetDstGeo(v uint32)

func (CHF) SetDstGeoCity 

func (s CHF) SetDstGeoCity(v uint32)

func (CHF) SetDstGeoRegion 

func (s CHF) SetDstGeoRegion(v uint32)

func (CHF) SetDstMac 

func (s CHF) SetDstMac(v uint32)

func (CHF) SetDstNextHopAs 

func (s CHF) SetDstNextHopAs(v uint32)

func (CHF) SetDstRouteLength 

func (s CHF) SetDstRouteLength(v uint8)

func (CHF) SetDstRoutePrefix 

func (s CHF) SetDstRoutePrefix(v uint32)

func (CHF) SetDstSecondAsn 

func (s CHF) SetDstSecondAsn(v uint32)

func (CHF) SetDstThirdAsn 

func (s CHF) SetDstThirdAsn(v uint32)

func (CHF) SetFlowTags 

func (s CHF) SetFlowTags(v string) error

func (CHF) SetHeaderLen 

func (s CHF) SetHeaderLen(v uint32)

func (CHF) SetInBytes 

func (s CHF) SetInBytes(v uint64)

func (CHF) SetInPkts 

func (s CHF) SetInPkts(v uint64)

func (CHF) SetInputPort 

func (s CHF) SetInputPort(v uint32)

func (CHF) SetIpSize 

func (s CHF) SetIpSize(v uint32)

func (CHF) SetIpv4DstAddr 

func (s CHF) SetIpv4DstAddr(v uint32)

func (CHF) SetIpv4DstNextHop 

func (s CHF) SetIpv4DstNextHop(v uint32)

func (CHF) SetIpv4NextHop 

func (s CHF) SetIpv4NextHop(v uint32)

func (CHF) SetIpv4SrcAddr 

func (s CHF) SetIpv4SrcAddr(v uint32)

func (CHF) SetIpv4SrcNextHop 

func (s CHF) SetIpv4SrcNextHop(v uint32)

func (CHF) SetIpv6DstAddr 

func (s CHF) SetIpv6DstAddr(v []byte) error

func (CHF) SetIpv6DstNextHop 

func (s CHF) SetIpv6DstNextHop(v []byte) error

func (CHF) SetIpv6DstRoutePrefix 

func (s CHF) SetIpv6DstRoutePrefix(v []byte) error

func (CHF) SetIpv6SrcAddr 

func (s CHF) SetIpv6SrcAddr(v []byte) error

func (CHF) SetIpv6SrcNextHop 

func (s CHF) SetIpv6SrcNextHop(v []byte) error

func (CHF) SetIpv6SrcRoutePrefix 

func (s CHF) SetIpv6SrcRoutePrefix(v []byte) error

func (CHF) SetIsMetric 

func (s CHF) SetIsMetric(v bool)

func (CHF) SetL4DstPort 

func (s CHF) SetL4DstPort(v uint32)

func (CHF) SetL4SrcPort 

func (s CHF) SetL4SrcPort(v uint32)

func (CHF) SetMplsType 

func (s CHF) SetMplsType(v uint32)

func (CHF) SetOutBytes 

func (s CHF) SetOutBytes(v uint64)

func (CHF) SetOutPkts 

func (s CHF) SetOutPkts(v uint64)

func (CHF) SetOutputPort 

func (s CHF) SetOutputPort(v uint32)

func (CHF) SetProtocol 

func (s CHF) SetProtocol(v uint32)

func (CHF) SetSampleAdj 

func (s CHF) SetSampleAdj(v bool)

func (CHF) SetSampleRate 

func (s CHF) SetSampleRate(v uint32)

func (CHF) SetSampledPacketSize 

func (s CHF) SetSampledPacketSize(v uint32)

func (CHF) SetSrcAs 

func (s CHF) SetSrcAs(v uint32)

func (CHF) SetSrcBgpAsPath 

func (s CHF) SetSrcBgpAsPath(v string) error

func (CHF) SetSrcBgpCommunity 

func (s CHF) SetSrcBgpCommunity(v string) error

func (CHF) SetSrcEthMac 

func (s CHF) SetSrcEthMac(v uint64)

func (CHF) SetSrcFlowTags 

func (s CHF) SetSrcFlowTags(v string) error

func (CHF) SetSrcGeo 

func (s CHF) SetSrcGeo(v uint32)

func (CHF) SetSrcGeoCity 

func (s CHF) SetSrcGeoCity(v uint32)

func (CHF) SetSrcGeoRegion 

func (s CHF) SetSrcGeoRegion(v uint32)

func (CHF) SetSrcMac 

func (s CHF) SetSrcMac(v uint32)

func (CHF) SetSrcNextHopAs 

func (s CHF) SetSrcNextHopAs(v uint32)

func (CHF) SetSrcRouteLength 

func (s CHF) SetSrcRouteLength(v uint8)

func (CHF) SetSrcRoutePrefix 

func (s CHF) SetSrcRoutePrefix(v uint32)

func (CHF) SetSrcSecondAsn 

func (s CHF) SetSrcSecondAsn(v uint32)

func (CHF) SetSrcThirdAsn 

func (s CHF) SetSrcThirdAsn(v uint32)

func (CHF) SetTcpFlags 

func (s CHF) SetTcpFlags(v uint32)

func (CHF) SetTcpRetransmit 

func (s CHF) SetTcpRetransmit(v uint32)

func (CHF) SetTimestamp 

func (s CHF) SetTimestamp(v int64)

func (CHF) SetTimestampNano 

func (s CHF) SetTimestampNano(v int64)

func (CHF) SetTos 

func (s CHF) SetTos(v uint32)

func (CHF) SetVlanIn 

func (s CHF) SetVlanIn(v uint32)

func (CHF) SetVlanOut 

func (s CHF) SetVlanOut(v uint32)

func (CHF) SrcAs 

func (s CHF) SrcAs() uint32

func (CHF) SrcBgpAsPath 

func (s CHF) SrcBgpAsPath() (string, error)

func (CHF) SrcBgpAsPathBytes 

func (s CHF) SrcBgpAsPathBytes() ([]byte, error)

func (CHF) SrcBgpCommunity 

func (s CHF) SrcBgpCommunity() (string, error)

func (CHF) SrcBgpCommunityBytes 

func (s CHF) SrcBgpCommunityBytes() ([]byte, error)

func (CHF) SrcEthMac 

func (s CHF) SrcEthMac() uint64

func (CHF) SrcFlowTags 

func (s CHF) SrcFlowTags() (string, error)

func (CHF) SrcFlowTagsBytes 

func (s CHF) SrcFlowTagsBytes() ([]byte, error)

func (CHF) SrcGeo 

func (s CHF) SrcGeo() uint32

func (CHF) SrcGeoCity 

func (s CHF) SrcGeoCity() uint32

func (CHF) SrcGeoRegion 

func (s CHF) SrcGeoRegion() uint32

func (CHF) SrcMac 

func (s CHF) SrcMac() uint32

func (CHF) SrcNextHopAs 

func (s CHF) SrcNextHopAs() uint32

func (CHF) SrcRouteLength 

func (s CHF) SrcRouteLength() uint8

func (CHF) SrcRoutePrefix 

func (s CHF) SrcRoutePrefix() uint32

func (CHF) SrcSecondAsn 

func (s CHF) SrcSecondAsn() uint32

func (CHF) SrcThirdAsn 

func (s CHF) SrcThirdAsn() uint32

func (CHF) String 

func (s CHF) String() string

func (CHF) TcpFlags 

func (s CHF) TcpFlags() uint32

func (CHF) TcpRetransmit 

func (s CHF) TcpRetransmit() uint32

func (CHF) Timestamp 

func (s CHF) Timestamp() int64

func (CHF) TimestampNano 

func (s CHF) TimestampNano() int64

func (CHF) Tos 

func (s CHF) Tos() uint32

func (CHF) VlanIn 

func (s CHF) VlanIn() uint32

func (CHF) VlanOut 

func (s CHF) VlanOut() uint32

type CHF_List 

type CHF_List struct{ capnp.List }

CHF_List is a list of CHF.

func NewCHF_List 

func NewCHF_List(s *capnp.Segment, sz int32) (CHF_List, error)

NewCHF creates a new list of CHF.

func (CHF_List) At 

func (s CHF_List) At(i int) CHF

func (CHF_List) Set 

func (s CHF_List) Set(i int, v CHF) error

func (CHF_List) String 

func (s CHF_List) String() string

type CHF_Promise 

type CHF_Promise struct{ *capnp.Pipeline }

CHF_Promise is a wrapper for a CHF promised by a client call.

func (CHF_Promise) Struct 

func (p CHF_Promise) Struct() (CHF, error)

type Custom 

type Custom struct{ capnp.Struct }

func NewCustom 

func NewCustom(s *capnp.Segment) (Custom, error)

func NewRootCustom 

func NewRootCustom(s *capnp.Segment) (Custom, error)

func ReadRootCustom 

func ReadRootCustom(msg *capnp.Message) (Custom, error)

func (Custom) Id 

func (s Custom) Id() uint32

func (Custom) IsDimension 

func (s Custom) IsDimension() bool

func (Custom) SetId 

func (s Custom) SetId(v uint32)

func (Custom) SetIsDimension 

func (s Custom) SetIsDimension(v bool)

func (Custom) String 

func (s Custom) String() string

func (Custom) Value 

func (s Custom) Value() Custom_value

type Custom_List 

type Custom_List struct{ capnp.List }

Custom_List is a list of Custom.

func NewCustom_List 

func NewCustom_List(s *capnp.Segment, sz int32) (Custom_List, error)

NewCustom creates a new list of Custom.

func (Custom_List) At 

func (s Custom_List) At(i int) Custom

func (Custom_List) Set 

func (s Custom_List) Set(i int, v Custom) error

func (Custom_List) String 

func (s Custom_List) String() string

type Custom_Promise 

type Custom_Promise struct{ *capnp.Pipeline }

Custom_Promise is a wrapper for a Custom promised by a client call.

func (Custom_Promise) Struct 

func (p Custom_Promise) Struct() (Custom, error)

func (Custom_Promise) Value 

func (p Custom_Promise) Value() Custom_value_Promise

type Custom_value 

type Custom_value Custom

func (Custom_value) AddrVal 

func (s Custom_value) AddrVal() ([]byte, error)

func (Custom_value) Float32Val 

func (s Custom_value) Float32Val() float32

func (Custom_value) HasAddrVal 

func (s Custom_value) HasAddrVal() bool

func (Custom_value) HasStrVal 

func (s Custom_value) HasStrVal() bool

func (Custom_value) SetAddrVal 

func (s Custom_value) SetAddrVal(v []byte) error

func (Custom_value) SetFloat32Val 

func (s Custom_value) SetFloat32Val(v float32)

func (Custom_value) SetStrVal 

func (s Custom_value) SetStrVal(v string) error

func (Custom_value) SetUint16Val 

func (s Custom_value) SetUint16Val(v uint16)

func (Custom_value) SetUint32Val 

func (s Custom_value) SetUint32Val(v uint32)

func (Custom_value) SetUint64Val 

func (s Custom_value) SetUint64Val(v uint64)

func (Custom_value) SetUint8Val 

func (s Custom_value) SetUint8Val(v uint8)

func (Custom_value) StrVal 

func (s Custom_value) StrVal() (string, error)

func (Custom_value) StrValBytes 

func (s Custom_value) StrValBytes() ([]byte, error)

func (Custom_value) Uint16Val 

func (s Custom_value) Uint16Val() uint16

func (Custom_value) Uint32Val 

func (s Custom_value) Uint32Val() uint32

func (Custom_value) Uint64Val 

func (s Custom_value) Uint64Val() uint64

func (Custom_value) Uint8Val 

func (s Custom_value) Uint8Val() uint8

func (Custom_value) Which 

func (s Custom_value) Which() Custom_value_Which

type Custom_value_Promise 

type Custom_value_Promise struct{ *capnp.Pipeline }

Custom_value_Promise is a wrapper for a Custom_value promised by a client call.

func (Custom_value_Promise) Struct 

func (p Custom_value_Promise) Struct() (Custom_value, error)

type Custom_value_Which 

type Custom_value_Which uint16
const (
	Custom_value_Which_uint32Val  Custom_value_Which = 0
	Custom_value_Which_float32Val Custom_value_Which = 1
	Custom_value_Which_strVal     Custom_value_Which = 2
	Custom_value_Which_uint64Val  Custom_value_Which = 3
	Custom_value_Which_addrVal    Custom_value_Which = 4
	Custom_value_Which_uint16Val  Custom_value_Which = 5
	Custom_value_Which_uint8Val   Custom_value_Which = 6
)

func (Custom_value_Which) String 

func (w Custom_value_Which) String() string

type CustomsIndex 

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

CustomsIndex indexes a company's custom column values for a single flow record at a time in a performant way, using a few slices (two []uint32 and one []Custom_value), no maps, no clean-up processing when finished with a flow. The only allocations made are three slices at initialization.

Performance: - when indexing a flow, we scan its Customs list once, read once from a []uint32, write to two slices - when fetching a Custom by custom dimension ID, we read from 3 slices

func NewCustomsIndex 

func NewCustomsIndex(companyCIDs []uint32) *CustomsIndex

NewCustomsIndex builds a new CustomsIndex for a company, with all of the custom dimension IDs that will be considered.

func (*CustomsIndex) CustomColumnWithID 

func (c *CustomsIndex) CustomColumnWithID(customDimensionID uint32) (Custom_value, bool)

CustomColumnWithID returns custom column for the input ID - make sure to check the second "found" return value. If false, you'll likely get dangerous garbage you shouldn't mess with.

func (*CustomsIndex) IndexFlow 

func (c *CustomsIndex) IndexFlow(flow CHF)

IndexFlow indexes the input flow - the flow's customs will only ever be scanned once

type PackedCHF 

type PackedCHF struct{ capnp.Struct }

func NewPackedCHF 

func NewPackedCHF(s *capnp.Segment) (PackedCHF, error)

func NewRootPackedCHF 

func NewRootPackedCHF(s *capnp.Segment) (PackedCHF, error)

func ReadRootPackedCHF 

func ReadRootPackedCHF(msg *capnp.Message) (PackedCHF, error)

func (PackedCHF) HasMsgs 

func (s PackedCHF) HasMsgs() bool

func (PackedCHF) Msgs 

func (s PackedCHF) Msgs() (CHF_List, error)

func (PackedCHF) NewMsgs 

func (s PackedCHF) NewMsgs(n int32) (CHF_List, error)

NewMsgs sets the msgs field to a newly allocated CHF_List, preferring placement in s's segment.

func (PackedCHF) SetMsgs 

func (s PackedCHF) SetMsgs(v CHF_List) error

func (PackedCHF) String 

func (s PackedCHF) String() string

type PackedCHF_List 

type PackedCHF_List struct{ capnp.List }

PackedCHF_List is a list of PackedCHF.

func NewPackedCHF_List 

func NewPackedCHF_List(s *capnp.Segment, sz int32) (PackedCHF_List, error)

NewPackedCHF creates a new list of PackedCHF.

func (PackedCHF_List) At 

func (s PackedCHF_List) At(i int) PackedCHF

func (PackedCHF_List) Set 

func (s PackedCHF_List) Set(i int, v PackedCHF) error

func (PackedCHF_List) String 

func (s PackedCHF_List) String() string

type PackedCHF_Promise 

type PackedCHF_Promise struct{ *capnp.Pipeline }

PackedCHF_Promise is a wrapper for a PackedCHF promised by a client call.

func (PackedCHF_Promise) Struct 

func (p PackedCHF_Promise) Struct() (PackedCHF, error)

type Uint32Slice 

type Uint32Slice []uint32

Uint32Slice attaches the methods of sort.Interface to []uint32, sorting in increasing order.

func (Uint32Slice) Len 

func (s Uint32Slice) Len() int

func (Uint32Slice) Less 

func (s Uint32Slice) Less(i, j int) bool

func (Uint32Slice) Sort 

func (s Uint32Slice) Sort()

Sort is a convenience method.

func (Uint32Slice) Swap 

func (s Uint32Slice) Swap(i, j int)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.