worker

type Config struct {
	LocalMode    bool
	RabbitConfig *RabbitMQConfig
}

type RabbitMQConfig struct {
	UserName    string
	Password    string
	BrokerVHost string
	Host        string
	Port        string
	QueueName   string
}

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

type ScheduleOption func(*ScheduleConfig)

type Work func(ctx context.Context, payload string) error

type Worker interface {
	Schedule(ctx context.Context, name, payload string, options ...ScheduleOption) error
	RegisterTask(name string, taskFunc Work) error
	RunWorker(name string, concurrency int)
	CloseWorker()
}