logupload

package
v1.0.15 Latest Latest
Warning

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

 Go to latest Published: Dec 11, 2025 License: Apache-2.0, BSD-3-Clause Imports: 18 Imported by: 6

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

*

  • 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

*

  • 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

*

  • 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

View Source 
const (
	EstbIp            string = "estbIP"
	EstbMacAddress    string = "estbMacAddress"
	EcmMac            string = "ecmMacAddress"
	Env               string = "env"
	Model             string = "model"
	AccountMgmt       string = "accountMgmt"
	SerialNum         string = "serialNum"
	PartnerId         string = "partnerId"
	FirmwareVersion   string = "firmwareVersion"
	ControllerId      string = "controllerId"
	ChannelMapId      string = "channelMapId"
	VodId             string = "vodId"
	UploadImmediately string = "uploadImmediately"
	Timezone          string = "timezone"
	Application       string = "applicationType"
	AccountHash       string = "accountHash"
	AccountId         string = "accountId"
	ConfigSetHash     string = "configSetHash"
)
View Source 
const (
	EPON = iota + 1
	PARTNER_SETTINGS
)

Enum for SettingType

View Source 
const (
	MODE_TO_GET_LOG_FILES_0 = "LogFiles"
	MODE_TO_GET_LOG_FILES_1 = "LogFilesGroup"
	MODE_TO_GET_LOG_FILES_2 = "AllLogFiles"
)
View Source 
const (
	WHOLE_DAY_RANDOMIZED        = "Whole Day Randomized"
	UTC                  string = "UTC"
	LOCAL_TIME           string = "Local time"
)
View Source 
const (
	DEFAULT_TIME_ZONE  = "US/Eastern"
	ONE_HOUR_SECONDS   = 3600
	DEFAULT_OFFSET_ROW = -5
)
View Source 
const (
	DEFAULT_LOG_UPLOAD_SETTINGS_MESSAGE = "Don't upload your logs, but check for updates on this schedule."
)
View Source 
const PermanentTelemetryProfileConst = "PermanentTelemetryProfile"
View Source 
const (
	TelemetryTwoProfileJSONSchema = `` /* 19660-byte string literal not displayed */

)

Variables

View Source 
var GetCachedSimpleDaoFunc = db.GetCachedSimpleDao
View Source 
var SettingTypes = [...]string{"PARTNER_SETTINGS", "EPON", "partnersettings", "epon"}
View Source 
var TelemetryTwoProfileSchema *gojsonschema.Schema

Functions

func DeleteExpiredTelemetryProfile 

func DeleteExpiredTelemetryProfile(cacheUpdateWindowSize int64)

func DeleteTelemetryProfile 

func DeleteTelemetryProfile(rowKey string)

func GetRulesFromTimestampedRules 

func GetRulesFromTimestampedRules() []re.Rule

func GetTelemetryProfileMap 

func GetTelemetryProfileMap() *map[string]TelemetryProfile

func IsValidSettingType 

func IsValidSettingType(str string) bool

func IsValidUploadProtocol 

func IsValidUploadProtocol(p string) bool

func IsValidUrl 

func IsValidUrl(str string) bool

func NewDCMGenericRuleInf 

func NewDCMGenericRuleInf() interface{}

func NewDeviceSettingsInf 

func NewDeviceSettingsInf() interface{}

NewDeviceSettingsInf constructor

func NewLogFileInf 

func NewLogFileInf() interface{}

NewLogFileInf constructor

func NewLogFileListInf 

func NewLogFileListInf() interface{}

NewLogFileListInf constructor

func NewLogFilesGroupsInf 

func NewLogFilesGroupsInf() interface{}

NewLogFilesGroupsInf constructor

func NewLogUploadSettingsInf 

func NewLogUploadSettingsInf() interface{}

NewLogUploadSettingsInf constructor

func NewPermanentTelemetryProfileInf 

func NewPermanentTelemetryProfileInf() interface{}

NewPermanentTelemetryProfileInf constructor

func NewSettingProfilesInf 

func NewSettingProfilesInf() interface{}

NewSettingProfilesInf constructor

func NewSettingRulesInf 

func NewSettingRulesInf() interface{}

NewSettingRulesInf constructor

func NewTelemetryProfileInf 

func NewTelemetryProfileInf() interface{}

NewTelemetryProfileInf constructor

