Documentation
¶
Index ¶
- func NewK8sClient() nodeClient
- func NewNetlink() netlinker
- type MetadataClient
- type RouteManager
- func (rm *RouteManager) CheckDisableMultiNIC(ctx context.Context, nodeID string, nics []string, disableMultiNIC bool) (bool, error)
- func (rm *RouteManager) ConfigureRoute(nicName string, instanceIP string, tableID int) error
- func (rm *RouteManager) FindNextFreeTableID(startID int, nicIPAddr net.IP) (int, error)
- func (rm *RouteManager) GetNICIPAddr(nicName string) (net.IP, error)
- func (rm *RouteManager) GetStandardNICs() ([]string, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewK8sClient ¶
func NewK8sClient() nodeClient
Types ¶
type MetadataClient ¶
type MetadataClient interface {
GetNetworkInterfaces() ([]metadata.NetworkInterface, error)
}
MetadataClient abstracts the metadata service.
type RouteManager ¶
type RouteManager struct {
// contains filtered or unexported fields
}
RouteManager provides methods for network configuration using the netlinker interface.
func Manager ¶
func Manager(nl netlinker, nc nodeClient, mc MetadataClient) *RouteManager
func (*RouteManager) CheckDisableMultiNIC ¶
func (rm *RouteManager) CheckDisableMultiNIC(ctx context.Context, nodeID string, nics []string, disableMultiNIC bool) (bool, error)
CheckDisableMultiNIC checks for Multi-NIC feature via node label and cluster configuration. return true if disabled. return false if multi nic is enabled. if node label is specified, then it overrides cluster configuration for multi nic setup.
func (*RouteManager) ConfigureRoute ¶
func (rm *RouteManager) ConfigureRoute(nicName string, instanceIP string, tableID int) error
ConfigureRoute configures route between Lustre Instance and NIC on an available Table ID.
func (*RouteManager) FindNextFreeTableID ¶
FindNextFreeTableID finds available Table ID for NIC confiugration.
func (*RouteManager) GetNICIPAddr ¶
func (rm *RouteManager) GetNICIPAddr(nicName string) (net.IP, error)
GetNICIPAddr gets primary IP Address of NIC.
func (*RouteManager) GetStandardNICs ¶
func (rm *RouteManager) GetStandardNICs() ([]string, error)
GetStandardNICs gets all standard NICs on the node which are within the same VPC network as the GCE instance primary network.
Source Files