server

Documentation

Index

• type IPAMServer
  • func NewIPAMServer(conf conf.ServerConf, clusterConfig *config.ClusterConfig, ...) *IPAMServer
  • func (s *IPAMServer) AddNetwork(context context.Context, in *rpc.IPAMMessage) (*rpc.IPAMMessage, error)
  • func (s *IPAMServer) ClearNics(context context.Context, in *rpc.Nothing) (*rpc.Nothing, error)
  • func (s *IPAMServer) DelNetwork(context context.Context, in *rpc.IPAMMessage) (*rpc.IPAMMessage, error)
  • func (s *IPAMServer) ShowNics(context context.Context, in *rpc.Nothing) (*rpc.NicInfoList, error)
  • func (s *IPAMServer) Start(stopCh <-chan struct{}) error

Types

type IPAMServer

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

func NewIPAMServer

func NewIPAMServer(conf conf.ServerConf, clusterConfig *config.ClusterConfig, kubeclient kubernetes.Interface, ipamclient ipam.IPAMClient, metricsPort int) *IPAMServer

func (*IPAMServer) AddNetwork

func (s *IPAMServer) AddNetwork(context context.Context, in *rpc.IPAMMessage) (*rpc.IPAMMessage, error)

AddNetwork handle add pod request

func (*IPAMServer) ClearNics

func (s *IPAMServer) ClearNics(context context.Context, in *rpc.Nothing) (*rpc.Nothing, error)

func (*IPAMServer) DelNetwork

func (s *IPAMServer) DelNetwork(context context.Context, in *rpc.IPAMMessage) (*rpc.IPAMMessage, error)

DelNetwork handle del pod request

func (*IPAMServer) ShowNics

func (s *IPAMServer) ShowNics(context context.Context, in *rpc.Nothing) (*rpc.NicInfoList, error)

func (*IPAMServer) Start

func (s *IPAMServer) Start(stopCh <-chan struct{}) error