conf

type ConSelector struct {
	ConnSelectorStr string
	Type            string // mqtt edgex
	CfgKey          string // config key
}

type ConfKeysOperator interface {
	GetPluginName() string
	GetConfContentByte() ([]byte, error)
	// CopyConfContent get the configurations in etc and data folder
	CopyConfContent() map[string]map[string]interface{}
	// CopyReadOnlyConfContent get the configurations in etc folder
	CopyReadOnlyConfContent() map[string]map[string]interface{}
	// CopyUpdatableConfContent get the configurations in data folder
	CopyUpdatableConfContent() map[string]map[string]interface{}
	// CopyUpdatableConfContentFor get the configuration for the specific configKeys
	CopyUpdatableConfContentFor(configKeys []string) map[string]map[string]interface{}
	// LoadConfContent load the configurations into data configuration part
	LoadConfContent(cf map[string]map[string]interface{})
	GetConfKeys() (keys []string)
	GetReadOnlyConfKeys() (keys []string)
	GetUpdatableConfKeys() (keys []string)
	DeleteConfKey(confKey string)
	DeleteConfKeyField(confKey string, reqField map[string]interface{}) error
	AddConfKey(confKey string, reqField map[string]interface{}) error
	AddConfKeyField(confKey string, reqField map[string]interface{}) error
	ClearConfKeys()
}

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

type ConfigOperator interface {
	ConfKeysOperator
	SaveCfgToStorage() error
}

type ConnectionConfigKeysOps struct {
	*ConfigKeys
}

type JsonPathEval interface {
	Eval(data interface{}) (interface{}, error)
}

type KuiperConf struct {
	Basic struct {
		LogLevel            string      `yaml:"logLevel"`
		Debug               bool        `yaml:"debug"`
		ConsoleLog          bool        `yaml:"consoleLog"`
		FileLog             bool        `yaml:"fileLog"`
		LogDisableTimestamp bool        `yaml:"logDisableTimestamp"`
		Syslog              *syslogConf `yaml:"syslog"`
		RotateTime          int         `yaml:"rotateTime"`
		MaxAge              int         `yaml:"maxAge"`
		RotateSize          int64       `yaml:"rotateSize"`
		RotateCount         int         `yaml:"rotateCount"`
		TimeZone            string      `yaml:"timezone"`
		Ip                  string      `yaml:"ip"`
		Port                int         `yaml:"port"`
		RestIp              string      `yaml:"restIp"`
		RestPort            int         `yaml:"restPort"`
		RestTls             *tlsConf    `yaml:"restTls"`
		Prometheus          bool        `yaml:"prometheus"`
		PrometheusPort      int         `yaml:"prometheusPort"`
		PluginHosts         string      `yaml:"pluginHosts"`
		Authentication      bool        `yaml:"authentication"`
		IgnoreCase          bool        `yaml:"ignoreCase"`
		SQLConf             *SQLConf    `yaml:"sql"`
		RulePatrolInterval  string      `yaml:"rulePatrolInterval"`
		CfgStorageType      string      `yaml:"cfgStorageType"`
		EnableOpenZiti      bool        `yaml:"enableOpenZiti"`
	}
	Rule   api.RuleOption
	Sink   *SinkConf
	Source *SourceConf
	Store  struct {
		Type         string `yaml:"type"`
		ExtStateType string `yaml:"extStateType"`
		Redis        struct {
			Host               string `yaml:"host"`
			Port               int    `yaml:"port"`
			Password           string `yaml:"password"`
			Timeout            int    `yaml:"timeout"`
			ConnectionSelector string `yaml:"connectionSelector"`
		}
		Sqlite struct {
			Name string `yaml:"name"`
		}
		Fdb struct {
			Path string `yaml:"path"`
		}
	}
	Portable struct {
		PythonBin   string `yaml:"pythonBin"`
		InitTimeout int    `yaml:"initTimeout"`
	}
}

type PathConfigure struct {
	LoadFileType string
	Dirs         map[string]string
}

type SQLConf struct {
	MaxConnections int `yaml:"maxConnections"`
}

type SinkConf struct {
	MemoryCacheThreshold int    `json:"memoryCacheThreshold" yaml:"memoryCacheThreshold"`
	MaxDiskCache         int    `json:"maxDiskCache" yaml:"maxDiskCache"`
	BufferPageSize       int    `json:"bufferPageSize" yaml:"bufferPageSize"`
	EnableCache          bool   `json:"enableCache" yaml:"enableCache"`
	ResendInterval       int    `json:"resendInterval" yaml:"resendInterval"`
	CleanCacheAtStop     bool   `json:"cleanCacheAtStop" yaml:"cleanCacheAtStop"`
	ResendAlterQueue     bool   `json:"resendAlterQueue" yaml:"resendAlterQueue"`
	ResendPriority       int    `json:"resendPriority" yaml:"resendPriority"`
	ResendIndicatorField string `json:"resendIndicatorField" yaml:"resendIndicatorField"`
}

type SinkConfigKeysOps struct {
	*ConfigKeys
}

type SourceConf struct {
	HttpServerIp   string   `json:"httpServerIp" yaml:"httpServerIp"`
	HttpServerPort int      `json:"httpServerPort" yaml:"httpServerPort"`
	HttpServerTls  *tlsConf `json:"httpServerTls" yaml:"httpServerTls"`
}

type SourceConfigKeysOps struct {
	*ConfigKeys
}