func NewTelemetryRuleInf 

func NewTelemetryRuleInf() interface{}

NewTelemetryRuleInf constructor

func NewTelemetryTwoProfileInf 

func NewTelemetryTwoProfileInf() interface{}

NewTelemetryTwoProfileInf constructor

func NewTelemetryTwoRuleInf 

func NewTelemetryTwoRuleInf() interface{}

NewTelemetryTwoRuleInf constructor

func NewUploadRepositoryInf 

func NewUploadRepositoryInf() interface{}

NewUploadRepositoryInf constructor

func NewVodSettingsInf 

func NewVodSettingsInf() interface{}

NewVodSettingsInf constructor

func SetTelemetryProfile 

func SetTelemetryProfile(rowKey string, telemetry TelemetryProfile)

func SettingTypeEnum 

func SettingTypeEnum(s string) int

func ValidateTelemetryTwoProfileJson 

func ValidateTelemetryTwoProfileJson(json string) error

ValidateTelemetryTwoProfileJson validates JSON against the schema

Types

type ConfigurationServiceURL 

type ConfigurationServiceURL struct {
	ID          string `json:"id,omitempty"`
	Name        string `json:"name,omitempty"`
	Description string `json:"description,omitempty"`
	URL         string `json:"url,omitempty"`
}

type DCMFormula 

type DCMFormula struct {
	Formula DCMGenericRule `json:"formula"`
}

type DCMGenericRule 

type DCMGenericRule struct {
	re.Rule
	ID              string      `json:"id"`
	Updated         int64       `json:"updated"`
	Name            string      `json:"name,omitempty"`
	Description     string      `json:"description,omitempty"`
	Priority        int         `json:"priority,omitempty"`
	RuleExpression  string      `json:"ruleExpression,omitempty"`
	Percentage      int         `json:"percentage,omitempty"`
	PercentageL1    json.Number `json:"percentageL1,omitempty"`
	PercentageL2    json.Number `json:"percentageL2,omitempty"`
	PercentageL3    json.Number `json:"percentageL3,omitempty"`
	ApplicationType string      `json:"applicationType"`
}

DcmRule DcmRule table

func GetDCMGenericRuleList 

func GetDCMGenericRuleList() []*DCMGenericRule

func GetDCMGenericRuleListForAS 

func GetDCMGenericRuleListForAS() []*DCMGenericRule

func GetOneDCMGenericRule 

func GetOneDCMGenericRule(id string) *DCMGenericRule

func (*DCMGenericRule) Clone 

func (obj *DCMGenericRule) Clone() (*DCMGenericRule, error)

func (*DCMGenericRule) GetID 

func (obj *DCMGenericRule) GetID() string

func (*DCMGenericRule) GetId 

func (r *DCMGenericRule) GetId() string

GetId XRule interface

func (*DCMGenericRule) GetName 

func (r *DCMGenericRule) GetName() string

GetName XRule interface

func (*DCMGenericRule) GetPriority 

func (obj *DCMGenericRule) GetPriority() int

func (*DCMGenericRule) GetRule 

func (r *DCMGenericRule) GetRule() *re.Rule

GetRule XRule interface

func (*DCMGenericRule) GetRuleType 

func (r *DCMGenericRule) GetRuleType() string

GetRuleType XRule interface

func (*DCMGenericRule) GetTemplateId 

func (r *DCMGenericRule) GetTemplateId() string

GetTemplateId XRule interface

func (*DCMGenericRule) SetPriority 

func (obj *DCMGenericRule) SetPriority(priority int)

func (*DCMGenericRule) ToStringOnlyBaseProperties 

func (dcm *DCMGenericRule) ToStringOnlyBaseProperties() string

type DeviceSettings 

type DeviceSettings struct {
	ID                      string                  `json:"id"`
	Updated                 int64                   `json:"updated"`
	Name                    string                  `json:"name"`
	CheckOnReboot           bool                    `json:"checkOnReboot"`
	ConfigurationServiceURL ConfigurationServiceURL `json:"configurationServiceURL,omitempty"`
	SettingsAreActive       bool                    `json:"settingsAreActive"`
	Schedule                Schedule                `json:"schedule"`
	ApplicationType         string                  `json:"applicationType"`
}

DeviceSettings DeviceSettings2 table

func GetOneDeviceSettings 

