flow

type ApiRequest struct {
	RecordType int
	ItemType   int
	Request    *http.Request
}

type ApiResponse struct {
	Body   *string
	Status int
}

type Base struct {
	RecType   string `json:"recType,omitempty"`
	Identity  string `json:"identity,omitempty"`
	Parent    string `json:"parent,omitempty"`
	StartTime uint64 `json:"startTime,omitempty"`
	EndTime   uint64 `json:"endTime,omitempty"`
}

type BeaconRecord struct {
	Version    uint32 `json:"version,omitempty"`
	SourceType string `json:"sourceType,omitempty"`
	Address    string `json:"address,omitempty"`
	Direct     string `json:"direct,omitempty"`
	Now        uint64 `json:"now,omitempty"`
	Identity   string `json:"identity,omitempty"`
}

type CollectorRecord struct {
	Base
}

type ConnectorRecord struct {
	Base
	DestHost    *string `json:"destHost,omitempty"`
	DestPort    *string `json:"destPort,omitempty"`
	Protocol    *string `json:"protocol,omitempty"`
	Address     *string `json:"address,omitempty"`
	FlowCountL4 *uint64 `json:"flowCountL4,omitempty"`
	FlowRateL4  *uint64 `json:"flowRateL4,omitempty"`
	FlowCountL7 *uint64 `json:"flowCountL7,omitempty"`
	FlowRateL7  *uint64 `json:"flowRateL7,omitempty"`
	// contains filtered or unexported fields
}

type ControllerRecord struct {
	ImageName    string `json:"imageName,omitempty"`
	ImageVersion string `json:"imageVersion,omitempty"`
	Hostname     string `json:"hostame,omitempty"`
	Name         string `json:"name,omitempty"`
	BuildVersion string `json:"buildVersion,omitempty"`
	// contains filtered or unexported fields
}

type EgressRecord struct {
	Base
}

type FlowAggregateRecord struct {
	Base
	PairType                  string  `json:"pairType,omitempty"`
	RecordCount               uint64  `json:"recordCount,omitempty"`
	SourceId                  *string `json:"sourceId,omitempty"`
	SourceName                *string `json:"sourceName,omitempty"`
	DestinationId             *string `json:"destinationId,omitempty"`
	DestinationName           *string `json:"destinationName,omitempty"`
	SourceOctets              uint64  `json:"sourceOctets,omitempty"`
	SourceOctetRate           uint64  `json:"sourceOctetRate,omitempty"`
	SourceMinLatency          uint64  `json:"sourceMinLatency,omitempty"`
	SourceMaxLatency          uint64  `json:"sourceMaxLatency,omitempty"`
	SourceAverageLatency      uint64  `json:"sourceAverageLatency,omitempty"`
	DestinationOctets         uint64  `json:"destinationOctets,omitempty"`
	DestinationOctetRate      uint64  `json:"destinationOctetRate,omitempty"`
	DestinationMinLatency     uint64  `json:"destinationMinLatency,omitempty"`
	DestinationMaxLatency     uint64  `json:"destinationMaxLatency,omitempty"`
	DestinationAverageLatency uint64  `json:"destinationAverageLatency,omitempty"`
}

type FlowCollector struct {
	Request  chan ApiRequest
	Response chan ApiResponse

	Beacons        map[string]*BeaconRecord
	Sites          map[string]*SiteRecord
	Hosts          map[string]*HostRecord
	Routers        map[string]*RouterRecord
	Links          map[string]*LinkRecord
	Listeners      map[string]*ListenerRecord
	Connectors     map[string]*ConnectorRecord
	Flows          map[string]*FlowRecord
	FlowPairs      map[string]*FlowPairRecord
	FlowAggregates map[string]*FlowAggregateRecord
	Processes      map[string]*ProcessRecord
	ProcessGroups  map[string]*ProcessGroupRecord
	VanAddresses   map[string]*VanAddressRecord
	// contains filtered or unexported fields
}

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

type FlowPairRecord struct {
	Base
	SourceSiteId            string      `json:"sourceSiteId,omitempty"`
	DestinationSiteId       string      `json:"destinationSiteId,omitempty"`
	ForwardFlow             *FlowRecord `json:"forwardFlow,omitempty"`
	CounterFlow             *FlowRecord `json:"counterFlow,omitempty"`
	SiteAggregateId         *string     `json:"siteAggregateId,omitempty"`
	ProcessGroupAggregateId *string     `json:"processGroupAggregateId,omitempty"`
	ProcessAggregateId      *string     `json:"processAggregateId,omitempty"`
}

type FlowRecord struct {
	Base
	SourceHost     *string `json:"sourceHost,omitempty"`
	SourcePort     *string `json:"sourcePort,omitempty"`
	CounterFlow    *string `json:"counterFlow,omitempty"`
	Trace          *string `json:"trace,omitempty"`
	Latency        *uint64 `json:"latency,omitempty"`
	Octets         *uint64 `json:"octets"`
	OctetRate      *uint64 `json:"octetRate"`
	OctetsOut      *uint64 `json:"octetsOut,omitempty"`
	OctetsUnacked  *uint64 `json:"octetsUnacked,omitempty"`
	WindowClosures *uint64 `json:"windowClosures,omitempty"`
	WindowSize     *uint64 `json:"windowSize,omitempty"`
	Reason         *string `json:"reason,omitempty"`
	Method         *string `json:"method,omitempty"`
	Result         *string `json:"result,omitempty"`
	Process        *string `json:"process,omitempty"`
	ProcessName    *string `json:"processName,omitempty"`
}

