services

Documentation

Index

• func GetChannel(userId string) string
• type KafkaService
  • func NewKafkaService(brokers string, groupId string) (*KafkaService, error)
  • func (s *KafkaService) Close()
  • func (s *KafkaService) ConsumeMessages(handler func(msg kafka.Message)) error
  • func (s *KafkaService) Subscribe(topics []string) error
  • func (s *KafkaService) Unsubscribe() error
• type User
  • func GetCurrentUser(c *websocket.Conn) (*User, error)

Functions

func GetChannel

func GetChannel(userId string) string

Types

type KafkaService

type KafkaService struct {
	Consumer *kafka.Consumer
	Config   *kafka.ConfigMap
}

func NewKafkaService

func NewKafkaService(brokers string, groupId string) (*KafkaService, error)

Creates a new KafkaService instance

func (*KafkaService) Close

func (s *KafkaService) Close()

func (*KafkaService) ConsumeMessages

func (s *KafkaService) ConsumeMessages(handler func(msg kafka.Message)) error

Consumes messages from subscribed topics in a loop

func (*KafkaService) Subscribe

func (s *KafkaService) Subscribe(topics []string) error

Subscribes to a list of Kafka topics

func (*KafkaService) Unsubscribe

func (s *KafkaService) Unsubscribe() error

Unsubscribes from Kafka topics

type User

type User struct {
	ID string
}

func GetCurrentUser

func GetCurrentUser(c *websocket.Conn) (*User, error)