func GetOneDeviceSettings(id string) *DeviceSettings

func (*DeviceSettings) Clone 

func (obj *DeviceSettings) Clone() (*DeviceSettings, error)

type FormulaWithSettings 

type FormulaWithSettings struct {
	Formula           *DCMGenericRule    `json:"formula"`
	DeviceSettings    *DeviceSettings    `json:"deviceSettings"`
	LogUpLoadSettings *LogUploadSettings `json:"logUploadSettings"`
	VodSettings       *VodSettings       `json:"vodSettings"`
}

type LogFile 

type LogFile struct {
	ID             string `json:"id"`
	Updated        int64  `json:"updated"`
	Name           string `json:"name"`
	DeleteOnUpload bool   `json:"deleteOnUpload"`
}

LogFile table

func GetLogFileList 

func GetLogFileList(size int) []*LogFile

func (*LogFile) Clone 

func (obj *LogFile) Clone() (*LogFile, error)

type LogFileList 

type LogFileList struct {
	Updated int64      `json:"updated"`
	Data    []*LogFile `json:"data"`
}

LogFileList LogFileList table

func GetOneLogFileList 

func GetOneLogFileList(id string) (*LogFileList, error)

func (*LogFileList) Clone 

func (obj *LogFileList) Clone() (*LogFileList, error)

type LogFilesGroups 

type LogFilesGroups struct {
	ID         string   `json:"id"`
	Updated    int64    `json:"updated"`
	GroupName  string   `json:"groupName"`
	LogFileIDs []string `json:"logFileIds"`
}

LogFilesGroups table

func (*LogFilesGroups) Clone 

func (obj *LogFilesGroups) Clone() (*LogFilesGroups, error)

type LogUploadSettings 

type LogUploadSettings struct {
	ID                  string   `json:"id"`
	Updated             int64    `json:"updated"`
	Name                string   `json:"name"`
	UploadOnReboot      bool     `json:"uploadOnReboot"`
	NumberOfDays        int      `json:"numberOfDays"`
	AreSettingsActive   bool     `json:"areSettingsActive"`
	Schedule            Schedule `json:"schedule"`
	LogFileIds          []string `json:"logFileIds"`
	LogFilesGroupID     string   `json:"logFilesGroupId"`
	ModeToGetLogFiles   string   `json:"modeToGetLogFiles"`
	UploadRepositoryID  string   `json:"uploadRepositoryId"`
	ActiveDateTimeRange bool     `json:"activeDateTimeRange"`
	FromDateTime        string   `json:"fromDateTime"`
	ToDateTime          string   `json:"toDateTime"`
	ApplicationType     string   `json:"applicationType"`
}

LogUploadSettings LogUploadSettings2 table

func GetOneLogUploadSettings 

func GetOneLogUploadSettings(id string) *LogUploadSettings

func (*LogUploadSettings) Clone 

func (obj *LogUploadSettings) Clone() (*LogUploadSettings, error)

type PermanentTelemetryProfile 

type PermanentTelemetryProfile struct {
	Type             string             `json:"@type,omitempty"`
	ID               string             `json:"id"`
	TelemetryProfile []TelemetryElement `json:"telemetryProfile"`
	Schedule         string             `json:"schedule"`
	Expires          int64              `json:"expires"`
	Name             string             `json:"telemetryProfile:name"`
	UploadRepository string             `json:"uploadRepository:URL"`
	UploadProtocol   UploadProtocol     `json:"uploadRepository:uploadProtocol"`
	ApplicationType  string             `json:"applicationType,omitempty"`
}

PermanentTelemetryProfile PermanentTelemetry table

func GetOnePermanentTelemetryProfile 

func GetOnePermanentTelemetryProfile(rowKey string) *PermanentTelemetryProfile

func GetPermanentTelemetryProfileList 

func GetPermanentTelemetryProfileList() []*PermanentTelemetryProfile

func NullifyUnwantedFieldsPermanentTelemetryProfile 

func NullifyUnwantedFieldsPermanentTelemetryProfile(profile *PermanentTelemetryProfile) *PermanentTelemetryProfile

func (*PermanentTelemetryProfile) Clone 

func (obj *PermanentTelemetryProfile) Clone() (*PermanentTelemetryProfile, error)

func (*PermanentTelemetryProfile) EqualChangeData 

