Function newAgentClientV2

buildlog/coder.go:108–145

(ctx context.Context, logger slog.Logger, client *agentsdk.Client)

}

func newAgentClientV2(ctx context.Context, logger slog.Logger, client *agentsdk.Client) (CoderClient, error) {
	cctx, cancel := context.WithCancel(ctx)
	uid := uuid.New()
	ls := agentsdk.NewLogSender(logger)
	sl := ls.GetScriptLogger(uid)

	var conn drpc.Conn
	var err error
	for r := retry.New(10*time.Millisecond, time.Second); r.Wait(ctx); {
		conn, err = client.ConnectRPC(ctx)
		if err != nil {
			logger.Error(ctx, "connect err", slog.Error(err))
			continue
		}
		break
	}
	if conn == nil {
		cancel()
		return nil, xerrors.Errorf("connect rpc: %w", err)
	}

	arpc := proto.NewDRPCAgentClient(conn)
	go func() {
		err := ls.SendLoop(ctx, arpc)
		if err != nil {
			logger.Error(ctx, "send loop", slog.Error(err))
		}
	}()

	return &agentClientV2{
		ctx:    cctx,
		cancel: cancel,
		source: uid,
		ls:     ls,
		sl:     sl,
		log:    logger,
	}, nil
}

func OpenCoderClient(ctx context.Context, logger slog.Logger, accessURL *url.URL, hc *http.Client, token string) (CoderClient, error) {
	client := agentsdk.New(accessURL, agentsdk.WithFixedToken(token))