kafkax

type Auth struct {
	Username string `validate:"required" schema:"Логин"`
	Password string `validate:"required" schema:"Пароль"`
}

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

type Config struct {
	Publishers []*publisher.Publisher
	Consumers  []consumer.Consumer
}

type ConfigOption func(c *Config)

type ConsumerConfig struct {
	Addresses         []string `validate:"required" schema:"Список адресов брокеров для чтения сообщений"`
	Topic             string   `validate:"required" schema:"Топик"`
	GroupId           string   `validate:"required" schema:"Идентификатор консьюмера"`
	Concurrency       int      `schema:"Кол-во обработчиков, по умолчанию 1"`
	MaxBatchSizeMb    int      `` /* 133-byte string literal not displayed */
	CommitIntervalSec *int     `` /* 141-byte string literal not displayed */
	Auth              *Auth    `schema:"Параметры аутентификации"`
}

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

type LogObserver struct {
	NoopObserver
	// contains filtered or unexported fields
}

type NoopObserver struct{}

type Observer interface {
	ClientReady()
	ClientError(err error)
	ShutdownStarted()
	ShutdownDone()
}

type PublisherConfig struct {
	Addresses        []string `validate:"required" schema:"Список адресов брокеров для отправки сообщений"`
	Topic            string   `` /* 160-byte string literal not displayed */
	MaxMsgSizeMb     int64    `schema:"Максимальный размер сообщений в Мб, по умолчанию 64 Мб"`
	BatchSize        int      `` /* 142-byte string literal not displayed */
	BatchTimeoutMs   *int     `schema:"Периодичность записи батчей в кафку в мс, по умолчанию 500 мс"`
	WriteTimeoutSec  *int     `schema:"Таймаут отправки сообщений, по умолчанию 10 секунд"`
	RequiredAckLevel int      `` /* 179-byte string literal not displayed */
	Auth             *Auth    `schema:"Параметры аутентификации"`
}

type PublisherMetricStorage interface {
	ObservePublishDuration(topic string, t time.Duration)
	ObservePublishMsgSize(topic string, size int)
	IncPublishError(topic string)
}