config

Apr 10, 2024

Changes in this version

+ func PrepareMessage(topic string, message []byte) *sarama.ProducerMessage

Apr 10, 2024

Changes in this version

+ func NewSyncProducer(cfg *KafkaOutput) (sarama.SyncProducer, error)

+ type KafkaOutput struct

+ Brokers string

Mar 24, 2024

Changes in this version

+ type Consumer struct

+ func NewConsumerGroup(ctx context.Context, log *slog.Logger, cfg *KafkaInput, topics string) (*Consumer, error)

+ func (c *Consumer) Cleanup(sarama.ConsumerGroupSession) error

+ func (c *Consumer) ConsumeClaim(session sarama.ConsumerGroupSession, claim sarama.ConsumerGroupClaim) error

+ func (c *Consumer) Message() <-chan []byte

+ func (c *Consumer) Setup(sarama.ConsumerGroupSession) error

+ type KafkaInput struct

+ Brokers string

+ ClientID string

+ ConsumerGroup string

+ OffsetOldest bool

+ Verbose bool

Mar 23, 2024

Changes in this version

+ func InitPG(cfg *DB) (*sqlx.DB, error)

+ type DB struct

+ DBName string

+ Host string

+ MaxIdleConn int

+ MaxOpenConn int

+ Password string

+ Port int

+ Schema string

+ User string

Aug 20, 2023

Changes in this version

+ func GetVersion() string

+ func InitMetrics(addr string, logger *slog.Logger)

+ func InitSentry(dsn, ver string) error

+ type Monitoring struct

+ PromAddr string

+ SentryDSN string

Aug 20, 2023

Changes in this version

+ func InitSlog(cfg *Logger, version string, hook bool) *slog.Logger

+ type Logger struct

+ Fmt string

+ Level LoggerLevel

+ type LoggerLevel string

+ const LoggerLevelDebug

+ const LoggerLevelError

+ const LoggerLevelInfo

+ const LoggerLevelWarn