fixtures

package
v1.0.0 Latest Latest
Warning

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

 Go to latest Published: Aug 7, 2025 License: GPL-3.0 Imports: 20 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func CreateTestAppOptions 

func CreateTestAppOptions(name, image string) app.AppOptions

CreateTestAppOptions creates test app options

func CreateTestNodeInfo 

func CreateTestNodeInfo(id, hostname, address string) *node.NodeInfo

CreateTestNodeInfo creates a test node info

func CreateTestServiceInfo 

func CreateTestServiceInfo(name, namespace string) *service.ServiceInfo

CreateTestServiceInfo creates test service info

func CreateTestTask 

func CreateTestTask(id, name string) *scheduler.Task

CreateTestTask creates a test task for scheduling

func CreateTestVolumeOptions 

func CreateTestVolumeOptions(name string) storage.VolumeOptions

CreateTestVolumeOptions creates test volume options

func TestComponents 

func TestComponents(t *testing.T) (*app.Manager, *containerd.Manager, *node.Manager, *membership.Manager, *scheduler.EnhancedScheduler, *service.Discovery, *storage.Manager)

TestComponents creates all components needed for testing

func TestContext 

func TestContext(t *testing.T) (context.Context, context.CancelFunc)

TestContext creates a context with timeout for testing

func TestLogger 

func TestLogger() *logrus.Logger

TestLogger creates a logger for testing

func TestSecurityComponents 

func TestSecurityComponents(t *testing.T) (*security.SecretManager, *security.RbacManager, *security.ContainerScanner, *security.NetworkPolicyManager, *security.NetworkPolicyController, *security.StorageACLManager, *security.StorageEncryptionManager, *security.StorageQoSManager)

TestSecurityComponents creates all security components needed for testing

func TestTempDir 

func TestTempDir(t *testing.T) string

TestTempDir creates a temporary directory for testing

Types

type MockAppManager 

type MockAppManager struct {
	mock.Mock
	// contains filtered or unexported fields
}

MockAppManager is a mock implementation of the app manager

func NewMockAppManager 

func NewMockAppManager() *MockAppManager

NewMockAppManager creates a new mock app manager

func (*MockAppManager) CreateApp 

func (m *MockAppManager) CreateApp(ctx context.Context, opts app.AppOptions) (*app.App, error)

CreateApp mocks creating an app

func (*MockAppManager) DeleteApp 

func (m *MockAppManager) DeleteApp(ctx context.Context, id string) error

DeleteApp mocks deleting an app

func (*MockAppManager) GetApp 

func (m *MockAppManager) GetApp(ctx context.Context, id string) (*app.App, error)

GetApp mocks getting an app

func (*MockAppManager) ListApps 

func (m *MockAppManager) ListApps(ctx context.Context) ([]*app.App, error)

ListApps mocks listing apps

type MockContainerRuntime 

type MockContainerRuntime struct {
	mock.Mock
	// contains filtered or unexported fields
}

MockContainerRuntime is a mock implementation of the container runtime

func NewMockContainerRuntime 

func NewMockContainerRuntime() *MockContainerRuntime

NewMockContainerRuntime creates a new mock container runtime

func (*MockContainerRuntime) CreateContainer 

func (m *MockContainerRuntime) CreateContainer(ctx context.Context, opts containerd.ContainerOptions) (string, error)

CreateContainer mocks creating a container

func (*MockContainerRuntime) CreateVolume 

func (m *MockContainerRuntime) CreateVolume(ctx context.Context, name string, opts map[string]string) error

CreateVolume mocks creating a volume

func (*MockContainerRuntime) DeleteVolume 

func (m *MockContainerRuntime) DeleteVolume(ctx context.Context, name string) error

DeleteVolume mocks deleting a volume

func (*MockContainerRuntime) GetContainerMetrics 

func (m *MockContainerRuntime) GetContainerMetrics(ctx context.Context, containerID string) (*containerd.ContainerStats, error)

GetContainerMetrics mocks getting container metrics

func (*MockContainerRuntime) ListContainers 

func (m *MockContainerRuntime) ListContainers(ctx context.Context) ([]*containerd.Container, error)

ListContainers mocks listing containers

func (*MockContainerRuntime) ListVolumes 

func (m *MockContainerRuntime) ListVolumes(ctx context.Context) ([]*containerd.Volume, error)

ListVolumes mocks listing volumes

func (*MockContainerRuntime) PullImage 

func (m *MockContainerRuntime) PullImage(ctx context.Context, image string) error

PullImage mocks pulling an image

func (*MockContainerRuntime) StopContainer 

func (m *MockContainerRuntime) StopContainer(ctx context.Context, containerID string) error

StopContainer mocks stopping a container

type MockContainerdManager 

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

