telemetry

Dec 15, 2023

Changes in this version

type TelemetryBuffer

+ func (tb *TelemetryBuffer) ConnectToTelemetry()

Jan 9, 2023

Changes in this version

type TelemetryBuffer

+ func (tb *TelemetryBuffer) ConnectCNIToTelemetryService(telemetryNumRetries, telemetryWaitTimeInMilliseconds int, ...) error

Feb 4, 2022

Changes in this version

+ func LogAndSendEvent(tb *TelemetryBuffer, msg string)

Jan 31, 2020

Changes in this version

+ const CNIExecutimeMetricStr

+ func CreateAITelemetryHandle(aiConfig aitelemetry.AIConfig, disableAll, disableMetric, disableTrace bool) error

Aug 20, 2019

Changes in this version

type DNCReport

+ ContainerType string

+ NumberOfNCs int

+ NumberOfNodes int

+ Orchestrator string

Jun 19, 2019

Changes in this version

type Buffer

+ CNSReports []CNSReport

+ DNCReports []DNCReport

+ NPMReports []NPMReport

type NPMReport

+ Timestamp string

type TelemetryBuffer

+ func (tb *TelemetryBuffer) TryToConnectToTelemetryService()

Mar 25, 2019

Changes in this version

+ func StartTelemetryService(path string, args []string) error

type TelemetryBuffer

+ func (tb *TelemetryBuffer) BufferAndPushData(intervalms time.Duration)

Jan 10, 2019

Changes in this version

+ const CNSTelemetryFile

+ func SendCnsTelemetry(interval int, reports chan interface{}, service *restserver.HTTPRestService, ...)

+ type CNSReport struct

+ CPUUsage string

+ DncPartitionKey string

+ Errorcode string

+ EventMessage string

+ IsNewInstance bool

+ MemoryUsage string

+ Metadata Metadata

+ Processes string

+ Timestamp string

+ UUID string

type Payload

+ CNSReports []CNSReport

Dec 11, 2018

Changes in this version

+ const DefaultInterval

+ const HostNetAgentURL

+ type DNCReport struct

+ Allocations string

+ CPUUsage string

+ Errorcode string

+ EventMessage string

+ IsNewInstance bool

+ MemoryUsage string

+ Metadata Metadata

+ PartitionKey string

+ Processes string

+ Timestamp string

+ UUID string

+ type Payload struct

+ CNIReports []CNIReport

+ DNCReports []DNCReport

+ NPMReports []NPMReport

type TelemetryBuffer

+ func (tb *TelemetryBuffer) Start(intervalms time.Duration)

Oct 3, 2018

Changes in this version

type CNIReport

+ OSVersion string

+ type Metadata struct

+ KernelVersion string

+ Location string

+ OSVersion string

+ Offer string

+ OsType string

+ PlacementGroupID string

+ PlatformFaultDomain string

+ PlatformUpdateDomain string

+ Publisher string

+ ResourceGroupName string

+ Sku string

+ SubscriptionID string

+ Tags string

+ VMID string

+ VMName string

+ VMSize string

type NPMReport

+ IsNewInstance bool

+ Metadata Metadata

+ func (report *NPMReport) GetReport(clusterID, nodeName, npmVersion, kubernetesVersion string, ...)

type ReportManager

+ func (reportMgr *ReportManager) GetHostMetadata() error

+ func (reportMgr *ReportManager) GetKernelVersion()

+ func (reportMgr *ReportManager) GetReportState(telemetryFile string) bool

+ func (reportMgr *ReportManager) SetReportState(telemetryFile string) error

Jul 20, 2018

Changes in this version

+ const NPMTelemetryFile

type CNIReport

+ OrchestratorDetails *OrchestratorInfo

+ StartFlag bool

+ func (report *CNIReport) GetInterfaceDetails(queryUrl string)

+ func (report *CNIReport) GetOrchestratorDetails()

+ func (report *CNIReport) GetReportState() bool

