rule

Documentation

Index

• Variables
• type EngineRuleService
• type LogicCache
  • func NewLogicCache() LogicCache
• type RuleLogic
• type RuleService

Variables

var GetService = func() RuleService {
	return &ruleServiceImpl{}
}

var GetServiceForEngine = func() EngineRuleService {
	return GetService()
}

Types

type EngineRuleService

type EngineRuleService interface {
	FindAll() ([]types.Rule, error)
	SyncStart(after time.Duration, ruleID, engine string, force bool) (time.Duration, *types.RuleSyncInfo, error)
	SyncEnd(ruleSync types.RuleSyncInfo, syncData types.RuleSyncData) error
}

type LogicCache

type LogicCache interface {
	LogicFromRule(r types.Rule) (src RuleLogic, err error)
}

func NewLogicCache

func NewLogicCache() LogicCache

type RuleLogic

type RuleLogic interface {
	KubernetesRestConfig() (restConfig *rest.Config, poolName string, err error)
}

type RuleService

type RuleService interface {
	EngineRuleService
	Save(rules []*types.Rule, upsert bool) error
	FindMetadata(metadata map[string]string) ([]types.Rule, error)
	FindByRule(rule types.Rule) ([]types.Rule, error)
	FindByID(id string) (types.Rule, error)
	FindBySourceTsuruApp(appName string) ([]types.Rule, error)
	FindBySourceTsuruJob(jobName string) ([]types.Rule, error)
	Delete(id string) error
	DeleteMetadata(metadata map[string]string) error
	FindSyncs(ruleIDFilter []string) ([]types.RuleSyncInfo, error)
}