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)

New starts a Kafka consumer that manually commits messages.

Parameters:

• ctx: The context for managing the lifecycle of the function.
• core: A pointer to the Core struct containing necessary dependencies.

This function continuously listens for Kafka consumers and processes messages from specific topics. It runs indefinitely until the context is cancelled.

func NewAutoSubmit

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

NewAutoSubmit starts a Kafka consumer for auto-submission.

Parameters:

• ctx: The context for managing the lifecycle of the function.
• core: A pointer to the Core struct containing necessary dependencies.

This function continuously listens for messages on specific Kafka topics and processes them accordingly. It runs indefinitely until the context is cancelled.

Types

type Core

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

Core represents the core dependencies required for the consumer package.