func (s *PermanentTelemetryProfile) EqualChangeData(t *PermanentTelemetryProfile) bool

func (*PermanentTelemetryProfile) Equals 

func (s *PermanentTelemetryProfile) Equals(t *PermanentTelemetryProfile) bool

func (*PermanentTelemetryProfile) GetApplicationType 

func (s *PermanentTelemetryProfile) GetApplicationType() string

func (*PermanentTelemetryProfile) IsEmpty 

func (obj *PermanentTelemetryProfile) IsEmpty() bool

func (*PermanentTelemetryProfile) SetApplicationType 

func (s *PermanentTelemetryProfile) SetApplicationType(appType string)

func (*PermanentTelemetryProfile) Validate 

func (obj *PermanentTelemetryProfile) Validate() error

type PermanentTelemetryRuleDescriptor 

type PermanentTelemetryRuleDescriptor struct {
	RuleId   string `json:"ruleId"`
	RuleName string `json:"ruleName"`
}

func NewPermanentTelemetryRuleDescriptor 

func NewPermanentTelemetryRuleDescriptor() *PermanentTelemetryRuleDescriptor

type Schedule 

type Schedule struct {
	Type              string      `json:"type,omitempty"`
	Expression        string      `json:"expression,omitempty"`
	TimeZone          string      `json:"timeZone,omitempty"`
	ExpressionL1      string      `json:"expressionL1,omitempty"`
	ExpressionL2      string      `json:"expressionL2,omitempty"`
	ExpressionL3      string      `json:"expressionL3,omitempty"`
	StartDate         string      `json:"startDate,omitempty"`
	EndDate           string      `json:"endDate,omitempty"`
	TimeWindowMinutes json.Number `json:"timeWindowMinutes,omitempty"`
}

type SettingProfiles 

type SettingProfiles struct {
	ID               string            `json:"id"`
	Updated          int64             `json:"updated"`
	SettingProfileID string            `json:"settingProfileId"`
	SettingType      string            `json:"settingType"`
	Properties       map[string]string `json:"properties"`
	ApplicationType  string            `json:"applicationType"`
}

SettingProfiles table

func (*SettingProfiles) Clone 

func (obj *SettingProfiles) Clone() (*SettingProfiles, error)

type SettingRule 

type SettingRule struct {
	ID              string  `json:"id"`
	Updated         int64   `json:"updated"`
	Name            string  `json:"name"`
	Rule            re.Rule `json:"rule"`
	BoundSettingID  string  `json:"boundSettingId"`
	ApplicationType string  `json:"applicationType"`
}

SettingRule SettingRules table

func (*SettingRule) Clone 

func (obj *SettingRule) Clone() (*SettingRule, error)

func (*SettingRule) GetApplicationType 

func (r *SettingRule) GetApplicationType() string

func (*SettingRule) GetId 

func (r *SettingRule) GetId() string

GetId XRule interface

func (*SettingRule) GetName 

func (r *SettingRule) GetName() string

GetName XRule interface

func (*SettingRule) GetRule 

func (r *SettingRule) GetRule() *re.Rule

GetRule XRule interface

func (*SettingRule) GetRuleType 

func (r *SettingRule) GetRuleType() string

GetRuleType XRule interface

func (*SettingRule) GetTemplateId 

func (r *SettingRule) GetTemplateId() string

GetTemplateId XRule interface

type Settings 

type Settings struct {
	RuleIDs                           map[string]string
	SchedulerType                     string
	GroupName                         string
	CheckOnReboot                     bool
	ConfigurationServiceURL           string
	ScheduleCron                      string
	TimeZoneMode                      string
	ScheduleDurationMinutes           int
	ScheduleStartDate                 string
	ScheduleEndDate                   string
	LusMessage                        string
	LusName                           string
	LusNumberOfDay                    int
	LusUploadRepositoryName           string
	LusUploadRepositoryURLNew         string
	LusUploadRepositoryUploadProtocol string
	LusUploadRepositoryURL            string
	LusUploadOnReboot                 bool
	UploadImmediately                 bool
	//Upload flag to indicate if allowed to upload logs or not.
	Upload               bool
	LusLogFiles          []*LogFile
	LusLogFilesStartDate string
	LusLogFilesEndDate   string
	//For level one logging
	LusScheduleCron            string
	LusTimeZoneMode            string
	LusScheduleCronL1          string
	LusScheduleCronL2          string
	LusScheduleCronL3          string
	LusScheduleDurationMinutes int
	LusScheduleStartDate       string
	LusScheduleEndDate         string
	VodSettingsName            string
	LocationUrl                string
	TelemetryProfile           *PermanentTelemetryProfile
	SrmIPList                  map[string]string
	EponSettings               map[string]string
	PartnerSettings            map[string]string
}

