ipamd

Documentation

Index

• Constants
• func GetConfigForDebug() map[string]interface{}
• func UseCustomNetworkCfg() bool
• type IPAMContext
  • func New(k8sapiClient k8sapi.K8SAPIs, eniConfig *eniconfig.ENIConfigController) (*IPAMContext, error)
  • func (c *IPAMContext) RunRPCHandler() error
  • func (c *IPAMContext) SetupHTTP()
  • func (c *IPAMContext) StartNodeIPPoolManager()
• type LoggingHandler
  • func NewLoggingHandler(handler http.Handler) LoggingHandler
  • func (lh LoggingHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)

Constants

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

Functions

func GetConfigForDebug

func GetConfigForDebug() map[string]interface{}

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

func UseCustomNetworkCfg

func UseCustomNetworkCfg() bool

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

Types

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)