ipamd

Documentation

Index

• Constants
• type IPAMContext
  • func New(k8sapiClient k8sapi.K8SAPIs) (*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
)

Types

type IPAMContext

type IPAMContext struct {
	// contains filtered or unexported fields
}

IPAMContext contains node level control information

func New

func New(k8sapiClient k8sapi.K8SAPIs) (*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)