func CopySettings 

func CopySettings(output *Settings, settings *Settings, rule *DCMGenericRule, context map[string]string, fields log.Fields) *Settings

func NewSettings 

func NewSettings(logFileLenth int) *Settings

func (*Settings) AreFull 

func (s *Settings) AreFull() bool

func (*Settings) CopyDeviceSettings 

func (s *Settings) CopyDeviceSettings(settings *Settings)

func (*Settings) CopyLusSetting 

func (s *Settings) CopyLusSetting(settings *Settings, setLUSSettings bool)

func (*Settings) CopyVodSettings 

func (s *Settings) CopyVodSettings(settings *Settings)

func (*Settings) SetSettingProfiles 

func (s *Settings) SetSettingProfiles(settingProfiles []SettingProfiles)

type SettingsResponse 

type SettingsResponse struct {
	GroupName                         interface{}                `json:"urn:settings:GroupName"`
	CheckOnReboot                     bool                       `json:"urn:settings:CheckOnReboot"`
	TimeZoneMode                      string                     `json:"urn:settings:TimeZoneMode"`
	ScheduleCron                      interface{}                `json:"urn:settings:CheckSchedule:cron"`
	ScheduleDurationMinutes           int                        `json:"urn:settings:CheckSchedule:DurationMinutes"`
	LusMessage                        interface{}                `json:"urn:settings:LogUploadSettings:Message"`
	LusName                           interface{}                `json:"urn:settings:LogUploadSettings:Name"`
	LusNumberOfDay                    int                        `json:"urn:settings:LogUploadSettings:NumberOfDays"`
	LusUploadRepositoryName           interface{}                `json:"urn:settings:LogUploadSettings:UploadRepositoryName"`
	LusUploadRepositoryURLNew         string                     `json:"urn:settings:LogUploadSettings:UploadRepository:URL,omitempty"`
	LusUploadRepositoryUploadProtocol string                     `json:"urn:settings:LogUploadSettings:UploadRepository:uploadProtocol,omitempty"`
	LusUploadRepositoryURL            string                     `json:"urn:settings:LogUploadSettings:RepositoryURL,omitempty"`
	LusUploadOnReboot                 bool                       `json:"urn:settings:LogUploadSettings:UploadOnReboot"`
	UploadImmediately                 bool                       `json:"urn:settings:LogUploadSettings:UploadImmediately"`
	Upload                            bool                       `json:"urn:settings:LogUploadSettings:upload"`
	LusScheduleCron                   interface{}                `json:"urn:settings:LogUploadSettings:UploadSchedule:cron"`
	LusScheduleCronL1                 interface{}                `json:"urn:settings:LogUploadSettings:UploadSchedule:levelone:cron"`
	LusScheduleCronL2                 interface{}                `json:"urn:settings:LogUploadSettings:UploadSchedule:leveltwo:cron"`
	LusScheduleCronL3                 interface{}                `json:"urn:settings:LogUploadSettings:UploadSchedule:levelthree:cron"`
	LusTimeZoneMode                   string                     `json:"urn:settings:LogUploadSettings:UploadSchedule:TimeZoneMode"`
	LusScheduleDurationMinutes        int                        `json:"urn:settings:LogUploadSettings:UploadSchedule:DurationMinutes"`
	VodSettingsName                   interface{}                `json:"urn:settings:VODSettings:Name"`
	LocationUrl                       interface{}                `json:"urn:settings:VODSettings:LocationsURL"`
	SrmIPList                         interface{}                `json:"urn:settings:VODSettings:SRMIPList"`
	EponSettings                      map[string]string          `json:"urn:settings:SettingType:epon,omitempty"`
	TelemetryProfile                  *PermanentTelemetryProfile `json:"urn:settings:TelemetryProfile,omitempty"`
	PartnerSettings                   map[string]string          `json:"urn:settings:SettingType:partnersettings,omitempty"`
}

