Version: v1.2.0 Latest Latest

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

Go to latest
Published: Sep 26, 2018 License: Apache-2.0 Imports: 25 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).


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