scheduler

type Conf struct {
	DB struct {
		Host     string `yaml:"host"`
		Port     string `yaml:"port"`
		User     string `yaml:"user"`
		Password string `yaml:"password"`
		DBName   string `yaml:"dbname"`
	}
	MSG struct {
		Host     string `yaml:"host"`
		Port     string `yaml:"port"`
		User     string `yaml:"user"`
		Password string `yaml:"password"`
	}
	SDL struct {
		Cron string `yaml:"cron"`
	}
}

type DB interface {
	Connect() (*gorm.DB, error)
}

type EncodeService interface {
	Encode(interface{}) (string, error)
}

type Item struct {
	Url string
}

type JsonEncoder struct {
}

type Mq interface {
	Connect() error
	Close()
	Send(string) error
}

type MqImpl struct {
	Config *Conf

	Conn *amqp.Connection
	Ch   *amqp.Channel
	Q    *amqp.Queue
	// contains filtered or unexported fields
}

type Publisher interface {
	Publish() error
}

type Scheduler interface {
	Run(func())
}

type SourceService interface {
	Add(Item) error

	Get() <-chan rxgo.Item
}

type UrlItem struct {
	gorm.Model
	Url string
}