from flow import BaseFlowAnalyze
from services import get_service
from pprint import pprint


class NetflowAnalyze(BaseFlowAnalyze):
    def __init__(self):
        self.netflow_service = get_service("netflow")

    def get_biggest_flow(self, start_time, end_time):
        extra_match = {
            'l4_src_port': 443
        }
        return self.netflow_service.get_ingress_flow(start_time, end_time, addition_match=extra_match)

cbfe36693051816e1b8bf3ff9cf7ab297db08826
<mask token>


class NetflowAnalyze(BaseFlowAnalyze):
    <mask token>
    <mask token>

<mask token>


class NetflowAnalyze(BaseFlowAnalyze):

    def __init__(self):
        self.netflow_service = get_service('netflow')
    <mask token>

<mask token>


class NetflowAnalyze(BaseFlowAnalyze):

    def __init__(self):
        self.netflow_service = get_service('netflow')

    def get_biggest_flow(self, start_time, end_time):
        extra_match = {'l4_src_port': 443}
        return self.netflow_service.get_ingress_flow(start_time, end_time,
            addition_match=extra_match)

from flow import BaseFlowAnalyze
from services import get_service
from pprint import pprint


class NetflowAnalyze(BaseFlowAnalyze):

    def __init__(self):
        self.netflow_service = get_service('netflow')

    def get_biggest_flow(self, start_time, end_time):
        extra_match = {'l4_src_port': 443}
        return self.netflow_service.get_ingress_flow(start_time, end_time,
            addition_match=extra_match)

from flow import BaseFlowAnalyze
from services import get_service
from pprint import pprint


class NetflowAnalyze(BaseFlowAnalyze):
    def __init__(self):
        self.netflow_service = get_service("netflow")

    def get_biggest_flow(self, start_time, end_time):
        extra_match = {
            'l4_src_port': 443
        }
        return self.netflow_service.get_ingress_flow(start_time, end_time, addition_match=extra_match)
