Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type Config ¶
type Config struct { Neo4jDb struct { Target string `env:"NEO4J_TARGET,required"` User string `env:"NEO4J_AUTH_USER,required,unset"` Pwd string `env:"NEO4J_AUTH_PWD,required,unset"` Realm string `env:"NEO4J_AUTH_REALM"` MaxConnectionPoolSize int `env:"NEO4J_MAX_CONN_POOL_SIZE" envDefault:"100"` LogLevel string `env:"NEO4J_LOG_LEVEL" envDefault:"WARNING"` } PostgresDb struct { Host string `env:"DB_HOST,required"` Port int `env:"DB_PORT,required"` Pwd string `env:"DB_PWD,required,unset"` User string `env:"DB_USER,required"` MaxConn int `env:"DB_MAX_CONN"` MaxIdleConn int `env:"DB_MAX_IDLE_CONN"` ConnMaxLifetime int `env:"DB_CONN_MAX_LIFETIME"` Name string `env:"DB_NAME,required"` } AirbytePostgresDb struct { Host string `env:"DB_AIRBYTE_HOST,required"` Port int `env:"DB_AIRBYTE_PORT,required"` Pwd string `env:"DB_AIRBYTE_PWD,required,unset"` User string `env:"DB_AIRBYTE_USER,required"` MaxConn int `env:"DB_AIRBYTE_MAX_CONN"` MaxIdleConn int `env:"DB_AIRBYTE_MAX_IDLE_CONN"` ConnMaxLifetime int `env:"DB_AIRBYTE_CONN_MAX_LIFETIME"` Name string `env:"DB_AIRBYTE_NAME,required"` } SyncCustomerOsData struct { TimeoutAfterTaskRun int `env:"TIMEOUT_AFTER_TASK_RUN_SEC" envDefault:"60"` BatchSize int `env:"SYNC_CUSTOMER_OS_DATA_BATCH_SIZE" envDefault:"10"` } GrpcClientConfig commconf.GrpcClientConfig SyncToEventStore struct { BatchSize int `env:"SYNC_TO_EVENT_STORE_BATCH_SIZE" envDefault:"100"` Enabled bool `env:"SYNC_TO_EVENT_STORE_ENABLED" envDefault:"false"` TimeoutAfterTaskRun int `env:"SYNC_TO_EVENT_STORE_TIMEOUT_AFTER_TASK_RUN_SEC" envDefault:"30"` Emails struct { Enabled bool `env:"SYNC_TO_EVENT_STORE_EMAILS_ENABLED" envDefault:"true"` BatchSize int `env:"SYNC_TO_EVENT_STORE_EMAILS_BATCH_SIZE" envDefault:"-1"` } PhoneNumbers struct { Enabled bool `env:"SYNC_TO_EVENT_STORE_PHONE_NUMBERS_ENABLED" envDefault:"true"` BatchSize int `env:"SYNC_TO_EVENT_STORE_PHONE_NUMBERS_BATCH_SIZE" envDefault:"-1"` } Locations struct { Enabled bool `env:"SYNC_TO_EVENT_STORE_LOCATIONS_ENABLED" envDefault:"true"` BatchSize int `env:"SYNC_TO_EVENT_STORE_LOCATIONS_BATCH_SIZE" envDefault:"-1"` } Contacts struct { Enabled bool `env:"SYNC_TO_EVENT_STORE_CONTACTS_ENABLED" envDefault:"true"` BatchSize int `env:"SYNC_TO_EVENT_STORE_CONTACTS_BATCH_SIZE" envDefault:"-1"` } Organizations struct { Enabled bool `env:"SYNC_TO_EVENT_STORE_ORGANIZATIONS_ENABLED" envDefault:"true"` BatchSize int `env:"SYNC_TO_EVENT_STORE_ORGANIZATIONS_BATCH_SIZE" envDefault:"-1"` OrganizationDomainsBatchSize int `env:"SYNC_TO_EVENT_STORE_ORGANIZATIONS_DOMAINS_BATCH_SIZE" envDefault:"20"` } } Logger logger.Config PostgresLogLevel string `env:"POSTGRES_LOG_LEVEL" envDefault:"WARN"` Service struct { CustomerOsWebhooksAPI string `env:"CUSTOMER_OS_WEBHOOKS_API,required"` CustomerOsWebhooksAPIKey string `env:"CUSTOMER_OS_WEBHOOKS_API_KEY,required"` } Jaeger tracing.Config }
type RawDataStoreDB ¶
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
Click to show internal directories.
Click to hide internal directories.