configuration

Documentation

Index

• func NewLogger(logLevel string) *slog.Logger
• type ApiConfig
• type Configuration
  • func NewConfiguration() *Configuration
• type FfmpegConfig
• type JobConfig
• type KafkaConfig
• type KafkaConsumerConfig
• type KafkaProducerConfig

Functions

func NewLogger

func NewLogger(logLevel string) *slog.Logger

Types

type ApiConfig

type ApiConfig struct {
	Enabled bool   `mapstructure:"enabled"`
	Host    string `mapstructure:"host"`
	Port    string `mapstructure:"port"`
}

type Configuration

type Configuration struct {
	LogLevel      string `mapstructure:"log_level"`
	Logger        *slog.Logger
	OutputPath    string `mapstructure:"output_path"`
	InputPath     string `mapstructure:"input_path"`
	InternalQueue chan event.Event
	Api           ApiConfig    `mapstructure:"api"`
	Kafka         KafkaConfig  `mapstructure:"kafka"`
	Job           JobConfig    `mapstructure:"job"`
	Ffmpeg        FfmpegConfig `mapstructure:"ffmpeg"`
}

func NewConfiguration

func NewConfiguration() *Configuration

type FfmpegConfig

type FfmpegConfig struct {
	Path string `mapstructure:"path"`
}

type JobConfig

type JobConfig struct {
	Enabled bool `mapstructure:"enabled"`
	Workers int  `mapstructure:"workers"`
}

type KafkaConfig

type KafkaConfig struct {
	Enabled             bool                `mapstructure:"enabled"`
	KafkaProducerConfig KafkaProducerConfig `mapstructure:"producer"`
	KafkaConsumerConfig KafkaConsumerConfig `mapstructure:"consumer"`
}

type KafkaConsumerConfig

type KafkaConsumerConfig struct {
	Brokers []string `mapstructure:"brokers"`
	GroupID string   `mapstructure:"group_id"`
	Topic   string   `mapstructure:"topic"`
	Offset  string   `mapstructure:"offset"`
}

type KafkaProducerConfig

type KafkaProducerConfig struct {
	Brokers []string `mapstructure:"brokers"`
	Topic   string   `mapstructure:"topic"`
}