+ func (report *CNIReport) SetReportState() error

+ type CNIReportManager struct

+ IpamQueryURL string

+ Report *CNIReport

+ func (reportMgr *CNIReportManager) GetReport(name string, version string)

+ func (reportMgr *CNIReportManager) SendReport() error

+ type ClusterState struct

+ NsCount int

+ NwPolicyCount int

+ PodCount int

+ type NPMReport struct

+ ClusterID string

+ ClusterState ClusterState

+ ErrorMessage string

+ EventMessage string

+ InstanceName string

+ KubernetesVersion string

+ NodeName string

+ NpmVersion string

+ StartFlag bool

+ UpTime string

+ func (report *NPMReport) GetReportState() bool

+ func (report *NPMReport) SetReportState() error

+ type NPMReportManager struct

+ Report *NPMReport

+ func (reportMgr *NPMReportManager) GetReport(clusterID, nodeName, npmVersion, kubernetesVersion string, ...)

+ func (reportMgr *NPMReportManager) SendReport() error

May 4, 2018

Changes in this version

type Report

+ CniSucceeded bool

Jan 11, 2018

Changes in this version

+ const TelemetryFile — darwin/amd64, js/wasm

+ type OrchestratorInfo struct

+ ErrorMessage string

+ OrchestratorName string

+ OrchestratorVersion string

Dec 12, 2017

Changes in this version

+ const TelemetryFile — linux/amd64, windows/amd64

+ func ReadFileByLines(filename string) ([]string, error)

+ type OrchsestratorInfo struct

+ ErrorMessage string

+ OrchestratorName string

+ OrchestratorVersion string

+ type Report struct

+ BridgeDetails *BridgeInfo

+ Context string

+ ErrorMessage string

+ InterfaceDetails *InterfaceInfo

+ Name string

+ OSDetails *OSInfo

+ OrchestratorDetails *OrchsestratorInfo

+ StartFlag bool

+ SubContext string

+ SystemDetails *SystemInfo

+ Version string

+ VnetAddressSpace []string

+ func (report *Report) GetInterfaceDetails(queryUrl string)

+ func (report *Report) GetOSDetails()

+ func (report *Report) GetOrchestratorDetails()

+ func (report *Report) GetReportState() bool

+ func (report *Report) GetSystemDetails()

+ func (report *Report) SetReportState() error

type ReportManager

+ IpamQueryURL string

+ ReportType string

+ func (reportMgr *ReportManager) GetReport(name string, version string)

Nov 20, 2023

Changes in this version

+ const CNIAddTimeMetricStr

+ const CNIDelTimeMetricStr

+ const CNILockTimeoutStr

+ const CNIModeStr

+ const CNINetworkModeStr

+ const CNITelemetryFile

+ const CNIUpdateTimeMetricStr

+ const CniInstallDir — linux/amd64, windows/amd64

+ const ContentType

+ const ContextStr

+ const Delimiter

+ const FailedStr

+ const FdName

+ const KB — linux/amd64

+ const MB — linux/amd64

+ const MaxNumReports

+ const MaxPayloadSize

+ const MultiTenancyStr

+ const OSTypeStr

+ const OperationTypeStr

+ const SingleTenancyStr

+ const StatusStr

+ const SubContextStr

+ const SucceededStr

+ const TelemetryServiceProcessName — linux/amd64, windows/amd64

+ const VMUptimeStr

+ const VersionStr

+ var ErrTelemetryDisabled = errors.New("telemetry is disabled")

+ func CloseAITelemetryHandle()

+ func SendAIMetric(aiMetric AIMetric)

+ func SendAITelemetry(cnireport CNIReport)

+ func SendCNIEvent(tb *TelemetryBuffer, report *CNIReport)

+ func SendCNIMetric(cniMetric *AIMetric, tb *TelemetryBuffer) error

+ func SockExists() bool — linux/amd64, windows/amd64

+ func WaitForTelemetrySocket(maxAttempt int, waitTimeInMillisecs time.Duration)

