server

package

Go to main page

Versions in this module

v1

v1.14.7

Dec 16, 2024

v1.14.6

Nov 11, 2024

v1.14.5

Oct 21, 2024

v1.14.4

Sep 18, 2024

Changes in this version

+ const ProcessErr

v1.14.3

Aug 28, 2024

v1.14.2

Aug 20, 2024

v1.14.1

Jul 19, 2024 GO-2024-3078

GO-2024-3078: LF Edge eKuiper has a SQL Injection in sqlKvStore in github.com/lf-edge/ekuiper

v1.14.0

Jun 26, 2024 GO-2024-3078

GO-2024-3078: LF Edge eKuiper has a SQL Injection in sqlKvStore in github.com/lf-edge/ekuiper

Changes in this version

+ const ContentType

+ const ContentTypeJSON

+ const EtcOsRelease

+ const QueryRuleId

+ const UsrLibOsRelease

+ var NativeFunctionPlugin = []string

+ var NativeSinkPlugin = []string

+ var NativeSourcePlugin = []string

+ func InitConfManagers()

+ func Read() (osrelease map[string]string, err error)

+ func ReadFile(filename string) (osrelease map[string]string, err error)

+ func ReadString(content string) (osrelease map[string]string, err error)

+ func StartUp(Version string)

+ type ConfManager interface

+ Export func() map[string]string

+ Import func(context.Context, map[string]string) map[string]string

+ PartialImport func(context.Context, map[string]string) map[string]string

+ Reset func()

+ Status func() map[string]string

+ type Configuration struct

+ ConnectionConfig map[string]string

+ NativePlugins map[string]string

+ PortablePlugins map[string]string

+ Rules map[string]string

+ Schema map[string]string

+ Scripts map[string]string

+ Service map[string]string

+ SinkConfig map[string]string

+ SourceConfig map[string]string

+ Streams map[string]string

+ Tables map[string]string

+ Uploads map[string]string

+ type ConnectionBody struct

+ Endpoint string

+ type ImportConfigurationStatus struct

+ ConfigResponse Configuration

+ ErrorMsg string

+ type InstallScriptGetter interface

+ InstallScript func(s string) (string, string)

+ type Metrics struct

+ func NewMetrics() *Metrics

+ func (m *Metrics) GetCpuUsage() string

+ func (m *Metrics) GetMemoryUsage() string

+ type RuleMigrationProcessor struct

+ func NewRuleMigrationProcessor(r *processor.RuleProcessor, s *processor.StreamProcessor) *RuleMigrationProcessor

+ func (p *RuleMigrationProcessor) ConfigurationPartialExport(rules []string) ([]byte, error)

+ type RuleRegistry struct

+ func (rr *RuleRegistry) Delete(key string) (*rule.RuleState, bool)

+ func (rr *RuleRegistry) Load(key string) (value *rule.RuleState, ok bool)

+ func (rr *RuleRegistry) Store(key string, value *rule.RuleState)

+ type RuleStatusMetricsValue int

+ const RuleRunning

+ const RuleStopped

+ const RuleStoppedByError

+ type Server int

+ func (t *Server) CreatePlugin(arg *model.PluginDesc, reply *string) error

+ func (t *Server) CreateQuery(sql string, reply *string) error

+ func (t *Server) CreateRule(rule *model.RPCArgDesc, reply *string) error

+ func (t *Server) CreateSchema(arg *model.RPCTypedArgDesc, reply *string) error

+ func (t *Server) CreateService(arg *model.RPCArgDesc, reply *string) error

+ func (t *Server) DescPlugin(arg *model.PluginDesc, reply *string) error

+ func (t *Server) DescRule(name string, reply *string) error

+ func (t *Server) DescSchema(arg *model.RPCTypedArgDesc, reply *string) error

+ func (t *Server) DescService(name string, reply *string) error

+ func (t *Server) DescServiceFunc(name string, reply *string) error

+ func (t *Server) DescUdf(arg string, reply *string) error

+ func (t *Server) DropPlugin(arg *model.PluginDesc, reply *string) error

+ func (t *Server) DropRule(name string, reply *string) error

