merge branch 'pr-2174'

Sascha Grunert (1):
  Expose network interfaces via runc events

LGTMs: @cyphar @mrunalp
Closes #2174
This commit is contained in:
Aleksa Sarai 2019-12-06 13:07:44 +11:00
commit 5e63695384
No known key found for this signature in database
GPG Key ID: 9E18AA267DDB8DB4
5 changed files with 31 additions and 26 deletions

View File

@ -163,6 +163,7 @@ func convertLibcontainerStats(ls *libcontainer.Stats) *types.Stats {
} }
} }
s.NetworkInterfaces = ls.Interfaces
return &s return &s
} }

View File

@ -10,6 +10,7 @@ import (
"strings" "strings"
"github.com/opencontainers/runc/libcontainer/configs" "github.com/opencontainers/runc/libcontainer/configs"
"github.com/opencontainers/runc/types"
"github.com/vishvananda/netlink" "github.com/vishvananda/netlink"
) )
@ -37,8 +38,8 @@ func getStrategy(tpe string) (networkStrategy, error) {
} }
// Returns the network statistics for the network interfaces represented by the NetworkRuntimeInfo. // Returns the network statistics for the network interfaces represented by the NetworkRuntimeInfo.
func getNetworkInterfaceStats(interfaceName string) (*NetworkInterface, error) { func getNetworkInterfaceStats(interfaceName string) (*types.NetworkInterface, error) {
out := &NetworkInterface{Name: interfaceName} out := &types.NetworkInterface{Name: interfaceName}
// This can happen if the network runtime information is missing - possible if the // This can happen if the network runtime information is missing - possible if the
// container was created by an old version of libcontainer. // container was created by an old version of libcontainer.
if interfaceName == "" { if interfaceName == "" {

View File

@ -1,15 +0,0 @@
package libcontainer
type NetworkInterface struct {
// Name is the name of the network interface.
Name string
RxBytes uint64
RxPackets uint64
RxErrors uint64
RxDropped uint64
TxBytes uint64
TxPackets uint64
TxErrors uint64
TxDropped uint64
}

View File

@ -1,10 +1,13 @@
package libcontainer package libcontainer
import "github.com/opencontainers/runc/libcontainer/cgroups" import (
import "github.com/opencontainers/runc/libcontainer/intelrdt" "github.com/opencontainers/runc/libcontainer/cgroups"
"github.com/opencontainers/runc/libcontainer/intelrdt"
"github.com/opencontainers/runc/types"
)
type Stats struct { type Stats struct {
Interfaces []*NetworkInterface Interfaces []*types.NetworkInterface
CgroupStats *cgroups.Stats CgroupStats *cgroups.Stats
IntelRdtStats *intelrdt.Stats IntelRdtStats *intelrdt.Stats
} }

View File

@ -9,12 +9,13 @@ type Event struct {
// stats is the runc specific stats structure for stability when encoding and decoding stats. // stats is the runc specific stats structure for stability when encoding and decoding stats.
type Stats struct { type Stats struct {
CPU Cpu `json:"cpu"` CPU Cpu `json:"cpu"`
Memory Memory `json:"memory"` Memory Memory `json:"memory"`
Pids Pids `json:"pids"` Pids Pids `json:"pids"`
Blkio Blkio `json:"blkio"` Blkio Blkio `json:"blkio"`
Hugetlb map[string]Hugetlb `json:"hugetlb"` Hugetlb map[string]Hugetlb `json:"hugetlb"`
IntelRdt IntelRdt `json:"intel_rdt"` IntelRdt IntelRdt `json:"intel_rdt"`
NetworkInterfaces []*NetworkInterface `json:"network_interfaces"`
} }
type Hugetlb struct { type Hugetlb struct {
@ -113,3 +114,17 @@ type IntelRdt struct {
// The memory bandwidth schema in 'container_id' group // The memory bandwidth schema in 'container_id' group
MemBwSchema string `json:"mem_bw_schema,omitempty"` MemBwSchema string `json:"mem_bw_schema,omitempty"`
} }
type NetworkInterface struct {
// Name is the name of the network interface.
Name string
RxBytes uint64
RxPackets uint64
RxErrors uint64
RxDropped uint64
TxBytes uint64
TxPackets uint64
TxErrors uint64
TxDropped uint64
}