telemetry

package
v1.0.17 Latest Latest
Warning

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

 Go to latest Published: Jan 28, 2026 License: Apache-2.0, BSD-3-Clause Imports: 9 Imported by: 2

Documentation

Overview

*

  • Copyright 2022 Comcast Cable Communications Management, LLC *
  • Licensed under the Apache License, Version 2.0 (the "License");
  • you may not use this file except in compliance with the License.
  • You may obtain a copy of the License at *
  • http://www.apache.org/licenses/LICENSE-2.0 *
  • Unless required by applicable law or agreed to in writing, software
  • distributed under the License is distributed on an "AS IS" BASIS,
  • WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  • See the License for the specific language governing permissions and
  • limitations under the License. *
  • SPDX-License-Identifier: Apache-2.0

Index

Constants

This section is empty.

Variables

View Source 
var DeleteTelemetryProfileFunc = logupload.DeleteTelemetryProfile
View Source 
var GetOneTelemetryProfileFunc = logupload.GetOneTelemetryProfile
View Source 
var GetOneTelemetryTwoProfileFunc = logupload.GetOneTelemetryTwoProfile
View Source 
var GetTelemetryProfileMapFunc = logupload.GetTelemetryProfileMap
View Source 
var GetTimestampedRulesFunc = logupload.GetTimestampedRules
View Source 
var NewRuleProcessorFactoryFunc = re.NewRuleProcessorFactory
View Source 
var SetTelemetryProfileFunc = logupload.SetTelemetryProfile

Functions

This section is empty.

Types

type TelemetryProfileService 

type TelemetryProfileService struct {
	//RuleProcessorFactory		ev.RuleProcessorFactory
	CacheUpdateWindowSize int64
}

func NewTelemetryProfileService 

func NewTelemetryProfileService() *TelemetryProfileService

func (*TelemetryProfileService) ConvertToDescriptor 

func (t *TelemetryProfileService) ConvertToDescriptor(rule logupload.TelemetryRule) *logupload.PermanentTelemetryRuleDescriptor

func (*TelemetryProfileService) ConvertToProfileDescriptor 

func (t *TelemetryProfileService) ConvertToProfileDescriptor(profile logupload.TelemetryProfile) *logupload.TelemetryProfileDescriptor

func (*TelemetryProfileService) CreateRuleForAttribute 

func (t *TelemetryProfileService) CreateRuleForAttribute(contextAttribute string, expectedValue string) *logupload.TimestampedRule

func (*TelemetryProfileService) CreateTelemetryProfile 

func (t *TelemetryProfileService) CreateTelemetryProfile(contextAttribute string, expectedValue string, telemetry logupload.TelemetryProfile) *logupload.TimestampedRule

func (*TelemetryProfileService) DropTelemetryFor 

func (t *TelemetryProfileService) DropTelemetryFor(contextAttribute string, expectedValue string) *[]logupload.TelemetryProfile

func (*TelemetryProfileService) ExpireTemporaryTelemetryRules 

func (t *TelemetryProfileService) ExpireTemporaryTelemetryRules()

func (*TelemetryProfileService) GetAvailableDescriptors 

func (t *TelemetryProfileService) GetAvailableDescriptors(applicationType string) []*logupload.PermanentTelemetryRuleDescriptor

func (*TelemetryProfileService) GetAvailableProfileDescriptors 

func (t *TelemetryProfileService) GetAvailableProfileDescriptors(applicationType string) []*logupload.TelemetryProfileDescriptor

func (*TelemetryProfileService) GetMaxRule 

func (t *TelemetryProfileService) GetMaxRule(tRules []*logupload.TelemetryRule) *logupload.TelemetryRule

func (*TelemetryProfileService) GetPermanentProfileByTelemetryRule 

func (t *TelemetryProfileService) GetPermanentProfileByTelemetryRule(telemetryRule *logupload.TelemetryRule) *logupload.PermanentTelemetryProfile

func (*TelemetryProfileService) GetPermanentProfileForContext 

func (t *TelemetryProfileService) GetPermanentProfileForContext(context map[string]string) *logupload.PermanentTelemetryProfile

func (*TelemetryProfileService) GetTelemetryForContext 

func (t *TelemetryProfileService) GetTelemetryForContext(context map[string]string) *logupload.TelemetryProfile

func (*TelemetryProfileService) GetTelemetryRuleForContext 

func (t *TelemetryProfileService) GetTelemetryRuleForContext(context map[string]string) *logupload.TelemetryRule

func (*TelemetryProfileService) GetTelemetryTwoProfileByTelemetryRules 

func (t *TelemetryProfileService) GetTelemetryTwoProfileByTelemetryRules(telemetryTwoRules []*logupload.TelemetryTwoRule, fields log.Fields) []*logupload.TelemetryTwoProfile

func (*TelemetryProfileService) GetTemporaryProfileForContext 

func (t *TelemetryProfileService) GetTemporaryProfileForContext(context map[string]string) *logupload.TelemetryProfile

func (*TelemetryProfileService) ProcessEntityRules 

func (t *TelemetryProfileService) ProcessEntityRules(telemetryRuleList []*logupload.TelemetryRule, context map[string]string) []*logupload.TelemetryRule

func (*TelemetryProfileService) ProcessTelemetryTwoRules 

func (t *TelemetryProfileService) ProcessTelemetryTwoRules(context map[string]string) []*logupload.TelemetryTwoRule

func (*TelemetryProfileService) ProcessTelemetryTwoRulesForAS 

func (t *TelemetryProfileService) ProcessTelemetryTwoRulesForAS(context map[string]string) []*logupload.TelemetryTwoRule

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.