+ func (t *Server) DropSchema(arg *model.RPCTypedArgDesc, reply *string) error

+ func (t *Server) DropService(name string, reply *string) error

+ func (t *Server) Export(file string, reply *string) error

+ func (t *Server) ExportConfiguration(arg *model.ExportDataDesc, reply *string) error

+ func (t *Server) GetQueryResult(_ string, reply *string) error

+ func (t *Server) GetStatusImport(_ int, reply *string) error

+ func (t *Server) GetStatusRule(name string, reply *string) error

+ func (t *Server) GetTopoRule(name string, reply *string) error

+ func (t *Server) Import(file string, reply *string) error

+ func (t *Server) ImportConfiguration(arg *model.ImportDataDesc, reply *string) error

+ func (t *Server) RegisterPlugin(arg *model.PluginDesc, reply *string) error

+ func (t *Server) RestartRule(name string, reply *string) error

+ func (t *Server) ShowPlugins(arg int, reply *string) error

+ func (t *Server) ShowRules(_ int, reply *string) error

+ func (t *Server) ShowSchemas(schemaType string, reply *string) error

+ func (t *Server) ShowServiceFuncs(_ int, reply *string) error

+ func (t *Server) ShowServices(_ int, reply *string) error

+ func (t *Server) ShowUdfs(_ int, reply *string) error

+ func (t *Server) StartRule(name string, reply *string) error

+ func (t *Server) StopRule(name string, reply *string) error

+ func (t *Server) Stream(stream string, reply *string) error

+ func (t *Server) ValidateRule(rule *model.RPCArgDesc, reply *string) error

+ type UpdateRuleStateType int

+ const UpdateRuleOffset

+ const UpdateRuleState

v1.14.0-dev.1

Mar 25, 2024 GO-2024-3078

GO-2024-3078: LF Edge eKuiper has a SQL Injection in sqlKvStore in github.com/lf-edge/ekuiper

v1.14.0-beta.4

Jun 18, 2024 GO-2024-3078

GO-2024-3078: LF Edge eKuiper has a SQL Injection in sqlKvStore in github.com/lf-edge/ekuiper

v1.14.0-beta.3

Jun 14, 2024 GO-2024-3078

GO-2024-3078: LF Edge eKuiper has a SQL Injection in sqlKvStore in github.com/lf-edge/ekuiper

v1.14.0-beta.2

Jun 6, 2024 GO-2024-3078

GO-2024-3078: LF Edge eKuiper has a SQL Injection in sqlKvStore in github.com/lf-edge/ekuiper

v1.14.0-beta.1

Jun 4, 2024 GO-2024-3078

GO-2024-3078: LF Edge eKuiper has a SQL Injection in sqlKvStore in github.com/lf-edge/ekuiper

v1.14.0-alpha.4

May 16, 2024 GO-2024-3078

GO-2024-3078: LF Edge eKuiper has a SQL Injection in sqlKvStore in github.com/lf-edge/ekuiper

v1.14.0-alpha.3

May 10, 2024 GO-2024-3078

GO-2024-3078: LF Edge eKuiper has a SQL Injection in sqlKvStore in github.com/lf-edge/ekuiper

v1.14.0-alpha.2

Mar 29, 2024 GO-2024-3078

GO-2024-3078: LF Edge eKuiper has a SQL Injection in sqlKvStore in github.com/lf-edge/ekuiper

v1.14.0-alpha.1

Mar 22, 2024 GO-2024-3078

GO-2024-3078: LF Edge eKuiper has a SQL Injection in sqlKvStore in github.com/lf-edge/ekuiper

v1.14.0-alpha.0

Mar 25, 2024 GO-2024-3078

GO-2024-3078: LF Edge eKuiper has a SQL Injection in sqlKvStore in github.com/lf-edge/ekuiper

v1.4.0-beta.2

Jun 6, 2024 GO-2024-3078

GO-2024-3078: LF Edge eKuiper has a SQL Injection in sqlKvStore in github.com/lf-edge/ekuiper

Other modules containing this package

github.com/lf-edge/ekuiper/v2

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL