etcdcli

package

v0.0.0-...-cd4954e Latest Latest Go to latest Published: Dec 19, 2025 License: Apache-2.0 Imports: 14 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type EtcdClient struct {
	clientv3.Client
}

func Init(config *types.IPAMConfig) (*EtcdClient, error)

Init returns an etcd client from given config

func (alloc *EtcdClient) AllocateIP(nameSpace, nsIpPoolNames, podName string) (*current.IPConfig, *types.NSIPPool, error)

func (etcdCLient EtcdClient) Close()

Close ends the connection between etcd client and etcd

func (client *EtcdClient) CreateIPPool(pool *types.NSIPPool) error

func (client *EtcdClient) CreateServiceIPPool(serviceIPPool *types.ServiceIPPool) error

CreateServiceIPPool writes a new service IPPool into etcd

func (client *EtcdClient) Delete(pool *types.NSIPPool) error

Delete removes the given ns IPPool's record in etcd

func (client *EtcdClient) DeleteServiceIPPool(namespace string, servicePoolName string) error

DeleteServiceIPPool removes the given service IPPool's record in etcd by it's name and namespace

func (client *EtcdClient) GetAllPool() []*types.NSIPPool

GetAllPool calls GetList to get all ns IPPools

func (alloc *EtcdClient) GetIPFromNSPool(nameSpace, poolName, podName string) (*current.IPConfig, *types.NSIPPool, error)

func (client *EtcdClient) GetIPPoolByName(nsname, poolName string) *types.NSIPPool

GetIPPoolByName calls GetKV to get ns IPPool info from given namespace name and IPPool name

func (client *EtcdClient) GetNSAllPool(namespace string) []*types.NSIPPool

GetNSAllPool calls GetList to get all nsIPPools in the given namespace

func (r *EtcdClient) GetPodList() ([]types.PodNetwork, error)

func (client *EtcdClient) GetService(namespace, serviceName string) *types.CreateServiceRequest

func (client *EtcdClient) GetServicePool(namespace string, ServicePoolName string) (*types.ServiceIPPool, error)

GetServicePool calls GetKV to get service IPPool from the given namespace and service IPPool name

func (alloc *EtcdClient) GetServiceSpecIP(fixed bool, nameSpace, servicePoolName, podName, stsName string) (*net.IP, *types.NSIPPool, error)

func (etcdClient *EtcdClient) Release(nameSpace, podName string, releaseFixed bool) error