Method initializeGoCBAgent

rest/server_context.go:1878–1911

initializeGoCBAgent Obtains a gocb agent from the current server connection. Requires the agent to be closed after use. Uses retry loop

(ctx context.Context)

// initializeGoCBAgent Obtains a gocb agent from the current server connection. Requires the agent to be closed after use.
// Uses retry loop
func (sc *ServerContext) initializeGoCBAgent(ctx context.Context) (*gocbcore.Agent, error) {
	err, agent := base.RetryLoop(ctx, "Initialize Cluster Agent", func() (shouldRetry bool, err error, agent *gocbcore.Agent) {
		agent, err = base.NewClusterAgent(
			ctx,
			base.CouchbaseClusterSpec{
				Server:        sc.Config.Bootstrap.Server,
				Username:      sc.Config.Bootstrap.Username,
				Password:      sc.Config.Bootstrap.Password,
				X509Certpath:  sc.Config.Bootstrap.X509CertPath,
				X509Keypath:   sc.Config.Bootstrap.X509KeyPath,
				CACertpath:    sc.Config.Bootstrap.CACertPath,
				TLSSkipVerify: base.ValDefault(sc.Config.Bootstrap.ServerTLSSkipVerify, false),
			},
			base.CouchbaseClusterWaitUntilReadyOptions{
				// this timeout is pretty short since we are doing external retries
				Timeout: 5 * time.Second,
			})
		if err != nil {
			// since we're starting up - let's be verbose (on console) about these retries happening ... otherwise it looks like nothing is happening ...
			base.ConsolefCtx(ctx, base.LevelInfo, base.KeyConfig, "Couldn't initialize cluster agent: %v - will retry...", err)
			return true, err, nil
		}

		return false, nil, agent
	}, base.CreateSleeperFunc(27, 1000)) // ~2 mins total - 5 second gocb WaitUntilReady timeout and 1 second interval
	if err != nil {
		// warn and bubble up error for further handling
		base.ConsolefCtx(ctx, base.LevelWarn, base.KeyConfig, "Giving up initializing cluster agent after retry: %v", err)
		return nil, err
	}

	base.InfofCtx(ctx, base.KeyConfig, "Successfully initialized cluster agent")
	return agent, nil
}

// initializeNoX509HttpClient() returns an http client based on the bootstrap connection information, but
// without any x509 keypair included in the tls config.  This client can be used to perform basic