types

type CimConfig struct {
	Lmaas    *Lmaas    `json:"lmaas,omitempty"`
	App      *Config   `json:"cim_settings,omitempty"`
	Subjects *Subjects `json:"app_settings,omitempty"`
}

type CimState int

type CommonInfraConf struct {
	EtcdURL           string   `json:"etcd_url"`
	KafkaBrokers      []string `json:"kafka_brokers"`
	LoggingSvcUrl     string   `json:"logging_svc_url"`
	LoggingSvcTcpPort string   `json:"logging_svc_tcp_port"`
	EnableRetx        string   `json:"enable_retrx"`
	APIGwFqdn         string   `json:"apigw_rest_fqdn"`
	TopoEngineFqdn    string   `json:"topoengine_fqdn"`
	LogFormat         string   `json:"log_format"`
}

type Config struct {
	// KafkaEnabled       bool     `json:"kafka_enabled"`
	EnableKpi           bool   `json:"enable_kpi,omitempty"`
	KafkaClientID       string `json:"kafka_client_id,omitempty"`
	AppPort             string `json:"app_port,omitempty"`
	PrometheusEnabled   bool   `json:"prometheus_enabled,omitempty"`
	InsecureSkipVerify  bool   `json:"insecure_skip_verify,omitempty"` // Http2 enforces to use certs, if it's true client no need to send key.
	AllowHttp           bool   `json:"allow_http,omitempty"`           // if url contains https, then also handled
	KeyFilePath         string `json:"key_file_path,omitempty"`        // if insecureskipverify false, key file path
	LogLevel            string `json:"log_level,omitempty"`
	CimFileLog          bool   `json:"cim_file_log,omitempty"`
	NumGarpCount        int    `json:"num_garp_count,omitempty"`
	RemoteSvcRetryCount int    `json:"remote_svc_retry_count,omitempty"`
	TTLTimeout          int    `json:"ttl_timeout,omitempty"`
}

type ConfigObj struct {
	CimConfig *CimConfig `json:"cimConfig"`
}

type EventDetails struct {
	EventName             string              `json:"eventName"`
	EventTime             int64               `json:"eventTime"`
	EventSourceType       string              `json:"eventSourceType,omitempty"`
	ManagedObject         []KeyValueObjects   `json:"managedObject"`
	AdditionalInfo        []KeyValueObjects   `json:"additionalInfo,omitempty"`
	ThresholdInfo         []KeyValueObjects   `json:"thresholdInfo,omitempty"`
	StateChangeDefinition []KeyValueObjects   `json:"stateChangeDefinition,omitempty"`
	MonitoredAttributes   []KeyValueObjects   `json:"monitoredAttributes,omitempty"`
	SourceHeaders         SourceHeaderDetails `json:"sourceHeaders"`
	ContainerId           string              `json:"containerId"`
	SourceName            string              `json:"sourceName,omitempty"`
	SourceID              string              `json:"sourceId,omitempty"`
}

type KeyValueObjects struct {
	Name  string `json:"name"`
	Value string `json:"value"`
}

type Lmaas struct {
	MaxFileSizeInMB      int    `json:"max_file_size_in_mb"`
	MaxBackupFiles       int    `json:"max_backup_files"`
	MaxAge               int    `json:"max_age"`
	BufferSize           int    `json:"buffer_size"`
	FlushTimeout         int    `json:"flush_timeout"`
	LoggingMode          string `json:"logging_mode"`
	PreferLocalDeamonset bool   `json:"prefer_local_daemonset"`
}

type SourceHeaderDetails struct {
	PodUUID       string `json:"pod_uuid,omitempty"`
	UHN           string `json:"uhn,omitempty"`
	CNFCUUID      string `json:"cnfc_uuid,omitempty"`
	PodID         string `json:"podId"`
	Microservice  string `json:"microservice"`
	Nf            string `json:"nf"`
	NfPrefix      string `json:"nfPrefix"`
	NfType        string `json:"nfType"`
	SvcVersion    string `json:"svcVersion"`
	VendorID      string `json:"vendorId,omitempty"`
	XGVelaID      string `json:"xgvelaId,omitempty"`
	NfClass       string `json:"nfClass,omitempty"`
	NfID          string `json:"nfId,omitempty"`
	NfServiceID   string `json:"nfServiceId,omitempty"`
	NfServiceType string `json:"nfServiceType,omitempty"`
}

type Subjects struct {
	AppPort      int  `json:"app_port"`
	Http2Enabled bool `json:"http2_enabled"` // Http2 supported if true
}

type UserInput struct {
	Subject         []string
	QueueGroup      string
	MaxFileSizeMB   int
	MaxBackupFiles  int
	MaxAge          int
	BufSize         int
	PodID           string
	Namespace       string
	SubscriberCount int
	MsgCount        int
	FlushTimeout    time.Duration
}