core

type ConfigEngine struct {
	BusMap         map[string]string      `json:"bus_map"`
	Rules          map[string]*RuleOption `json:"rules"`
	TimeoutSession int                    `json:"timeout_session"`
	Log            ConfigLog              `json:"log"`
	Plugins        []string               `json:"plugins"`
}

type ConfigLog struct {
	Level         string `json:"level"`
	Output        string `json:"output"`
	FileName      string `json:"file_name"`
	LogMethodName bool   `json:"log_method_name"`
}

type DipperEngine struct {
	// contains filtered or unexported fields
}

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

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

type PluginDipper interface {
	Rules() []Rule
}

type Rule interface {
	Id() string
	Initialize(ctx context.Context, option map[string]interface{}) error
	Run(ctx context.Context,
		subscribeQueueInput func(ctx context.Context, callback queue.SubscribeFunction[*data.InputEngine]) error,
		pushQueueOutput func(ctx context.Context, input *data.OutputEngine) error)
	Stop(ctx context.Context) error
}

type RuleOption struct {
	Enable  bool                   `json:"enable"`
	Worker  int                    `json:"worker"`
	Options map[string]interface{} `json:"options"`
}