MockContainerdManager is a mock implementation of the containerd manager

func NewMockContainerdManager 

func NewMockContainerdManager(logger *logrus.Logger) *MockContainerdManager

NewMockContainerdManager creates a new mock containerd manager

func (*MockContainerdManager) Close 

func (m *MockContainerdManager) Close() error

Close mocks closing the containerd manager

func (*MockContainerdManager) CreateContainer 

func (m *MockContainerdManager) CreateContainer(ctx context.Context, opts containerd.ContainerOptions) (string, error)

CreateContainer mocks creating a container

func (*MockContainerdManager) CreateContainerWithOpts 

func (m *MockContainerdManager) CreateContainerWithOpts(ctx context.Context, opts containerd.ContainerOptions) (string, error)

CreateContainerWithOpts mocks creating a container with options

func (*MockContainerdManager) CreateVolume 

func (m *MockContainerdManager) CreateVolume(ctx context.Context, name string, opts map[string]string) error

CreateVolume mocks creating a volume

func (*MockContainerdManager) DeleteVolume 

func (m *MockContainerdManager) DeleteVolume(ctx context.Context, name string) error

DeleteVolume mocks deleting a volume

func (*MockContainerdManager) GetContainerMetrics 

func (m *MockContainerdManager) GetContainerMetrics(ctx context.Context, containerID string) (*containerd.ContainerStats, error)

GetContainerMetrics mocks getting container metrics

func (*MockContainerdManager) ListContainers 

func (m *MockContainerdManager) ListContainers(ctx context.Context) ([]*containerd.Container, error)

ListContainers mocks listing containers

func (*MockContainerdManager) ListImages 

func (m *MockContainerdManager) ListImages(ctx context.Context) ([]api.Image, error)

ListImages mocks listing images

func (*MockContainerdManager) ListVolumes 

func (m *MockContainerdManager) ListVolumes(ctx context.Context) ([]*containerd.Volume, error)

ListVolumes mocks listing volumes

func (*MockContainerdManager) PullImage 

func (m *MockContainerdManager) PullImage(ctx context.Context, image string) error

PullImage mocks pulling an image

func (*MockContainerdManager) StopContainer 

func (m *MockContainerdManager) StopContainer(ctx context.Context, containerID string) error

StopContainer mocks stopping a container

type MockNetworkPolicyController 

type MockNetworkPolicyController struct {
	*security.NetworkPolicyController // Embed the real controller to inherit its type
	// contains filtered or unexported fields
}

MockNetworkPolicyController is a mock implementation of the network policy controller

func NewMockNetworkPolicyController 

func NewMockNetworkPolicyController(logger *logrus.Logger) *MockNetworkPolicyController

NewMockNetworkPolicyController creates a new mock network policy controller

func (*MockNetworkPolicyController) AddNotificationEndpoint 

func (c *MockNetworkPolicyController) AddNotificationEndpoint(endpoint string)

AddNotificationEndpoint mocks adding a notification endpoint for policy violation alerts

func (*MockNetworkPolicyController) ApplyPolicy 

func (c *MockNetworkPolicyController) ApplyPolicy(ctx context.Context, policy security.NetworkPolicy) error

ApplyPolicy mocks applying a network policy

func (*MockNetworkPolicyController) EvaluateTraffic 

func (c *MockNetworkPolicyController) EvaluateTraffic(sourceIP, destIP, protocol string, port uint16, direction security.NetworkPolicyDirection) bool

EvaluateTraffic mocks evaluating if traffic is allowed based on network policies

func (*MockNetworkPolicyController) GetContainerIP 

func (c *MockNetworkPolicyController) GetContainerIP(containerID string) (net.IP, bool)

GetContainerIP mocks getting the IP address of a container

func (*MockNetworkPolicyController) GetContainerLabels 

func (c *MockNetworkPolicyController) GetContainerLabels(containerID string) (map[string]string, bool)

GetContainerLabels mocks getting the labels of a container

func (*MockNetworkPolicyController) RegisterContainer 

func (c *MockNetworkPolicyController) RegisterContainer(ctx context.Context, containerID string, ip net.IP, labels map[string]string) error

RegisterContainer mocks registering a container with its IP and labels for policy matching

func (*MockNetworkPolicyController) StoreContainerIP 

func (c *MockNetworkPolicyController) StoreContainerIP(ctx context.Context, containerID string, ip net.IP) error

StoreContainerIP mocks storing a container IP address temporarily

func (*MockNetworkPolicyController) StoreContainerLabels 

func (c *MockNetworkPolicyController) StoreContainerLabels(ctx context.Context, containerID string, labels map[string]string) error

StoreContainerLabels mocks storing container labels temporarily

func (*MockNetworkPolicyController) UnregisterContainer 

