Documentation
¶
Index ¶
- func BuildDBConnection(opt option.DatabaseOption) *sql.DB
- type ExecutorRepository
- type Job
- type RuleRepository
- func (r *RuleRepository) CreateRule(ctx context.Context, rule *domain.Rule) error
- func (r *RuleRepository) DeleteRule(ctx context.Context, rid string) error
- func (r *RuleRepository) Export(ctx context.Context) ([]*domain.Rule, error)
- func (r *RuleRepository) GetRuleByID(ctx context.Context, rid string) (*domain.Rule, error)
- func (r *RuleRepository) Import(ctx context.Context, rules ...*domain.Rule) error
- func (r *RuleRepository) UpdateRule(ctx context.Context, rule *domain.Rule) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func BuildDBConnection ¶
func BuildDBConnection(opt option.DatabaseOption) *sql.DB
BuildDBConnection MySQL Connection初始化函数
Types ¶
type ExecutorRepository ¶
type ExecutorRepository struct {
// contains filtered or unexported fields
}
ExecutorRepository ExecutorRepository的内存存储库实现
func NewExecutorRepository ¶
func NewExecutorRepository(size int) *ExecutorRepository
NewExecutorRepository 工厂函数
func (*ExecutorRepository) FindExecutor ¶
func (er *ExecutorRepository) FindExecutor(_ context.Context, path, method []byte) (*domain.Executor, bool)
FindExecutor 查询执行器
func (*ExecutorRepository) ImportAll ¶
func (er *ExecutorRepository) ImportAll(_ context.Context, executors ...*domain.Executor)
ImportAll 导入所有执行器
func (*ExecutorRepository) Purge ¶
func (er *ExecutorRepository) Purge(_ context.Context)
Purge 清空存储库
type Job ¶
type Job struct {
// contains filtered or unexported fields
}
Job AsyncJob的实现
func (*Job) WithExecutorRepository ¶
func (job *Job) WithExecutorRepository(er domain.ExecutorRepository)
WithExecutorRepository 载入执行器存储库
func (*Job) WithRuleRepository ¶
func (job *Job) WithRuleRepository(rr domain.RuleRepository)
WithRuleRepository 载入规则存储库
type RuleRepository ¶
type RuleRepository struct {
// contains filtered or unexported fields
}
RuleRepository RuleRepository的MySQL存储实现
func (*RuleRepository) CreateRule ¶
CreateRule 插入新纪录
func (*RuleRepository) DeleteRule ¶
func (r *RuleRepository) DeleteRule(ctx context.Context, rid string) error
DeleteRule 删除记录
func (*RuleRepository) GetRuleByID ¶
GetRuleByID 获取记录
func (*RuleRepository) UpdateRule ¶
UpdateRule 更新记录
Source Files
Click to show internal directories.
Click to hide internal directories.