data

type BaseModel struct {
	ID         int64      `gorm:"primary_key;type:bigint;" json:"id"`
	CreateTime *time.Time `gorm:"column:create_time;type:datetime not null;default:CURRENT_TIMESTAMP();comment:创建时间" json:"created_at"`
	CrawlDate  *time.Time `gorm:"column:crawl_date;type:date;default:(CURRENT_DATE);comment:爬取日期" json:"crawl_date"`
}

type ChanQueue struct {
	ErshoufangChan chan []biz.Message
	LoupanChan     chan []biz.Message
	CommercialChan chan []biz.Message
	ZufangChan     chan []biz.Message
	// contains filtered or unexported fields
}

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

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

type KafkaService interface {
	SendMessage(topic, key string, value []byte) error
	ReceiveMessages(ctx context.Context, topic, groupID string, handler func(key, value []byte) error)
}

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

type Queue interface {
	Send(ctx context.Context, msg []biz.Message, houseType biz.HoueseType) error
	Receive(ctx context.Context) error
}