func (c *MockNetworkPolicyController) UnregisterContainer(ctx context.Context, containerID string) error

UnregisterContainer mocks unregistering a container when it's removed

type MockNodeManager 

type MockNodeManager struct {
	mock.Mock
	// contains filtered or unexported fields
}

MockNodeManager is a mock implementation of the node manager

func NewMockNodeManager 

func NewMockNodeManager(nodeID string) *MockNodeManager

NewMockNodeManager creates a new mock node manager

func (*MockNodeManager) AddNode 

func (m *MockNodeManager) AddNode(id, hostname, address string)

AddNode adds a node to the mock

func (*MockNodeManager) CheckHealth 

func (m *MockNodeManager) CheckHealth() (bool, error)

CheckHealth checks the health of the node

func (*MockNodeManager) GetNodeDetails 

func (m *MockNodeManager) GetNodeDetails() ([]interface{}, error)

GetNodeDetails returns details about all known nodes

func (*MockNodeManager) GetNodeID 

func (m *MockNodeManager) GetNodeID() string

GetNodeID returns the node ID

func (*MockNodeManager) GetNodes 

func (m *MockNodeManager) GetNodes(ctx context.Context) ([]*node.NodeInfo, error)

GetNodes mocks getting nodes

func (*MockNodeManager) ListNodes 

func (m *MockNodeManager) ListNodes(ctx context.Context) ([]interface{}, error)

ListNodes mocks listing nodes

func (*MockNodeManager) RegisterNode 

func (m *MockNodeManager) RegisterNode(ctx context.Context, nodeInfo *node.NodeInfo) error

RegisterNode mocks registering a node

func (*MockNodeManager) RemoveNode 

func (m *MockNodeManager) RemoveNode(id string)

RemoveNode removes a node from the mock

func (*MockNodeManager) UpdateNodeResources 

func (m *MockNodeManager) UpdateNodeResources(id string, resources node.Resources)

UpdateNodeResources updates node resources

type MockScheduler 

type MockScheduler struct {
	mock.Mock
}

MockScheduler is a mock implementation of the scheduler

func NewMockScheduler 

func NewMockScheduler() *MockScheduler

NewMockScheduler creates a new mock scheduler

func (*MockScheduler) Schedule 

func (m *MockScheduler) Schedule(ctx context.Context, task *scheduler.Task) (string, error)

Schedule mocks scheduling a task

type MockSecurityManager 

type MockSecurityManager struct {
	mock.Mock
	// contains filtered or unexported fields
}

MockSecurityManager is a mock implementation of the security manager

func NewMockSecurityManager 

func NewMockSecurityManager() *MockSecurityManager

NewMockSecurityManager creates a new mock security manager

func (*MockSecurityManager) CreateNetworkPolicy 

func (m *MockSecurityManager) CreateNetworkPolicy(ctx context.Context, name string, selector security.NetworkSelector, ingressRules, egressRules []security.NetworkRule) (*security.NetworkPolicy, error)

CreateNetworkPolicy mocks creating a network policy

func (*MockSecurityManager) CreateSecret 

func (m *MockSecurityManager) CreateSecret(ctx context.Context, name, description string, data []byte, createdBy string, labels, annotations map[string]string, expiration *time.Time, rotationPolicy *security.SecretRotationPolicy) (*security.Secret, error)

CreateSecret mocks creating a secret

func (*MockSecurityManager) GetNetworkPolicy 

func (m *MockSecurityManager) GetNetworkPolicy(ctx context.Context, name string) (*security.NetworkPolicy, error)

GetNetworkPolicy mocks getting a network policy

func (*MockSecurityManager) GetSecret 

func (m *MockSecurityManager) GetSecret(ctx context.Context, id, requestedBy string) (*security.Secret, error)

GetSecret mocks getting a secret

type MockServiceDiscovery 

type MockServiceDiscovery struct {
	mock.Mock
	// contains filtered or unexported fields
}

MockServiceDiscovery is a mock implementation of the service discovery

func NewMockServiceDiscovery 

func NewMockServiceDiscovery() *MockServiceDiscovery

NewMockServiceDiscovery creates a new mock service discovery

func (*MockServiceDiscovery) DiscoverService 

func (m *MockServiceDiscovery) DiscoverService(ctx context.Context, name, namespace string) (*service.ServiceInfo, error)

DiscoverService mocks discovering a service

func (*MockServiceDiscovery) ListServices 

func (m *MockServiceDiscovery) ListServices(ctx context.Context) (map[string][]*service.ServiceInfo, error)

ListServices mocks listing services

func (*MockServiceDiscovery) RegisterService 

func (m *MockServiceDiscovery) RegisterService(ctx context.Context, serviceInfo *service.ServiceInfo) error

RegisterService mocks registering a service

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.