Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var DB *gorm.DB
db is sql *db
View Source
var Kafka = &Server{}
View Source
var Mdb *mongo.Client
View Source
var Mem *cache.Cache
View Source
var Rdb *redis.Client
Functions ¶
func InitKafkaProducer ¶
func InitKafkaProducer()
func InitMemory ¶
func InitMemory()
Types ¶
type KafkaConfig ¶
type Server ¶
type Server struct { SyncProducer sarama.SyncProducer AsyncProducer sarama.AsyncProducer }
func (*Server) PrepareMessage ¶
func (s *Server) PrepareMessage(topic, message string) *sarama.ProducerMessage
Click to show internal directories.
Click to hide internal directories.