Function createBootstrapConnectionWithOpts

rest/main.go:437–473

(ctx context.Context, opts bootstrapConnectionOpts)

}

func createBootstrapConnectionWithOpts(ctx context.Context, opts bootstrapConnectionOpts) (base.BootstrapConnection, error) {
	if base.ServerIsWalrus(opts.server) {
		cluster := base.NewRosmarCluster(opts.server)
		return cluster, nil
	}

	var connStr string
	var err error
	if opts.isServerless {
		connStr, err = base.GetGoCBConnStringWithDefaults(opts.server, base.DefaultServerlessGoCBConnStringParams())
	} else {
		connStr, err = base.GetGoCBConnStringWithDefaults(opts.server, base.DefaultGoCBConnStringParams())
	}
	if err != nil {
		return nil, err
	}
	cluster, err := base.NewCouchbaseCluster(ctx,
		base.CouchbaseClusterSpec{
			Server:        connStr,
			Username:      opts.username,
			Password:      opts.password,
			X509Certpath:  opts.x509CertPath,
			X509Keypath:   opts.x509KeyPath,
			CACertpath:    opts.caCertPath,
			TLSSkipVerify: base.ValDefault(opts.tlsSkipVerify, false),
		},
		opts.isServerless,
		opts.bucketCredentials,
		opts.useXattrConfig,
		opts.bucketConnectionMode)
	if err != nil {
		base.InfofCtx(ctx, base.KeyConfig, "Couldn't create couchbase cluster instance: %v", err)
		return nil, err
	}

	return cluster, nil
}

// parseFlags handles the parsing of legacy and persistent config flags.
func parseFlags(ctx context.Context, args []string) (flagStartupConfig *StartupConfig, fs *flag.FlagSet, disablePersistentConfig *bool, err error) {