v2

Documentation

Index

• type NetworkManager
  • func CreateNetworkManager(ctx context.Context, cfg config.Config, clusterName string, ...) *NetworkManager
  • func (nm *NetworkManager) ContainerCallback(notif containercollection.PubSubEvent)
  • func (nm *NetworkManager) ContainerReachedMaxTime(containerID string)
  • func (nm *NetworkManager) ReportDroppedEvent(k8sContainerID string)
  • func (nm *NetworkManager) ReportNetworkEvent(k8sContainerID string, event tracernetworktype.Event)

Types

type NetworkManager

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

func CreateNetworkManager

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

func (*NetworkManager) ContainerCallback

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

func (*NetworkManager) ContainerReachedMaxTime

func (nm *NetworkManager) ContainerReachedMaxTime(containerID string)

func (*NetworkManager) ReportDroppedEvent

func (nm *NetworkManager) ReportDroppedEvent(k8sContainerID string)

func (*NetworkManager) ReportNetworkEvent

func (nm *NetworkManager) ReportNetworkEvent(k8sContainerID string, event tracernetworktype.Event)