type FlushRecord struct {
	Address string `json:"address,omitempty"`
	Source  string `json:"source,omitempty"`
}

type HeartbeatRecord struct {
	Source   string `json:"source,omityempty"`
	Identity string `json:"identity,omitempty"`
	Version  uint32 `json:"version,omitempty"`
	Now      uint64 `json:"now,omitempty"`
}

type HostRecord struct {
	Base
	Location          *string `json:"location,omitempty"`
	Provider          *string `json:"provider,omitempty"`
	Platform          *string `json:"platform,omitempty"`
	Name              *string `json:"name,omitempty"`
	Arch              *string `json:"arch,omitempty"`
	OperatingSystem   *string `json:"operatingSystem,omitempty"`
	OperatingSystemId *string `json:"operatingSystemId,omitempty"`
	Region            *string `json:"region,omitempty"`
	Zone              *string `json:"zone,omitempty"`
	ContainerRuntime  *string `json:"containerRuntime,omitempty"`
	KernelVersion     *string `json:"kernelVersion,omitempty"`
	KubeProxyVersion  *string `json:"kubeProxyVersion,omitempty"`
	KubeletVersion    *string `json:"kubeletVersion,omitempty"`
}

type ImageRecord struct {
	Base
	Name    string `json:"name,omitempty"`
	Version string `json:"version,omitempty"`
}

type IngressRecord struct {
	Base
}

type LinkRecord struct {
	Base
	Mode      *string `json:"mode,omitempty"`
	Name      *string `json:"name,omitempty"`
	LinkCost  *uint64 `json:"linkCost,omitempty"`
	Direction *string `json:"direction,omitempty"`
}

type ListenerRecord struct {
	Base
	Name        *string `json:"name,omitempty"`
	DestHost    *string `json:"destHost,omitempty"`
	DestPort    *string `json:"destPort,omitempty"`
	Protocol    *string `json:"protocol,omitempty"`
	Address     *string `json:"address,omitempty"`
	FlowCountL4 *uint64 `json:"flowCountL4,omitempty"`
	FlowRateL4  *uint64 `json:"flowRateL4,omitempty"`
	FlowCountL7 *uint64 `json:"flowCountL7,omitempty"`
	FlowRateL7  *uint64 `json:"flowRateL7,omitempty"`
}

type Payload struct {
	Results       interface{} `json:"results,omitempty"`
	Timestamp     uint64      `json:"timestamp,omitempty"`
	LengthTotal   int         `json:"lengthTotal,omitempty"`
	LengthResults int         `json:"lengthResults,omitempty"`
}

type ProcessGroupRecord struct {
	Base
	Name               *string `json:"name,omitempty"`
	OctetsSent         uint64  `json:"octetsSent"`
	OctetsSentRate     uint64  `json:"octetSentRate"`
	OctetsReceived     uint64  `json:"octetsReceived"`
	OctetsReceivedRate uint64  `json:"octetReceivedRate"`
}

type ProcessRecord struct {
	Base
	Name               *string `json:"name,omitempty"`
	ParentName         *string `json:"parentName,omitempty"`
	ImageName          *string `json:"imageName,omitempty"`
	Image              *string `json:"image,omitempty"`
	GroupName          *string `json:"groupName,omitempty"`
	GroupIdentity      *string `json:"groupIdentity,omitempty"`
	HostName           *string `json:"hostName,omitempty"`
	SourceHost         *string `json:"sourceHost,omitempty"`
	OctetsSent         uint64  `json:"octetsSent"`
	OctetsSentRate     uint64  `json:"octetSentRate"`
	OctetsReceived     uint64  `json:"octetsReceived"`
	OctetsReceivedRate uint64  `json:"octetReceivedRate"`
	// contains filtered or unexported fields
}

type RouterRecord struct {
	Base
	Name         *string `json:"name,omitempty"`
	Namespace    *string `json:"namespace,omitempty"`
	Mode         *string `json:"mode,omitempty"`
	ImageName    *string `json:"imageName,omitempty"`
	ImageVersion *string `json:"imageVersion,omitempty"`
	Hostname     *string `json:"hostname,omitempty"`
	BuildVersion *string `json:"buildVersion,omitempty"`
}

type SiteRecord struct {
	Base
	Location           *string `json:"location,omitempty"`
	Provider           *string `json:"provider,omitempty"`
	Platform           *string `json:"platform,omitempty"`
	Name               *string `json:"name,omitempty"`
	NameSpace          *string `json:"nameSpace,omitempty"`
	OctetsSent         uint64  `json:"octetsSent"`
	OctetsSentRate     uint64  `json:"octetSentRate"`
	OctetsReceived     uint64  `json:"octetsReceived"`
	OctetsReceivedRate uint64  `json:"octetReceivedRate"`
}

type VanAddressRecord struct {
	Base
	Name           string `json:"name,omitempty"`
	ListenerCount  int    `json:"listenerCount"`
	ConnectorCount int    `json:"connectorCount"`
	TotalFlows     int    `json:"totalFlows"`
	CurrentFlows   int    `json:"currentFlows"`
}