INNER CODE UNIT · Go

initAerospike

lamoda/gonkey · main.go:195

func initAerospike(cfg config) *aerospikeAdapter.Client {
	if cfg.AerospikeHost != "" {
		address, port, namespace := parseAerospikeHost(cfg.AerospikeHost)
		client, err := aerospike.NewClient(address, port)
		if err != nil {
			log.Fatal("Couldn't connect to aerospike: ", err)
		}

		return aerospikeAdapter.New(client, namespace)
	}

	return nil
}

func initDB(cfg config) *sql.DB {
	if cfg.DbDsn != "" {
		var err error
		db, err := sql.Open("postgres", cfg.DbDsn)

View source record →