5 #ifndef __PKT_SANDESH_FLOW_H__
6 #define __PKT_SANDESH_FLOW_H__
10 #include "pkt/pkt_types.h"
56 FlowStatsCollectorRecordsResp *
resp_;
virtual bool Run()
Code to execute. Returns true if task is completed. Return false to reschedule the task.
virtual ~PktSandeshFlowStats()
DISALLOW_COPY_AND_ASSIGN(PktSandeshFlowStats)
bool SetProto(std::string &key)
FlowStatsCollectorRecordsResp * resp_
bool SetProtoKey(std::string key)
PktSandeshFlowStats(Agent *agent, FlowStatsCollectorRecordsResp *obj, std::string resp_ctx, std::string key)
void set_delete_op(bool delete_op)
static const std::string start_key
FlowKey flow_iteration_key_
static const int kMaxFlowResponse
virtual ~PktSandeshFlow()
void SetSandeshFlowData(std::vector< SandeshFlowData > &list, FlowEntry *fe, const FlowExportInfo *info)
static std::string GetFlowKey(const FlowKey &key, uint16_t partition_id)
std::string Description() const
virtual bool Run()
Code to execute. Returns true if task is completed. Return false to reschedule the task.
bool SetFlowKey(std::string key)
DISALLOW_COPY_AND_ASSIGN(PktSandeshFlow)
PktSandeshFlow(Agent *agent, FlowRecordsResp *obj, std::string resp_ctx, std::string key)
void SendResponse(SandeshResponse *resp)
static const char kDelimiter
FlowRecordsResp * resp_obj_
Task is a wrapper over tbb::task to support policies.