-
Notifications
You must be signed in to change notification settings - Fork 32
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
NETOBSERV-759: decorate flows with agent IP
only for Protocol Buffers encoding. IPFIX is still missing.
- Loading branch information
Mario Macias
committed
Dec 19, 2022
1 parent
0e3f5ea
commit 94114f0
Showing
18 changed files
with
460 additions
and
75 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,137 @@ | ||
| package agent | ||
|
|
||
| import ( | ||
| "fmt" | ||
| "net" | ||
| "strings" | ||
| ) | ||
|
|
||
| // dependencies that can be injected from testing | ||
| var ( | ||
| interfaceByName = net.InterfaceByName | ||
| interfaceAddrs = net.InterfaceAddrs | ||
| dial = net.Dial | ||
| ifaceAddrs = func(iface *net.Interface) ([]net.Addr, error) { | ||
| return iface.Addrs() | ||
| } | ||
| ) | ||
|
|
||
| // fetchAgentIP guesses the non-loopback IP address of the Agent host, according to the | ||
| // user-provided configuration: | ||
| // - If AgentIP is provided, this value is used whatever is the real IP of the Agent. | ||
| // - AgentIPIface specifies which interface this function should look into in order to pickup an address. | ||
| // - AgentIPType specifies which type of IP address should the agent pickup ("any" to pickup whichever | ||
| // ipv4 or ipv6 address is found first) | ||
| func fetchAgentIP(cfg *Config) (net.IP, error) { | ||
| if cfg.AgentIP != "" { | ||
| if ip := net.ParseIP(cfg.AgentIP); ip != nil { | ||
| return ip, nil | ||
| } | ||
| return nil, fmt.Errorf("can't parse provided IP %v", cfg.AgentIP) | ||
| } | ||
|
|
||
| if cfg.AgentIPType != IPTypeAny && | ||
| cfg.AgentIPType != IPTypeIPV6 && | ||
| cfg.AgentIPType != IPTypeIPV4 { | ||
| return nil, fmt.Errorf("invalid IP type %q. Valid values are: %s, %s or %s", | ||
| cfg.AgentIPType, IPTypeIPV4, IPTypeIPV6, IPTypeAny) | ||
| } | ||
|
|
||
| switch cfg.AgentIPIface { | ||
| case IPIfaceLocal: | ||
| return fromLocal(cfg.AgentIPType) | ||
| case IPIfaceExternal: | ||
| return fromExternal(cfg.AgentIPType) | ||
| default: | ||
| if !strings.HasPrefix(cfg.AgentIPIface, IPIfaceNamedPrefix) { | ||
| return nil, fmt.Errorf( | ||
| "invalid IP interface %q. Valid values are: %s, %s or %s<iface_name>", | ||
| cfg.AgentIPIface, IPIfaceLocal, IPIfaceExternal, IPIfaceNamedPrefix) | ||
| } | ||
| return fromInterface(cfg.AgentIPIface[len(IPIfaceNamedPrefix):], cfg.AgentIPType) | ||
| } | ||
| } | ||
|
|
||
| func fromInterface(ifName, ipType string) (net.IP, error) { | ||
| iface, err := interfaceByName(ifName) | ||
| if err != nil { | ||
| return nil, err | ||
| } | ||
| addrs, err := ifaceAddrs(iface) | ||
| if err != nil { | ||
| return nil, err | ||
| } | ||
| if ip, ok := findAddress(addrs, ipType); ok { | ||
| return ip, nil | ||
| } | ||
| return nil, fmt.Errorf("no matching %q addresses found at interface %v", ipType, ifName) | ||
| } | ||
|
|
||
| func fromLocal(ipType string) (net.IP, error) { | ||
| addrs, err := interfaceAddrs() | ||
| if err != nil { | ||
| return nil, err | ||
| } | ||
| if ip, ok := findAddress(addrs, ipType); ok { | ||
| return ip, nil | ||
| } | ||
| return nil, fmt.Errorf("no matching local %q addresses found", ipType) | ||
| } | ||
|
|
||
| func fromExternal(ipType string) (net.IP, error) { | ||
| // We don't really care about the existence or nonexistence of the addresses. | ||
| // This will just establish an external dialer where we can pickup the external | ||
| // host address | ||
| addrStr := "8.8.8.8:80" | ||
| if ipType == IPTypeIPV6 { | ||
| addrStr = "[2001:4860:4860::8888]:80" | ||
| } | ||
| conn, err := dial("udp", addrStr) | ||
| if err != nil { | ||
| return nil, fmt.Errorf("can't establish an external connection %w", err) | ||
| } | ||
| if addr, ok := conn.LocalAddr().(*net.UDPAddr); !ok { | ||
| return nil, fmt.Errorf("unexpected local address type %T for external connection", | ||
| conn.LocalAddr()) | ||
| } else if ip, ok := getIP(addr.IP, ipType); ok { | ||
| return ip, nil | ||
| } | ||
| return nil, fmt.Errorf("no matching %q external addresses found", ipType) | ||
| } | ||
|
|
||
| func findAddress(addrs []net.Addr, ipType string) (net.IP, bool) { | ||
| for _, addr := range addrs { | ||
| if ipnet, ok := addr.(*net.IPNet); ok && ipnet != nil { | ||
| if ip, ok := getIP(ipnet.IP, ipType); ok { | ||
| return ip, true | ||
| } | ||
| } | ||
| } | ||
| return nil, false | ||
| } | ||
|
|
||
| func getIP(pip net.IP, ipType string) (net.IP, bool) { | ||
| if pip == nil || pip.IsLoopback() { | ||
| return nil, false | ||
| } | ||
| switch ipType { | ||
| case IPTypeIPV4: | ||
| if ip := pip.To4(); ip != nil { | ||
| return ip, true | ||
| } | ||
| case IPTypeIPV6: | ||
| // as any IP4 address can be converted to IP6, we only return any | ||
| // address that can be converted to IP6 but not to IP4 | ||
| if ip := pip.To16(); ip != nil && pip.To4() == nil { | ||
| return ip, true | ||
| } | ||
| default: // Any | ||
| if ip := pip.To4(); ip != nil { | ||
| return ip, true | ||
| } | ||
| if ip := pip.To16(); ip != nil { | ||
| return ip, true | ||
| } | ||
| } | ||
| return nil, false | ||
| } |
Oops, something went wrong.