const region1 … const region2 … const node1 … const node2 … const classA … const classB … const driverA … const driverB … const pool1 … const pool2 … const pool3 … const pool4 … const req0 … const req1 … const req2 … const req3 … const claim0 … const claim1 … const slice1 … const slice2 … const device1 … const device2 … const device3 … func init() { … } const fieldNameKey … const regionKey … const planetKey … const planetValueEarth … // generate a node object given a name and a region func node(name, region string) *v1.Node { … } // generate a DeviceClass object with the given name and a driver CEL selector. // driver name is assumed to be the same as the class name. func class(name, driver string) *resourceapi.DeviceClass { … } // generate a DeviceConfiguration object with the given driver and attribute. func deviceConfiguration(driver, attribute string) resourceapi.DeviceConfiguration { … } // generate a DeviceClass object with the given name and attribute. // attribute is used to generate device configuration parameters in a form of JSON {attribute: attributeValue}. func classWithConfig(name, driver, attribute string) *resourceapi.DeviceClass { … } // generate a ResourceClaim object with the given name and device requests. func claimWithRequests(name string, constraints []resourceapi.DeviceConstraint, requests ...resourceapi.DeviceRequest) *resourceapi.ResourceClaim { … } // generate a DeviceRequest object with the given name, class and selectors. func request(name, class string, count int64, selectors ...resourceapi.DeviceSelector) resourceapi.DeviceRequest { … } // generate a ResourceClaim object with the given name, request and class. func claim(name, req, class string, constraints ...resourceapi.DeviceConstraint) *resourceapi.ResourceClaim { … } // generate a ResourceClaim object with the given name, request, class, and attribute. // attribute is used to generate parameters in a form of JSON {attribute: attributeValue}. func claimWithDeviceConfig(name, request, class, driver, attribute string) *resourceapi.ResourceClaim { … } // generate allocated ResourceClaim object func allocatedClaim(name, request, class string, results ...resourceapi.DeviceRequestAllocationResult) *resourceapi.ResourceClaim { … } // generate a Device object with the given name, capacity and attributes. func device(name string, capacity map[resourceapi.QualifiedName]resource.Quantity, attributes map[resourceapi.QualifiedName]resourceapi.DeviceAttribute) resourceapi.Device { … } // generate a ResourceSlice object with the given name, node, // driver and pool names, generation and a list of devices. // The nodeSelection parameter may be a string (= node name), // true (= all nodes), or a node selector (= specific nodes). func slice(name string, nodeSelection any, pool, driver string, devices ...resourceapi.Device) *resourceapi.ResourceSlice { … } func deviceAllocationResult(request, driver, pool, device string, adminAccess bool) resourceapi.DeviceRequestAllocationResult { … } // nodeLabelSelector creates a node selector with a label match for "key" in "values". func nodeLabelSelector(key string, values ...string) *v1.NodeSelector { … } // localNodeSelector returns a node selector for a specific node. func localNodeSelector(nodeName string) *v1.NodeSelector { … } // allocationResult returns a matcher for one AllocationResult pointer with a list of // embedded device allocation results. The order of those results doesn't matter. func allocationResult(selector *v1.NodeSelector, results ...resourceapi.DeviceRequestAllocationResult) types.GomegaMatcher { … } // matchNodeSelector returns a matcher for a node selector. The order // of terms, requirements, and values is irrelevant. func matchNodeSelector(selector *v1.NodeSelector) types.GomegaMatcher { … } func matchNodeSelectorTerms(terms []v1.NodeSelectorTerm) types.GomegaMatcher { … } func matchNodeSelectorTerm(term v1.NodeSelectorTerm) types.GomegaMatcher { … } func matchNodeSelectorRequirements(requirements []v1.NodeSelectorRequirement) types.GomegaMatcher { … } func matchNodeSelectorRequirement(requirement v1.NodeSelectorRequirement) types.GomegaMatcher { … } func allocationResultWithConfig(selector *v1.NodeSelector, driver string, source resourceapi.AllocationConfigSource, attribute string, results ...resourceapi.DeviceRequestAllocationResult) *resourceapi.AllocationResult { … } // convert a list of objects to a slice func objects[T any](objs ...T) []T { … } // generate a ResourceSlice object with the given parameters and one device "device-1" func sliceWithOneDevice(name string, nodeSelection any, pool, driver string) *resourceapi.ResourceSlice { … } func TestAllocator(t *testing.T) { … } type claimLister … func (l claimLister) ListAllAllocated() ([]*resourceapi.ResourceClaim, error) { … } type informerLister … func (l informerLister[T]) List(selector labels.Selector) (ret []*T, err error) { … } func (l informerLister[T]) Get(name string) (*T, error) { … }
Codebase Browser
kubernetes