processors

Documentation

Index

• type RuleProcessor
  • func NewRuleProcessor(d string) *RuleProcessor
  • func (p *RuleProcessor) ExecCreate(name, ruleJson string) (*api.Rule, error)
  • func (p *RuleProcessor) ExecDesc(name string) (string, error)
  • func (p *RuleProcessor) ExecDrop(name string) (string, error)
  • func (p *RuleProcessor) ExecQuery(ruleid, sql string) (*xstream.TopologyNew, error)
  • func (p *RuleProcessor) ExecReplaceRuleState(name string, triggered bool) (err error)
  • func (p *RuleProcessor) ExecUpdate(name, ruleJson string) (*api.Rule, error)
  • func (p *RuleProcessor) GetAllRules() ([]string, error)
  • func (p *RuleProcessor) GetRuleByName(name string) (*api.Rule, error)
• type StreamProcessor
  • func NewStreamProcessor(d string) *StreamProcessor
  • func (p *StreamProcessor) DescStream(name string) (*xsql.StreamStmt, error)
  • func (p *StreamProcessor) DropStream(name string) (string, error)
  • func (p *StreamProcessor) ExecReplaceStream(statement string) (string, error)
  • func (p *StreamProcessor) ExecStmt(statement string) (result []string, err error)
  • func (p *StreamProcessor) ExecStreamSql(statement string) (string, error)
  • func (p *StreamProcessor) ShowStream() ([]string, error)

Types

type RuleProcessor

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

func NewRuleProcessor

func NewRuleProcessor(d string) *RuleProcessor

func (*RuleProcessor) ExecCreate

func (p *RuleProcessor) ExecCreate(name, ruleJson string) (*api.Rule, error)

func (*RuleProcessor) ExecDesc

func (p *RuleProcessor) ExecDesc(name string) (string, error)

func (*RuleProcessor) ExecDrop

func (p *RuleProcessor) ExecDrop(name string) (string, error)

func (*RuleProcessor) ExecQuery

func (p *RuleProcessor) ExecQuery(ruleid, sql string) (*xstream.TopologyNew, error)

func (*RuleProcessor) ExecReplaceRuleState

func (p *RuleProcessor) ExecReplaceRuleState(name string, triggered bool) (err error)

func (*RuleProcessor) ExecUpdate

func (p *RuleProcessor) ExecUpdate(name, ruleJson string) (*api.Rule, error)

func (*RuleProcessor) GetAllRules

func (p *RuleProcessor) GetAllRules() ([]string, error)

func (*RuleProcessor) GetRuleByName

func (p *RuleProcessor) GetRuleByName(name string) (*api.Rule, error)

type StreamProcessor

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

func NewStreamProcessor

func NewStreamProcessor(d string) *StreamProcessor

@params d : the directory of the DB to save the stream info

func (*StreamProcessor) DescStream

func (p *StreamProcessor) DescStream(name string) (*xsql.StreamStmt, error)

func (*StreamProcessor) DropStream

func (p *StreamProcessor) DropStream(name string) (string, error)

func (*StreamProcessor) ExecReplaceStream

func (p *StreamProcessor) ExecReplaceStream(statement string) (string, error)

func (*StreamProcessor) ExecStmt

func (p *StreamProcessor) ExecStmt(statement string) (result []string, err error)

func (*StreamProcessor) ExecStreamSql

func (p *StreamProcessor) ExecStreamSql(statement string) (string, error)

func (*StreamProcessor) ShowStream

func (p *StreamProcessor) ShowStream() ([]string, error)