components

Documentation

Overview

Package components provides kafka consumer and producer

Index

• type KafkaConsumer
  • func NewKafkaConsumer(brokers, groupID, topic string) (*KafkaConsumer, error)
• type RedisClient
  • func GetRedisClient(address, password string, db int) (*RedisClient, error)

Types

type KafkaConsumer

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

KafkaConsumer is a wrapper around the kafka consumer

func NewKafkaConsumer

func NewKafkaConsumer(brokers, groupID, topic string) (*KafkaConsumer, error)

NewKafkaConsumer creates a new kafka consumer

type RedisClient

type RedisClient struct {
	Client *redis.Client
	// contains filtered or unexported fields
}

_RedisClient is a wrapper around the redis client

func GetRedisClient

func GetRedisClient(address, password string, db int) (*RedisClient, error)

Func GetRedisClient creates a new redis client (or reuse the existing one)