kafka

Documentation

Overview

Copyright (c) 2023 Tiago Melo. All rights reserved. Use of this source code is governed by the MIT License that can be found in the LICENSE file.

Index

• type Worker
  • func (c *Worker) Work(ctx context.Context)

Types

type Worker

type Worker struct {
	Msg   *kafka.Message
	Stats *stats.KafkaConsumerStats
	Db    *mongodb.MongoDb
	Log   *log.Logger
}

Worker represents a Kafka consumer worker.

func (*Worker) Work

func (c *Worker) Work(ctx context.Context)

Work processes the Kafka message and performs the necessary operations.