fake

package
v0.15.7 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Dec 3, 2024 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type FakeClusterIdentity added in v0.3.57

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

func NewFakeClusterIdentity added in v0.3.57

func NewFakeClusterIdentity(clusterId string, clusterPool string) *FakeClusterIdentity

func (*FakeClusterIdentity) GetClusterId added in v0.3.57

func (f *FakeClusterIdentity) GetClusterId() string

func (*FakeClusterIdentity) GetClusterPool added in v0.3.57

func (f *FakeClusterIdentity) GetClusterPool() string

type SyncFakeClusterContext

type SyncFakeClusterContext struct {
	Pods             map[string]*v1.Pod
	Events           map[string][]*v1.Event
	AnnotationsAdded map[string]map[string]string
	// contains filtered or unexported fields
}

func NewSyncFakeClusterContext

func NewSyncFakeClusterContext() *SyncFakeClusterContext

func (*SyncFakeClusterContext) AddAnnotation

func (c *SyncFakeClusterContext) AddAnnotation(pod *v1.Pod, annotations map[string]string) error

func (*SyncFakeClusterContext) AddPodEventHandler

func (*SyncFakeClusterContext) DeleteIngress

func (c *SyncFakeClusterContext) DeleteIngress(ingress *networking.Ingress) error

func (*SyncFakeClusterContext) DeletePodWithCondition added in v0.3.47

func (c *SyncFakeClusterContext) DeletePodWithCondition(pod *v1.Pod, condition func(pod *v1.Pod) bool, pessimistic bool) error

func (*SyncFakeClusterContext) DeletePods

func (c *SyncFakeClusterContext) DeletePods(pods []*v1.Pod)

func (*SyncFakeClusterContext) DeleteService

func (c *SyncFakeClusterContext) DeleteService(service *v1.Service) error

func (*SyncFakeClusterContext) GetActiveBatchPods

func (c *SyncFakeClusterContext) GetActiveBatchPods() ([]*v1.Pod, error)

func (*SyncFakeClusterContext) GetAllPods

func (c *SyncFakeClusterContext) GetAllPods() ([]*v1.Pod, error)

func (*SyncFakeClusterContext) GetBatchPods

func (c *SyncFakeClusterContext) GetBatchPods() ([]*v1.Pod, error)

func (*SyncFakeClusterContext) GetClusterId

func (c *SyncFakeClusterContext) GetClusterId() string

func (*SyncFakeClusterContext) GetClusterPool

func (c *SyncFakeClusterContext) GetClusterPool() string

func (*SyncFakeClusterContext) GetEndpointSlices added in v0.3.47

func (c *SyncFakeClusterContext) GetEndpointSlices(namespace string, labelName string, labelValue string) ([]*discovery.EndpointSlice, error)

func (*SyncFakeClusterContext) GetIngresses

func (c *SyncFakeClusterContext) GetIngresses(pod *v1.Pod) ([]*networking.Ingress, error)

func (*SyncFakeClusterContext) GetNode

func (c *SyncFakeClusterContext) GetNode(nodeName string) (*v1.Node, error)

func (*SyncFakeClusterContext) GetNodeStatsSummary

func (c *SyncFakeClusterContext) GetNodeStatsSummary(ctx *armadacontext.Context, node *v1.Node) (*v1alpha1.Summary, error)

func (*SyncFakeClusterContext) GetNodes

func (c *SyncFakeClusterContext) GetNodes() ([]*v1.Node, error)

func (*SyncFakeClusterContext) GetPodEvents

func (c *SyncFakeClusterContext) GetPodEvents(pod *v1.Pod) ([]*v1.Event, error)

func (*SyncFakeClusterContext) GetServices

func (c *SyncFakeClusterContext) GetServices(pod *v1.Pod) ([]*v1.Service, error)

func (*SyncFakeClusterContext) SimulateDeletionEvent

func (c *SyncFakeClusterContext) SimulateDeletionEvent(pod *v1.Pod)

func (*SyncFakeClusterContext) SimulatePodAddEvent added in v0.3.50

func (c *SyncFakeClusterContext) SimulatePodAddEvent(pod *v1.Pod)

func (*SyncFakeClusterContext) Stop

func (*SyncFakeClusterContext) Stop()

func (*SyncFakeClusterContext) SubmitIngress

func (c *SyncFakeClusterContext) SubmitIngress(ingress *networking.Ingress) (*networking.Ingress, error)

func (*SyncFakeClusterContext) SubmitPod

func (c *SyncFakeClusterContext) SubmitPod(pod *v1.Pod, owner string, ownerGroups []string) (*v1.Pod, error)

func (*SyncFakeClusterContext) SubmitService

func (c *SyncFakeClusterContext) SubmitService(service *v1.Service) (*v1.Service, error)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL