Documentation
¶
Index ¶
Constants ¶
View Source
const (
// IntrospectionPort is the port for ipamd introspection
IntrospectionPort = 61678
)
Variables ¶
This section is empty.
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)
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.