rule

type Dispatcher interface {
	io.Closer
	Dispatch(ctx context.Context, event *EventExt) error
}

type EventExt struct {
	*v1.EventExt
}

type Executor interface {
	Matcher
	io.Closer
	Dispatch(context.Context, *EventExt) error
	Transform(ctx context.Context, event *EventExt) ([]*EventExt, error)
	Update(context.Context, *Rule) error
	IsFilterPatternEqual(filterPattern string) bool
	IsTargetsEqual(Targets []*Target) bool
}

type Matcher interface {
	Pattern(ctx context.Context, event *EventExt) (bool, error)
}

type NewDispatcherFunc func(ctx context.Context, logger log.Logger, Target *Target) (Dispatcher, error)

type NewExecutorFunc func(context.Context, log.Logger, *Rule, ...Option) (Executor, error)

type NewMatcherFunc func(ctx context.Context, logger log.Logger, pattern map[string]interface{}) (Matcher, error)

type NewTransformerFunc func(ctx context.Context, logger log.Logger, Target *Target) (Transformer, error)

type NotExistsValT struct{}

type Option func(*options)

type Rule struct {
	Name    string
	BusName string
	Status  v1.RuleStatus
	Pattern string
	Targets []*Target
}

type Rules interface {
	GetExecutors(busName string) (map[string]Executor, error)
}

type RulesManager interface {
	GetExecutors() (map[string]Executor, error)
	UpdateRules(ctx context.Context, rs []*Rule) error
	CleanupRules() error
}

type Target struct {
	ID            uint64
	Type          string
	Params        []*TargetParam
	RetryStrategy v1.RetryStrategy
}

type TargetParam struct {
	Key      string
	Form     string
	Value    string
	Template *string
}

type Transformer interface {
	Transform(ctx context.Context, event *EventExt) (*EventExt, error)
}