Version: v1.2.1 Latest Latest

This package is not in the latest version of its module.

Go to latest
Published: Oct 11, 2018 License: Apache-2.0 Imports: 26 Imported by: 0




View Source
const (
	// IntrospectionPort is the port for ipamd introspection
	IntrospectionPort = 61678


This section is empty.


func GetConfigForDebug added in v1.2.0

func GetConfigForDebug() map[string]interface{}

GetConfigForDebug returns the active values of the configuration env vars (for debugging purposes).

func UseCustomNetworkCfg added in v1.2.1

func UseCustomNetworkCfg() bool

UseCustomerNetworkCfg() return whether Pods needs to use pod specific config


type IPAMContext

type IPAMContext struct {
	// contains filtered or unexported fields

IPAMContext contains node level control information

func New

func New(k8sapiClient k8sapi.K8SAPIs, eniConfig *eniconfig.ENIConfigController) (*IPAMContext, error)

New retrieves IP address usage information from Instance MetaData service and Kubelet then initializes IP address pool data store

func (*IPAMContext) RunRPCHandler

func (c *IPAMContext) RunRPCHandler() error

RunRPCHandler handles request from gRPC

func (*IPAMContext) SetupHTTP

func (c *IPAMContext) SetupHTTP()

SetupHTTP sets up ipamd introspection service endpoint

func (*IPAMContext) StartNodeIPPoolManager

func (c *IPAMContext) StartNodeIPPoolManager()

StartNodeIPPoolManager monitors the IP Pool, add or del them when it is required.

type LoggingHandler

type LoggingHandler struct {
	// contains filtered or unexported fields

LoggingHandler is a object for handling http request

func NewLoggingHandler

func NewLoggingHandler(handler http.Handler) LoggingHandler

NewLoggingHandler creates a new LoggingHandler object.

func (LoggingHandler) ServeHTTP

func (lh LoggingHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)


Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL