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()
Click to show internal directories.
Click to hide internal directories.