executor

Documentation

Index

• Constants
• Variables
• func HandleRuleNotification(r *Rule) error
• type ExecutorService
  • func (s *ExecutorService) Name() string
  • func (s *ExecutorService) Start() error
  • func (s *ExecutorService) Stop()
• type ExecutorServiceFactory
  • func (m *ExecutorServiceFactory) New(name string, c core.Config, ch chan core.ServiceCommand) (core.Service, error)
• type Rule

Constants

const (
	RuleActionNew    = "new"
	RuleActionDelete = "delete"
	RuleActionUpdate = "update"
	RuleActionStart  = "start"
	RuleActionStop   = "stop"
)

const (
	RuleStatusIdle    = "idle"
	RuleStatusStarted = "started"
	RuleStatusStoped  = "stoped"
)

Variables

var Configs = map[string]string{}

Functions

func HandleRuleNotification

func HandleRuleNotification(r *Rule) error

HandleRuleNotification handle rule notifications recevied from kafka, it will check rule's validity,for example, wether rule exist in database.

Types

type ExecutorService

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

func (*ExecutorService) Name

func (s *ExecutorService) Name() string

Name

func (*ExecutorService) Start

func (s *ExecutorService) Start() error

Start

func (*ExecutorService) Stop

func (s *ExecutorService) Stop()

Stop

type ExecutorServiceFactory

type ExecutorServiceFactory struct{}

func (*ExecutorServiceFactory) New

func (m *ExecutorServiceFactory) New(name string, c core.Config, ch chan core.ServiceCommand) (core.Service, error)

New create executor service factory

type Rule

type Rule struct {
	RuleName  string `json:"ruleName"`
	RuleId    string `json:"ruleId"`
	ProductId string `json:"productId"`
	Sal       string `json:"sql"`
	Target    string `json:"target"`
	Status    string `json:"status"`
	Action    string
}