func CreateSettingsResponseObject 

func CreateSettingsResponseObject(settings *Settings) *SettingsResponse

type TelemetryElement 

type TelemetryElement struct {
	ID               string `json:"id,omitempty"`
	Header           string `json:"header"`
	Content          string `json:"content"`
	Type             string `json:"type"`
	PollingFrequency string `json:"pollingFrequency"`
	Component        string `json:"component,omitempty"`
}

TelemetryElement a telemetry element

func (*TelemetryElement) EqualTelemetryData 

func (t *TelemetryElement) EqualTelemetryData(o *TelemetryElement) bool

func (*TelemetryElement) Equals 

func (t *TelemetryElement) Equals(o *TelemetryElement) bool

type TelemetryProfile 

type TelemetryProfile struct {
	ID               string             `json:"id"`
	TelemetryProfile []TelemetryElement `json:"telemetryProfile"`
	Schedule         string             `json:"schedule"`
	Expires          int64              `json:"expires"`
	Name             string             `json:"telemetryProfile:name"`
	UploadRepository string             `json:"uploadRepository:URL"`
	UploadProtocol   UploadProtocol     `json:"uploadRepository:uploadProtocol"`
	ApplicationType  string             `json:"applicationType"`
}

TelemetryProfile Telemetry table

func GetOneTelemetryProfile 

func GetOneTelemetryProfile(rowKey string) *TelemetryProfile

func GetTelemetryProfileList 

func GetTelemetryProfileList() []*TelemetryProfile

func (*TelemetryProfile) Clone 

func (obj *TelemetryProfile) Clone() (*TelemetryProfile, error)

type TelemetryProfileDescriptor 

type TelemetryProfileDescriptor struct {
	ID   string `json:"id"`
	Name string `json:"name"`
}

func NewTelemetryProfileDescriptor 

func NewTelemetryProfileDescriptor() *TelemetryProfileDescriptor

type TelemetryRule 

type TelemetryRule struct {
	re.Rule
	ID               string `json:"id"`
	Updated          int64  `json:"updated"`
	BoundTelemetryID string `json:"boundTelemetryId"`
	Name             string `json:"name"`
	ApplicationType  string `json:"applicationType"`
}

TelemetryRule TelemetryRules table

func GetTelemetryRuleList 

func GetTelemetryRuleList() []*TelemetryRule

func GetTelemetryRuleListForAs 

func GetTelemetryRuleListForAs() []*TelemetryRule

func (*TelemetryRule) Clone 

func (obj *TelemetryRule) Clone() (*TelemetryRule, error)

func (*TelemetryRule) GetApplicationType 

func (r *TelemetryRule) GetApplicationType() string

func (*TelemetryRule) GetId 

func (r *TelemetryRule) GetId() string

GetId XRule interface

func (*TelemetryRule) GetName 

func (r *TelemetryRule) GetName() string

GetName XRule interface

func (*TelemetryRule) GetRule 

func (r *TelemetryRule) GetRule() *re.Rule

GetRule XRule interface

func (*TelemetryRule) GetRuleType 

func (r *TelemetryRule) GetRuleType() string

GetRuleType XRule interface

func (*TelemetryRule) GetTemplateId 

func (r *TelemetryRule) GetTemplateId() string

GetTemplateId XRule interface

type TelemetryTwoProfile 

type TelemetryTwoProfile struct {
	Type            string `json:"@type,omitempty"`
	ID              string `json:"id"`
	Updated         int64  `json:"updated"`
	Name            string `json:"name"`
	Jsonconfig      string `json:"jsonconfig"`
	ApplicationType string `json:"applicationType"`
}

TelemetryTwoProfile TelemetryTwoProfiles table

func GetOneTelemetryTwoProfile 

func GetOneTelemetryTwoProfile(rowKey string) *TelemetryTwoProfile

func (*TelemetryTwoProfile) Clone 

func (obj *TelemetryTwoProfile) Clone() (*TelemetryTwoProfile, error)

func (*TelemetryTwoProfile) EqualChangeData 

func (s *TelemetryTwoProfile) EqualChangeData(t *TelemetryTwoProfile) bool

func (*TelemetryTwoProfile) Equals 

func (s *TelemetryTwoProfile) Equals(t *TelemetryTwoProfile) bool

