testendpointmanager

package
v1.20.0-pre.3 Latest Latest
Warning

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

 Go to latest Published: Jun 1, 2026 License: Apache-2.0 Imports: 12 Imported by: 0

Documentation

Overview

Package testendpointmanager provides a shared mock implementation of the endpointmanager.EndpointManager interface for use in tests.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type MockEndpointManager 

type MockEndpointManager struct {
	Endpoints []*endpoint.Endpoint
}

MockEndpointManager is a mock implementation of endpointmanager.EndpointManager for use in unit tests. Most methods panic by default with a few exceptions. Tests embed *MockEndpointManager in a local type to override additional methods. Add additional mock implementations here if required.

func NewMockEndpointManager 

func NewMockEndpointManager() *MockEndpointManager

NewMockEndpointManager returns a MockEndpointManager with no endpoints and every panic-by-default method left unimplemented.

func (*MockEndpointManager) AddEndpoint 

func (*MockEndpointManager) AddEndpoint(ep *endpoint.Endpoint) error

func (*MockEndpointManager) DeleteK8sCiliumEndpointSync 

func (*MockEndpointManager) DeleteK8sCiliumEndpointSync(e *endpoint.Endpoint)

func (*MockEndpointManager) EndpointExists 

func (*MockEndpointManager) EndpointExists(id uint16) bool

func (*MockEndpointManager) GetEndpointList 

func (*MockEndpointManager) GetEndpointList(params endpointapi.GetEndpointParams) []*models.Endpoint

func (*MockEndpointManager) GetEndpoints 

func (m *MockEndpointManager) GetEndpoints() []*endpoint.Endpoint

func (*MockEndpointManager) GetEndpointsByContainerID 

func (*MockEndpointManager) GetEndpointsByContainerID(containerID string) []*endpoint.Endpoint

func (*MockEndpointManager) GetEndpointsByNamespace 

func (m *MockEndpointManager) GetEndpointsByNamespace(namespace string) []*endpoint.Endpoint

func (*MockEndpointManager) GetEndpointsByPodName 

func (*MockEndpointManager) GetEndpointsByPodName(name string) []*endpoint.Endpoint

func (*MockEndpointManager) GetEndpointsByServiceAccount 

func (*MockEndpointManager) GetEndpointsByServiceAccount(namespace string, serviceAccount string) []*endpoint.Endpoint

func (*MockEndpointManager) GetHostEndpoint 

func (*MockEndpointManager) GetHostEndpoint() *endpoint.Endpoint

func (*MockEndpointManager) GetIngressEndpoint 

func (*MockEndpointManager) GetIngressEndpoint() *endpoint.Endpoint

func (*MockEndpointManager) HostEndpointExists 

func (*MockEndpointManager) HostEndpointExists() bool

func (*MockEndpointManager) IngressEndpointExists 

func (*MockEndpointManager) IngressEndpointExists() bool

func (*MockEndpointManager) InitHostEndpointLabels 

func (*MockEndpointManager) InitHostEndpointLabels(ctx context.Context)

func (*MockEndpointManager) Lookup 

func (*MockEndpointManager) Lookup(id string) (*endpoint.Endpoint, error)

func (*MockEndpointManager) LookupCEPName 

func (*MockEndpointManager) LookupCEPName(name string) *endpoint.Endpoint

func (*MockEndpointManager) LookupCNIAttachmentID 

func (*MockEndpointManager) LookupCNIAttachmentID(id string) *endpoint.Endpoint

func (*MockEndpointManager) LookupCiliumID 

func (*MockEndpointManager) LookupCiliumID(id uint16) *endpoint.Endpoint

func (*MockEndpointManager) LookupIP 

func (*MockEndpointManager) LookupIP(ip netip.Addr) *endpoint.Endpoint

func (*MockEndpointManager) LookupIPv4 

func (*MockEndpointManager) LookupIPv4(ipv4 string) *endpoint.Endpoint

func (*MockEndpointManager) LookupIPv6 

func (*MockEndpointManager) LookupIPv6(ipv6 string) *endpoint.Endpoint

func (*MockEndpointManager) OverrideEndpointOpts 

func (*MockEndpointManager) OverrideEndpointOpts(om option.OptionMap)

func (*MockEndpointManager) RegenerateAllEndpoints 

func (*MockEndpointManager) RegenerateAllEndpoints(regenMetadata *regeneration.ExternalRegenerationMetadata) *sync.WaitGroup

func (*MockEndpointManager) RemoveEndpoint 

func (*MockEndpointManager) RemoveEndpoint(ep *endpoint.Endpoint, conf endpoint.DeleteConfig) []error

func (*MockEndpointManager) RestoreEndpoint 

func (*MockEndpointManager) RestoreEndpoint(ep *endpoint.Endpoint) error

func (*MockEndpointManager) RunK8sCiliumEndpointSync 

func (*MockEndpointManager) RunK8sCiliumEndpointSync(ep *endpoint.Endpoint, hr cell.Health)

func (*MockEndpointManager) Subscribe 

func (*MockEndpointManager) Subscribe(s endpointmanager.Subscriber)

func (*MockEndpointManager) TriggerRegenerateAllEndpoints 

func (*MockEndpointManager) TriggerRegenerateAllEndpoints()

func (*MockEndpointManager) Unsubscribe 

func (*MockEndpointManager) Unsubscribe(s endpointmanager.Subscriber)

func (*MockEndpointManager) UpdatePolicy 

func (*MockEndpointManager) UpdatePolicy(idsToRegen *set.Set[identity.NumericIdentity], fromRev, toRev uint64)

func (*MockEndpointManager) UpdatePolicyMaps 

func (*MockEndpointManager) UpdatePolicyMaps(ctx context.Context) error

func (*MockEndpointManager) UpdateReferences 

func (*MockEndpointManager) UpdateReferences(ep *endpoint.Endpoint) error

func (*MockEndpointManager) WaitForEndpointsAtPolicyRev 

func (*MockEndpointManager) WaitForEndpointsAtPolicyRev(ctx context.Context, rev uint64) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.