+ type AIMetric struct

+ Metric aitelemetry.Metric

+ type BridgeInfo struct

+ BridgeName string

+ ErrorMessage string

+ NetworkMode string

+ type Buffer struct

+ CNIReports []CNIReport

+ type CNIReport struct

+ BridgeDetails BridgeInfo

+ CniSucceeded bool

+ ContainerName string

+ Context string

+ ErrorMessage string

+ EventMessage string

+ InfraVnetID string

+ InterfaceDetails InterfaceInfo

+ IsNewInstance bool

+ Logger *zap.Logger

+ Metadata common.Metadata

+ Name string

+ OSDetails OSInfo

+ OperationDuration int

+ OperationType string

+ SubContext string

+ SystemDetails SystemInfo

+ Timestamp string

+ VMUptime string

+ Version string

+ VnetAddressSpace []string

+ func (report *CNIReport) GetOSDetails()

+ func (report *CNIReport) GetReport(name string, version string, ipamQueryURL string)

+ func (report *CNIReport) GetSystemDetails()

+ type DiskInfo struct — linux/amd64, windows/amd64

+ DiskFree uint64

+ DiskTotal uint64

+ type InterfaceInfo struct

+ ErrorMessage string

+ InterfaceType string

+ MAC string

+ Name string

+ PrimaryCA string

+ SecondaryCATotalCount int

+ SecondaryCAUsedCount int

+ Subnet string

+ type MemInfo struct — linux/amd64, windows/amd64

+ MemFree uint64

+ MemTotal uint64

+ type OSInfo struct

+ ErrorMessage string

+ KernelVersion string

+ OSDistribution string

+ OSType string

+ OSVersion string

+ type ReportManager struct

+ ContentType string

+ HostNetAgentURL string

+ Report interface{}

+ func (reportMgr *ReportManager) ReportToBytes() ([]byte, error)

+ func (reportMgr *ReportManager) SendReport(tb *TelemetryBuffer) error

+ type SystemInfo struct

+ CPUCount int

+ DiskVMFree uint64

+ DiskVMTotal uint64

+ ErrorMessage string

+ MemUsedByProcess uint64

+ MemVMFree uint64

+ MemVMTotal uint64

+ type TelemetryBuffer struct

+ Connected bool

+ FdExists bool

+ func NewTelemetryBuffer(logger *zap.Logger) *TelemetryBuffer

+ func (tb *TelemetryBuffer) Cancel()

+ func (tb *TelemetryBuffer) Cleanup(name string) error

+ func (tb *TelemetryBuffer) Close()

+ func (tb *TelemetryBuffer) Connect() error

+ func (tb *TelemetryBuffer) ConnectToTelemetryService(telemetryNumRetries, telemetryWaitTimeInMilliseconds int)

+ func (tb *TelemetryBuffer) CreateAITelemetryHandle(aiConfig aitelemetry.AIConfig, disableAll, disableMetric, disableTrace bool) error

+ func (tb *TelemetryBuffer) Dial(name string) (err error)

+ func (tb *TelemetryBuffer) Listen(name string) (err error)

+ func (tb *TelemetryBuffer) PushData(ctx context.Context)

+ func (tb *TelemetryBuffer) StartServer() error

+ func (tb *TelemetryBuffer) StartTelemetryService(path string, args []string) error

+ func (tb *TelemetryBuffer) Write(b []byte) (c int, err error)

+ type TelemetryConfig struct

+ BatchIntervalInSecs int

+ BatchSizeInBytes int

+ DebugMode bool

+ DisableAll bool

+ DisableMetadataThread bool

+ DisableMetric bool

+ DisableTelemetryToNetAgent bool

+ DisableTrace bool

+ GetEnvRetryCount int

+ GetEnvRetryWaitTimeInSecs int

+ RefreshTimeoutInSecs int

+ ReportToHostIntervalInSeconds time.Duration

+ func ReadConfigFile(filePath string) (TelemetryConfig, error)