Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var Conn *kafka.Conn
Conn - соединение к серверу nats
Functions ¶
func CloseConnection ¶
func CloseConnection()
CloseConnection - закрывает соединение с сервером Nats
func ConnectTopic ¶
func ConnectTopic(TopicName, GroupID string) *kafka.Reader
ConnectTopic - подключает кафку к нужному топику
func Connect_err ¶
func Connect_err() error
Connect_err - подключается к серверу Nats и возвращает ошибку
func FillSettings ¶
func FillSettings()
FillSettings загружает переменные окружения в структуру из файла или из переменных окружения
func StartKafka ¶
func StartKafka()
StartKafka - необходимые процедуры для подключения к серверу Nats
Types ¶
type SettingsINI ¶
type SettingsINI struct {
KAFKA_HOST string
KAFKA_PORT string
KAFKA_LOGIN string
KAFKA_PASSWORD string
}
SettingsINI - структура для хранения всех нужных переменных окружения
var Settings SettingsINI
Settings хранит все нужные переменные окружения
Source Files
Click to show internal directories.
Click to hide internal directories.