v1

Jul 2, 2024

Changes in this version

+ type NetworkManager struct

+ func CreateNetworkManager(ctx context.Context, cfg config.Config, k8sClient k8sclient.K8sClientInterface, ...) *NetworkManager

+ func (am *NetworkManager) ContainerCallback(notif containercollection.PubSubEvent)

+ func (am *NetworkManager) ContainerReachedMaxTime(containerID string)

+ func (am *NetworkManager) ReportDroppedEvent(containerID string, event tracernetworktype.Event)

+ func (am *NetworkManager) ReportNetworkEvent(containerID string, event tracernetworktype.Event)

+ type NetworkManagerClient interface

+ ContainerCallback func(notif containercollection.PubSubEvent)

+ ContainerReachedMaxTime func(containerID string)

+ ReportDroppedEvent func(containerID string, event tracernetworktype.Event)

+ ReportNetworkEvent func(containerID string, event tracernetworktype.Event)

+ type NetworkManagerMock struct

+ func (am *NetworkManagerMock) ContainerCallback(_ containercollection.PubSubEvent)

+ func (am *NetworkManagerMock) ContainerReachedMaxTime(_ string)

+ func (am *NetworkManagerMock) ReportDroppedEvent(_ string, _ tracernetworktype.Event)

+ func (am *NetworkManagerMock) ReportNetworkEvent(_ string, _ tracernetworktype.Event)