protoproducer

package

Go to main page

Versions in this module

v2

v2.1.3

Mar 24, 2024

v2.1.2

Jan 20, 2024

Changes in this version

+ func StringRenderer(msg *ProtoProducerMessage, fieldName string, data interface{}) interface

type RendererID

+ const RendererString

v2.1.1

Jan 6, 2024

v2.1.0

Jan 1, 2024

Changes in this version

+ func DateTimeNanoRenderer(msg *ProtoProducerMessage, fieldName string, data interface{}) interface

+ func DateTimeRenderer(msg *ProtoProducerMessage, fieldName string, data interface{}) interface

+ func Is8021Q(etherType []byte) bool

+ func IsARP(etherType []byte) bool

+ func IsIPv4(etherType []byte) bool

+ func IsIPv6(etherType []byte) bool

+ func IsMPLS(etherType []byte) bool

+ func Parse8021Q(offset int, flowMessage *ProtoProducerMessage, data []byte) (etherType []byte, newOffset int, err error)

+ func ParseEthernet(offset int, flowMessage *ProtoProducerMessage, data []byte) (etherType []byte, newOffset int, err error)

+ func ParseICMP(offset int, flowMessage *ProtoProducerMessage, data []byte) (newOffset int, err error)

+ func ParseICMPv6(offset int, flowMessage *ProtoProducerMessage, data []byte) (newOffset int, err error)

+ func ParseIPv4(offset int, flowMessage *ProtoProducerMessage, data []byte) (nextHeader byte, newOffset int, err error)

+ func ParseIPv6(offset int, flowMessage *ProtoProducerMessage, data []byte) (nextHeader byte, newOffset int, err error)

+ func ParseIPv6Headers(nextHeader byte, offset int, flowMessage *ProtoProducerMessage, data []byte) (newNextHeader byte, newOffset int, err error)

+ func ParseMPLS(offset int, flowMessage *ProtoProducerMessage, data []byte) (etherType []byte, newOffset int, err error)

+ func ParseTCP(offset int, flowMessage *ProtoProducerMessage, data []byte) (newOffset int, err error)

+ func ParseUDP(offset int, flowMessage *ProtoProducerMessage, data []byte) (newOffset int, err error)

type RendererID

+ const RendererDateTime

+ const RendererDateTimeNano

v2.0.0

Apr 16, 2023

Changes in this version

+ var BigEndian EndianType = "big"

+ var LittleEndian EndianType = "little"

+ var ProtoString ProtoType = "string"

+ var ProtoTypeMap = map[string]ProtoType

+ var ProtoVarint ProtoType = "varint"

+ func ConvertNetFlowDataSet(flowMessage *ProtoProducerMessage, version uint16, baseTime uint32, ...) error

+ func ConvertNetFlowLegacyRecord(flowMessage *ProtoProducerMessage, baseTime uint64, uptime uint32, ...)

+ func CreateProtoProducer(cfg *ProducerConfig, samplingRateSystem func() SamplingRateSystem) (producer.ProducerInterface, error)

+ func DecodeNumber(b []byte, out interface{}) error

+ func DecodeNumberLE(b []byte, out interface{}) error

+ func DecodeUNumber(b []byte, out interface{}) error

+ func DecodeUNumberLE(b []byte, out interface{}) error

+ func EtypeRenderer(msg *ProtoProducerMessage, fieldName string, data interface{}) interface

+ func ExtractTag(name, original string, tag reflect.StructTag) string

+ func GetBytes(d []byte, offset int, length int) []byte

+ func GetSFlowFlowSamples(packet *sflow.Packet) []interface

+ func ICMPRenderer(msg *ProtoProducerMessage, fieldName string, data interface{}) interface

+ func IPRenderer(msg *ProtoProducerMessage, fieldName string, data interface{}) interface

+ func IcmpCodeType(proto, icmpCode, icmpType uint32) string

+ func IsInt(k reflect.Kind) bool

+ func IsUInt(k reflect.Kind) bool

+ func MacRenderer(msg *ProtoProducerMessage, fieldName string, data interface{}) interface

+ func MapCustom(flowMessage *ProtoProducerMessage, v []byte, cfg MapConfigBase) error

+ func MapCustomNetFlow(flowMessage *ProtoProducerMessage, df netflow.DataField, mapper *NetFlowMapper) error

+ func NetFlowLookFor(dataFields []netflow.DataField, typeId uint16) (bool, interface{})

+ func NetFlowPopulate(dataFields []netflow.DataField, typeId uint16, addr interface{}) (bool, error)

+ func NetworkRenderer(msg *ProtoProducerMessage, fieldName string, data interface{}) interface

+ func NilRenderer(msg *ProtoProducerMessage, fieldName string, data interface{}) interface

+ func ParseEthernetHeader(flowMessage *ProtoProducerMessage, data []byte, config *SFlowMapper) error

+ func ParseSampledHeader(flowMessage *ProtoProducerMessage, sampledHeader *sflow.SampledHeader) error

+ func ParseSampledHeaderConfig(flowMessage *ProtoProducerMessage, sampledHeader *sflow.SampledHeader, ...) error

+ func ProcessMessageIPFIXConfig(packet *netflow.IPFIXPacket, samplingRateSys SamplingRateSystem, ...) (flowMessageSet []producer.ProducerMessage, err error)

+ func ProcessMessageNetFlowLegacy(packet *netflowlegacy.PacketNetFlowV5) ([]producer.ProducerMessage, error)

