node

Documentation

Index

• Constants
• Variables
• func IPUsage(eniIP map[string]*networkv1beta1.IP) (int, int)
• func IdlesWithAvailable(eniIP map[string]*networkv1beta1.IP) (count int)
• func Notify(ctx context.Context, name string)
• type Condition
• type EniIP
• type NodeStatus
  • func MetaCtx(ctx context.Context) *NodeStatus
• type PodRequest
• type ReconcileNode
  • func (n *ReconcileNode) Reconcile(ctx context.Context, request reconcile.Request) (reconcile.Result, error)

Constants

const (
	ConditionInsufficientIP = "InsufficientIP"
	ConditionOperationErr   = "OperationErr"
)

const (
	ControllerName = "multi-ip-node"
)

Variables

var (
	// ResourcePoolTotal terway total source amount in the pool
	ResourcePoolTotal = prometheus.NewGaugeVec(
		prometheus.GaugeOpts{
			Name: "gc_count_total",
			Help: "controlplane gc total",
		},
		[]string{"node"},
	)

	SyncOpenAPITotal = prometheus.NewGaugeVec(
		prometheus.GaugeOpts{
			Name: "sync_openapi_count_total",
			Help: "controlplane sync data with openapi total",
		},
		[]string{"node"},
	)
)

var EniOptions = map[eniTypeKey]*aliyunClient.CreateNetworkInterfaceOptions{
	// contains filtered or unexported fields
}

var EventCh = make(chan event.GenericEvent, 1000)

Functions

func IPUsage

func IPUsage(eniIP map[string]*networkv1beta1.IP) (int, int)

func IdlesWithAvailable

func IdlesWithAvailable(eniIP map[string]*networkv1beta1.IP) (count int)

func Notify

func Notify(ctx context.Context, name string)

Types

type Condition

type Condition string

type EniIP

type EniIP struct {
	NetworkInterface *networkv1beta1.NetworkInterface
	IP               *networkv1beta1.IP
}

type NodeStatus

type NodeStatus struct {
	NeedSyncOpenAPI   *atomic.Bool
	StatusChanged     *atomic.Bool
	LastGCTime        time.Time
	LastReconcileTime time.Time
}

func MetaCtx

func MetaCtx(ctx context.Context) *NodeStatus

type PodRequest

type PodRequest struct {
	// requirements
	PodUID string

	RequireIPv4 bool
	RequireIPv6 bool

	RequireERDMA bool

	// status form pod status, only used in takeover
	IPv4 string
	IPv6 string
	// contains filtered or unexported fields
}

type ReconcileNode

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

func (*ReconcileNode) Reconcile

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