Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Flow ¶
type Flow struct {
UID string `json:"uid,omitempty"`
Src net.IP `json:"source,omitempty"`
Dst net.IP `json:"destination,omitempty"`
Value uint64 `json:"value,omitempty"`
LastUpdatedTimestamp uint64 `json:"timestamp,omitempty"`
}
Network flow between two endpoints. Value is in bytes/s
type FlowCollector ¶
type FlowCollector struct {
// contains filtered or unexported fields
}
func NewFlowCollector ¶
func NewFlowCollector(c *conntrack.ConnTrack) *FlowCollector
func (*FlowCollector) GetAllFlows ¶
func (this *FlowCollector) GetAllFlows() []*Flow
func (*FlowCollector) OnEndpointsUpdate ¶
func (this *FlowCollector) OnEndpointsUpdate(allEndpoints []api.Endpoints)
Implement k8s.io/pkg/proxy/config/EndpointsConfigHandler Interface.
func (*FlowCollector) Reset ¶
func (this *FlowCollector) Reset()
func (*FlowCollector) TrackFlow ¶
func (this *FlowCollector) TrackFlow()
Source Files
Click to show internal directories.
Click to hide internal directories.