+ func ProcessMessageNetFlowV9Config(packet *netflow.NFv9Packet, samplingRateSys SamplingRateSystem, ...) (flowMessageSet []producer.ProducerMessage, err error)

+ func ProcessMessageSFlowConfig(packet *sflow.Packet, config *producerConfigMapped) (flowMessageSet []producer.ProducerMessage, err error)

+ func ProtoRenderer(msg *ProtoProducerMessage, fieldName string, data interface{}) interface

+ func RenderIP(addr []byte) string

+ func SearchNetFlowDataSets(version uint16, baseTime uint32, uptime uint32, ...) (flowMessageSet []producer.ProducerMessage, err error)

+ func SearchNetFlowDataSetsRecords(version uint16, baseTime uint32, uptime uint32, ...) (flowMessageSet []producer.ProducerMessage, err error)

+ func SearchNetFlowLegacyRecords(baseTime uint64, uptime uint32, dataRecords []netflowlegacy.RecordsNetFlowV5) (flowMessageSet []producer.ProducerMessage)

+ func SearchNetFlowOptionDataSets(dataFlowSet []netflow.OptionsDataFlowSet) (samplingRate uint32, found bool, err error)

+ func SearchSFlowSampleConfig(flowMessage *ProtoProducerMessage, flowSample interface{}, config *SFlowMapper) error

+ func SearchSFlowSamplesConfig(samples []interface{}, config *SFlowMapper) (flowMessageSet []producer.ProducerMessage, err error)

+ func SplitIPFIXSets(packetIPFIX netflow.IPFIXPacket) ([]netflow.DataFlowSet, []netflow.TemplateFlowSet, ...)

+ func SplitNetFlowSets(packetNFv9 netflow.NFv9Packet) ([]netflow.DataFlowSet, []netflow.TemplateFlowSet, ...)

+ func WriteDecoded(o int64, out interface{}) error

+ func WriteUDecoded(o uint64, out interface{}) error

+ type DataMap struct

+ type DataMapLayer struct

+ Length int

+ Offset int

+ func GetSFlowConfigLayer(m *SFlowMapper, layer string) []DataMapLayer

+ type EndianType string

+ type FormatterConfig struct

+ Fields []string

+ Key []string

+ Protobuf []ProtobufFormatterConfig

+ Rename map[string]string

+ Render map[string]RendererID

+ type FormatterConfigMapper struct

+ type IPFIXProducerConfig struct

+ Mapping []NetFlowMapField

+ type MapConfigBase struct

+ Destination string

+ Endianness EndianType

+ ProtoArray bool

+ ProtoIndex int32

+ ProtoType ProtoType

+ type NetFlowMapField struct

+ Destination string

+ Endian EndianType

+ Pen uint32

+ PenProvided bool

+ Type uint16

+ type NetFlowMapper struct

+ func (m *NetFlowMapper) Map(field netflow.DataField) (DataMap, bool)

+ type NetFlowV9ProducerConfig struct

+ Mapping []NetFlowMapField

+ type ProducerConfig struct

+ Formatter FormatterConfig

+ IPFIX IPFIXProducerConfig

+ NetFlowV9 NetFlowV9ProducerConfig

+ SFlow SFlowProducerConfig

+ type ProtoProducer struct

+ func (p *ProtoProducer) Close()

+ func (p *ProtoProducer) Commit(flowMessageSet []producer.ProducerMessage)

+ func (p *ProtoProducer) Produce(msg interface{}, args *producer.ProduceArgs) (flowMessageSet []producer.ProducerMessage, err error)

+ type ProtoProducerMessage struct

+ func (m *ProtoProducerMessage) FormatMessageReflectCustom(ext, quotes, sep, sign string, null bool) string

+ func (m *ProtoProducerMessage) FormatMessageReflectJSON(ext string) string

+ func (m *ProtoProducerMessage) FormatMessageReflectText(ext string) string

+ func (m *ProtoProducerMessage) Key() []byte

+ func (m *ProtoProducerMessage) MarshalBinary() ([]byte, error)

+ func (m *ProtoProducerMessage) MarshalJSON() ([]byte, error)

+ func (m *ProtoProducerMessage) MarshalText() ([]byte, error)

+ type ProtoType string

+ type ProtobufFormatterConfig struct

+ Array bool

+ Index int32

+ Name string

+ Type string

+ type RenderFunc func(msg *ProtoProducerMessage, fieldName string, data interface{}) interface

+ type RendererID string

+ const RendererEtype

+ const RendererIP

+ const RendererMac

+ const RendererNetwork

+ const RendererNone

+ const RendererProto

+ const RendererType

+ type SFlowMapField struct

+ Destination string

+ Endian EndianType

+ Layer string

+ Length int

+ Offset int

+ type SFlowMapper struct

+ type SFlowProducerConfig struct

+ Mapping []SFlowMapField

+ type SamplingRateSystem interface

+ AddSamplingRate func(version uint16, obsDomainId uint32, samplingRate uint32)

+ GetSamplingRate func(version uint16, obsDomainId uint32) (uint32, error)

+ func CreateSamplingSystem() SamplingRateSystem

+ type SingleSamplingRateSystem struct

+ Sampling uint32

+ func (s *SingleSamplingRateSystem) AddSamplingRate(version uint16, obsDomainId uint32, samplingRate uint32)

+ func (s *SingleSamplingRateSystem) GetSamplingRate(version uint16, obsDomainId uint32) (uint32, error)

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