node

Documentation

Index

• Variables
• type Client
  • func GetPoolManager(nodeName string) (*Client, error)
  • func (c *Client) GetClient() (*eni_pool.Manager, error)
  • func (c *Client) SetClient(client *eni_pool.Manager)
• type ReconcileNode
  • func NewReconcileNode(mgr manager.Manager, aliyunClient register.Interface, ...) *ReconcileNode
  • func (m *ReconcileNode) Reconcile(ctx context.Context, request reconcile.Request) (reconcile.Result, error)
• type Wrapper
  • func (w *Wrapper) Start(ctx context.Context) error

Variables

var ErrNodeNotSynced = errors.New("node is not synced")

Types

type Client

type Client struct {
	sync.Mutex
	// contains filtered or unexported fields
}

Client represent the client for each node several cases need to be concerned 1. synchronous sync k8s nodes 2. async all nodes with enis

func GetPoolManager

func GetPoolManager(nodeName string) (*Client, error)

func (*Client) GetClient

func (c *Client) GetClient() (*eni_pool.Manager, error)

func (*Client) SetClient

func (c *Client) SetClient(client *eni_pool.Manager)

type ReconcileNode

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

ReconcileNode reconciles node

func NewReconcileNode

func NewReconcileNode(mgr manager.Manager, aliyunClient register.Interface, swPool *vswitch.SwitchPool) *ReconcileNode

func (*ReconcileNode) Reconcile

func (m *ReconcileNode) Reconcile(ctx context.Context, request reconcile.Request) (reconcile.Result, error)

type Wrapper

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

func (*Wrapper) Start

func (w *Wrapper) Start(ctx context.Context) error

Start the controller