model

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

type EncryptionConf struct {
	Algorithm  string         `yaml:"algorithm,omitempty" json:"algorithm"`
	Properties map[string]any `yaml:"properties,omitempty" json:"properties"`
	Key        string         `yaml:"key,omitempty" json:"key"`
}

type IndexValuer interface {
	ValueByIndex(index int, sourceIndex int) (any, bool)
	SetByIndex(index int, value any)
	SetTempByIndex(index int, value any)
	TempByIndex(index int) any
}

type InfoNode interface {
	Info() NodeInfo
	TransformType() api.Source
}

type KuiperConf struct {
	Hack struct {
		Cold bool `yaml:"cold"`
	}
	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"`
		Pprof                   bool                  `yaml:"pprof"`
		PprofIp                 string                `yaml:"pprofIp"`
		PprofPort               int                   `yaml:"pprofPort"`
		PluginHosts             string                `yaml:"pluginHosts"`
		Authentication          bool                  `yaml:"authentication"`
		IgnoreCase              bool                  `yaml:"ignoreCase"`
		SQLConf                 *SQLConf              `yaml:"sql"`
		RulePatrolInterval      cast.DurationConf     `yaml:"rulePatrolInterval"`
		EnableOpenZiti          bool                  `yaml:"enableOpenZiti"`
		AesKey                  string                `yaml:"aesKey"`
		GracefulShutdownTimeout cast.DurationConf     `yaml:"gracefulShutdownTimeout"`
		ResourceProfileConfig   ResourceProfileConfig `yaml:"ResourceProfileConfig"`
		MetricsDumpConfig       MetricsDumpConfig     `yaml:"metricsDumpConfig"`
		EnableRestAuditLog      bool                  `yaml:"enableRestAuditLog"`
	}
	Rule   def.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            cast.DurationConf `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 cast.DurationConf `yaml:"initTimeout"`
		SendTimeout time.Duration     `yaml:"sendTimeout"`
		RecvTimeout time.Duration     `yaml:"recvTimeout"`
	}
	Connection struct {
		BackoffMaxElapsedDuration cast.DurationConf `yaml:"backoffMaxElapsedDuration"`
	}
	OpenTelemetry OpenTelemetry `yaml:"openTelemetry"`
	AesKey        []byte
	Security      *SecurityConf
}

type MetricsDumpConfig struct {
	Enable           bool          `yaml:"enable"`
	RetainedDuration time.Duration `yaml:"retainedDuration"`
}

type NodeInfo struct {
	NeedDecode      bool
	NeedBatchDecode bool // like decrypt, decompress as a whole
	HasCompress     bool
	HasInterval     bool
}

type OpenTelemetry struct {
	ServiceName           string `yaml:"serviceName"`
	EnableRemoteCollector bool   `yaml:"enableRemoteCollector"`
	RemoteEndpoint        string `yaml:"remoteEndpoint"`
	LocalTraceCapacity    int    `yaml:"localTraceCapacity"`
	EnableLocalStorage    bool   `yaml:"enableLocalStorage"`
}

type PropsConsumer interface {
	Consume(props map[string]any)
}

type ResourceProfileConfig struct {
	Enable   bool          `yaml:"enable"`
	Interval time.Duration `yaml:"interval"`
}

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

type SecurityConf struct {
	Encryption *EncryptionConf          `yaml:"encryption,omitempty"`
	Tls        *TlsConfigurationOptions `yaml:"tls,omitempty"`
}

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       cast.DurationConf `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"`
	ResendDestination    string            `json:"resendDestination" yaml:"resendDestination"`
}

type SinkInfo struct {
	HasCompress bool
	HasBatch    bool
}

type SinkInfoNode interface {
	Info() SinkInfo
}

type SliceVal []any

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

type StreamReader interface {
	CreateWriter(ctx api.StreamContext, currWriter io.Writer, compression string, encryption string) (io.Writer, error)
}

type StreamWriter interface {
	CreateWriter(ctx api.StreamContext, currWriter io.Writer, compression string, encryption string) (io.Writer, error)
}

type SyslogConf struct {
	Enable  bool   `yaml:"enable"`
	Network string `yaml:"network"`
	Address string `yaml:"address"`
	Tag     string `yaml:"tag"`
	Level   string `yaml:"level"`
}

type TlsConf struct {
	Certfile string `yaml:"certfile"`
	Keyfile  string `yaml:"keyfile"`
}

type TlsConfigurationOptions struct {
	SkipCertVerify       bool            `json:"insecureSkipVerify" yaml:"insecureSkipVerify"`
	CertificationRaw     string          `json:"certificationRaw" yaml:"certificationRaw"`
	PrivateKeyRaw        string          `json:"privateKeyRaw" yaml:"privateKeyRaw"`
	RootCARaw            string          `json:"rootCARaw" yaml:"rootCARaw"`
	CertFile             string          `json:"certificationPath" yaml:"certificationPath"`
	KeyFile              string          `json:"privateKeyPath" yaml:"privateKeyPath"`
	CaFile               string          `json:"rootCaPath" yaml:"rootCaPath"`
	TLSMinVersion        string          `json:"tlsMinVersion" yaml:"tlsMinVersion"`
	RenegotiationSupport string          `json:"renegotiationSupport" yaml:"renegotiationSupport"`
	Decrypt              *EncryptionConf `json:"decrypt" yaml:"decrypt,omitempty"`
	// whether use default tls setting
	Tls string `json:"tls"`
}

type TlsKeys struct {
	RawCABytes   []byte
	RawCertBytes []byte
	RawKeyBytes  []byte
}

type UniqueConn interface {
	ConnId(props map[string]any) string
}

type UniqueSub interface {
	SubId(props map[string]any) string
}