Versions in this module Expand all Collapse all v0 v0.0.2 Dec 20, 2020 v0.0.1 Dec 3, 2020 Changes in this version + var Module = module.Module + type Service struct + func (s *Service) Insert(message *common.FlowMessage) + func (s *Service) Name() string + func (s *Service) Ping() error + func (s *Service) RegisterModel(rule string, model *common.Model) + func (s *Service) Start(ctx context.Context) error + func (s *Service) Stop() error + func (s *Service) Worker(ctx context.Context) + type Settings struct + Address string + BatchSize int + BatchTimeout time.Duration + Database string + Debug bool + FlowTable string + Password string + ReadTimeout int + Username string + WriteTimeout int
Go to main page