func (*TelemetryTwoProfile) GetApplicationType 

func (obj *TelemetryTwoProfile) GetApplicationType() string

func (*TelemetryTwoProfile) SetApplicationType 

func (obj *TelemetryTwoProfile) SetApplicationType(appType string)

func (*TelemetryTwoProfile) Validate 

func (entity *TelemetryTwoProfile) Validate() error

func (*TelemetryTwoProfile) ValidateAll 

func (entity *TelemetryTwoProfile) ValidateAll(existingEntities []*TelemetryTwoProfile) error

type TelemetryTwoRule 

type TelemetryTwoRule struct {
	re.Rule
	ID                string   `json:"id"`
	Updated           int64    `json:"updated"`
	Name              string   `json:"name"`
	ApplicationType   string   `json:"applicationType"`
	BoundTelemetryIDs []string `json:"boundTelemetryIds"`
	NoOp              bool     `json:"noOp"`
}

TelemetryTwoRule TelemetryTwoRules table

func GetTelemetryTwoRuleList 

func GetTelemetryTwoRuleList() []*TelemetryTwoRule

func GetTelemetryTwoRuleListForAS 

func GetTelemetryTwoRuleListForAS() []*TelemetryTwoRule

func (*TelemetryTwoRule) Clone 

func (obj *TelemetryTwoRule) Clone() (*TelemetryTwoRule, error)

func (*TelemetryTwoRule) Equals 

func (t *TelemetryTwoRule) Equals(o *TelemetryTwoRule) bool

func (*TelemetryTwoRule) GetId 

func (r *TelemetryTwoRule) GetId() string

GetId XRule interface

func (*TelemetryTwoRule) GetName 

func (r *TelemetryTwoRule) GetName() string

GetName XRule interface

func (*TelemetryTwoRule) GetRule 

func (r *TelemetryTwoRule) GetRule() *re.Rule

GetRule XRule interface

func (*TelemetryTwoRule) GetRuleType 

func (r *TelemetryTwoRule) GetRuleType() string

GetRuleType XRule interface

func (*TelemetryTwoRule) GetTemplateId 

func (r *TelemetryTwoRule) GetTemplateId() string

GetTemplateId XRule interface

func (*TelemetryTwoRule) String 

func (t *TelemetryTwoRule) String() string

type TimestampedRule 

type TimestampedRule struct {
	re.Rule
	Timestamp int64
}

func GetTimestampedRules 

func GetTimestampedRules() []TimestampedRule

func NewTimestampedRule 

func NewTimestampedRule() *TimestampedRule

func (*TimestampedRule) Equals 

func (t *TimestampedRule) Equals(x *TimestampedRule) bool

func (*TimestampedRule) ToString 

func (t *TimestampedRule) ToString() string

type UploadProtocol 

type UploadProtocol string

UploadProtocol enum 

const (
	TFTP  UploadProtocol = "TFTP"
	SFTP  UploadProtocol = "SFTP"
	SCP   UploadProtocol = "SCP"
	HTTP  UploadProtocol = "HTTP"
	HTTPS UploadProtocol = "HTTPS"
	S3    UploadProtocol = "S3"
)

type UploadRepository 

type UploadRepository struct {
	ID              string `json:"id"`
	Updated         int64  `json:"updated"`
	Name            string `json:"name"`
	Description     string `json:"description"`
	URL             string `json:"url"`
	ApplicationType string `json:"applicationType"`
	Protocol        string `json:"protocol"`
}

UploadRepository table

func GetOneUploadRepository 

func GetOneUploadRepository(id string) *UploadRepository

func (*UploadRepository) Clone 

func (obj *UploadRepository) Clone() (*UploadRepository, error)

type VodSettings 

type VodSettings struct {
	ID              string            `json:"id"`
	Updated         int64             `json:"updated"`
	Name            string            `json:"name"`
	LocationsURL    string            `json:"locationsURL"`
	IPNames         []string          `json:"ipNames"`
	IPList          []string          `json:"ipList"`
	SrmIPList       map[string]string `json:"srmIPList"`
	ApplicationType string            `json:"applicationType"`
}

VodSettings table

func GetOneVodSettings 

func GetOneVodSettings(id string) *VodSettings

func (*VodSettings) Clone 

func (obj *VodSettings) Clone() (*VodSettings, error)

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.