config

Documentation

Index

• type Config
  • func Load() *Config
• type Context
• type RawDataStoreDB
  • func InitPoolManager(cfg *Config) *RawDataStoreDB
  • func (s *RawDataStoreDB) CreateDBHandler(ctx *Context) *gorm.DB
  • func (s *RawDataStoreDB) GetDBHandler(ctx *Context) *gorm.DB

Types

type Config

type Config struct {
	Neo4j commonConfig.Neo4jConfig

	PostgresConfig      commonConfig.PostgresConfig
	PostgresAsyncConfig commonConfig.PostgresAsyncConfig

	Logger             logger.Config
	Jaeger             tracing.JaegerConfig
	Cron               cronConfig.Config
	RawDataStoreDBName string `env:"RAW_DATA_STORE_DB_NAME,required" envDefault:"destination"`
}

func Load

func Load() *Config

type Context

type Context struct {
	Schema string
}

type RawDataStoreDB

type RawDataStoreDB struct {
	CreationMutex sync.Mutex
	// contains filtered or unexported fields
}

func InitPoolManager

func InitPoolManager(cfg *Config) *RawDataStoreDB

func (*RawDataStoreDB) CreateDBHandler

func (s *RawDataStoreDB) CreateDBHandler(ctx *Context) *gorm.DB

func (*RawDataStoreDB) GetDBHandler

func (s *RawDataStoreDB) GetDBHandler(ctx *Context) *gorm.DB