v1

Documentation

Index

• type NetworkManager
  • 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
• type NetworkManagerMock
  • 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)

Types

type NetworkManager

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

func CreateNetworkManager

func CreateNetworkManager(ctx context.Context, cfg config.Config, k8sClient k8sclient.K8sClientInterface, storageClient storage.StorageClient, clusterName string, dnsResolverClient dnsmanager.DNSResolver, preRunningContainerIDs mapset.Set[string], k8sObjectCache objectcache.K8sObjectCache) *NetworkManager

func (*NetworkManager) ContainerCallback

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

func (*NetworkManager) ContainerReachedMaxTime

func (am *NetworkManager) ContainerReachedMaxTime(containerID string)

func (*NetworkManager) ReportDroppedEvent

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

func (*NetworkManager) ReportNetworkEvent

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

type NetworkManagerClient

type NetworkManagerClient interface {
	ContainerCallback(notif containercollection.PubSubEvent)
	ContainerReachedMaxTime(containerID string)
	ReportNetworkEvent(containerID string, event tracernetworktype.Event)
	ReportDroppedEvent(containerID string, event tracernetworktype.Event)
}

type NetworkManagerMock

type NetworkManagerMock struct {
}

func (*NetworkManagerMock) ContainerCallback

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

func (*NetworkManagerMock) ContainerReachedMaxTime

func (am *NetworkManagerMock) ContainerReachedMaxTime(_ string)

func (*NetworkManagerMock) ReportDroppedEvent

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

func (*NetworkManagerMock) ReportNetworkEvent

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