# Path: duct/protocol/sflow/protocol/flows.py
# class IPv4Header(object):
# class ISO8023Header(object):
# class IPv6Header(object):
# class IEEE80211MACHeader(object):
# class PPPHeader(object):
# class HeaderSample(object):
# class EthernetSample(object):
# class IPV4Sample(object):
# class IPV6Sample(object):
# class SwitchSample(object):
# class RouterSample(object):
# class GatewaySample(object):
# class UserSample(object):
# class URLSample(object):
# class MPLSSample(object):
# class NATSample(object):
# class MPLSTunnelSample(object):
# class MPLSVCSample(object):
# class MPLSFTNSample(object):
# class MPLSLDPFECSample(object):
# class VLANTunnelSample(object):
#     def __init__(self, data):
#     def __init__(self, data):
#     def __init__(self, u):
#     def __init__(self, u):
#     def __init__(self, u):
#     def __init__(self, u):
#     def __init__(self, u):
#     def __init__(self, u):
#     def __init__(self, u):
#     def __init__(self, u):
#     def __init__(self, u):
#     def __init__(self, u):
#     def __init__(self, u):
#     def __init__(self, u):
#     def __init__(self, u):
#     def __init__(self, u):
#     def __init__(self, u):
#     def __init__(self, u):
#     def __init__(self, u):
#     def __init__(self, u):
#     def __init__(self, u):
# def getDecoder(fmt):
# 
# Path: duct/protocol/sflow/protocol/counters.py
# class InterfaceCounters(object):
# class EthernetCounters(object):
# class VLANCounters(object):
# class TokenringCounters(object):
# class VGCounters(object):
# class HostCounters(object):
# class HostAdapters(object):
# class HostParent(object):
# class HostCPUCounters(object):
# class HostMemoryCounters(object):
# class DiskIOCounters(object):
# class NetIOCounters(object):
# class SocketIPv4Counters(object):
# class SocketIPv6Counters(object):
# class VirtMemoryCounters(object):
# class VirtDiskIOCounters(object):
# class VirtNetIOCounters(object):
#     def __init__(self, u):
#     def __init__(self, u):
#     def __init__(self, u):
#     def __init__(self, u):
#     def __init__(self, u):
#     def __init__(self, u):
#     def __init__(self, u):
#     def __init__(self, u):
#     def __init__(self, u):
#     def __init__(self, u):
#     def __init__(self, u):
#     def __init__(self, u):
#     def __init__(self, u):
#     def __init__(self, u):
#     def __init__(self, u):
#     def __init__(self, u):
#     def __init__(self, u):
# def getDecoder(fmt):


import xdrlib
from duct.protocol.sflow.protocol import flows, counters
        for _i in range(self.record_count):
            flow_format = u.unpack_uint()
            flow_head = u.unpack_opaque()
            flow_u = xdrlib.Unpacker(flow_head)

            d = flows.getDecoder(flow_format)
            if d:
                self.flows[flow_format] = d(flow_u)

class CounterSample(object):
    """Counter sample object
    """
    def __init__(self, u):

        self.size = u.unpack_uint()
        self.sequence = u.unpack_uint()

        self.source_id = u.unpack_uint()

        self.record_count = u.unpack_uint()

        self.counters = {}

        for _i in range(self.record_count):
            counter_format = u.unpack_uint()
            counter = u.unpack_opaque()

            d = counters.getDecoder(counter_format)

            if d:

# Path: duct/protocol/sflow/protocol/flows.py
# class IPv4Header(object):
# class ISO8023Header(object):
# class IPv6Header(object):
# class IEEE80211MACHeader(object):
# class PPPHeader(object):
# class HeaderSample(object):
# class EthernetSample(object):
# class IPV4Sample(object):
# class IPV6Sample(object):
# class SwitchSample(object):
# class RouterSample(object):
# class GatewaySample(object):
# class UserSample(object):
# class URLSample(object):
# class MPLSSample(object):
# class NATSample(object):
# class MPLSTunnelSample(object):
# class MPLSVCSample(object):
# class MPLSFTNSample(object):
# class MPLSLDPFECSample(object):
# class VLANTunnelSample(object):
#     def __init__(self, data):
#     def __init__(self, data):
#     def __init__(self, u):
#     def __init__(self, u):
#     def __init__(self, u):
#     def __init__(self, u):
#     def __init__(self, u):
#     def __init__(self, u):
#     def __init__(self, u):
#     def __init__(self, u):
#     def __init__(self, u):
#     def __init__(self, u):
#     def __init__(self, u):
#     def __init__(self, u):
#     def __init__(self, u):
#     def __init__(self, u):
#     def __init__(self, u):
#     def __init__(self, u):
#     def __init__(self, u):
#     def __init__(self, u):
#     def __init__(self, u):
# def getDecoder(fmt):
# 
# Path: duct/protocol/sflow/protocol/counters.py
# class InterfaceCounters(object):
# class EthernetCounters(object):
# class VLANCounters(object):
# class TokenringCounters(object):
# class VGCounters(object):
# class HostCounters(object):
# class HostAdapters(object):
# class HostParent(object):
# class HostCPUCounters(object):
# class HostMemoryCounters(object):
# class DiskIOCounters(object):
# class NetIOCounters(object):
# class SocketIPv4Counters(object):
# class SocketIPv6Counters(object):
# class VirtMemoryCounters(object):
# class VirtDiskIOCounters(object):
# class VirtNetIOCounters(object):
#     def __init__(self, u):
#     def __init__(self, u):
#     def __init__(self, u):
#     def __init__(self, u):
#     def __init__(self, u):
#     def __init__(self, u):
#     def __init__(self, u):
#     def __init__(self, u):
#     def __init__(self, u):
#     def __init__(self, u):
#     def __init__(self, u):
#     def __init__(self, u):
#     def __init__(self, u):
#     def __init__(self, u):
#     def __init__(self, u):
#     def __init__(self, u):
#     def __init__(self, u):
# def getDecoder(fmt):


# Path: duct/protocol/sflow/protocol/protocol.py
import xdrlib
from duct.protocol.sflow.protocol import flows, counters

        for _i in range(self.record_count):
            flow_format = u.unpack_uint()
            flow_head = u.unpack_opaque()
            flow_u = xdrlib.Unpacker(flow_head)

            d = flows.getDecoder(flow_format)
            if d:
                self.flows[flow_format] = d(flow_u)

class CounterSample(object):
    """Counter sample object
    """
    def __init__(self, u):

        self.size = u.unpack_uint()
        self.sequence = u.unpack_uint()

        self.source_id = u.unpack_uint()

        self.record_count = u.unpack_uint()

        self.counters = {}

        for _i in range(self.record_count):
            counter_format = u.unpack_uint()
            counter = u.unpack_opaque()

            d = counters.getDecoder(counter_format)

            if d:

                self.counters[counter_format] = d(xdrlib.Unpacker(counter))