utils

Documentation

Index

• func ContextWithSignal(ctx context.Context) context.Context
• func GetenvInt(s string, defaultValue int64) int64
• func GetenvOrFile(varName, fileVarName string, required bool) string
• func GetenvRequired(s string) string
• func NormalizeEntityConfig(v *viper.Viper, singular string, plural string) error
• func ViperSubMap(v *viper.Viper, key string) map[string]*viper.Viper
• func ViperSubSlice(v *viper.Viper, key string) []*viper.Viper
• type IoSourceFactory
  • func (*IoSourceFactory) CreateConsumer(config *viper.Viper, logger *zerolog.Logger) v1.Consumer
  • func (*IoSourceFactory) CreateProducer(config *viper.Viper, logger *zerolog.Logger) v1.Producer

Functions

func ContextWithSignal

func ContextWithSignal(ctx context.Context) context.Context

func GetenvInt

func GetenvInt(s string, defaultValue int64) int64

func GetenvOrFile

func GetenvOrFile(varName, fileVarName string, required bool) string

func GetenvRequired

func GetenvRequired(s string) string

func NormalizeEntityConfig

func NormalizeEntityConfig(v *viper.Viper, singular string, plural string) error

func ViperSubMap

func ViperSubMap(v *viper.Viper, key string) map[string]*viper.Viper

func ViperSubSlice

func ViperSubSlice(v *viper.Viper, key string) []*viper.Viper

Types

type IoSourceFactory

type IoSourceFactory struct {
}

func (*IoSourceFactory) CreateConsumer

func (*IoSourceFactory) CreateConsumer(config *viper.Viper, logger *zerolog.Logger) v1.Consumer

func (*IoSourceFactory) CreateProducer

func (*IoSourceFactory) CreateProducer(config *viper.Viper, logger *zerolog.Logger) v1.Producer