core

Jul 22, 2023

Changes in this version

type DipperEngine

+ func (d *DipperEngine) OutputSubscribe(ctx context.Context, callback queue.SubscribeFunction[*data.ResultSession])

Oct 29, 2022

Changes in this version

+ func NewSessionInfo(timeout time.Duration, session *data.Session, mapRule map[string]Rule) *data.Info

type DipperEngine

+ func (d *DipperEngine) ControlGetRule(session uint64) []string

+ func (d *DipperEngine) ControlSession(ruleName string) []uint64

+ func (d *DipperEngine) ControlStopSession(ruleName string, session uint64)

+ func (d *DipperEngine) ListControl() []string

+ func (d *DipperEngine) StartSession(ctx context.Context, sessionId uint64) error

type Rule

+ Infinity func() bool

+ type SessionControl interface

+ InfoSession func(id uint64) map[string]interface{}

+ ListSession func() []uint64

+ StopSession func(id uint64)

Oct 22, 2022

Changes in this version

+ type ConfigEngine struct

+ BusMap map[string]string

+ Log ConfigLog

+ Plugins []string

+ Rules map[string]*RuleOption

+ TimeoutSession int

+ type ConfigLog struct

+ FileName string

+ Level string

+ LogMethodName bool

+ Output string

+ type DipperEngine struct

+ func NewDipperEngine(config *ConfigEngine, factoryQueue FactoryQueue[*data.InputEngine], ...) *DipperEngine

+ func (d *DipperEngine) Add(ctx context.Context, sessionData *data.Session) error

+ func (d *DipperEngine) AddRule(rules ...Rule)

+ func (d *DipperEngine) LoadPlugin()

+ func (d *DipperEngine) RuleEnable() []string

+ func (d *DipperEngine) SessionInputQueue(factoryQueueName FactoryQueueName[*data.Session])

+ func (d *DipperEngine) SessionOutputQueue(factoryQueueOutputName FactoryQueueName[*data.ResultSession])

+ func (d *DipperEngine) SetConfig(conf *ConfigEngine)

+ func (d *DipperEngine) SetContext(ctx context.Context)

+ func (d *DipperEngine) Start() error

+ func (d *DipperEngine) Stop() error

+ type FactoryQueue func(engine Rule) queue.QueueEngine[T]

+ func FactoryQueueDefault() FactoryQueue[T]

+ type FactoryQueueName func(name string) queue.QueueEngine[T]

+ func FactoryQueueNameDefault() FactoryQueueName[T]

+ type PluginDipper interface

+ Rules func() []Rule

+ type Rule interface

+ Id func() string

+ Initialize func(ctx context.Context, option map[string]interface{}) error

+ Run func(ctx context.Context, ...)

+ Stop func(ctx context.Context) error

+ type RuleOption struct

+ Enable bool

+ Options map[string]interface{}

+ Worker int