consumer

Documentation

Index

• func New(ctx context.Context, core *Core)
• func NewAutoSubmit(ctx context.Context, core *Core)
• type Core

Functions

func New

func New(ctx context.Context, core *Core)

func NewAutoSubmit

func NewAutoSubmit(ctx context.Context, core *Core)

Types

type Core

type Core struct {
	Logger        *logger.Manager
	Redis         *redis.Manager
	MysqlDB       map[string]*gorm.DB
	KafkaConsumer *kafka.Manager
}