backend

Documentation

Index

• Constants
• func Batch(m interface{}, batchSize int, f Func) error
• func GetNodes(reqCtx *svcCtx.RequestContext, kubeClient client.Client) ([]v1.Node, error)
• type EndpointWithENI
  • func NewEndpointWithENI(reqCtx *svcCtx.RequestContext, kubeClient client.Client) (*EndpointWithENI, error)
• type Func

Constants

const (
	MaxBackendNum = 39
)

MAX_BACKEND_NUM max batch backend num

Functions

func Batch

func Batch(m interface{}, batchSize int, f Func) error

Batch batch process `object` m with func `func` for general purpose

func GetNodes

func GetNodes(reqCtx *svcCtx.RequestContext, kubeClient client.Client) ([]v1.Node, error)

Types

type EndpointWithENI

type EndpointWithENI struct {
	// TrafficPolicy
	// external traffic policy.
	TrafficPolicy helper.TrafficPolicy
	// AddressIPVersion
	// it indicates the address ip version type of the backends attached to the LoadBalancer
	AddressIPVersion model.AddressIPVersionType
	// Nodes
	// contains all the candidate nodes consider of LoadBalance Backends.
	// Cloud implementation has the right to make any filter on it.
	Nodes []v1.Node
	// Endpoints
	// It is the direct pod location information which cloud implementation
	// may needed for some kind of filtering. eg. direct ENI attach.
	Endpoints *v1.Endpoints
	// EndpointSlices
	// contains all the endpointslices of a service
	EndpointSlices []discovery.EndpointSlice
}

EndpointWithENI Currently, EndpointWithENI accept two kind of backend normal nodes of type []*v1.Node, and endpoints of type *v1.Endpoints

func NewEndpointWithENI

func NewEndpointWithENI(reqCtx *svcCtx.RequestContext, kubeClient client.Client) (*EndpointWithENI, error)

type Func

type Func func([]interface{}) error